| 2267 | } |
| 2268 | |
| 2269 | void MasterImpl::LoadAllDeadNodeTablets() { |
| 2270 | std::vector<TabletPtr> all_tablet_list; |
| 2271 | tablet_manager_->ShowTable(NULL, &all_tablet_list); |
| 2272 | |
| 2273 | std::vector<TabletPtr>::iterator it; |
| 2274 | for (it = all_tablet_list.begin(); it != all_tablet_list.end(); ++it) { |
| 2275 | TabletPtr tablet = *it; |
| 2276 | if (tablet->GetStatus() != TabletMeta::kTabletOffline) { |
| 2277 | continue; |
| 2278 | } |
| 2279 | TabletNodePtr node; |
| 2280 | if (tabletnode_manager_->FindTabletNode(tablet->GetServerAddr(), &node) && |
| 2281 | node->GetState() == kReady) { |
| 2282 | continue; |
| 2283 | } |
| 2284 | LOG(INFO) << "try load tablets in dead node, " << tablet; |
| 2285 | TryLoadTablet(tablet); |
| 2286 | } |
| 2287 | } |
| 2288 | |
| 2289 | bool MasterImpl::TryKickTabletNode(TabletNodePtr node) { |
| 2290 | // concurrently kicking is not allowed |
nothing calls this directly
no test coverage detected