| 169 | } |
| 170 | |
| 171 | void WaitSet::signal(Condition_ptr condition) |
| 172 | { |
| 173 | Condition_var condv(Condition::_duplicate(condition)); |
| 174 | ACE_GUARD(ACE_Recursive_Thread_Mutex, g, lock_); |
| 175 | |
| 176 | if (attached_conditions_.find(condv) != attached_conditions_.end()) { |
| 177 | signaled_conditions_.insert(condv); |
| 178 | cond_.notify_one(); |
| 179 | } |
| 180 | } |
| 181 | |
| 182 | WaitSet_ptr WaitSet::_duplicate(WaitSet_ptr obj) |
| 183 | { |
no test coverage detected