| 849 | |
| 850 | |
| 851 | void TaskGroup::ready_to_run(TaskMeta* meta, bool nosignal) { |
| 852 | #ifdef BRPC_BTHREAD_TRACER |
| 853 | _control->_task_tracer.set_status(TASK_STATUS_READY, meta); |
| 854 | #endif // BRPC_BTHREAD_TRACER |
| 855 | push_rq(meta->tid); |
| 856 | if (nosignal) { |
| 857 | ++_num_nosignal; |
| 858 | } else { |
| 859 | const int additional_signal = _num_nosignal; |
| 860 | _num_nosignal = 0; |
| 861 | _nsignaled += 1 + additional_signal; |
| 862 | _control->signal_task(1 + additional_signal, _tag); |
| 863 | } |
| 864 | } |
| 865 | |
| 866 | void TaskGroup::flush_nosignal_tasks() { |
| 867 | const int val = _num_nosignal; |
no test coverage detected