MCPcopy Create free account
hub / github.com/apache/brpc / wakeup

Method wakeup

test/bthread_timer_thread_unittest.cpp:65–73  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

63 }
64
65 void wakeup() {
66 if (_sleep_ms != 0) {
67 _sleep_ms = 0;
68 bthread::futex_wake_private(&_sleep_ms, 1);
69 } else {
70 LOG(ERROR) << "No need to wakeup "
71 << (_name ? _name : "") << " task_id=" << _task_id;
72 }
73 }
74
75 // verify the first run is in specified time range.
76 void expect_first_run()

Callers 1

TESTFunction · 0.80

Calls 1

futex_wake_privateFunction · 0.50

Tested by

no test coverage detected