From: Adam C. Emerson Date: Fri, 29 Mar 2019 01:40:28 +0000 (-0400) Subject: common: Update Finisher.h to work without using namespace X-Git-Tag: v15.0.0~19^2~16 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=d196e00ec99fa5b3b583f28b9ed8057ce48ce5b3;p=ceph-ci.git common: Update Finisher.h to work without using namespace Signed-off-by: Adam C. Emerson --- diff --git a/src/common/Finisher.h b/src/common/Finisher.h index cca3f81c884..b70b600af6c 100644 --- a/src/common/Finisher.h +++ b/src/common/Finisher.h @@ -46,18 +46,18 @@ class Finisher { bool finisher_empty_wait; ///< True mean someone wait finisher empty. /// Queue for contexts for which complete(0) will be called. - vector> finisher_queue; + std::vector> finisher_queue; - string thread_name; + std::string thread_name; /// Performance counter for the finisher's queue length. /// Only active for named finishers. PerfCounters *logger; - + void *finisher_thread_entry(); struct FinisherThread : public Thread { - Finisher *fin; + Finisher *fin; explicit FinisherThread(Finisher *f) : fin(f) {} void* entry() override { return fin->finisher_thread_entry(); } } finisher_thread; @@ -69,47 +69,47 @@ class Finisher { if (finisher_queue.empty()) { finisher_cond.notify_all(); } - finisher_queue.push_back(make_pair(c, r)); + finisher_queue.push_back(std::make_pair(c, r)); if (logger) logger->inc(l_finisher_queue_len); } - void queue(list& ls) { + void queue(std::list& ls) { { std::unique_lock ul(finisher_lock); if (finisher_queue.empty()) { finisher_cond.notify_all(); } for (auto i : ls) { - finisher_queue.push_back(make_pair(i, 0)); + finisher_queue.push_back(std::make_pair(i, 0)); } if (logger) logger->inc(l_finisher_queue_len, ls.size()); } ls.clear(); } - void queue(deque& ls) { + void queue(std::deque& ls) { { std::unique_lock ul(finisher_lock); if (finisher_queue.empty()) { finisher_cond.notify_all(); } for (auto i : ls) { - finisher_queue.push_back(make_pair(i, 0)); + finisher_queue.push_back(std::make_pair(i, 0)); } if (logger) logger->inc(l_finisher_queue_len, ls.size()); } ls.clear(); } - void queue(vector& ls) { + void queue(std::vector& ls) { { std::unique_lock ul(finisher_lock); if (finisher_queue.empty()) { finisher_cond.notify_all(); } for (auto i : ls) { - finisher_queue.push_back(make_pair(i, 0)); + finisher_queue.push_back(std::make_pair(i, 0)); } if (logger) logger->inc(l_finisher_queue_len, ls.size()); @@ -142,12 +142,12 @@ class Finisher { finisher_thread(this) {} /// Construct a named Finisher that logs its queue length. - Finisher(CephContext *cct_, string name, string tn) : + Finisher(CephContext *cct_, std::string name, std::string tn) : cct(cct_), finisher_lock(ceph::make_mutex("Finisher::" + name)), finisher_stop(false), finisher_running(false), finisher_empty_wait(false), thread_name(tn), logger(0), finisher_thread(this) { - PerfCountersBuilder b(cct, string("finisher-") + name, + PerfCountersBuilder b(cct, std::string("finisher-") + name, l_finisher_first, l_finisher_last); b.add_u64(l_finisher_queue_len, "queue_len"); b.add_time_avg(l_finisher_complete_lat, "complete_latency"); @@ -189,7 +189,7 @@ public: }; class ContextQueue { - list q; + std::list q; std::mutex q_mutex; ceph::mutex& mutex; ceph::condition_variable& cond; @@ -198,7 +198,7 @@ public: ceph::condition_variable& con) : mutex(mut), cond(con) {} - void queue(list& ls) { + void queue(std::list& ls) { bool empty = false; { std::scoped_lock l(q_mutex); @@ -218,7 +218,7 @@ public: ls.clear(); } - void swap(list& ls) { + void swap(std::list& ls) { ls.clear(); std::scoped_lock l(q_mutex); if (!q.empty()) {