From 4b5bb65b61985fcc9afa64cc76f184adbd3174e8 Mon Sep 17 00:00:00 2001 From: Haomai Wang Date: Sat, 28 May 2016 23:03:33 +0800 Subject: [PATCH] Event: change submit_to related to cephcontext Signed-off-by: Haomai Wang --- src/msg/async/AsyncConnection.cc | 4 ++-- src/msg/async/AsyncConnection.h | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc index 35809c8c116b2..7e14ff5df45a7 100644 --- 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 3f87d6886c648..5769827b9d720 100644 --- 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; -- 2.39.5