Import ceph 15.2.8

[ceph.git] / ceph / src / msg / async / Stack.cc

diff --git a/ceph/src/msg/async/Stack.cc b/ceph/src/msg/async/Stack.cc
index 6b18d1de9cb81fb8c2ec39f36479dd5dd9f088a9..eb5b628a79e20fd5dd88adbc9de4f67359dfb6f8 100644 (file)
--- a/ceph/src/msg/async/Stack.cc
+++ b/ceph/src/msg/async/Stack.cc
@@ -117,7 +117,9 @@ NetworkStack::NetworkStack(CephContext *c, const string &t): type(t), started(fa
 
   for (unsigned worker_id = 0; worker_id < num_workers; ++worker_id) {
     Worker *w = create_worker(cct, type, worker_id);
-    w->center.init(InitEventNumber, worker_id, type);
+    int ret = w->center.init(InitEventNumber, worker_id, type);
+    if (ret)
+      throw std::system_error(-ret, std::generic_category());
     workers.push_back(w);
   }
 }