| /leveldb-1.20/helpers/memenv/ |
| H A D | memenv_test.cc | 18 Env* env_; member in leveldb::MemEnvTest
21 : env_(NewMemEnv(Env::Default())) { in MemEnvTest()
24 delete env_; in ~MemEnvTest()
33 ASSERT_OK(env_->CreateDir("/dir")); in TEST()
48 ASSERT_TRUE(env_->FileExists("/dir/f")); in TEST()
75 ASSERT_TRUE(env_->FileExists("/dir/g")); in TEST()
89 ASSERT_OK(env_->DeleteFile("/dir/g")); in TEST()
93 ASSERT_OK(env_->DeleteDir("/dir")); in TEST()
103 ASSERT_OK(env_->CreateDir("/dir")); in TEST()
143 ASSERT_OK(env_->UnlockFile(lock)); in TEST()
[all …]
|
| /leveldb-1.20/util/ |
| H A D | env_test.cc | 22 Env* env_; member in leveldb::EnvTest
23 EnvTest() : env_(Env::Default()) { } in EnvTest()
32 env_->Schedule(&SetBool, &called); in TEST()
33 env_->SleepForMicroseconds(kDelayMicros); in TEST()
59 env_->Schedule(&CB::Run, &cb1); in TEST()
60 env_->Schedule(&CB::Run, &cb2); in TEST()
61 env_->Schedule(&CB::Run, &cb3); in TEST()
62 env_->Schedule(&CB::Run, &cb4); in TEST()
64 env_->SleepForMicroseconds(kDelayMicros); in TEST()
88 env_->StartThread(&ThreadBody, &state); in TEST()
[all …]
|
| H A D | env_posix_test.cc | 19 Env* env_; member in leveldb::EnvPosixTest
20 EnvPosixTest() : env_(Env::Default()) { } in EnvPosixTest()
31 ASSERT_OK(env_->GetTestDirectory(&test_dir)); in TEST()
45 ASSERT_OK(env_->NewRandomAccessFile(test_file, &files[i])); in TEST()
56 ASSERT_OK(env_->DeleteFile(test_file)); in TEST()
|
| /leveldb-1.20/db/ |
| H A D | repair.cc | 49 env_(options.env), in Repairer()
101 Env* const env_; member in leveldb::__anon9dee4fc20111::Repairer
186 reporter.env = env_; in ConvertLogToTable()
328 Status s = env_->NewWritableFile(copy, &file); in RepairTable()
363 s = env_->RenameFile(copy, orig); in RepairTable()
371 env_->DeleteFile(copy); in RepairTable()
416 env_->DeleteFile(tmp); in WriteDescriptor()
426 status = SetCurrentFile(env_, dbname_, 1); in WriteDescriptor()
428 env_->DeleteFile(tmp); in WriteDescriptor()
445 env_->CreateDir(new_dir); // Ignore error in ArchiveFile()
[all …]
|
| H A D | fault_injection_test.cc | 122 FaultInjectionTestEnv* env_; member in leveldb::TestWritableFile
165 env_(env) { in TestWritableFile()
188 env_->WritableFileClosed(state_); in Close()
204 env_->DirWasSynced(); in SyncParent()
210 if (!env_->IsFilesystemActive()) { in Sync()
364 FaultInjectionTestEnv* env_; member in leveldb::FaultInjectionTest
371 : env_(new FaultInjectionTestEnv), in FaultInjectionTest()
377 options_.env = env_; in FaultInjectionTest()
387 delete env_; in ~FaultInjectionTest()
453 env_->ResetState(); in OpenDB()
[all …]
|
| H A D | recovery_test.cc | 20 RecoveryTest() : env_(Env::Default()), db_(NULL) { in RecoveryTest()
32 Env* env() const { return env_; } in env()
36 Status s = env_->NewAppendableFile(CurrentFileName(dbname_), &tmp); in CanAppend()
60 opts.env = env_; in Open()
83 ASSERT_OK(ReadFileToString(env_, CurrentFileName(dbname_), ¤t)); in ManifestFileName()
98 ASSERT_OK(env_->DeleteFile(LogName(logs[i]))) << LogName(logs[i]); in DeleteLogFiles()
109 ASSERT_OK(env_->GetChildren(dbname_, &filenames)); in GetFiles()
131 ASSERT_OK(env_->GetFileSize(fname, &result)) << fname; in FileSize()
143 ASSERT_OK(env_->NewWritableFile(fname, &file)); in MakeLogFile()
155 Env* env_; member in leveldb::RecoveryTest
|
| H A D | db_test.cc | 94 SpecialEnv* env_; in NewWritableFile() member in leveldb::SpecialEnv::NewWritableFile::DataFile
99 : env_(env), in NewWritableFile()
125 SpecialEnv* env_; in NewWritableFile() member in leveldb::SpecialEnv::NewWritableFile::ManifestFile
205 SpecialEnv* env_; member in leveldb::DBTest
222 delete env_; in ~DBTest()
550 env_->delay_data_sync_.Release_Store(env_); // Block sync calls in TEST()
1007 options.env = env_; in TEST()
1557 options.env = env_; in TEST()
1564 env_->no_space_.Release_Store(env_); // Force out-of-space errors in TEST()
1601 env_->data_sync_error_.Release_Store(env_); in TEST()
[all …]
|
| H A D | corruption_test.cc | 29 test::ErrorEnv env_; member in leveldb::CorruptionTest
37 options_.env = &env_; in CorruptionTest()
129 ASSERT_OK(env_.GetChildren(dbname_, &filenames)); in Corrupt()
214 env_.writable_file_error_ = true; in TEST()
221 env_.writable_file_error_ = true; in TEST()
231 ASSERT_GE(env_.num_writable_file_errors_, 1); in TEST()
232 env_.writable_file_error_ = false; in TEST()
344 env_.SleepForMicroseconds(100000); in TEST()
|
| H A D | db_impl.cc | 118 : env_(raw_options.env), in DBImpl()
158 env_->UnlockFile(db_lock_); in ~DBImpl()
186 Status s = env_->NewWritableFile(manifest, &file); in NewDB()
202 s = SetCurrentFile(env_, dbname_, 1); in NewDB()
204 env_->DeleteFile(manifest); in NewDB()
280 env_->CreateDir(dbname_); in Recover()
320 s = env_->GetChildren(dbname_, &filenames); in Recover()
394 reporter.env = env_; in RecoverLogFile()
491 const uint64_t start_micros = env_->NowMicros(); in WriteLevel0Table()
659 env_->Schedule(&DBImpl::BGWork, this); in MaybeScheduleCompaction()
[all …]
|
| H A D | table_cache.cc | 35 : env_(options->env), in TableCache()
56 s = env_->NewRandomAccessFile(fname, &file); in FindTable()
59 if (env_->NewRandomAccessFile(old_fname, &file).ok()) { in FindTable()
|
| H A D | table_cache.h | 51 Env* const env_;
|
| H A D | version_set.cc | 779 : env_(options->env), in VersionSet()
853 s = env_->NewWritableFile(new_manifest_file, &descriptor_file_); in LogAndApply()
880 s = SetCurrentFile(env_, dbname_, manifest_file_number_); in LogAndApply()
898 env_->DeleteFile(new_manifest_file); in LogAndApply()
915 Status s = ReadFileToString(env_, CurrentFileName(dbname_), ¤t); in Recover()
926 s = env_->NewSequentialFile(dscname, &file); in Recover()
1037 !env_->GetFileSize(dscname, &manifest_size).ok() || in ReuseManifest()
1045 Status r = env_->NewAppendableFile(dscname, &descriptor_file_); in ReuseManifest()
|
| H A D | db_impl.h | 122 Env* const env_; variable
|
| H A D | version_set.h | 297 Env* const env_; variable
|