Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 9d2a06c2 authored by Alex Elder's avatar Alex Elder Committed by Sage Weil
Browse files

libceph: kill message trail 



The wart that is the ceph message trail can now be removed, because
its only user was the osd client, and the previous patch made that
no longer the case.

The result allows write_partial_msg_pages() to be simplified
considerably.

Signed-off-by: default avatarAlex Elder <elder@inktank.com>
Reviewed-by: default avatarJosh Durgin <josh.durgin@inktank.com>
parent 95e072eb

include/linux/ceph/messenger.h

+0 −4
Original line number Original line Diff line number Diff line
@@ -69,7 +69,6 @@ struct ceph_messenger { 
#ifdef CONFIG_BLOCK

#ifdef CONFIG_BLOCK

#define ceph_msg_has_bio(m)		((m)->b.type == CEPH_MSG_DATA_BIO)

#define ceph_msg_has_bio(m)		((m)->b.type == CEPH_MSG_DATA_BIO)

#endif /* CONFIG_BLOCK */

#endif /* CONFIG_BLOCK */

#define ceph_msg_has_trail(m)		((m)->t.type == CEPH_MSG_DATA_PAGELIST)





enum ceph_msg_data_type {

enum ceph_msg_data_type {

	CEPH_MSG_DATA_NONE,	/* message contains no data payload */

	CEPH_MSG_DATA_NONE,	/* message contains no data payload */
@@ -155,7 +154,6 @@ struct ceph_msg { 
#ifdef CONFIG_BLOCK

#ifdef CONFIG_BLOCK

	struct ceph_msg_data	b;	/* bio */

	struct ceph_msg_data	b;	/* bio */

#endif /* CONFIG_BLOCK */

#endif /* CONFIG_BLOCK */

	struct ceph_msg_data	t;	/* trail */





	struct ceph_connection *con;

	struct ceph_connection *con;

	struct list_head list_head;	/* links for connection lists */

	struct list_head list_head;	/* links for connection lists */
@@ -295,8 +293,6 @@ extern void ceph_msg_data_set_pages(struct ceph_msg *msg, struct page **pages, 
extern void ceph_msg_data_set_pagelist(struct ceph_msg *msg,

extern void ceph_msg_data_set_pagelist(struct ceph_msg *msg,

				struct ceph_pagelist *pagelist);

				struct ceph_pagelist *pagelist);

extern void ceph_msg_data_set_bio(struct ceph_msg *msg, struct bio *bio);

extern void ceph_msg_data_set_bio(struct ceph_msg *msg, struct bio *bio);

extern void ceph_msg_data_set_trail(struct ceph_msg *msg,

				struct ceph_pagelist *trail);





extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,

extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,

				     bool can_fail);

				     bool can_fail);

net/ceph/messenger.c

+5 −39
Original line number Original line Diff line number Diff line
@@ -1115,8 +1115,6 @@ static void prepare_message_data(struct ceph_msg *msg, 
		ceph_msg_data_cursor_init(&msg->p);

		ceph_msg_data_cursor_init(&msg->p);

	if (ceph_msg_has_pagelist(msg))

	if (ceph_msg_has_pagelist(msg))

		ceph_msg_data_cursor_init(&msg->l);

		ceph_msg_data_cursor_init(&msg->l);

	if (ceph_msg_has_trail(msg))

		ceph_msg_data_cursor_init(&msg->t);





	msg_pos->did_page_crc = false;

	msg_pos->did_page_crc = false;

}

}
@@ -1398,7 +1396,7 @@ static int write_partial_kvec(struct ceph_connection *con) 
}

}





static void out_msg_pos_next(struct ceph_connection *con, struct page *page,

static void out_msg_pos_next(struct ceph_connection *con, struct page *page,

			size_t len, size_t sent, bool in_trail)

			size_t len, size_t sent)

