| /rocksdb-6.9/util/ |
| D | threadpool_imp.cc | 70 void Submit(std::function<void()>&& schedule,
71 std::function<void()>&& unschedule, void* tag);
117 std::function<void()> function; member
118 std::function<void()> unschedFunction;
223 auto func = std::move(queue_.front().function); in BGThread()
359 std::function<void()>&& unschedule, void* tag) { in Submit()
374 item.function = std::move(schedule); in Submit()
393 std::vector<std::function<void()>> candidates; in UnSchedule()
463 void ThreadPoolImpl::SubmitJob(const std::function<void()>& job) { in SubmitJob()
469 void ThreadPoolImpl::SubmitJob(std::function<void()>&& job) { in SubmitJob()
[all …]
|
| D | repeatable_thread.h | 23 RepeatableThread(std::function<void()> function,
26 : function_(function), in function_() argument
64 void TEST_WaitForRun(std::function<void()> callback = nullptr) {
129 const std::function<void()> function_;
|
| D | threadpool_imp.h | 64 void SubmitJob(const std::function<void()>&) override;
66 void SubmitJob(std::function<void()>&&) override;
71 void Schedule(void (*function)(void* arg1), void* arg, void* tag,
|
| D | defer.h | 41 Defer(std::function<void()>&& fn) : fn_(std::move(fn)) {} in Defer()
49 std::function<void()> fn_;
|
| /rocksdb-6.9/table/ |
| D | iterator.cc | 18 cleanup_.function = nullptr; in Cleanable()
31 other.cleanup_.function = nullptr; in operator =()
55 if (cleanup_.function == nullptr) { in DelegateCleanupsTo()
59 other->RegisterCleanup(c->function, c->arg1, c->arg2); in DelegateCleanupsTo()
66 cleanup_.function = nullptr; in DelegateCleanupsTo()
72 if (cleanup_.function == nullptr) { in RegisterCleanup()
73 cleanup_.function = c->function; in RegisterCleanup()
86 if (cleanup_.function == nullptr) { in RegisterCleanup()
93 c->function = func; in RegisterCleanup()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | cleanable.h | 34 void RegisterCleanup(CleanupFunction function, void* arg1, void* arg2);
39 cleanup_.function = nullptr; in Reset()
45 CleanupFunction function; member
59 if (cleanup_.function != nullptr) { in DoCleanup()
60 (*cleanup_.function)(cleanup_.arg1, cleanup_.arg2); in DoCleanup()
62 (*c->function)(c->arg1, c->arg2); in DoCleanup()
|
| D | threadpool.h | 49 virtual void SubmitJob(const std::function<void()>&) = 0;
51 virtual void SubmitJob(std::function<void()>&&) = 0;
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_impl.h | 49 std::function<Status(const std::string& src_dirname,
52 std::function<Status(const std::string& src_dirname,
56 std::function<Status(const std::string& fname,
67 std::function<Status(const std::string& src_dirname,
70 std::function<Status(const std::string& src_dirname,
|
| D | checkpoint_impl.cc | 168 std::function<Status(const std::string& src_dirname, in CreateCustomCheckpoint()
171 std::function<Status(const std::string& src_dirname, in CreateCustomCheckpoint()
175 std::function<Status(const std::string& fname, const std::string& contents, in CreateCustomCheckpoint()
471 std::function<Status(const std::string& src_dirname, in ExportFilesInMetaData()
474 std::function<Status(const std::string& src_dirname, in ExportFilesInMetaData()
|
| /rocksdb-6.9/db/ |
| D | file_indexer.h | 129 std::function<int(const FileMetaData*, const FileMetaData*)> cmp_op,
130 std::function<void(IndexUnit*, int32_t)> set_index);
135 std::function<int(const FileMetaData*, const FileMetaData*)> cmp_op,
136 std::function<void(IndexUnit*, int32_t)> set_index);
|
| D | file_indexer.cc | 146 std::function<int(const FileMetaData*, const FileMetaData*)> cmp_op, in CalculateLB()
147 std::function<void(IndexUnit*, int32_t)> set_index) { in CalculateLB()
183 std::function<int(const FileMetaData*, const FileMetaData*)> cmp_op, in CalculateRB()
184 std::function<void(IndexUnit*, int32_t)> set_index) { in CalculateRB()
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier_file.h | 82 const std::function<void()> callback) = 0;
262 const uint64_t file_off, const std::function<void()> callback) in IO()
273 std::function<void()> callback_; // Callback on completion
283 const std::function<void()> callback) override;
|
| /rocksdb-6.9/env/ |
| D | env_posix.cc | 215 void Schedule(void (*function)(void* arg1), void* arg, Priority pri = LOW,
221 void StartThread(void (*function)(void* arg), void* arg) override;
432 void PosixEnv::Schedule(void (*function)(void* arg1), void* arg, Priority pri, in Schedule()
435 thread_pools_[pri].Schedule(function, arg, tag, unschedFunction); in Schedule()
459 void PosixEnv::StartThread(void (*function)(void* arg), void* arg) { in StartThread()
462 state->user_function = function; in StartThread()
|
| D | io_posix.h | 61 std::function<size_t(int)> get_logical_block_size_of_fd =
63 std::function<Status(const std::string&, size_t*)>
116 std::function<size_t(int)> get_logical_block_size_of_fd_;
117 std::function<Status(const std::string&, size_t*)>
|
| /rocksdb-6.9/port/win/ |
| D | win_thread.cc | 25 std::function<void()> func_;
28 Data(std::function<void()>&& func) : in Data()
40 void WindowsThread::Init(std::function<void()>&& func) { in Init()
|
| D | win_thread.h | 36 void Init(std::function<void()>&&);
83 std::function<void()> target = binder; in WindowsThread()
|
| D | env_win.h | 49 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
54 void StartThread(void(*function)(void* arg), void* arg);
303 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
308 void StartThread(void(*function)(void* arg), void* arg) override;
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_test.h | 218 std::function<void(size_t, Status)> txn_t0_with_status = [&](size_t index,
237 std::function<void(size_t)> txn_t0 = [&](size_t index) {
240 std::function<void(size_t)> txn_t1 = [&](size_t index) {
264 std::function<void(size_t)> txn_t2 = [&](size_t index) {
297 std::function<void(size_t)> txn_t3 = [&](size_t index) {
330 std::function<void(size_t)> txn_t4 = [&](size_t index) {
|
| /rocksdb-6.9/java/rocksjni/ |
| D | table_filter_jnicallback.h | 25 std::function<bool(const ROCKSDB_NAMESPACE::TableProperties&)>
30 std::function<bool(const ROCKSDB_NAMESPACE::TableProperties&)>
|
| D | writebatchhandlerjnicallback.h | 79 std::function<void(jbyteArray, jbyteArray)> kvFn);
85 const Slice& key, std::function<void(jbyteArray)> kFn);
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2016-04-26-rocksdb-4-5-1-released.markdown | 53 …* CompactionFilter has new member function called IgnoreSnapshots which allows CompactionFilter to…
55 …* Introduce LoadLatestOptions() in rocksdb/utilities/options_util.h. This function can construct t…
56 …* Introduce CheckOptionsCompatibility() in rocksdb/utilities/options_util.h. This function checks …
|
| D | 2017-03-02-rocksdb-5-2-1-released.markdown | 13 * Added new overloaded function GetApproximateSizes that allows to specify if memtable stats should…
14 * Added new function GetApproximateMemTableStats that approximates both number of records and size …
|
| /rocksdb-6.9/hdfs/ |
| D | env_hdfs.h | 104 void Schedule(void (*function)(void* arg), void* arg, Priority pri = LOW,
107 posixEnv->Schedule(function, arg, pri, tag, unschedFunction);
114 void StartThread(void (*function)(void* arg), void* arg) override { in StartThread()
115 posixEnv->StartThread(function, arg); in StartThread()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.h | 32 std::unordered_map<std::string, std::function<void(void*)> > callbacks_;
48 const std::function<void(void*)>& callback) { in SetCallBack()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | backupable_db.h | 153 std::function<void()> progress_callback = []() {};
312 std::function<void()> progress_callback = []() {}) {
327 std::function<void()> progress_callback =
|