Event: change submit_to related to cephcontext

Signed-off-by: Haomai Wang <haomai@xsky.com>

diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc
index 35809c8c116b2e7f2af477f322fec2742b312549..7e14ff5df45a76b2b01f9259cb704fee528c240b 100644 (file)
--- a/src/msg/async/AsyncConnection.cc
+++ b/src/msg/async/AsyncConnection.cc
@@ -1834,7 +1834,7 @@ ssize_t AsyncConnection::handle_connect_msg(ceph_msg_connect &connect, bufferlis
     dispatch_queue->queue_reset(this);
     existing->lock.Unlock();
 
-    EventCenter::submit_to(existing->center->get_id(), [existing, connect, reply, authorizer_reply]() mutable {
+    center->submit_to(existing->center->get_id(), [existing, connect, reply, authorizer_reply]() mutable {
       Mutex::Locker l(existing->lock);
       if (existing->_reply_accept(CEPH_MSGR_TAG_RETRY_GLOBAL, connect, reply, authorizer_reply) < 0) {
         // handle error
@@ -2457,7 +2457,7 @@ void AsyncConnection::DelayedDelivery::do_request(int id)
 
 void AsyncConnection::DelayedDelivery::flush() {
   stop_dispatch = true;
-  EventCenter::submit_to(
+  center->submit_to(
       center->get_id(), [this] () mutable {
     Mutex::Locker l(delay_lock);
     while (!delay_queue.empty()) {

diff --git a/src/msg/async/AsyncConnection.h b/src/msg/async/AsyncConnection.h
index 3f87d6886c648178dd3d52e708cb9d823851922e..5769827b9d720819205e858ff6f790377c19afad 100644 (file)
--- a/src/msg/async/AsyncConnection.h
+++ b/src/msg/async/AsyncConnection.h
@@ -164,7 +164,7 @@ class AsyncConnection : public Connection {
     }
     void discard() {
       stop_dispatch = true;
-      EventCenter::submit_to(center->get_id(), [this] () mutable {
+      center->submit_to(center->get_id(), [this] () mutable {
         Mutex::Locker l(delay_lock);
         while (!delay_queue.empty()) {
           Message *m = delay_queue.front().second;