Method Exit

src/tabletnode/tabletnode_impl.cc:314–355

}

bool TabletNodeImpl::Exit() {
  running_ = false;
  exit_event_.Set();

  cache_metrics_.reset(NULL);

  std::vector<io::TabletIO*> tablet_ios;
  tablet_manager_->GetAllTablets(&tablet_ios);

  std::vector<std::thread> unload_threads;
  unload_threads.reserve(tablet_ios.size());

  Counter worker_count;
  worker_count.Set(tablet_ios.size());

  for (uint32_t i = 0; i < tablet_ios.size(); ++i) {
    io::TabletIO* tablet_io = tablet_ios[i];
    unload_threads.emplace_back(
        std::bind(&TabletNodeImpl::UnloadTabletProc, this, tablet_io, &worker_count));
  }
  int64_t print_ms_ = get_millis();
  int64_t left = 0;
  while ((left = worker_count.Get()) > 0) {
    if (get_millis() - print_ms_ > 1000) {
      LOG(INFO) << "[Exit] " << left << " tablets are still unloading ...";
      print_ms_ = get_millis();
    }
    ThisThread::Sleep(100);
  }
  for (uint32_t i = 0; i < tablet_ios.size(); ++i) {
    unload_threads[i].join();
  }
  tablet_healthcheck_thread_.join();

  std::unique_ptr<leveldb::Logger> logger(leveldb::Logger::DefaultLogger());
  if (logger) {
    logger->Exit();
  }

  zk_adapter_->Exit();
  return true;
}

void TabletNodeImpl::RefreshTabletsStatus() {
  while (running_) {