| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_impl.cc | 46 Status s = db_->GetEnv()->FileExists(full_private_path); in CleanStagingDirectory()
52 db_->GetEnv()->GetChildren(full_private_path, &subchildren); in CleanStagingDirectory()
55 s = db_->GetEnv()->DeleteFile(subchild_path); in CleanStagingDirectory()
60 s = db_->GetEnv()->DeleteDir(full_private_path); in CleanStagingDirectory()
77 Status s = db_->GetEnv()->FileExists(checkpoint_dir); in CreateCheckpoint()
107 s = db_->GetEnv()->CreateDir(full_private_path); in CreateCheckpoint()
349 auto s = db_->GetEnv()->FileExists(export_dir); in ExportColumnFamily()
368 s = db_->GetEnv()->CreateDir(tmp_export_dir); in ExportColumnFamily()
406 s = db_->GetEnv()->RenameFile(tmp_export_dir, export_dir); in ExportColumnFamily()
413 s = db_->GetEnv()->NewDirectory(export_dir, &dir_ptr); in ExportColumnFamily()
[all …]
|
| /rocksdb-6.9/db/ |
| D | options_file_test.cc | 28 db->GetEnv()->GetChildren(db->GetName(), &filenames); in UpdateOptionsFiles()
45 db->GetEnv()->GetChildren(db->GetName(), &filenames); in VerifyOptionsFileName()
|
| D | forward_iterator_bench.cc | 292 db_->GetEnv()->TimeToString(time(nullptr)).c_str(), in run()
|
| D | listener_test.cc | 135 ASSERT_EQ(db->GetEnv()->GetThreadID(), ci.thread_id); in OnCompactionCompleted()
287 ASSERT_EQ(db->GetEnv()->GetThreadID(), info.thread_id); in OnFlushCompleted()
|
| D | db_test2.cc | 4232 db_->GetEnv()->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_F()
4234 db_->GetEnv()->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
4246 db_->GetEnv()->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
|
| D | db_test.cc | 2908 Env* GetEnv() const override { return nullptr; } in GetEnv() function in ROCKSDB_NAMESPACE::ModelDB
|
| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction_db.cc | 401 return lock_mgr_.TryLock(txn, cfh_id, key, GetEnv(), exclusive); in TryLock()
406 lock_mgr_.UnLock(txn, keys, GetEnv()); in UnLock()
411 lock_mgr_.UnLock(txn, cfh_id, key, GetEnv()); in UnLock()
|
| D | transaction_base.cc | 28 start_time_(db_->GetEnv()->NowMicros()), in TransactionBaseImpl()
66 start_time_ = db_->GetEnv()->NowMicros(); in Reinitialize()
596 return (db_->GetEnv()->NowMicros() - start_time_) / 1000; in GetElapsedTime()
|
| D | pessimistic_transaction.cc | 120 if (db_->GetEnv()->NowMicros() >= expiration_time_) { in IsExpired()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 129 DBWithTTLImpl::SanitizeOptions(ttl, &sanitized_options, GetEnv()); in CreateColumnFamilyWithTtl()
309 Handler handler(GetEnv()); in Write()
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_util.cc | 141 ThreadStatusUpdater* thread_updater = db->GetEnv()->GetThreadStatusUpdater(); in EraseDatabaseInfo()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | stackable_db.h | 300 virtual Env* GetEnv() const override { return db_->GetEnv(); } in GetEnv() function
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 1674 internal::posix::GetEnv("TESTBRIDGE_TEST_ONLY"); in GetDefaultFilter()
4450 const char* const term = posix::GetEnv("TERM"); in ShouldUseColor()
4600 internal::posix::GetEnv(kTestTotalShards)); in OnTestIterationStart()
6197 NULL : internal::posix::GetEnv("TEST_PREMATURE_EXIT_FILE")); in Run()
6692 const char* const test_shard_file = posix::GetEnv(kTestShardStatusFile); in WriteToShardStatusFileIfNeeded()
6759 const char* str_val = posix::GetEnv(var); in Int32FromEnvOrDie()
7430 const char* temp_dir = internal::posix::GetEnv("TEMP"); in TempDir()
10662 const char* const string_value = posix::GetEnv(env_var.c_str()); in BoolFromGTestEnv()
10676 const char* const string_value = posix::GetEnv(env_var.c_str()); in Int32FromGTestEnv()
10705 const char* xml_output_file_env = posix::GetEnv("XML_OUTPUT_FILE"); in OutputFlagAlsoCheckEnvVar()
[all …]
|
| D | gtest.h | 3786 inline const char* GetEnv(const char* name) {
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 2825 Env* DBImpl::GetEnv() const { return env_; } in GetEnv() function in ROCKSDB_NAMESPACE::DBImpl
2828 static LegacyFileSystemWrapper fs_wrap(GetEnv()); in GetFileSystem()
3742 s = GetEnv()->GetChildren(GetName(), &filenames); in DeleteObsoleteOptionsFiles()
3759 immutable_db_options_.info_log, GetEnv()); in DeleteObsoleteOptionsFiles()
3774 s = GetEnv()->RenameFile(file_name, options_file_name); in RenameTempFileToOptionsFile()
|
| D | db_impl.h | 327 virtual Env* GetEnv() const override;
|
| /rocksdb-6.9/include/rocksdb/ |
| D | db.h | 1183 virtual Env* GetEnv() const = 0;
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db_test.cc | 52 Env* GetEnv() const override { return options_.env; } in GetEnv() function in ROCKSDB_NAMESPACE::__anon6f9a36820111::DummyDB
|
| /rocksdb-6.9/java/rocksjni/ |
| D | rocksjni.cc | 2735 return reinterpret_cast<jlong>(db->GetEnv()); in Java_org_rocksdb_RocksDB_getEnv()
|
| D | portal.h | 1574 const jint env_rs = jvm->GetEnv(reinterpret_cast<void**>(&env), in getJniEnv()
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd.cc | 3139 s = ReadFileToString(db_->GetEnv(), CurrentFileName(db_->GetName()), in DoCommand()
|