RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-19 17:41:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #12809 from wjin/optimize_atomic

Browse Source 
msg/async: avoid atomic variable overhead

Reviewed-by: Haomai Wang <haomai@xsky.com>
This commit is contained in:
Kefu Chai 2017-01-11 13:02:17 +08:00 committed by GitHub
commit 87256a1fbc
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/msg/async/Stack.cc
View File

@ -174,7 +174,7 @@ void NetworkStack::stop()
class C_drain : public EventCallback {
Mutex drain_lock;
Cond drain_cond;
std::atomic<unsigned> drain_count;
unsigned drain_count;
public:
explicit C_drain(size_t c)
@ -183,11 +183,11 @@ class C_drain : public EventCallback {
void do_request(int id) {
Mutex::Locker l(drain_lock);
drain_count--;
drain_cond.Signal();
if (drain_count == 0) drain_cond.Signal();
}
void wait() {
Mutex::Locker l(drain_lock);
while (drain_count.load())
while (drain_count)
drain_cond.Wait(drain_lock);
}
};