Method SetupWithParameters

be/src/runtime/io/data-cache-test.cc:213–239

Create a bunch of test directories in which the data cache will reside.

  // Create a bunch of test directories in which the data cache will reside.
  void SetupWithParameters(DataCacheTestParam param) {
    test_env_.reset(new TestEnv());
    flag_saver_.reset(new google::FlagSaver());
    ASSERT_OK(test_env_->Init());
    for (int i = 0; i < NUM_TEST_DIRS; ++i) {
      const string& path = Substitute("$0/data-cache-test.$1", BASE_CACHE_DIR, i);
      ASSERT_OK(FileSystemUtil::RemoveAndCreateDirectory(path));
      data_cache_dirs_.push_back(path);
    }
    data_cache_trace_dir_ = ("/tmp" / boost::filesystem::unique_path()).string();
    ASSERT_OK(FileSystemUtil::RemoveAndCreateDirectory(data_cache_trace_dir_));

    // Force a single shard to avoid imbalance between shards in the Kudu LRU cache which
    // may lead to unintended eviction. This allows the capacity of the cache is utilized
    // to the limit for the purpose of this test.
    FLAGS_cache_force_single_shard = true;

    // Allows full write concurrency for the multi-threaded tests.
    FLAGS_data_cache_write_concurrency = NUM_THREADS;

    // This is parameterized to allow testing LRU and LIRS
    FLAGS_data_cache_eviction_policy = param.eviction_policy;

    // This is parameterized to allow testing asynchronous write.
    FLAGS_data_cache_num_async_write_threads = param.num_write_threads;
    FLAGS_data_cache_async_write_buffer_limit = "1G";
  }

  // Delete all the test directories created.
  virtual void TearDown() {