import 15.2.0 Octopus source

[ceph.git] / ceph / src / seastar / demos / udp_server_demo.cc

diff --git a/ceph/src/seastar/demos/udp_server_demo.cc b/ceph/src/seastar/demos/udp_server_demo.cc
index 86dabaaf191dd99cfe211914d84f6001d42f890d..e5bc879a7936d085eeae3732638a9e7b5b57aaa2 100644 (file)
--- a/ceph/src/seastar/demos/udp_server_demo.cc
+++ b/ceph/src/seastar/demos/udp_server_demo.cc
@@ -44,7 +44,8 @@ public:
         });
         _stats_timer.arm_periodic(1s);
 
-        keep_doing([this] {
+        // Run server in background.
+        (void)keep_doing([this] {
             return _chan.receive().then([this] (udp_datagram dgram) {
                 return _chan.send(dgram.get_src(), std::move(dgram.get_data())).then([this] {
                     _n_sent++;
@@ -68,11 +69,12 @@ int main(int ac, char ** av) {
         auto&& config = app.configuration();
         uint16_t port = config["port"].as<uint16_t>();
         auto server = new distributed<udp_server>;
-        server->start().then([server = std::move(server), port] () mutable {
+        // Run server in background.
+        (void)server->start().then([server = std::move(server), port] () mutable {
             engine().at_exit([server] {
                 return server->stop();
             });
-            server->invoke_on_all(&udp_server::start, port);
+            return server->invoke_on_all(&udp_server::start, port);
         }).then([port] {
             std::cout << "Seastar UDP server listening on port " << port << " ...\n";
         });