MCPcopy Create free account
hub / github.com/ceph/ceph / notify_all

Method notify_all

src/common/condition_variable_debug.cc:45–55  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

43}
44
45void 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
57std::cv_status condition_variable_debug::_wait_until(mutex_debug* mutex,
58 timespec* ts)

Callers 15

finishMethod · 0.45
~RWRefMethod · 0.45
completeMethod · 0.45
make_requestMethod · 0.45
_closed_mds_sessionMethod · 0.45
handle_client_sessionMethod · 0.45
build_client_requestMethod · 0.45
handle_client_replyMethod · 0.45
ms_dispatch2Method · 0.45
send_reconnectMethod · 0.45
kick_requestsMethod · 0.45

Calls 1

is_lockedMethod · 0.45

Tested by

no test coverage detected