| /rocksdb-6.9/utilities/ |
| D | object_registry_test.cc | 20 static FactoryFunc<Env> test_reg_a = ObjectLibrary::Default()->Register<Env>(
25 return Env::Default(); in __anonb60cb4c90102()
28 static FactoryFunc<Env> test_reg_b = ObjectLibrary::Default()->Register<Env>(
67 library->Register<Env>( in TEST_F()
92 library->Register<Env>( in TEST_F()
97 library->Register<Env>( in TEST_F()
112 Env* env = nullptr; in TEST_F()
116 library->Register<Env>( in TEST_F()
121 library->Register<Env>( in TEST_F()
140 library->Register<Env>( in TEST_F()
[all …]
|
| /rocksdb-6.9/util/ |
| D | rate_limiter.cc | 81 for (auto& r : queue_[Env::IO_HIGH]) { in ~GenericRateLimiter()
84 for (auto& r : queue_[Env::IO_LOW]) { in ~GenericRateLimiter()
146 ((!queue_[Env::IO_HIGH].empty() && in Request()
148 (!queue_[Env::IO_LOW].empty() && in Request()
175 (!queue_[Env::IO_HIGH].empty() && in Request()
177 (!queue_[Env::IO_LOW].empty() && in Request()
178 &r == queue_[Env::IO_LOW].front())); in Request()
180 (!queue_[Env::IO_HIGH].empty() && in Request()
182 (!queue_[Env::IO_LOW].empty() && in Request()
203 if (!queue_[Env::IO_HIGH].empty()) { in Request()
[all …]
|
| D | rate_limiter.h | 47 const Env::IOPriority pri = Env::IO_TOTAL) const override {
49 if (pri == Env::IO_TOTAL) {
50 return total_bytes_through_[Env::IO_LOW] +
57 const Env::IOPriority pri = Env::IO_TOTAL) const override {
59 if (pri == Env::IO_TOTAL) {
60 return total_requests_[Env::IO_LOW] + total_requests_[Env::IO_HIGH];
74 uint64_t NowMicrosMonotonic(Env* env) { in NowMicrosMonotonic()
88 Env* const env_;
94 int64_t total_requests_[Env::IO_TOTAL];
95 int64_t total_bytes_through_[Env::IO_TOTAL];
[all …]
|
| D | rate_limiter_test.cc | 47 ASSERT_EQ(0, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
49 ASSERT_EQ(1000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
64 auto* env = Env::Default(); in TEST_F()
76 auto* thread_env = Env::Default(); in TEST_F()
85 Env::IO_HIGH, nullptr /* stats */, in TEST_F()
130 auto* env = Env::Default(); in TEST_F()
133 Arg(int32_t _request_size, Env::IOPriority _pri, in TEST_F()
137 Env::IOPriority pri; in TEST_F()
154 Env::Default(), false /* auto_tuned */); in TEST_F()
160 Arg arg(target, Env::IO_HIGH, limiter); in TEST_F()
[all …]
|
| D | thread_list_test.cc | 61 void WaitUntilScheduled(int job_count, Env* env) { in WaitUntilScheduled()
122 Env* env = Env::Default(); in TEST_F()
127 env->SetBackgroundThreads(kHighPriorityThreads, Env::HIGH); in TEST_F()
128 env->SetBackgroundThreads(kLowPriorityThreads, Env::LOW); in TEST_F()
136 &running_task, Env::Priority::HIGH); in TEST_F()
140 &running_task, Env::Priority::LOW); in TEST_F()
215 Env* env = Env::Default(); in TEST_F()
257 &flush_write_task, Env::Priority::HIGH); in TEST_F()
263 &compaction_write_task, Env::Priority::LOW); in TEST_F()
269 &compaction_read_task, Env::Priority::LOW); in TEST_F()
[all …]
|
| D | threadpool_imp.cc | 75 void SetHostEnv(Env* env) { env_ = env; } in SetHostEnv()
77 Env* GetHostEnv() const { return env_; } in GetHostEnv()
106 Env::Priority priority_;
107 Env* env_;
135 priority_(Env::LOW), in Impl()
287 case Env::Priority::HIGH: in BGThreadWrapper()
290 case Env::Priority::LOW: in BGThreadWrapper()
293 case Env::Priority::BOTTOM: in BGThreadWrapper()
296 case Env::Priority::USER: in BGThreadWrapper()
299 case Env::Priority::TOTAL: in BGThreadWrapper()
[all …]
|
| /rocksdb-6.9/env/ |
| D | env.cc | 25 Env::Env() : thread_status_updater_(nullptr) { in Env() function in ROCKSDB_NAMESPACE::Env
29 Env::Env(std::shared_ptr<FileSystem> fs) in Env() function in ROCKSDB_NAMESPACE::Env
33 Env::~Env() { in ~Env()
41 Status Env::LoadEnv(const std::string& value, Env** result) { in LoadEnv()
42 Env* env = *result; in LoadEnv()
55 Status Env::LoadEnv(const std::string& value, Env** result, in LoadEnv()
60 Env* env = nullptr; in LoadEnv()
69 env = Env::Default(); in LoadEnv()
85 std::string Env::PriorityToString(Env::Priority priority) { in PriorityToString()
89 case Env::Priority::LOW: in PriorityToString()
[all …]
|
| D | env_test.cc | 88 Env* env_;
121 for (int pri = Env::BOTTOM; pri < Env::TOTAL; ++pri) { in TEST_F()
150 auto* env = Env::Default(); in TEST_F()
171 if (env_ == Env::Default()) { in TEST_F()
1966 ::testing::Values(std::pair<Env*, bool>(Env::Default(), in TEST_P()
1970 ::testing::Values(std::pair<Env*, bool>(Env::Default(), in TEST_P()
1976 NewChrootEnv(Env::Default(), test::TmpDir(Env::Default()))); in TEST_P()
2002 env_ptr_ = std::unique_ptr<Env>(new FaultInjectionTestEnv(Env::Default())); in TEST_P()
2019 Env* env_; in TEST_P()
2084 Env::Default()->SetBackgroundThreads(8, Env::HIGH); in TEST_P()
[all …]
|
| D | env_basic_test.cc | 22 explicit NormalizingEnvWrapper(Env* base) : EnvWrapper(base) {} in NormalizingEnvWrapper()
54 public ::testing::WithParamInterface<Env*> {
56 Env* env_;
83 static std::unique_ptr<Env> def_env(new NormalizingEnvWrapper(Env::Default()));
89 static std::unique_ptr<Env> mock_env(new MockEnv(Env::Default()));
93 static std::unique_ptr<Env> mem_env(NewMemEnv(Env::Default()));
104 std::vector<Env*> GetCustomEnvs() { in GetCustomEnvs()
105 static Env* custom_env; in GetCustomEnvs()
111 Env::LoadEnv(uri, &custom_env); in GetCustomEnvs()
115 std::vector<Env*> res; in GetCustomEnvs()
[all …]
|
| D | env_posix.cc | 138 if (this == Env::Default()) { in ~PosixEnv()
142 for (int pool_id = 0; pool_id < Env::Priority::TOTAL; ++pool_id) { in ~PosixEnv()
319 return Env::GetThreadStatusUpdater(); in GetThreadStatusUpdater()
385 friend Env* Env::Default();
414 for (int pool_id = 0; pool_id < Env::Priority::TOTAL; ++pool_id) { in PosixEnv()
416 static_cast<Env::Priority>(pool_id)); in PosixEnv()
480 std::string Env::GenerateUniqueId() { in GenerateUniqueId()
508 Env* Env::Default() { in Default()
526 std::unique_ptr<Env> NewCompositeEnv(std::shared_ptr<FileSystem> fs) { in NewCompositeEnv()
527 PosixEnv* default_env = static_cast<PosixEnv*>(Env::Default()); in NewCompositeEnv()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | env.cc | 27 return reinterpret_cast<jlong>(ROCKSDB_NAMESPACE::Env::Default()); in Java_org_rocksdb_Env_getDefaultEnvInternal()
37 auto* e = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_RocksEnv_disposeInternal()
49 auto* rocks_env = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_Env_setBackgroundThreads()
62 auto* rocks_env = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_Env_getBackgroundThreads()
75 auto* rocks_env = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_Env_getThreadPoolQueueLen()
88 auto* rocks_env = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_Env_incBackgroundThreadsIfNeeded()
101 auto* rocks_env = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_Env_lowerThreadPoolIOPriority()
174 auto* e = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_RocksMemEnv_disposeInternal()
193 ROCKSDB_NAMESPACE::Env* hdfs_env; in Java_org_rocksdb_HdfsEnv_createHdfsEnv()
211 auto* e = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_HdfsEnv_disposeInternal()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Env.java | 14 public abstract class Env extends RocksObject { class
20 private static final Env DEFAULT_ENV = new RocksEnv(getDefaultEnvInternal());
41 public static Env getDefault() { in getDefault()
54 public Env setBackgroundThreads(final int number) { in setBackgroundThreads()
80 public Env setBackgroundThreads(final int number, final Priority priority) { in setBackgroundThreads()
107 public Env incBackgroundThreadsIfNeeded(final int number, in incBackgroundThreadsIfNeeded()
120 public Env lowerThreadPoolIOPriority(final Priority priority) { in lowerThreadPoolIOPriority()
132 public Env lowerThreadPoolCPUPriority(final Priority priority) { in lowerThreadPoolCPUPriority()
148 Env(final long nativeHandle) { in Env() method in Env
|
| D | OptionsUtil.java | 49 public static void loadLatestOptions(String dbPath, Env env, DBOptions dbOptions, in loadLatestOptions()
68 public static void loadLatestOptions(String dbPath, Env env, DBOptions dbOptions, in loadLatestOptions()
89 public static void loadOptionsFromFile(String optionsFileName, Env env, DBOptions dbOptions, in loadOptionsFromFile()
108 public static void loadOptionsFromFile(String optionsFileName, Env env, DBOptions dbOptions, in loadOptionsFromFile()
124 public static String getLatestOptionsFileName(String dbPath, Env env) throws RocksDBException { in getLatestOptionsFileName()
|
| /rocksdb-6.9/port/win/ |
| D | env_win.h | 42 explicit WinEnvThreads(Env* hosted_env);
52 int UnSchedule(void* arg, Env::Priority pri);
58 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const;
67 void SetBackgroundThreads(int num, Env::Priority pri);
68 int GetBackgroundThreads(Env::Priority pri);
74 Env* hosted_env_;
85 explicit WinEnvIO(Env* hosted_env);
198 Env* hosted_env_;
206 class WinEnv : public Env {
306 int UnSchedule(void* arg, Env::Priority pri) override;
[all …]
|
| D | env_win.cc | 72 WinEnvIO::WinEnvIO(Env* hosted_env) in WinEnvIO()
1194 WinEnvThreads::WinEnvThreads(Env* hosted_env) in WinEnvThreads()
1199 static_cast<Env::Priority>(pool_id)); in WinEnvThreads()
1217 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in Schedule()
1265 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetThreadPoolQueueLen()
1281 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in SetBackgroundThreads()
1286 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetBackgroundThreads()
1291 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in IncBackgroundThreadsIfNeeded()
1463 int WinEnv::UnSchedule(void* arg, Env::Priority pri) { in UnSchedule()
1496 int WinEnv::GetBackgroundThreads(Env::Priority pri) { in GetBackgroundThreads()
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | env.h | 134 class Env {
144 Env();
146 Env(std::shared_ptr<FileSystem> fs);
148 Env(const Env&) = delete;
151 virtual ~Env();
167 static Env* Default();
901 Env::IOPriority io_priority_;
1167 class EnvWrapper : public Env {
1402 Env* target_;
1599 Env* NewMemEnv(Env* base_env);
[all …]
|
| D | rate_limiter.h | 48 virtual void Request(const int64_t /*bytes*/, const Env::IOPriority /*pri*/) { in Request()
55 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request()
66 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request()
78 Env::IOPriority io_priority, Statistics* stats,
86 const Env::IOPriority pri = Env::IO_TOTAL) const = 0;
90 const Env::IOPriority pri = Env::IO_TOTAL) const = 0;
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util_test.cc | 33 env_.reset(new test::StringEnv(Env::Default())); in OptionsUtilTest()
253 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
264 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
268 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
272 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
284 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
288 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
292 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
304 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
309 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_test.cc | 61 status = Env::Default()->DeleteDir(folder); in RemoveDirectory()
107 Env* env, const std::string& path, in NewBlockCache()
150 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
170 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
175 cache_ = NewTieredCache(Env::Default(), path_, in TEST_F()
210 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
223 cache_ = NewBlockCache(Env::Default(), path_, in TEST_F()
236 cache_ = NewTieredCache(Env::Default(), path_, in TEST_F()
250 Env::Default(), path_, in TEST_F()
264 return NewBlockCache(Env::Default(), dbname); in MakeBlockCache()
[all …]
|
| /rocksdb-6.9/logging/ |
| D | auto_roll_logger_test.cc | 31 NoSleepEnv(Env* base) : EnvWrapper(base) {} in NoSleepEnv()
74 Env::Default()->CreateDir(kTestDir); in InitTestDb()
79 void RollLogFileByTimeTest(Env*, AutoRollLogger* logger, size_t time,
120 static Env* default_env;
129 Env* AutoRollLoggerTest::default_env = Env::Default();
203 AutoRollLogger logger(Env::Default(), kTestDir, "", log_max_size, 0, in TEST_F()
211 NoSleepEnv nse(Env::Default()); in TEST_F()
277 NoSleepEnv nse(Env::Default()); in TEST_F()
295 NoSleepEnv nse(Env::Default()); in TEST_F()
570 Env::Default()->GetChildren(dirname, &children); in GetOldFileNames()
[all …]
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_lock_mgr.h | 77 const std::string& key, Env* env, bool exclusive);
82 Env* env);
84 const std::string& key, Env* env);
129 bool IsLockExpired(TransactionID txn_id, const LockInfo& lock_info, Env* env,
136 const std::string& key, Env* env, int64_t timeout,
140 const std::string& key, Env* env,
145 LockMapStripe* stripe, LockMap* lock_map, Env* env);
150 const bool& exclusive, Env* const env);
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_util.cc | 18 void ThreadStatusUtil::RegisterThread(const Env* env, in RegisterThread()
36 const Env* env, in SetColumnFamily()
60 uint64_t current_time = Env::Default()->NowMicros(); in SetThreadOperation()
122 const Env* env) { in NewColumnFamilyInfo()
148 bool ThreadStatusUtil::MaybeInitThreadLocalUpdater(const Env* env) { in MaybeInitThreadLocalUpdater()
170 bool ThreadStatusUtil::MaybeInitThreadLocalUpdater(const Env* /*env*/) {
175 const Env* /*env*/,
191 const Env* /*env*/) {}
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | SstFileManagerTest.java | 18 try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { in maxAllowedSpaceUsage()
27 try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { in compactionBufferSize()
35 try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { in totalSize()
42 try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { in trackedFiles()
49 try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { in deleteRateBytesPerSecond()
59 try (final SstFileManager sstFileManager = new SstFileManager(Env.getDefault())) { in maxTrashDBRatio()
|
| D | DefaultEnvTest.java | 29 try (final Env defaultEnv = RocksEnv.getDefault()) { in backgroundThreads()
46 try (final Env defaultEnv = RocksEnv.getDefault()) { in threadPoolQueueLen()
55 try (final Env defaultEnv = RocksEnv.getDefault()) { in incBackgroundThreadsIfNeeded()
69 try (final Env defaultEnv = RocksEnv.getDefault()) { in lowerThreadPoolIOPriority()
80 try (final Env defaultEnv = RocksEnv.getDefault()) { in lowerThreadPoolCPUPriority()
91 try (final Env defaultEnv = RocksEnv.getDefault()) { in threadList()
99 try (final Env env = RocksEnv.getDefault(); in threadList_integration()
|
| /rocksdb-6.9/db/ |
| D | builder.h | 30 class Env; variable
65 const std::string& dbname, Env* env, FileSystem* fs,
82 const Env::IOPriority io_priority = Env::IO_HIGH,
85 Env::WriteLifeTimeHint write_hint = Env::WLTH_NOT_SET,
|