Method InitCacheSystem

src/tabletnode/tabletnode_impl.cc:278–312

}

bool TabletNodeImpl::InitCacheSystem() {
  sysinfo_.SetPersistentCacheSize(0);
  if (!io::GetCachePaths().empty()) {
    if (FLAGS_tera_enable_persistent_cache) {
      LOG(INFO) << "Enable persistent cache.";
      std::shared_ptr<leveldb::PersistentCache> persistent_cache;
      auto status = ::tera::io::GetPersistentCache(&persistent_cache);

      if (!status.ok() || !persistent_cache) {
        LOG(ERROR) << "Init persistent cache failed: " << status.ToString() << ", exit on error.";
        return false;
      }
      sysinfo_.SetPersistentCacheSize(persistent_cache->GetCapacity());
    } else {
      LOG(INFO) << "Enable flash env.";
      // compitable with legacy FlashEnv
      leveldb::FlashEnv* flash_env = (leveldb::FlashEnv*)io::LeveldbFlashEnv();
      if (FLAGS_tera_tabletnode_clean_persistent_cache_paths) {
        for (const auto& path : io::GetCachePaths()) {
          auto s = leveldb::Env::Default()->DeleteDirRecursive(path);
          if (!s.ok()) {
            LOG(WARNING) << "Remove persistent cache paths " << path << " failed: " << s.ToString();
          }
        }
      }
      assert(flash_env);
      flash_env->SetFlashPath(FLAGS_tera_tabletnode_cache_paths,
                              FLAGS_tera_io_cache_path_vanish_allowed);
      flash_env->SetUpdateFlashThreadNumber(FLAGS_tera_tabletnode_cache_update_thread_num);
      flash_env->SetIfForceReadFromCache(FLAGS_tera_tabletnode_cache_force_read_from_cache);
      flash_env->TryRollbackPersistentCacheFiles();
    }
  }
  return true;
}

bool TabletNodeImpl::Exit() {
  running_ = false;