Home
last modified time | relevance | path

Searched refs:arg (Results 1 – 25 of 92) sorted by relevance

1234

/rocksdb-6.9/util/
Drate_limiter_test.cc77 auto* arg = static_cast<Arg*>(p); in TEST_F() local
84 arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, in TEST_F()
88 arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, Env::IO_LOW, in TEST_F()
95 Arg arg(target, i / 4 + 1); in TEST_F() local
101 arg.limiter->SetBytesPerSecond(target); in TEST_F()
105 env->StartThread(writer, &arg); in TEST_F()
142 auto* arg = static_cast<Arg*>(p); in TEST_F() local
143 arg->limiter->Request(arg->request_size, arg->pri, nullptr /* stats */, in TEST_F()
160 Arg arg(target, Env::IO_HIGH, limiter); in TEST_F() local
165 env->StartThread(writer, &arg); in TEST_F()
[all …]
Dthreadpool_imp.cc73 int UnSchedule(void* arg);
102 static void BGThreadWrapper(void* arg);
278 void ThreadPoolImpl::Impl::BGThreadWrapper(void* arg) { in BGThreadWrapper() argument
279 BGThreadMetadata* meta = reinterpret_cast<BGThreadMetadata*>(arg); in BGThreadWrapper()
390 int ThreadPoolImpl::Impl::UnSchedule(void* arg) { in UnSchedule() argument
400 if (arg == (*it).tag) { in UnSchedule()
473 void ThreadPoolImpl::Schedule(void(*function)(void* arg1), void* arg, in Schedule() argument
474 void* tag, void(*unschedFunction)(void* arg)) { in Schedule() argument
478 impl_->Submit(std::bind(function, arg), std::bind(unschedFunction, arg), in Schedule()
483 int ThreadPoolImpl::UnSchedule(void* arg) { in UnSchedule() argument
[all …]
Drepeatable_thread_test.cc66 "InstrumentedCondVar::TimedWaitInternal", [&](void* arg) { in TEST_F() argument
82 uint64_t time_us = *reinterpret_cast<uint64_t*>(arg); in TEST_F()
84 *reinterpret_cast<uint64_t*>(arg) = mock_env_->RealNowMicros() + 1000; in TEST_F()
/rocksdb-6.9/env/
Denv_posix.cc219 int UnSchedule(void* arg, Priority pri) override;
221 void StartThread(void (*function)(void* arg), void* arg) override;
435 thread_pools_[pri].Schedule(function, arg, tag, unschedFunction); in Schedule()
438 int PosixEnv::UnSchedule(void* arg, Priority pri) { in UnSchedule() argument
439 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
449 void* arg; member
452 static void* StartThreadWrapper(void* arg) { in StartThreadWrapper() argument
453 StartThreadState* state = reinterpret_cast<StartThreadState*>(arg); in StartThreadWrapper()
454 state->user_function(state->arg); in StartThreadWrapper()
459 void PosixEnv::StartThread(void (*function)(void* arg), void* arg) { in StartThread() argument
[all …]
/rocksdb-6.9/db/
Dobsolete_files_test.cc116 "DBImpl::DeleteObsoleteFileImpl:AfterDeletion", [&](void* arg) { in TEST_F() argument
117 Status* p_status = reinterpret_cast<Status*>(arg); in TEST_F()
121 "DBImpl::CloseHelper:PendingPurgeFinished", [&](void* arg) { in TEST_F() argument
123 reinterpret_cast<std::unordered_set<uint64_t>*>(arg); in TEST_F()
152 "DBImpl::PurgeObsoleteFiles:CheckOptionsFiles:1", [&](void* arg) { in TEST_F() argument
153 optsfiles_nums.push_back(*reinterpret_cast<uint64_t*>(arg)); in TEST_F()
156 "DBImpl::PurgeObsoleteFiles:CheckOptionsFiles:2", [&](void* arg) { in TEST_F() argument
157 optsfiles_keep.push_back(*reinterpret_cast<bool*>(arg)); in TEST_F()
Dc_test.c206 static void CmpDestroy(void* arg) { (void)arg; } in CmpDestroy() argument
210 (void)arg; in CmpCompare()
221 (void)arg; in CmpName()
227 static void FilterDestroy(void* arg) { (void)arg; } in FilterDestroy() argument
229 (void)arg; in FilterName()
237 (void)arg; in FilterCreate()
250 (void)arg; in FilterKeyMatch()
259 static void CFilterDestroy(void* arg) { (void)arg; } in CFilterDestroy() argument
261 (void)arg; in CFilterName()
270 (void)arg; in CFilterFilter()
[all …]
Ddb_io_failure_test.cc274 "SpecialEnv::SStableFile::RangeSync", [&](void* arg) { in TEST_F() argument
276 Status* st = static_cast<Status*>(arg); in TEST_F()
356 Status* st = static_cast<Status*>(arg); in TEST_F()
393 "SpecialEnv::SStableFile::Close", [&](void* arg) { in TEST_F() argument
395 Status* st = static_cast<Status*>(arg); in TEST_F()
445 "SpecialEnv::SStableFile::Close", [&](void* arg) { in TEST_F() argument
447 Status* st = static_cast<Status*>(arg); in TEST_F()
484 "SpecialEnv::SStableFile::Sync", [&](void* arg) { in TEST_F() argument
486 Status* st = static_cast<Status*>(arg); in TEST_F()
537 "SpecialEnv::SStableFile::Sync", [&](void* arg) { in TEST_F() argument
[all …]
Ddb_universal_compaction_test.cc254 ASSERT_TRUE(arg != nullptr); in TEST_P()
400 if (arg) { in TEST_P()
481 if (arg) { in TEST_P()
713 ASSERT_TRUE(arg != nullptr); in TEST_P()
714 int output_level = *(static_cast<int*>(arg)); in TEST_P()
848 if (arg) { in TEST_P()
1170 ASSERT_TRUE(arg != nullptr); in TEST_P()
1171 int output_level = *(static_cast<int*>(arg)); in TEST_P()
1215 ASSERT_TRUE(arg != nullptr); in TEST_P()
2193 [&](void* arg) { in TEST_F() argument
[all …]
Ddb_wal_test.cc299 int* max_open_files = static_cast<int*>(arg); in TEST_F()
448 "DBTestWalFile.GetPreallocationStatus", [&](void* arg) { in TEST_F() argument
449 ASSERT_TRUE(arg != nullptr); in TEST_F()
450 size_t preallocation_size = *(static_cast<size_t*>(arg)); in TEST_F()
467 "DBTestWalFile.GetPreallocationStatus", [&](void* arg) { in TEST_F() argument
468 ASSERT_TRUE(arg != nullptr); in TEST_F()
469 size_t preallocation_size = *(static_cast<size_t*>(arg)); in TEST_F()
487 "DBTestWalFile.GetPreallocationStatus", [&](void* arg) { in TEST_F() argument
488 ASSERT_TRUE(arg != nullptr); in TEST_F()
508 "DBTestWalFile.GetPreallocationStatus", [&](void* arg) { in TEST_F() argument
[all …]
/rocksdb-6.9/build_tools/
Dgnu_parallel1407 for(my $arg = shift @ARGV; @ARGV; $arg = shift @ARGV) {
3910 my $arg;
6758 my @arg;
6765 if(not @arg) { @arg = (Arg->new("")); }
6807 for my $arg (@arg) {
7425 my $arg;
7450 $arg = $prepend.$arg; # For line continuation
7578 my $arg;
7582 for my $arg (@strings) { $arg =~ s/^\s+//; }
7584 for my $arg (@strings) { $arg =~ s/\s+$//; }
[all …]
/rocksdb-6.9/port/win/
Denv_win.h49 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
50 void* tag, void(*unschedFunction)(void* arg));
52 int UnSchedule(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,
304 void* tag, void(*unschedFunction)(void* arg)) override;
306 int UnSchedule(void* arg, Env::Priority pri) override;
308 void StartThread(void(*function)(void* arg), void* arg) override;
Denv_win.cc1222 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
1229 void* arg; member
1232 void* StartThreadWrapper(void* arg) { in StartThreadWrapper() argument
1234 reinterpret_cast<StartThreadState*>(arg)); in StartThreadWrapper()
1235 state->user_function(state->arg); in StartThreadWrapper()
1241 void WinEnvThreads::StartThread(void(*function)(void* arg), void* arg) { in StartThread() argument
1244 state->arg = arg; in StartThread()
1463 int WinEnv::UnSchedule(void* arg, Env::Priority pri) { in UnSchedule() argument
1464 return winenv_threads_.UnSchedule(arg, pri); in UnSchedule()
1467 void WinEnv::StartThread(void(*function)(void* arg), void* arg) { in StartThread() argument
[all …]
Dwin_thread.cc36 static unsigned int __stdcall ThreadProc(void* arg);
172 unsigned int __stdcall WindowsThread::Data::ThreadProc(void* arg) { in ThreadProc() argument
173 auto ptr = reinterpret_cast<std::shared_ptr<Data>*>(arg); in ThreadProc()
/rocksdb-6.9/monitoring/
Dstats_history_test.cc48 "InstrumentedCondVar::TimedWaitInternal", [&](void* arg) { in TEST_F() argument
49 uint64_t time_us = *reinterpret_cast<uint64_t*>(arg); in TEST_F()
51 *reinterpret_cast<uint64_t*>(arg) = mock_env->RealNowMicros() + 1000; in TEST_F()
86 "InstrumentedCondVar::TimedWaitInternal", [&](void* arg) { in TEST_F() argument
87 uint64_t time_us = *reinterpret_cast<uint64_t*>(arg); in TEST_F()
122 "InstrumentedCondVar::TimedWaitInternal", [&](void* arg) { in TEST_F() argument
123 uint64_t time_us = *reinterpret_cast<uint64_t*>(arg); in TEST_F()
155 "InstrumentedCondVar::TimedWaitInternal", [&](void* arg) { in TEST_F() argument
156 uint64_t time_us = *reinterpret_cast<uint64_t*>(arg); in TEST_F()
211 "InstrumentedCondVar::TimedWaitInternal", [&](void* arg) { in TEST_F() argument
[all …]
/rocksdb-6.9/hdfs/
Denv_hdfs.h104 void Schedule(void (*function)(void* arg), void* arg, Priority pri = LOW,
106 void (*unschedFunction)(void* arg) = 0) override {
107 posixEnv->Schedule(function, arg, pri, tag, unschedFunction);
114 void StartThread(void (*function)(void* arg), void* arg) override { in StartThread() argument
115 posixEnv->StartThread(function, arg); in StartThread()
332 virtual void Schedule(void (* /*function*/)(void* arg), void* /*arg*/,
334 void (* /*unschedFunction*/)(void* arg) = 0) override {}
338 virtual void StartThread(void (* /*function*/)(void* arg), in StartThread() argument
/rocksdb-6.9/CMakeFiles/
DCMakeConfigureLog.yaml207 arg [-o] ==> ignore
208 arg [cmTC_2c3e0] ==> ignore
214 arg [-lc++] ==> lib [c++]
215 arg [-lm] ==> lib [m]
216 arg [-lgcc] ==> lib [gcc]
220 arg [-lc] ==> lib [c]
221 arg [-lgcc] ==> lib [gcc]
356 arg [-o] ==> ignore
363 arg [-lgcc] ==> lib [gcc]
367 arg [-lc] ==> lib [c]
[all …]
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_test.cc27 static void OnOpenForRead(void* arg) { in OnOpenForRead() argument
28 int* val = static_cast<int*>(arg); in OnOpenForRead()
35 static void OnOpenForWrite(void* arg) { in OnOpenForWrite() argument
36 int* val = static_cast<int*>(arg); in OnOpenForWrite()
65 static void OnDeleteDir(void* arg) { in OnDeleteDir() argument
66 char* dir = static_cast<char*>(arg); in OnDeleteDir()
274 static void UniqueIdCallback(void* arg) { in UniqueIdCallback() argument
275 int* result = reinterpret_cast<int*>(arg); in UniqueIdCallback()
Dblock_cache_tier_metadata.cc35 cache_file_index_.Clear([](BlockCacheFile* arg){ delete arg; }); in Clear() argument
36 block_index_.Clear([](BlockInfo* arg){ delete arg; }); in Clear() argument
/rocksdb-6.9/tools/
Ddb_bench_tool_test.cc46 for (const auto& arg : args) { in AppendArgs() local
47 ASSERT_LE(cursor_ + arg.size() + 1, kArgBufferSize); in AppendArgs()
49 snprintf(arg_buffer_ + cursor_, arg.size() + 1, "%s", arg.c_str()); in AppendArgs()
52 cursor_ += arg.size() + 1; in AppendArgs()
Ddb_repl_stress.cc46 static void DataPumpThreadBody(void* arg) { in DataPumpThreadBody() argument
47 DataPumpThread* t = reinterpret_cast<DataPumpThread*>(arg); in DataPumpThreadBody()
67 static void ReplicationThreadBody(void* arg) { in ReplicationThreadBody() argument
68 ReplicationThread* t = reinterpret_cast<ReplicationThread*>(arg); in ReplicationThreadBody()
/rocksdb-6.9/trace_replay/
Dtrace_replay.h159 static void BGWorkGet(void* arg);
163 static void BGWorkWriteBatch(void* arg);
167 static void BGWorkIterSeek(void* arg);
171 static void BGWorkIterSeekForPrev(void* arg);
Dtrace_replay.cc407 void Replayer::BGWorkGet(void* arg) { in BGWorkGet() argument
409 reinterpret_cast<ReplayerWorkerArg*>(arg)); in BGWorkGet()
429 void Replayer::BGWorkWriteBatch(void* arg) { in BGWorkWriteBatch() argument
431 reinterpret_cast<ReplayerWorkerArg*>(arg)); in BGWorkWriteBatch()
437 void Replayer::BGWorkIterSeek(void* arg) { in BGWorkIterSeek() argument
439 reinterpret_cast<ReplayerWorkerArg*>(arg)); in BGWorkIterSeek()
461 void Replayer::BGWorkIterSeekForPrev(void* arg) { in BGWorkIterSeekForPrev() argument
463 reinterpret_cast<ReplayerWorkerArg*>(arg)); in BGWorkIterSeekForPrev()
/rocksdb-6.9/db/blob/
Dblob_file_garbage_test.cc112 "BlobFileGarbage::EncodeTo::CustomFields", [&](void* arg) { in TEST_F() argument
113 std::string* output = static_cast<std::string*>(arg); in TEST_F()
137 "BlobFileGarbage::EncodeTo::CustomFields", [&](void* arg) { in TEST_F() argument
138 std::string* output = static_cast<std::string*>(arg); in TEST_F()
Dblob_file_addition_test.cc139 "BlobFileAddition::EncodeTo::CustomFields", [&](void* arg) { in TEST_F() argument
140 std::string* output = static_cast<std::string*>(arg); in TEST_F()
167 "BlobFileAddition::EncodeTo::CustomFields", [&](void* arg) { in TEST_F() argument
168 std::string* output = static_cast<std::string*>(arg); in TEST_F()
/rocksdb-6.9/file/
Ddelete_scheduler_test.cc127 [&](void* arg) { penalties.push_back(*(static_cast<uint64_t*>(arg))); }); in TEST_F() argument
130 "DeleteScheduler::DeleteTrashFile::AfterSyncDir", [&](void* arg) { in TEST_F() argument
132 std::string* dir = reinterpret_cast<std::string*>(arg); in TEST_F()
241 [&](void* arg) { penalties.push_back(*(static_cast<uint64_t*>(arg))); }); in TEST_F() argument
554 [&](void* arg) { penalties.push_back(*(static_cast<int*>(arg))); }); in TEST_F() argument

1234