Signed-off-by: Yingxin <yingxin.cheng@intel.com>
// hooray!
h.peer_global_seq = h.reply.global_seq;
policy.lossy = h.reply.flags & CEPH_MSG_CONNECT_LOSSY;
- state = state_t::open;
h.connect_seq++;
h.backoff = 0ms;
set_features(h.reply.features & h.connect.features);
return seastar::repeat([this] {
return repeat_connect();
});
+ // TODO: handle errors for state_t::connecting
}).then([this] {
state = state_t::open;
// start background processing of tags
return seastar::repeat([this] {
return repeat_handle_connect();
});
+ // TODO: handle errors for state_t::accepting
}).then([this] {
state = state_t::open;
// start background processing of tags