From cfd33b7eb3b0f2dd218281b65b9b755cf5a68565 Mon Sep 17 00:00:00 2001 From: Yingxin Cheng Date: Fri, 2 Dec 2022 16:21:55 +0800 Subject: [PATCH] crimson/net: change out_state_changed to promise<> as it is not shared Signed-off-by: Yingxin Cheng --- src/crimson/net/Protocol.cc | 4 ++-- src/crimson/net/Protocol.h | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/crimson/net/Protocol.cc b/src/crimson/net/Protocol.cc index 38b0217631f..6bdcf2db5c2 100644 --- a/src/crimson/net/Protocol.cc +++ b/src/crimson/net/Protocol.cc @@ -173,7 +173,7 @@ void Protocol::set_out_state( if (out_state != new_state) { out_state = new_state; out_state_changed.set_value(); - out_state_changed = seastar::shared_promise<>(); + out_state_changed = seastar::promise<>(); } // The above needs to be atomic @@ -335,7 +335,7 @@ seastar::future<> Protocol::do_out_dispatch() } else { logger().info("{} do_out_dispatch: delay ...", conn); } - return out_state_changed.get_shared_future( + return out_state_changed.get_future( ).then([] { return stop_t::no; }); case out_state_t::drop: ceph_assert(out_dispatching); diff --git a/src/crimson/net/Protocol.h b/src/crimson/net/Protocol.h index 5957956900b..819c7aa9504 100644 --- a/src/crimson/net/Protocol.h +++ b/src/crimson/net/Protocol.h @@ -167,7 +167,7 @@ class Protocol { out_state_t out_state = out_state_t::none; // wait until current out_state changed - seastar::shared_promise<> out_state_changed; + seastar::promise<> out_state_changed; bool out_dispatching = false; -- 2.39.5