Lines Matching refs:syncId
43 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps)
46 name_.c_str(), static_cast<int>(syncId));
49 waitSet_.insert(syncId);
51 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); });
52 syncMap_.erase(syncId);
56 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs)
59 name_.c_str(), static_cast<int>(syncId), timeoutMs);
64 waitSet_.insert(syncId);
66 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); });
68 syncMap_.erase(syncId);
70 waitSet_.erase(syncId);
75 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps, ResultType& result)
78 name_.c_str(), static_cast<int>(syncId));
81 waitSet_.insert(syncId);
83 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); });
84 result = syncMap_[syncId];
85 syncMap_.erase(syncId);
89 bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result)
92 name_.c_str(), static_cast<int>(syncId), timeoutMs);
97 waitSet_.insert(syncId);
99 waitSet_.erase(syncId);
102 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); });
104 result = syncMap_[syncId];
105 syncMap_.erase(syncId);
107 static_cast<int>(syncId));
109 waitSet_.erase(syncId);
114 void Notify(SyncIdType syncId, ResultType result = ResultType())
117 name_.c_str(), static_cast<int>(syncId));
119 if (waitSet_.find(syncId) != waitSet_.end()) {
120 waitSet_.erase(syncId);
121 syncMap_.insert({syncId, result});