| 948 | } |
| 949 | |
| 950 | bool TabletClient::GetTableFollower(uint32_t tid, uint32_t pid, |
| 951 | uint64_t& offset, |
| 952 | std::map<std::string, uint64_t>& info_map, |
| 953 | std::string& msg) { |
| 954 | ::fedb::api::GetTableFollowerRequest request; |
| 955 | ::fedb::api::GetTableFollowerResponse response; |
| 956 | request.set_tid(tid); |
| 957 | request.set_pid(pid); |
| 958 | bool ok = |
| 959 | client_.SendRequest(&::fedb::api::TabletServer_Stub::GetTableFollower, |
| 960 | &request, &response, FLAGS_request_timeout_ms, 1); |
| 961 | if (response.has_msg()) { |
| 962 | msg = response.msg(); |
| 963 | } |
| 964 | if (!ok || response.code() != 0) { |
| 965 | return false; |
| 966 | } |
| 967 | for (int idx = 0; idx < response.follower_info_size(); idx++) { |
| 968 | info_map.insert(std::make_pair(response.follower_info(idx).endpoint(), |
| 969 | response.follower_info(idx).offset())); |
| 970 | } |
| 971 | offset = response.offset(); |
| 972 | return true; |
| 973 | } |
| 974 | |
| 975 | void TabletClient::ShowTp() { |
| 976 | if (!FLAGS_enable_show_tp) { |
no test coverage detected