Home
last modified time | relevance | path

Searched refs:env_ (Results 1 – 25 of 161) sorted by relevance

1234567

/rocksdb-6.9/env/
Denv_basic_test.cc56 Env* env_; member in ROCKSDB_NAMESPACE::EnvBasicTestWithParam
60 EnvBasicTestWithParam() : env_(GetParam()) { in EnvBasicTestWithParam()
68 env_->GetChildren(test_dir_, &files); in TearDown()
149 ASSERT_OK(env_->FileExists(test_dir_ + "/f")); in TEST_P()
155 ASSERT_OK(env_->DeleteFile(test_dir_ + "/f")); in TEST_P()
177 ASSERT_OK(env_->FileExists(test_dir_ + "/g")); in TEST_P()
301 env_->GetChildren(test_dir_, &children); in TEST_P()
316 ASSERT_OK(env_->FileExists(test_dir_)); in TEST_P()
330 env_->DeleteDir(test_dir_ + "/" + each); in TEST_P()
334 ASSERT_OK(env_->DeleteDir(test_dir_)); in TEST_P()
[all …]
Denv_test.cc88 Env* env_; member in ROCKSDB_NAMESPACE::EnvPosixTest
99 env_ = param_pair.first; in EnvPosixTestWithParam()
133 env_->WaitForJoin(); in TEST_F()
1552 ASSERT_OK(env_->GetChildrenFileAttributes(test::TmpDir(env_), &file_attrs)); in TEST_P()
1728 env_->DeleteFile(path); in TEST_P()
1795 env_->DeleteFile(path); in TEST_P()
1855 env_->DeleteFile(path); in TEST_P()
1896 env_->DeleteFile(path); in TEST_P()
2019 Env* env_; in TEST_P() member in ROCKSDB_NAMESPACE::EnvFSTestWithParam
2029 opts.env = env_; in TEST_P()
[all …]
Dmock_env_test.cc19 MockEnv* env_; member in ROCKSDB_NAMESPACE::MockEnvTest
23 : env_(new MockEnv(Env::Default())) { in MockEnvTest()
25 ~MockEnvTest() override { delete env_; } in ~MockEnvTest()
33 ASSERT_OK(env_->NewWritableFile(kFileName, &writable_file, soptions_)); in TEST_F()
41 ASSERT_OK(env_->NewRandomAccessFile(kFileName, &rand_file, soptions_)); in TEST_F()
47 ASSERT_OK(dynamic_cast<MockEnv*>(env_)->CorruptBuffer(kFileName)); in TEST_F()
60 ASSERT_OK(dynamic_cast<MockEnv*>(env_)->CorruptBuffer(kFileName)); in TEST_F()
69 auto s = env_->GetCurrentTime(&now); in TEST_F()
71 env_->FakeSleepForMicroseconds(3 * 1000 * 1000); in TEST_F()
73 s = env_->GetCurrentTime(&after_sleep); in TEST_F()
/rocksdb-6.9/utilities/
Denv_mirror_test.cc19 EnvMirror* env_; member in ROCKSDB_NAMESPACE::EnvMirrorTest
26 env_(new EnvMirror(a_, b_)) {} in EnvMirrorTest()
28 delete env_; in ~EnvMirrorTest()
39 ASSERT_OK(env_->CreateDir("/dir")); in TEST_F()
44 ASSERT_OK(env_->GetChildren("/dir", &children)); in TEST_F()
52 ASSERT_OK(env_->FileExists("/dir/f")); in TEST_F()
84 ASSERT_OK(env_->FileExists("/dir/g")); in TEST_F()
106 ASSERT_OK(env_->DeleteFile("/dir/g")); in TEST_F()
110 ASSERT_OK(env_->DeleteDir("/dir")); in TEST_F()
120 ASSERT_OK(env_->CreateDir("/dir")); in TEST_F()
[all …]
Denv_librados_test.cc58 EnvLibrados* env_; member in ROCKSDB_NAMESPACE::EnvLibradosTest
65 delete env_; in ~EnvLibradosTest()
340 options.env = env_; in TEST_F()
423 options2.env = env_; in TEST_F()
504 options2.env = env_; in TEST_F()
588 options2.env = env_; in TEST_F()
685 options2.env = env_; in TEST_F()
744 EnvLibrados* env_; member in ROCKSDB_NAMESPACE::EnvLibradosMutipoolTest
751 delete env_; in ~EnvLibradosMutipoolTest()
882 options.env = env_; in TEST_F()
[all …]
/rocksdb-6.9/trace_replay/
Dblock_cache_tracer_test.cc30 env_ = ROCKSDB_NAMESPACE::Env::Default(); in BlockCacheTracerTest()
31 EXPECT_OK(env_->CreateDir(test_path_)); in BlockCacheTracerTest()
36 EXPECT_OK(env_->DeleteFile(trace_file_path_)); in ~BlockCacheTracerTest()
37 EXPECT_OK(env_->DeleteDir(test_path_)); in ~BlockCacheTracerTest()
66 record.access_timestamp = env_->NowMicros(); in WriteBlockAccess()
96 record.access_timestamp = env_->NowMicros(); in GenerateAccessRecord()
152 Env* env_; member in ROCKSDB_NAMESPACE::BlockCacheTracerTest
169 ASSERT_OK(env_->FileExists(trace_file_path_)); in TEST_F()
193 ASSERT_OK(env_->FileExists(trace_file_path_)); in TEST_F()
218 ASSERT_OK(env_->FileExists(trace_file_path_)); in TEST_F()
[all …]
/rocksdb-6.9/db/
Ddb_io_failure_test.cc25 options.env = env_; in TEST_F()
70 options.env = env_; in TEST_F()
97 options.env = env_; in TEST_F()
125 options.env = env_; in TEST_F()
215 options.env = env_; in TEST_F()
255 options.env = env_; in TEST_F()
314 options.env = env_; in TEST_F()
381 options.env = env_; in TEST_F()
421 options.env = env_; in TEST_F()
471 options.env = env_; in TEST_F()
[all …]
Dfault_injection_test.cc71 FaultInjectionTestEnv* env_; member in ROCKSDB_NAMESPACE::FaultInjectionTest
83 env_(nullptr), in FaultInjectionTest()
147 assert(env_ == nullptr); in NewDB()
149 env_ = in NewDB()
153 options_.env = env_; in NewDB()
181 delete env_; in TearDown()
182 env_ = nullptr; in TearDown()
262 env_->ResetState(); in OpenDB()
284 env_->AssertNoOpenFile(); in ResetDBState()
413 env_->SetFilesystemActive(false); in TEST_P()
[all …]
Ddb_sst_test.cc56 options.env = env_; in TEST_F()
154 options.env = env_; in TEST_F()
196 options.env = env_; in TEST_F()
367 env_->addon_time_.fetch_add( in TEST_F()
378 env_->no_slowdown_ = true; in TEST_F()
390 options.env = env_; in TEST_F()
452 env_->no_slowdown_ = true; in TEST_F()
457 options.env = env_; in TEST_F()
611 env_->CreateDirIfMissing(dbname_); in TEST_F()
643 options.env = env_; in TEST_F()
[all …]
Ddb_test_util.h77 uint64_t start = env_->NowMicros(); in WaitFor()
79 uint64_t now = env_->NowMicros(); in WaitFor()
99 Env* env_;
216 SpecialEnv* env_; in NewWritableFile()
223 if (env_->table_write_callback_) { in NewWritableFile()
275 ++env_->sync_counter_; in NewWritableFile()
313 ++env_->sync_counter_; in NewWritableFile()
326 SpecialEnv* env_; in NewWritableFile()
371 ++env_->sync_counter_; in NewWritableFile()
382 SpecialEnv* env_; in NewWritableFile()
[all …]
Dwal_manager_test.cc34 : env_(new MockEnv(Env::Default())), in WalManagerTest()
44 ASSERT_OK(env_->CreateDirIfMissing(dbname_)); in Init()
49 db_options_.env = env_.get(); in Init()
50 fs_.reset(new LegacyFileSystemWrapper(env_.get())); in Init()
83 ASSERT_OK(env_->NewWritableFile(fname, &file, env_options_)); in RollTheLog()
107 std::unique_ptr<MockEnv> env_; member in ROCKSDB_NAMESPACE::WalManagerTest
126 ASSERT_OK(env_->NewWritableFile(path, &file, EnvOptions())); in TEST_F()
233 ListSpecificFiles(env_.get(), archive_dir, kLogFile); in TEST_F()
244 env_->FakeSleepForMicroseconds(2 * 1000 * 1000); in TEST_F()
266 ListSpecificFiles(env_.get(), archive_dir, kLogFile); in TEST_F()
[all …]
Drepair_test.cc55 ASSERT_OK(env_->FileExists(manifest_path)); in TEST_F()
56 ASSERT_OK(env_->DeleteFile(manifest_path)); in TEST_F()
76 ASSERT_OK(env_->FileExists(manifest_path)); in TEST_F()
78 LegacyFileSystemWrapper fs(env_); in TEST_F()
139 ASSERT_OK(env_->DeleteFile(sst_path)); in TEST_F()
159 LegacyFileSystemWrapper fs(env_); in TEST_F()
186 ASSERT_OK(env_->FileExists(manifest_path)); in TEST_F()
187 ASSERT_OK(env_->DeleteFile(manifest_path)); in TEST_F()
214 ASSERT_OK(env_->FileExists(manifest_path)); in TEST_F()
256 ASSERT_OK(env_->FileExists(manifest_path)); in TEST_F()
[all …]
Ddb_options_test.cc68 options.env = env_; in GetRandomizedMutableCFOptionsMap()
94 options.env = env_; in TEST_F()
106 options.env = env_; in TEST_F()
130 options.env = env_; in TEST_F()
179 options.env = env_; in TEST_F()
214 options.env = env_; in TEST_F()
267 options.env = env_; in TEST_F()
379 options.env = env_; in TEST_F()
398 options.env = env_; in TEST_F()
411 options.env = env_; in TEST_F()
[all …]
Dwal_manager.cc40 auto s = env_->DeleteFile(db_options_.wal_dir + "/" + fname); in DeleteFile()
69 Status exists = env_->FileExists(archivedir); in GetSortedWalFiles()
144 Status s = env_->GetCurrentTime(&current_time); in PurgeObsoleteWALFiles()
164 s = env_->GetChildren(archival_dir, &files); in PurgeObsoleteWALFiles()
206 s = env_->GetFileSize(file_path, &file_size); in PurgeObsoleteWALFiles()
275 Status s = env_->RenameFile(fname, archived_log_name); in ArchiveWALFile()
287 const Status status = env_->GetChildren(path, &all_files); in GetSortedWalsOfType()
317 if (env_->FileExists(archived_file).ok()) { in GetSortedWalsOfType()
318 s = env_->GetFileSize(archived_file, &size_bytes); in GetSortedWalsOfType()
392 if (!s.ok() && env_->FileExists(fname).ok()) { in ReadFirstRecord()
[all …]
Ddb_test.cc201 options.env = env_; in TEST_F()
219 options.env = env_; in TEST_F()
267 options.env = env_; in TEST_F()
328 options.env = env_; in TEST_F()
384 options.env = env_; in TEST_F()
677 options.env = env_; in TEST_F()
711 options.env = env_; in TEST_F()
2226 opts.env = env_; in TEST_F()
3464 options.env = env_; in TEST_F()
3680 options.env = env_; in TEST_F()
[all …]
Ddb_iter_test.cc231 Env* env_; member in ROCKSDB_NAMESPACE::DBIteratorTest
233 DBIteratorTest() : env_(Env::Default()) {} in DBIteratorTest()
253 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
286 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
313 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
346 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
382 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
412 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
2556 : env_(Env::Default()), icomp_(BytewiseComparator()) { in DBIterWithMergeIterTest()
2586 Env* env_; member in ROCKSDB_NAMESPACE::DBIterWithMergeIterTest
[all …]
/rocksdb-6.9/util/
Dstop_watch.h20 : env_(env), in env_() function
38 *elapsed_ = env_->NowMicros() - start_time_; in ~StopWatch()
40 *elapsed_ += env_->NowMicros() - start_time_; in ~StopWatch()
58 delay_start_time_ = env_->NowMicros(); in DelayStart()
64 total_delay_ += env_->NowMicros() - delay_start_time_; in DelayStop()
76 Env* const env_;
92 : env_(env), start_(0) { in env_() function
98 void Start() { start_ = env_->NowNanos(); } in Start()
101 auto now = env_->NowNanos();
110 return (env_ != nullptr) ? ElapsedNanos(reset) : 0U;
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_env.cc101 if (!env_->IsFilesystemActive()) { in Fsync()
102 return env_->GetError(); in Fsync()
104 env_->SyncDir(dirname_); in Fsync()
114 env_(env) { in TestWritableFile()
126 if (!env_->IsFilesystemActive()) { in Append()
127 return env_->GetError(); in Append()
160 env_->WritableFileSynced(state_); in Sync()
179 return env_->GetError(); in Write()
187 return env_->GetError(); in Read()
199 return env_->GetError(); in Flush()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc36 options.env = env_; in ~DBSecondaryTest()
113 options.env = env_; in TEST_F()
146 options.env = env_; in TEST_F()
155 options1.env = env_; in TEST_F()
240 options.env = env_; in TEST_F()
284 options.env = env_; in TEST_F()
339 options.env = env_; in TEST_F()
356 options.env = env_; in TEST_F()
379 options.env = env_; in TEST_F()
408 options.env = env_; in TEST_F()
[all …]
/rocksdb-6.9/file/
Ddelete_scheduler_test.cc26 DeleteSchedulerTest() : env_(Env::Default()) { in DeleteSchedulerTest()
42 test::DestroyDir(env_, dummy_files_dir); in ~DeleteSchedulerTest()
47 ASSERT_OK(test::DestroyDir(env_, dir)); in DestroyAndCreateDir()
48 EXPECT_OK(env_->CreateDir(dir)); in DestroyAndCreateDir()
84 env_->NewWritableFile(file_path, &f, EnvOptions()); in NewDummyFile()
97 fs(std::make_shared<LegacyFileSystemWrapper>(env_)); in NewDeleteScheduler()
104 Env* env_; member in ROCKSDB_NAMESPACE::DeleteSchedulerTest
164 uint64_t delete_start_time = env_->NowMicros(); in TEST_F()
284 uint64_t delete_start_time = env_->NowMicros(); in TEST_F()
326 ASSERT_TRUE(env_->FileExists(dummy_file).IsNotFound()); in TEST_F()
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer_test.cc48 env_ = ROCKSDB_NAMESPACE::Env::Default(); in BlockCacheTracerTest()
49 EXPECT_OK(env_->CreateDir(test_path_)); in BlockCacheTracerTest()
72 EXPECT_OK(env_->DeleteFile(trace_file_path_)); in ~BlockCacheTracerTest()
73 EXPECT_OK(env_->DeleteDir(test_path_)); in ~BlockCacheTracerTest()
203 Env* env_; member in ROCKSDB_NAMESPACE::BlockCacheTracerTest
231 ASSERT_OK(env_->FileExists(trace_file_path_)); in TEST_F()
273 ASSERT_OK(env_->DeleteFile(mrc_path)); in TEST_F()
362 ASSERT_OK(env_->DeleteFile(skewness_file_path)); in TEST_F()
513 ASSERT_OK(env_->DeleteFile(file_name)); in TEST_F()
599 ASSERT_OK(env_->DeleteFile(filename)); in TEST_F()
[all …]
/rocksdb-6.9/logging/
Dauto_roll_logger.cc27 env_(env), in AutoRollLogger()
32 cached_now(static_cast<uint64_t>(env_->NowMicros() * 1e-6)), in AutoRollLogger()
44 if (env_->FileExists(log_fname_).ok()) { in AutoRollLogger()
56 status_ = env_->NewLogger(log_fname_, &logger_); in ResetLogger()
70 cached_now = static_cast<uint64_t>(env_->NowMicros() * 1e-6); in ResetLogger()
82 uint64_t now = env_->NowMicros(); in RollLogFile()
88 } while (env_->FileExists(old_fname).ok()); in RollLogFile()
89 env_->RenameFile(log_fname_, old_fname); in RollLogFile()
103 GetInfoLogFiles(env_, db_log_dir_, dbname_, &parent_dir, &info_log_files); in GetExistingFiles()
130 Status s = env_->DeleteFile(old_log_files_.front()); in TrimOldLogFiles()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_db_iterator.h27 env_(env), in BlobDBIterator()
47 StopWatch seek_sw(env_, statistics_, BLOB_DB_SEEK_MICROS); in SeekToFirst()
56 StopWatch seek_sw(env_, statistics_, BLOB_DB_SEEK_MICROS); in SeekToLast()
65 StopWatch seek_sw(env_, statistics_, BLOB_DB_SEEK_MICROS); in Seek()
74 StopWatch seek_sw(env_, statistics_, BLOB_DB_SEEK_MICROS); in SeekForPrev()
84 StopWatch next_sw(env_, statistics_, BLOB_DB_NEXT_MICROS); in Next()
94 StopWatch prev_sw(env_, statistics_, BLOB_DB_PREV_MICROS); in Prev()
140 Env* env_; variable
/rocksdb-6.9/monitoring/
Dinstrumented_mutex.h23 : mutex_(adaptive), stats_(nullptr), env_(nullptr), in mutex_()
29 : mutex_(adaptive), stats_(stats), env_(env), in mutex_()
47 Env* env_; variable
74 env_(instrumented_mutex->env_), in InstrumentedCondVar()
94 Env* env_; variable
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc43 Env* env_; member in ROCKSDB_NAMESPACE::CheckpointTest
52 CheckpointTest() : env_(Env::Default()) { in CheckpointTest()
53 env_->SetBackgroundThreads(1, Env::LOW); in CheckpointTest()
67 env_->DeleteDir(snapshot_name_); in CheckpointTest()
69 env_->DeleteDir(snapshot_tmp_name); in CheckpointTest()
72 test::DestroyDir(env_, export_path_); in CheckpointTest()
97 test::DestroyDir(env_, export_path_); in ~CheckpointTest()
103 options.env = env_; in CurrentOptions()
407 test::DestroyDir(env_, export_path_); in TEST_F()
591 env_->DeleteDir(dbname); in TEST_F()
[all …]

1234567