| 609 | } |
| 610 | |
| 611 | void RemoteTabletNode::DoLoadTablet(google::protobuf::RpcController* controller, |
| 612 | const LoadTabletRequest* request, LoadTabletResponse* response, |
| 613 | google::protobuf::Closure* done) { |
| 614 | uint64_t id = request->sequence_id(); |
| 615 | LOG(INFO) << "run RPC (LoadTablet) id: " << id; |
| 616 | { |
| 617 | std::lock_guard<std::mutex> lock(tablets_ctrl_mutex_); |
| 618 | tablets_ctrl_status_[request->path()] = TabletCtrlStatus::kCtrlOnLoad; |
| 619 | } |
| 620 | tabletnode_impl_->LoadTablet(request, response); |
| 621 | { |
| 622 | std::lock_guard<std::mutex> lock(tablets_ctrl_mutex_); |
| 623 | tablets_ctrl_status_.erase(request->path()); |
| 624 | } |
| 625 | LOG(INFO) << "finish RPC (LoadTablet) id: " << id; |
| 626 | done->Run(); |
| 627 | } |
| 628 | |
| 629 | void RemoteTabletNode::DoUnloadTablet(google::protobuf::RpcController* controller, |
| 630 | const UnloadTabletRequest* request, |
nothing calls this directly
no test coverage detected