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

Function run_in_local_task_group

src/bthread/butex.cpp:297–303  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

295}
296
297inline void run_in_local_task_group(TaskGroup* g, TaskMeta* next_meta, bool nosignal) {
298 if (!nosignal) {
299 TaskGroup::exchange(&g, next_meta);
300 } else {
301 g->ready_to_run(next_meta, nosignal);
302 }
303}
304
305int butex_wake(void* arg, bool nosignal) {
306 Butex* b = container_of(static_cast<butil::atomic<int>*>(arg), Butex, value);

Callers 2

butex_wakeFunction · 0.85
butex_wake_nFunction · 0.85

Calls 1

ready_to_runMethod · 0.80

Tested by

no test coverage detected