RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-01 08:32:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/net: init h.global_seq during handshake

Browse Source 
Signed-off-by: Yingxin <yingxin.cheng@intel.com>
This commit is contained in:
Yingxin 2018-08-30 18:10:07 +08:00
parent 692932caac
commit 9b66c5bc11
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/crimson/net/SocketConnection.cc
View File

@ -526,9 +526,10 @@ seastar::future<>
SocketConnection::send_connect_reply_ready(msgr_tag_t tag,
bufferlist&& authorizer_reply)
{
h.global_seq = get_messenger()->get_global_seq();
h.reply.tag = tag;
h.reply.features = policy.features_supported;
h.reply.global_seq = get_messenger()->get_global_seq();
h.reply.global_seq = h.global_seq;
h.reply.connect_seq = h.connect_seq;
h.reply.flags = 0;
if (policy.lossy) {
@ -820,6 +821,7 @@ seastar::future<> SocketConnection::client_handshake(entity_type_t peer_type,
bufferlist bl;
bl.append(buffer::create_static(banner_size, banner));
::encode(my_addr, bl, 0);
h.global_seq = get_messenger()->get_global_seq();
return out.write(std::move(bl)).then([this] { return out.flush(); });
}).then([=] {
return seastar::do_until([=] { return state == state_t::open; },