| 43 | } |
| 44 | |
| 45 | void condition_variable_debug::notify_all(bool sloppy) |
| 46 | { |
| 47 | if (!sloppy) { |
| 48 | // make sure signaler is holding the waiter's lock. |
| 49 | ceph_assert(waiter_mutex == NULL || |
| 50 | waiter_mutex->is_locked()); |
| 51 | } |
| 52 | if (int r = pthread_cond_broadcast(&cond); r != 0 && !sloppy) { |
| 53 | throw std::system_error(r, std::generic_category()); |
| 54 | } |
| 55 | } |
| 56 | |
| 57 | std::cv_status condition_variable_debug::_wait_until(mutex_debug* mutex, |
| 58 | timespec* ts) |
no test coverage detected