msg/async: s/nowait/always_async/ in EventCenter::submit_to().

Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>

diff --git a/src/msg/async/Event.h b/src/msg/async/Event.h
index d7dba443956dc58ea7fd4d5ea5cf7b1dd91bc192..5d6d04c9e8ecc48d915c98ce5d3a13ffd92b8f78 100644 (file)
--- a/src/msg/async/Event.h
+++ b/src/msg/async/Event.h
@@ -244,11 +244,11 @@ class EventCenter {
 
  public:
   template <typename func>
-  void submit_to(int i, func &&f, bool nowait = false) {
+  void submit_to(int i, func &&f, bool always_async = false) {
     ceph_assert(i < MAX_EVENTCENTER && global_centers);
     EventCenter *c = global_centers->centers[i];
     ceph_assert(c);
-    if (nowait) {
+    if (always_async) {
       C_submit_event<func> *event = new C_submit_event<func>(std::move(f), true);
       c->dispatch_event_external(event);
     } else if (c->in_thread()) {

diff --git a/src/msg/async/ProtocolV1.cc b/src/msg/async/ProtocolV1.cc
index a082d187a7f5e6513dd9bc53136d2c47126fd23c..4560cb5a031d163342f245d85c8b6e70cf9daf11 100644 (file)
--- a/src/msg/async/ProtocolV1.cc
+++ b/src/msg/async/ProtocolV1.cc
@@ -1276,7 +1276,7 @@ void ProtocolV1::reset_recv_state()
       std::lock_guard<std::mutex> l(connection->lock);
       std::lock_guard<std::mutex> wl(connection->write_lock);
       reset_security();
-    }, /* nowait = */true);
+    }, /* always_async = */true);
   } else {
     reset_security();
   }

diff --git a/src/msg/async/ProtocolV2.cc b/src/msg/async/ProtocolV2.cc
index f258eb12ee074447e164d5329b68764621ee17cd..8fc02db6e559a24616dbe49afe0daaca23a95306 100644 (file)
--- a/src/msg/async/ProtocolV2.cc
+++ b/src/msg/async/ProtocolV2.cc
@@ -248,7 +248,7 @@ void ProtocolV2::reset_recv_state() {
       std::lock_guard<std::mutex> l(connection->lock);
       std::lock_guard<std::mutex> wl(connection->write_lock);
       reset_security();
-    }, /* nowait = */true);
+    }, /* always_async = */true);
   } else {
     reset_security();
   }