Commit 473bd2d7 authored by Arnd Bergmann's avatar Arnd Bergmann Committed by Ilya Dryomov
Browse files

libceph: use timespec64 in for keepalive2 and ticket validity 



ceph_con_keepalive_expired() is the last user of timespec_add() and some
of the last uses of ktime_get_real_ts().  Replacing this with timespec64
based interfaces  lets us remove that deprecated API.

I'm introducing new ceph_encode_timespec64()/ceph_decode_timespec64()
here that take timespec64 structures and convert to/from ceph_timespec,
which is defined to have an unsigned 32-bit tv_sec member. This extends
the range of valid times to year 2106, avoiding the year 2038 overflow.

The ceph file system portion still uses the old functions for inode
timestamps, this will be done separately after the VFS layer is converted.

Signed-off-by: default avatarArnd Bergmann <arnd@arndb.de>
Reviewed-by: default avatarIlya Dryomov <idryomov@gmail.com>
Signed-off-by: default avatarIlya Dryomov <idryomov@gmail.com>
parent 67fcd151

include/linux/ceph/decode.h

+19 −1
Original line number Diff line number Diff line
@@ -194,8 +194,26 @@ ceph_decode_skip_n(p, end, sizeof(u8), bad) 
	} while (0)



/*

 * struct ceph_timespec <-> struct timespec

 * struct ceph_timespec <-> struct timespec64

 */

static inline void ceph_decode_timespec64(struct timespec64 *ts,

					  const struct ceph_timespec *tv)

{

	/*

	 * This will still overflow in year 2106.  We could extend

	 * the protocol to steal two more bits from tv_nsec to

	 * add three more 136 year epochs after that the way ext4

	 * does if necessary.

	 */

	ts->tv_sec = (time64_t)le32_to_cpu(tv->tv_sec);

	ts->tv_nsec = (long)le32_to_cpu(tv->tv_nsec);

}

static inline void ceph_encode_timespec64(struct ceph_timespec *tv,

					  const struct timespec64 *ts)

{

	tv->tv_sec = cpu_to_le32((u32)ts->tv_sec);

	tv->tv_nsec = cpu_to_le32((u32)ts->tv_nsec);

}

static inline void ceph_decode_timespec(struct timespec *ts,

					const struct ceph_timespec *tv)

{

include/linux/ceph/messenger.h

+1 −1
Original line number Diff line number Diff line
@@ -330,7 +330,7 @@ struct ceph_connection { 
	int in_base_pos;     /* bytes read */

	__le64 in_temp_ack;  /* for reading an ack */



	struct timespec last_keepalive_ack; /* keepalive2 ack stamp */

	struct timespec64 last_keepalive_ack; /* keepalive2 ack stamp */



	struct delayed_work work;	    /* send|recv work */

	unsigned long       delay;          /* current delay interval */

net/ceph/auth_x.c

+7 −7
Original line number Diff line number Diff line
@@ -149,12 +149,12 @@ static int process_one_ticket(struct ceph_auth_client *ac, 
	void *dp, *dend;

	int dlen;

	char is_enc;

	struct timespec validity;

	struct timespec64 validity;

	void *tp, *tpend;

	void **ptp;

	struct ceph_crypto_key new_session_key = { 0 };

	struct ceph_buffer *new_ticket_blob;

	unsigned long new_expires, new_renew_after;

	time64_t new_expires, new_renew_after;

	u64 new_secret_id;

	int ret;
@@ -189,11 +189,11 @@ static int process_one_ticket(struct ceph_auth_client *ac, 
	if (ret)

		goto out;



	ceph_decode_timespec(&validity, dp);

	ceph_decode_timespec64(&validity, dp);

	dp += sizeof(struct ceph_timespec);

	new_expires = get_seconds() + validity.tv_sec;

	new_expires = ktime_get_real_seconds() + validity.tv_sec;

	new_renew_after = new_expires - (validity.tv_sec / 4);

	dout(" expires=%lu renew_after=%lu\n", new_expires,

	dout(" expires=%llu renew_after=%llu\n", new_expires,

	     new_renew_after);



	/* ticket blob for service */
@@ -385,13 +385,13 @@ static bool need_key(struct ceph_x_ticket_handler *th) 
	if (!th->have_key)

		return true;



	return get_seconds() >= th->renew_after;

	return ktime_get_real_seconds() >= th->renew_after;

}



static bool have_key(struct ceph_x_ticket_handler *th)

{

	if (th->have_key) {

		if (get_seconds() >= th->expires)

		if (ktime_get_real_seconds() >= th->expires)

			th->have_key = false;

	}

net/ceph/auth_x.h

+1 −1
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ struct ceph_x_ticket_handler { 
	u64 secret_id;

	struct ceph_buffer *ticket_blob;



	unsigned long renew_after, expires;

	time64_t renew_after, expires;

};



#define CEPHX_AU_ENC_BUF_LEN	128  /* big enough for encrypted blob */

net/ceph/cls_lock_client.c

+2 −2
Original line number Diff line number Diff line
@@ -32,7 +32,7 @@ int ceph_cls_lock(struct ceph_osd_client *osdc, 
	int desc_len = strlen(desc);

	void *p, *end;

	struct page *lock_op_page;

	struct timespec mtime;

	struct timespec64 mtime;

	int ret;



	lock_op_buf_size = name_len + sizeof(__le32) +
@@ -63,7 +63,7 @@ int ceph_cls_lock(struct ceph_osd_client *osdc, 
	ceph_encode_string(&p, end, desc, desc_len);

	/* only support infinite duration */

	memset(&mtime, 0, sizeof(mtime));

	ceph_encode_timespec(p, &mtime);

	ceph_encode_timespec64(p, &mtime);

	p += sizeof(struct ceph_timespec);

	ceph_encode_8(&p, flags);

CRA Git | Maintained and supported by SUSTech CRA and CCSE