| 2372 | ////////// table operation //////////// |
| 2373 | |
| 2374 | bool MasterImpl::LoadTabletSync(const TabletMeta &meta, const TableSchema &schema, |
| 2375 | StatusCode *status) { |
| 2376 | TabletNodePtr node; |
| 2377 | if (!tabletnode_manager_->FindTabletNode(meta.server_addr(), &node)) { |
| 2378 | SetStatusCode(kTabletNodeOffline, status); |
| 2379 | return false; |
| 2380 | } |
| 2381 | |
| 2382 | tabletnode::TabletNodeClient node_client(thread_pool_.get(), meta.server_addr(), |
| 2383 | FLAGS_tera_master_load_rpc_timeout); |
| 2384 | |
| 2385 | LoadTabletRequest request; |
| 2386 | LoadTabletResponse response; |
| 2387 | request.set_tablet_name(meta.table_name()); |
| 2388 | request.set_sequence_id(this_sequence_id_.Inc()); |
| 2389 | request.mutable_key_range()->CopyFrom(meta.key_range()); |
| 2390 | request.set_path(meta.path()); |
| 2391 | request.mutable_schema()->CopyFrom(schema); |
| 2392 | request.set_session_id(node->uuid_); |
| 2393 | |
| 2394 | if (node_client.LoadTablet(&request, &response) && response.status() == kTabletNodeOk) { |
| 2395 | return true; |
| 2396 | } |
| 2397 | SetStatusCode(response.status(), status); |
| 2398 | return false; |
| 2399 | } |
| 2400 | |
| 2401 | bool MasterImpl::UnloadTabletSync(const std::string &table_name, const std::string &key_start, |
| 2402 | const std::string &key_end, const std::string &server_addr, |
nothing calls this directly
no test coverage detected