| 189 | } |
| 190 | |
| 191 | void SingleThreadedSchedulerClient::EmptyQueue() |
| 192 | { |
| 193 | assert(!m_pscheduler->AreThreadsServicingQueue()); |
| 194 | bool should_continue = true; |
| 195 | while (should_continue) { |
| 196 | ProcessQueue(); |
| 197 | LOCK(m_callbacks_mutex); |
| 198 | should_continue = !m_callbacks_pending.empty(); |
| 199 | } |
| 200 | } |
| 201 | |
| 202 | size_t SingleThreadedSchedulerClient::CallbacksPending() |
| 203 | { |
no test coverage detected