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

Method flush_nosignal_tasks_remote_locked

src/bthread/task_group.cpp:899–909  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

897}
898
899void TaskGroup::flush_nosignal_tasks_remote_locked(butil::Mutex& locked_mutex) {
900 const int val = _remote_num_nosignal;
901 if (!val) {
902 locked_mutex.unlock();
903 return;
904 }
905 _remote_num_nosignal = 0;
906 _remote_nsignaled += val;
907 locked_mutex.unlock();
908 _control->signal_task(val, _tag);
909}
910
911void TaskGroup::ready_to_run_general(TaskMeta* meta, bool nosignal) {
912 if (tls_task_group == this) {

Callers

nothing calls this directly

Calls 2

signal_taskMethod · 0.80
unlockMethod · 0.45

Tested by

no test coverage detected