From 98ccadfc412683e22f0ae46db03fdad78953ed23 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Tue, 16 Oct 2018 09:12:34 -0500 Subject: [PATCH] common/AsyncOpTracker: Mutex -> ceph::mutex Signed-off-by: Sage Weil --- src/common/AsyncOpTracker.cc | 12 ++++++------ src/common/AsyncOpTracker.h | 4 ++-- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/src/common/AsyncOpTracker.cc b/src/common/AsyncOpTracker.cc index 6d78368f8e7..fb6439d384c 100644 --- a/src/common/AsyncOpTracker.cc +++ b/src/common/AsyncOpTracker.cc @@ -5,23 +5,23 @@ #include "include/Context.h" AsyncOpTracker::AsyncOpTracker() - : m_lock("AsyncOpTracker::m_lock", false, false) { +{ } AsyncOpTracker::~AsyncOpTracker() { - std::lock_guard locker(m_lock); + std::lock_guard locker(m_lock); ceph_assert(m_pending_ops == 0); } void AsyncOpTracker::start_op() { - std::lock_guard locker(m_lock); + std::lock_guard locker(m_lock); ++m_pending_ops; } void AsyncOpTracker::finish_op() { Context *on_finish = nullptr; { - std::lock_guard locker(m_lock); + std::lock_guard locker(m_lock); ceph_assert(m_pending_ops > 0); if (--m_pending_ops == 0) { std::swap(on_finish, m_on_finish); @@ -35,7 +35,7 @@ void AsyncOpTracker::finish_op() { void AsyncOpTracker::wait_for_ops(Context *on_finish) { { - std::lock_guard locker(m_lock); + std::lock_guard locker(m_lock); ceph_assert(m_on_finish == nullptr); if (m_pending_ops > 0) { m_on_finish = on_finish; @@ -46,7 +46,7 @@ void AsyncOpTracker::wait_for_ops(Context *on_finish) { } bool AsyncOpTracker::empty() { - std::lock_guard locker(m_lock); + std::lock_guard locker(m_lock); return (m_pending_ops == 0); } diff --git a/src/common/AsyncOpTracker.h b/src/common/AsyncOpTracker.h index f600cbd7f24..d913032aa56 100644 --- a/src/common/AsyncOpTracker.h +++ b/src/common/AsyncOpTracker.h @@ -4,7 +4,7 @@ #ifndef CEPH_ASYNC_OP_TRACKER_H #define CEPH_ASYNC_OP_TRACKER_H -#include "common/Mutex.h" +#include "common/ceph_mutex.h" struct Context; @@ -21,7 +21,7 @@ public: bool empty(); private: - Mutex m_lock; + ceph::mutex m_lock = ceph::make_mutex("AsyncOpTracker::m_lock"); uint32_t m_pending_ops = 0; Context *m_on_finish = nullptr; -- 2.39.5