MCPcopy Create free account
hub / github.com/apache/impala / Notify

Method Notify

be/src/kudu/util/notification.h:96–103  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

94 }
95
96 void Notify() {
97 auto s = base::subtle::Release_AtomicExchange(&state_, NOTIFIED);
98 DCHECK_NE(s, NOTIFIED) << "may only notify once";
99 if (s == NOT_NOTIFIED_HAS_WAITERS) {
100 sys_futex(&state_, FUTEX_WAKE | FUTEX_PRIVATE_FLAG, INT_MAX,
101 nullptr /* ignored */, nullptr /* ignored */, 0 /* ignored */);
102 }
103 }
104
105 private:
106 enum {

Callers 3

TEST_FFunction · 0.45
SyncRequestMethod · 0.45
GetNextMethod · 0.45

Calls 2

Release_AtomicExchangeFunction · 0.85
CountDownMethod · 0.80

Tested by 1

TEST_FFunction · 0.36