{

{

	struct ceph_msg *msg = con->out_msg;

	struct ceph_msg *msg = con->out_msg;

	struct ceph_msg_pos *msg_pos = &con->out_msg_pos;

	struct ceph_msg_pos *msg_pos = &con->out_msg_pos;
@@ -1409,9 +1407,7 @@ static void out_msg_pos_next(struct ceph_connection *con, struct page *page, 




	msg_pos->data_pos += sent;

	msg_pos->data_pos += sent;

	msg_pos->page_pos += sent;

	msg_pos->page_pos += sent;

	if (in_trail)

	if (ceph_msg_has_pages(msg))

		need_crc = ceph_msg_data_advance(&msg->t, sent);

	else if (ceph_msg_has_pages(msg))

		need_crc = ceph_msg_data_advance(&msg->p, sent);

		need_crc = ceph_msg_data_advance(&msg->p, sent);

	else if (ceph_msg_has_pagelist(msg))

	else if (ceph_msg_has_pagelist(msg))

		need_crc = ceph_msg_data_advance(&msg->l, sent);

		need_crc = ceph_msg_data_advance(&msg->l, sent);
@@ -1481,14 +1477,6 @@ static int write_partial_message_data(struct ceph_connection *con) 
	bool do_datacrc = !con->msgr->nocrc;

	bool do_datacrc = !con->msgr->nocrc;

	int ret;

	int ret;

	int total_max_write;

	int total_max_write;

	bool in_trail = false;

	size_t trail_len = 0;

	size_t trail_off = data_len;



	if (ceph_msg_has_trail(msg)) {

		trail_len = msg->t.pagelist->length;

		trail_off -= trail_len;

	}





	dout("%s %p msg %p page %d offset %d\n", __func__,

	dout("%s %p msg %p page %d offset %d\n", __func__,

	     con, msg, msg_pos->page, msg_pos->page_pos);

	     con, msg, msg_pos->page, msg_pos->page_pos);
@@ -1508,16 +1496,9 @@ static int write_partial_message_data(struct ceph_connection *con) 
		bool use_cursor = false;

		bool use_cursor = false;

		bool last_piece = true;	/* preserve existing behavior */

		bool last_piece = true;	/* preserve existing behavior */





		in_trail = in_trail || msg_pos->data_pos >= trail_off;

		total_max_write = data_len - msg_pos->data_pos;

		if (!in_trail)

			total_max_write = trail_off - msg_pos->data_pos;





		if (in_trail) {

		if (ceph_msg_has_pages(msg)) {

			BUG_ON(!ceph_msg_has_trail(msg));

			use_cursor = true;

			page = ceph_msg_data_next(&msg->t, &page_offset,

							&length, &last_piece);

		} else if (ceph_msg_has_pages(msg)) {

			use_cursor = true;

			use_cursor = true;

			page = ceph_msg_data_next(&msg->p, &page_offset,

			page = ceph_msg_data_next(&msg->p, &page_offset,

							&length, &last_piece);

							&length, &last_piece);
@@ -1552,7 +1533,7 @@ static int write_partial_message_data(struct ceph_connection *con) 
		if (ret <= 0)

		if (ret <= 0)

			goto out;

			goto out;





		out_msg_pos_next(con, page, length, (size_t) ret, in_trail);

		out_msg_pos_next(con, page, length, (size_t) ret);

	}

	}





	dout("%s %p msg %p done\n", __func__, con, msg);

	dout("%s %p msg %p done\n", __func__, con, msg);
@@ -3145,17 +3126,6 @@ void ceph_msg_data_set_bio(struct ceph_msg *msg, struct bio *bio) 
}

}

EXPORT_SYMBOL(ceph_msg_data_set_bio);

EXPORT_SYMBOL(ceph_msg_data_set_bio);





void ceph_msg_data_set_trail(struct ceph_msg *msg, struct ceph_pagelist *trail)

{

	BUG_ON(!trail);

	BUG_ON(!trail->length);

	BUG_ON(msg->b.type != CEPH_MSG_DATA_NONE);



	msg->t.type = CEPH_MSG_DATA_PAGELIST;

	msg->t.pagelist = trail;

}

EXPORT_SYMBOL(ceph_msg_data_set_trail);



/*

/*

 * construct a new message with given type, size

 * construct a new message with given type, size

 * the new msg has a ref count of 1.

 * the new msg has a ref count of 1.
@@ -3179,7 +3149,6 @@ struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags, 
	ceph_msg_data_init(&m->p);

	ceph_msg_data_init(&m->p);

	ceph_msg_data_init(&m->l);

	ceph_msg_data_init(&m->l);

	ceph_msg_data_init(&m->b);

	ceph_msg_data_init(&m->b);

	ceph_msg_data_init(&m->t);





	/* front */

	/* front */

	m->front_max = front_len;

	m->front_max = front_len;
@@ -3345,9 +3314,6 @@ void ceph_msg_last_put(struct kref *kref) 
		m->l.pagelist = NULL;

		m->l.pagelist = NULL;

	}

	}





	if (ceph_msg_has_trail(m))

		m->t.pagelist = NULL;



	if (m->pool)

	if (m->pool)

		ceph_msgpool_put(m->pool, m);

		ceph_msgpool_put(m->pool, m);

	else

	else