Searched refs:guard (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/utilities/ |
| D | object_registry_test.cc | 63 std::unique_ptr<Env> guard; in TEST_F() local
81 ObjectRegistry::NewInstance()->NewObject("test-global", &guard, &msg), in TEST_F()
83 ASSERT_NE(registry->NewObject<Env>("test-local", &guard, &msg), nullptr); in TEST_F()
84 ASSERT_NE(registry->NewObject<Env>("test-global", &guard, &msg), nullptr); in TEST_F()
98 "guarded", [](const std::string& /*uri*/, std::unique_ptr<Env>* guard, in TEST_F()
100 guard->reset(new EnvWrapper(Env::Default())); in TEST_F()
101 return guard->get(); in TEST_F()
124 guard->reset(new EnvWrapper(Env::Default())); in TEST_F()
125 return guard->get(); in TEST_F()
148 guard->reset(new EnvWrapper(Env::Default())); in TEST_F()
[all …]
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | object_registry.h | 57 return factory_(target, guard, msg); in NewFactoryObject()
112 T* NewObject(const std::string& target, std::unique_ptr<T>* guard, in NewObject() argument
114 guard->reset(); in NewObject()
119 return factory->NewFactoryObject(target, guard, errmsg); in NewObject()
156 std::unique_ptr<T> guard; in NewSharedObject() local
157 T* ptr = NewObject(target, &guard, &errmsg); in NewSharedObject()
160 } else if (guard) { in NewSharedObject()
161 result->reset(guard.release()); in NewSharedObject()
178 std::unique_ptr<T> guard; in NewStaticObject() local
179 T* ptr = NewObject(target, &guard, &errmsg); in NewStaticObject()
[all …]
|
| /rocksdb-6.9/env/ |
| D | env.cc | 56 std::shared_ptr<Env>* guard) { in LoadEnv() argument
63 assert(guard != nullptr); in LoadEnv()
72 guard->reset(uniq_guard.release()); in LoadEnv()
73 *result = guard->get(); in LoadEnv()
79 (void)guard; in LoadEnv()
|
| /rocksdb-6.9/ |
| D | ROCKSDB_LITE.md | 13 When adding a new big feature to RocksDB, please add ROCKSDB_LITE compile guard if:
17 Don't add ROCKSDB_LITE compile guard if:
|
| /rocksdb-6.9/db/ |
| D | write_thread.cc | 47 std::unique_lock<std::mutex> guard(w->StateMutex()); in BlockingAwaitState() local
48 w->StateCV().wait(guard, [w] { in BlockingAwaitState()
216 std::lock_guard<std::mutex> guard(w->StateMutex()); in SetState() local
591 std::lock_guard<std::mutex> guard(write_group->leader->StateMutex()); in CompleteParallelMemTableWriter() local
|
| D | forward_iterator_bench.cc | 107 std::lock_guard<std::mutex> guard(queue_mutex_); in run() local
176 std::lock_guard<std::mutex> guard(queue_mutex_); in onWrite() local
305 std::lock_guard<std::mutex> guard(cvm_); in ~StatsThread() local
|
| /rocksdb-6.9/options/ |
| D | options_test.cc | 360 [](const std::string& /*name*/, std::unique_ptr<MergeOperator>* guard, in TEST_F()
362 guard->reset(new BytesXOROperator()); in TEST_F()
363 return guard->get(); in TEST_F()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 1481 std::unique_lock<std::mutex> guard(switch_mutex_); in WaitForPendingWrites()
1482 switch_cv_.wait(guard, in WaitForPendingWrites()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | env.h | 160 std::shared_ptr<Env>* guard);
|