| 35 | } |
| 36 | |
| 37 | void GrpcVerbsService::Shutdown() { |
| 38 | bool did_shutdown = false; |
| 39 | { |
| 40 | mutex_lock l(shutdown_mu_); |
| 41 | if (!is_shutdown_) { |
| 42 | LOG(INFO) << "Shutting down GrpcWorkerService."; |
| 43 | is_shutdown_ = true; |
| 44 | did_shutdown = true; |
| 45 | } |
| 46 | } |
| 47 | if (did_shutdown) { |
| 48 | shutdown_alarm_ = |
| 49 | new ::grpc::Alarm(cq_, gpr_now(GPR_CLOCK_MONOTONIC), nullptr); |
| 50 | } |
| 51 | } |
| 52 | |
| 53 | // This macro creates a new request for the given RPC method name |
| 54 | // (e.g., `ENQUEUE_REQUEST(GetRemoteAddress, false);`), and enqueues it on |
no outgoing calls
no test coverage detected