From: Samuel Just Date: Sat, 15 Feb 2020 00:35:29 +0000 (-0800) Subject: test_alien_echo: convert Condition to use readable_eventfd X-Git-Tag: v15.1.1~410^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F33345%2Fhead;p=ceph.git test_alien_echo: convert Condition to use readable_eventfd Should have been included in 5f05a50bae8bb4889dba0d249ed5fc3a2fcdcfa5. Signed-off-by: Samuel Just --- diff --git a/src/test/crimson/test_alien_echo.cc b/src/test/crimson/test_alien_echo.cc index abccc5034ec..876d5490ed4 100644 --- a/src/test/crimson/test_alien_echo.cc +++ b/src/test/crimson/test_alien_echo.cc @@ -7,7 +7,6 @@ #include "crimson/net/Dispatcher.h" #include "crimson/net/Messenger.h" #include "crimson/net/Config.h" -#include "crimson/thread/Condition.h" #include "crimson/thread/Throttle.h" #include @@ -95,7 +94,7 @@ struct Client { class SeastarContext { seastar::file_desc begin_fd; - crimson::thread::Condition on_end; + seastar::readable_eventfd on_end; public: SeastarContext() @@ -112,7 +111,7 @@ public: // alien: i've sent my request. have you replied it? // wait_for_seastar(); // alien: you are free to go! - on_end.notify(); + on_end.write_side().signal(1); }}; } @@ -122,7 +121,7 @@ public: return set_seastar_ready(); }).then([this] { // seastar: let me know once i am free to leave. - return on_end.wait(); + return on_end.wait().then([](size_t){}); }).handle_exception([](auto ep) { std::cerr << "Error: " << ep << std::endl; }).finally([] {