| 3831 | } |
| 3832 | |
| 3833 | void TabletImpl::GetTaskStatus(RpcController* controller, |
| 3834 | const ::fedb::api::TaskStatusRequest* request, |
| 3835 | ::fedb::api::TaskStatusResponse* response, |
| 3836 | Closure* done) { |
| 3837 | brpc::ClosureGuard done_guard(done); |
| 3838 | std::lock_guard<std::mutex> lock(mu_); |
| 3839 | for (const auto& kv : task_map_) { |
| 3840 | for (const auto& task_info : kv.second) { |
| 3841 | ::fedb::api::TaskInfo* task = response->add_task(); |
| 3842 | task->CopyFrom(*task_info); |
| 3843 | } |
| 3844 | } |
| 3845 | response->set_code(::fedb::base::ReturnCode::kOk); |
| 3846 | response->set_msg("ok"); |
| 3847 | } |
| 3848 | |
| 3849 | void TabletImpl::DeleteOPTask(RpcController* controller, |
| 3850 | const ::fedb::api::DeleteTaskRequest* request, |
nothing calls this directly
no outgoing calls
no test coverage detected