| 295 | } |
| 296 | |
| 297 | inline 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 | |
| 305 | int butex_wake(void* arg, bool nosignal) { |
| 306 | Butex* b = container_of(static_cast<butil::atomic<int>*>(arg), Butex, value); |
no test coverage detected