| 448 | } |
| 449 | |
| 450 | Status ResetAll(ServerContext* context, const EmptyRequest* request, |
| 451 | EmptyResponse* response) override { |
| 452 | std::lock_guard<std::recursive_mutex> lock(mutex_); |
| 453 | |
| 454 | Status status; |
| 455 | WorkerPauser wp; |
| 456 | |
| 457 | LOG(INFO) << "*** ResetAll requested ***"; |
| 458 | |
| 459 | status = ResetModules(context, request, response); |
| 460 | if (response->error().code() != 0) { |
| 461 | return status; |
| 462 | } |
| 463 | |
| 464 | status = ResetPorts(context, request, response); |
| 465 | if (response->error().code() != 0) { |
| 466 | return status; |
| 467 | } |
| 468 | |
| 469 | status = ResetTcs(context, request, response); |
| 470 | if (response->error().code() != 0) { |
| 471 | return status; |
| 472 | } |
| 473 | |
| 474 | status = ResetWorkers(context, request, response); |
| 475 | if (response->error().code() != 0) { |
| 476 | return status; |
| 477 | } |
| 478 | |
| 479 | return Status::OK; |
| 480 | } |
| 481 | |
| 482 | Status PauseAll(ServerContext*, const EmptyRequest*, |
| 483 | EmptyResponse*) override { |
nothing calls this directly
no outgoing calls
no test coverage detected