| 97 | |
| 98 | private: |
| 99 | void CountThread(std::atomic<int>* counter, int until, Notification* start) { |
| 100 | if (start != nullptr) start->WaitForNotification(); |
| 101 | while (!coord_->ShouldStop() && counter->load() < until) { |
| 102 | (*counter)++; |
| 103 | Env::Default()->SleepForMicroseconds(10 * 1000); |
| 104 | } |
| 105 | coord_->RequestStop().IgnoreError(); |
| 106 | } |
| 107 | void SetStatusThread(const Status& status, BlockingCounter* counter, |
| 108 | Notification* start) { |
| 109 | start->WaitForNotification(); |
nothing calls this directly
no test coverage detected