| 1268 | } |
| 1269 | |
| 1270 | bool TabletClient::SendIndexData( |
| 1271 | uint32_t tid, uint32_t pid, |
| 1272 | const std::map<uint32_t, std::string>& pid_endpoint_map, |
| 1273 | std::shared_ptr<TaskInfo> task_info) { |
| 1274 | ::fedb::api::SendIndexDataRequest request; |
| 1275 | ::fedb::api::GeneralResponse response; |
| 1276 | request.set_tid(tid); |
| 1277 | request.set_pid(pid); |
| 1278 | for (const auto& kv : pid_endpoint_map) { |
| 1279 | auto pair = request.add_pairs(); |
| 1280 | pair->set_pid(kv.first); |
| 1281 | pair->set_endpoint(kv.second); |
| 1282 | } |
| 1283 | if (task_info) { |
| 1284 | request.mutable_task_info()->CopyFrom(*task_info); |
| 1285 | } |
| 1286 | bool ok = |
| 1287 | client_.SendRequest(&fedb::api::TabletServer_Stub::SendIndexData, |
| 1288 | &request, &response, FLAGS_request_timeout_ms, 1); |
| 1289 | if (!ok || response.code() != 0) { |
| 1290 | return false; |
| 1291 | } |
| 1292 | return true; |
| 1293 | } |
| 1294 | |
| 1295 | bool TabletClient::LoadIndexData(uint32_t tid, uint32_t pid, |
| 1296 | uint32_t partition_num, |
nothing calls this directly
no test coverage detected