diff options
author | Alex Elder <elder@inktank.com> | 2012-06-11 15:57:13 -0400 |
---|---|---|
committer | Sage Weil <sage@inktank.com> | 2012-07-06 00:14:18 -0400 |
commit | abdaa6a849af1d63153682c11f5bbb22dacb1f6b (patch) | |
tree | 449810fd8346abb8ba9b608aaa0f2d8a250696d2 /net | |
parent | 572c588edadaa3da3992bd8a0fed830bbcc861f8 (diff) |
libceph: don't use bio_iter as a flag
Recently a bug was fixed in which the bio_iter field in a ceph
message was not being properly re-initialized when a message got
re-transmitted:
commit 43643528cce60ca184fe8197efa8e8da7c89a037
Author: Yan, Zheng <zheng.z.yan@intel.com>
rbd: Clear ceph_msg->bio_iter for retransmitted message
We are now only initializing the bio_iter field when we are about to
start to write message data (in prepare_write_message_data()),
rather than every time we are attempting to write any portion of the
message data (in write_partial_msg_pages()). This means we no
longer need to use the msg->bio_iter field as a flag.
So just don't do that any more. Trust prepare_write_message_data()
to ensure msg->bio_iter is properly initialized, every time we are
about to begin writing (or re-writing) a message's bio data.
Signed-off-by: Alex Elder <elder@inktank.com>
Reviewed-by: Sage Weil <sage@inktank.com>
Diffstat (limited to 'net')
-rw-r--r-- | net/ceph/messenger.c | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c index fedad914b238..3a4330371d88 100644 --- a/net/ceph/messenger.c +++ b/net/ceph/messenger.c | |||
@@ -604,7 +604,7 @@ static void prepare_write_message_data(struct ceph_connection *con) | |||
604 | else | 604 | else |
605 | con->out_msg_pos.page_pos = 0; | 605 | con->out_msg_pos.page_pos = 0; |
606 | #ifdef CONFIG_BLOCK | 606 | #ifdef CONFIG_BLOCK |
607 | if (msg->bio && !msg->bio_iter) | 607 | if (msg->bio) |
608 | init_bio_iter(msg->bio, &msg->bio_iter, &msg->bio_seg); | 608 | init_bio_iter(msg->bio, &msg->bio_iter, &msg->bio_seg); |
609 | #endif | 609 | #endif |
610 | con->out_msg_pos.data_pos = 0; | 610 | con->out_msg_pos.data_pos = 0; |
@@ -672,10 +672,6 @@ static void prepare_write_message(struct ceph_connection *con) | |||
672 | m->hdr.seq = cpu_to_le64(++con->out_seq); | 672 | m->hdr.seq = cpu_to_le64(++con->out_seq); |
673 | m->needs_out_seq = false; | 673 | m->needs_out_seq = false; |
674 | } | 674 | } |
675 | #ifdef CONFIG_BLOCK | ||
676 | else | ||
677 | m->bio_iter = NULL; | ||
678 | #endif | ||
679 | 675 | ||
680 | dout("prepare_write_message %p seq %lld type %d len %d+%d+%d %d pgs\n", | 676 | dout("prepare_write_message %p seq %lld type %d len %d+%d+%d %d pgs\n", |
681 | m, con->out_seq, le16_to_cpu(m->hdr.type), | 677 | m, con->out_seq, le16_to_cpu(m->hdr.type), |