| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | InlineFunctionRef.h | 129 InlineFunctionRef(Func&& func) { in InlineFunctionRef() argument
137 construct(ConstructMode<Func>{}, folly::as_const(func)); in InlineFunctionRef()
164 void construct(InSituTag, Func& func) { in construct() argument
176 new (&storage_) Value{func}; in construct()
185 void construct(RefTag, Func& func) { in construct() argument
188 new (&storage_) Pointer{&func}; in construct()
|
| /rocksdb-6.9/util/ |
| D | thread_local_test.cc | 122 auto func = [](void* ptr) { in TEST_F() local
146 env_->StartThread(func, static_cast<void*>(&p)); in TEST_F()
172 auto func = [](void* ptr) { in TEST_F() local
221 env_->StartThread(func, static_cast<void*>(&p1)); in TEST_F()
224 env_->StartThread(func, static_cast<void*>(&p2)); in TEST_F()
400 auto func = [](void* ptr) { in TEST_F() local
431 env_->StartThread(func, static_cast<void*>(&p)); in TEST_F()
469 auto func = [](void* ptr) { in TEST_F() local
490 env_->StartThread(func, static_cast<void*>(¶ms)); in TEST_F()
|
| D | thread_local.cc | 80 void Fold(uint32_t id, FoldFunc func, void* res);
453 void ThreadLocalPtr::StaticMeta::Fold(uint32_t id, FoldFunc func, void* res) { in Fold() argument
459 func(ptr, res); in Fold()
550 void ThreadLocalPtr::Fold(FoldFunc func, void* res) { in Fold() argument
551 Instance()->Fold(id_, func, res); in Fold()
|
| D | thread_local.h | 77 void Fold(FoldFunc func, void* res);
|
| D | threadpool_imp.cc | 223 auto func = std::move(queue_.front().function); in BGThread() local
266 func(); in BGThread()
|
| /rocksdb-6.9/port/win/ |
| D | win_thread.cc | 28 Data(std::function<void()>&& func) : in Data()
29 func_(std::move(func)), in Data()
40 void WindowsThread::Init(std::function<void()>&& func) { in Init() argument
42 data_ = std::make_shared<Data>(std::move(func)); in Init()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | DistributedMutex-inl.h | 363 explicit RequestWithReturn(Func func) : func_{std::move(func)} {} in RequestWithReturn() argument
417 explicit RequestWithoutReturn(Func func) : func_{std::move(func)} {} in RequestWithoutReturn() argument
471 explicit TaskWithCoalesce(Func func, Waiter& waiter) in TaskWithCoalesce() argument
472 : func_{std::move(func)}, waiter_(waiter) {} in TaskWithCoalesce()
493 explicit TaskWithoutCoalesce(Func func, Waiter&) : func_{std::move(func)} {} in TaskWithoutCoalesce() argument
525 explicit TaskWithBigReturnValue(Func func, Waiter&) in TaskWithBigReturnValue() argument
526 : func_{std::move(func)} {} in TaskWithBigReturnValue()
1052 auto DistributedMutex<Atomic, TimePublishing>::lock_combine(Func func)
1061 auto&& task = Request<Func>{func};
1070 return func();
|
| D | ParkingLot.h | 232 void unpark(const Key key, Unparker&& func);
286 void ParkingLot<Data>::unpark(const Key bits, Func&& func) { in unpark() argument
302 auto result = std::forward<Func>(func)(node->data_); in unpark()
|
| /rocksdb-6.9/memory/ |
| D | concurrent_arena.h | 129 char* AllocateImpl(size_t bytes, bool force_arena, const Func& func) { in AllocateImpl() argument
145 auto rv = func(); in AllocateImpl()
177 auto rv = func(); in AllocateImpl()
|
| /rocksdb-6.9/table/ |
| D | iterator.cc | 83 void Cleanable::RegisterCleanup(CleanupFunction func, void* arg1, void* arg2) { in RegisterCleanup() argument
84 assert(func != nullptr); in RegisterCleanup()
93 c->function = func; in RegisterCleanup()
|
| /rocksdb-6.9/third-party/folly/folly/ |
| D | ScopeGuard.h | 29 ScopeGuardImpl<DecayedFunc> operator+(ScopeGuardEnum, Func&& func) {
30 return ScopeGuardImpl<DecayedFunc>{std::forward<Func>(func)};
|
| /rocksdb-6.9/env/ |
| D | env_posix.cc | 109 Status LoadSymbol(const std::string& sym_name, void** func) override { in LoadSymbol() argument
110 assert(nullptr != func); in LoadSymbol()
112 *func = dlsym(handle_, sym_name.c_str()); in LoadSymbol()
113 if (*func != nullptr) { in LoadSymbol()
|
| /rocksdb-6.9/cache/ |
| D | lru_cache.h | 166 void ApplyToAllCacheEntries(T func) { in ApplyToAllCacheEntries() argument
172 func(h); in ApplyToAllCacheEntries()
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend_test.cc | 121 static void SetOpenDbFunction(OpenFuncPtr func) { in SetOpenDbFunction() argument
122 OpenDb = func; in SetOpenDbFunction()
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_env.cc | 377 std::function<Status(Env*, FileState)> func) { in DropFileData() argument
385 s = func(target(), state); in DropFileData()
|
| D | fault_injection_test_env.h | 175 Status DropFileData(std::function<Status(Env*, FileState)> func);
|
| /rocksdb-6.9/include/rocksdb/ |
| D | env.h | 1079 virtual Status LoadSymbol(const std::string& sym_name, void** func) = 0;
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_transaction_test.cc | 2385 auto add_key = [&](std::function<Status()> func) { in TEST_P() argument
2386 ASSERT_OK(func()); in TEST_P()
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest.h | 2985 ThreadWithParam(UserThreadFunc* func, T param, Notification* thread_can_start)
2986 : func_(func),
3176 ThreadWithParam(UserThreadFunc* func, T param, Notification* thread_can_start)
3177 : ThreadWithParamBase(new RunnableImpl(func, param), thread_can_start) {
3184 RunnableImpl(UserThreadFunc* func, T param)
3185 : func_(func),
11793 ParamNameGenFunctor GetParamNameGen(ParamNameGenFunctor func) {
11794 return func;
11937 GeneratorCreationFunc* func,
11941 InstantiationInfo(instantiation_name, func, name_func, file, line));
|