| 480 | } |
| 481 | |
| 482 | Status PauseAll(ServerContext*, const EmptyRequest*, |
| 483 | EmptyResponse*) override { |
| 484 | std::lock_guard<std::recursive_mutex> lock(mutex_); |
| 485 | |
| 486 | pause_all_workers(); |
| 487 | LOG(INFO) << "*** All workers have been paused ***"; |
| 488 | return Status::OK; |
| 489 | } |
| 490 | |
| 491 | Status PauseWorker(ServerContext*, const PauseWorkerRequest* req, |
| 492 | EmptyResponse*) override { |
nothing calls this directly
no test coverage detected