From 193bd35566ebb38fa8bfa54299ff878072e720ac Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Tue, 29 Oct 2019 15:30:40 -0500 Subject: [PATCH] common/admin_socket: switch tell queue to cref_t (from ref_t) Signed-off-by: Sage Weil --- src/common/admin_socket.cc | 8 ++++---- src/common/admin_socket.h | 8 ++++---- src/messages/MMonCommandAck.h | 2 +- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/src/common/admin_socket.cc b/src/common/admin_socket.cc index c3b0681622c..0d6527facc8 100644 --- a/src/common/admin_socket.cc +++ b/src/common/admin_socket.cc @@ -386,8 +386,8 @@ void AdminSocket::do_accept() void AdminSocket::do_tell_queue() { ldout(m_cct,10) << __func__ << dendl; - std::list> q; - std::list> lq; + std::list> q; + std::list> lq; { std::lock_guard l(tell_lock); q.swap(tell_queue); @@ -525,14 +525,14 @@ void AdminSocket::execute_command( in_hook_cond.notify_all(); } -void AdminSocket::queue_tell_command(ref_t m) +void AdminSocket::queue_tell_command(cref_t m) { ldout(m_cct,10) << __func__ << " " << *m << dendl; std::lock_guard l(tell_lock); tell_queue.push_back(std::move(m)); wakeup(); } -void AdminSocket::queue_tell_command(ref_t m) +void AdminSocket::queue_tell_command(cref_t m) { ldout(m_cct,10) << __func__ << " " << *m << dendl; std::lock_guard l(tell_lock); diff --git a/src/common/admin_socket.h b/src/common/admin_socket.h index 3ac5f140e1c..6073869c7ef 100644 --- a/src/common/admin_socket.h +++ b/src/common/admin_socket.h @@ -117,8 +117,8 @@ public: std::ostream& errss, bufferlist *outbl); - void queue_tell_command(ref_t m); - void queue_tell_command(ref_t m); // for compat + void queue_tell_command(cref_t m); + void queue_tell_command(cref_t m); // for compat private: @@ -149,8 +149,8 @@ private: std::unique_ptr getdescs_hook; std::mutex tell_lock; - std::list> tell_queue; - std::list> tell_legacy_queue; + std::list> tell_queue; + std::list> tell_legacy_queue; struct hook_info { AdminSocketHook* hook; diff --git a/src/messages/MMonCommandAck.h b/src/messages/MMonCommandAck.h index 0eea4d26cb7..e075452bee7 100644 --- a/src/messages/MMonCommandAck.h +++ b/src/messages/MMonCommandAck.h @@ -24,7 +24,7 @@ public: std::string rs; MMonCommandAck() : PaxosServiceMessage{MSG_MON_COMMAND_ACK, 0} {} - MMonCommandAck(std::vector& c, int _r, std::string s, version_t v) : + MMonCommandAck(const std::vector& c, int _r, std::string s, version_t v) : PaxosServiceMessage{MSG_MON_COMMAND_ACK, v}, cmd(c), r(_r), rs(s) { } private: -- 2.39.5