1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #include "common/AsyncOpTracker.h"
5 #include "include/Context.h"
7 AsyncOpTracker::AsyncOpTracker()
8 : m_lock("AsyncOpTracker::m_lock", false, false) {
11 AsyncOpTracker::~AsyncOpTracker() {
12 Mutex::Locker locker(m_lock);
13 assert(m_pending_ops == 0);
16 void AsyncOpTracker::start_op() {
17 Mutex::Locker locker(m_lock);
21 void AsyncOpTracker::finish_op() {
22 Context *on_finish = nullptr;
24 Mutex::Locker locker(m_lock);
25 assert(m_pending_ops > 0);
26 if (--m_pending_ops == 0) {
27 std::swap(on_finish, m_on_finish);
31 if (on_finish != nullptr) {
32 on_finish->complete(0);
36 void AsyncOpTracker::wait_for_ops(Context *on_finish) {
38 Mutex::Locker locker(m_lock);
39 assert(m_on_finish == nullptr);
40 if (m_pending_ops > 0) {
41 m_on_finish = on_finish;
45 on_finish->complete(0);
48 bool AsyncOpTracker::empty() {
49 Mutex::Locker locker(m_lock);
50 return (m_pending_ops == 0);