| 178 | } |
| 179 | |
| 180 | int TaskQueueSize(bool is_blocking) { |
| 181 | if (is_blocking) { |
| 182 | return blocking_work_queue_.Size(); |
| 183 | } else { |
| 184 | unsigned total_size = 0; |
| 185 | for (int i = 0; i < non_blocking_work_sharding_factor_; ++i) { |
| 186 | total_size += non_blocking_work_queues_[i]->queue.Size(); |
| 187 | } |
| 188 | return total_size; |
| 189 | } |
| 190 | } |
| 191 | |
| 192 | int64 GetTracemeId() { return traceme_id_.load(std::memory_order_relaxed); } |
| 193 |