Home
last modified time | relevance | path

Searched refs:l (Results 1 – 25 of 86) sorted by relevance

1234

/rocksdb-6.9/build_tools/
Drun_ci_db_test.ps195 $l = $ExcludeCases -split ' ' variable
96 ForEach($t in $l) {
104 $l = $ExcludeExes -split ' ' variable
105 ForEach($t in $l) {
139 ForEach( $l in $Tests) { in ExtractTestCases() variable
142 $l = $l -replace '^\s+','' in ExtractTestCases() variable
144 if ($l -match "\.$" -and $l -notmatch "\s+") { in ExtractTestCases() variable
145 $Group = $l in ExtractTestCases()
148 $test = $l in ExtractTestCases()
436 ForEach($l in $log_content) { in RunJobs() variable
[all …]
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc50 MutexLock l(&mu_); in Close() local
67 MutexLock l(&mu_); in OnAddFile() local
76 MutexLock l(&mu_); in OnAddFile() local
84 MutexLock l(&mu_); in OnDeleteFile() local
92 MutexLock l(&mu_); in OnCompactionCompletion() local
132 MutexLock l(&mu_); in SetMaxAllowedSpaceUsage() local
138 MutexLock l(&mu_); in SetCompactionBufferSize() local
143 MutexLock l(&mu_); in IsMaxAllowedSpaceReached() local
151 MutexLock l(&mu_); in IsMaxAllowedSpaceReachedIncludingCompactions() local
162 MutexLock l(&mu_); in EnoughRoomForCompaction() local
[all …]
Ddelete_scheduler.cc46 InstrumentedMutexLock l(&mu_); in ~DeleteScheduler() local
93 InstrumentedMutexLock l(&mu_); in DeleteFile() local
104 InstrumentedMutexLock l(&mu_); in GetBackgroundErrors() local
168 InstrumentedMutexLock l(&file_move_mu_); in MarkAsTrash() local
194 InstrumentedMutexLock l(&mu_); in BackgroundEmptyTrash() local
349 InstrumentedMutexLock l(&mu_); in WaitForEmptyTrash() local
/rocksdb-6.9/db/db_impl/
Ddb_impl_debug.cc20 InstrumentedMutexLock l(&mutex_); in TEST_GetLevel0TotalSize() local
26 InstrumentedMutexLock l(&mutex_); in TEST_SwitchWAL() local
53 InstrumentedMutexLock l(&mutex_); in TEST_MaxNextLevelOverlappingBytes() local
62 InstrumentedMutexLock l(&mutex_); in TEST_GetFilesMetaData() local
106 InstrumentedMutexLock l(&mutex_); in TEST_SwitchMemtable() local
168 InstrumentedMutexLock l(&mutex_); in TEST_WaitForCompact() local
195 InstrumentedMutexLock l(&mutex_); in TEST_LogsToFreeSize() local
200 InstrumentedMutexLock l(&mutex_); in TEST_LogfileNumber() local
243 InstrumentedMutexLock l(&mutex_); in TEST_GetLatestMutableCFOptions() local
251 InstrumentedMutexLock l(&mutex_); in TEST_BGCompactionsAllowed() local
[all …]
Ddb_impl.cc411 InstrumentedMutexLock l(&mutex_); in CancelAllBackgroundWork() local
530 for (auto l : logs_to_free_) { in CloseHelper() local
531 delete l; in CloseHelper()
647 InstrumentedMutexLock l(&mutex_); in StartTimedTasks() local
697 InstrumentedMutexLock l(&mutex_); in PersistStats() local
891 AddToLogsToFreeQueue(l); in ScheduleBgLogWriterClose()
2837 InstrumentedMutexLock l(&mutex_); in GetOptions() local
2844 InstrumentedMutexLock l(&mutex_); in GetDBOptions() local
2952 InstrumentedMutexLock l(&mutex_); in ResetStats() local
3061 InstrumentedMutexLock l(&mutex_); in GetColumnFamilyHandleUnlocked() local
[all …]
/rocksdb-6.9/util/
Dcrc32c.cc332 *l = table3_[c & 0xff] ^ in Slow_CRC32()
339 *l = table3_[c & 0xff] ^ in Slow_CRC32()
347 Slow_CRC32(l, p); in Fast_CRC32()
349 *l = _mm_crc32_u64(*l, LE_LOAD64(*p)); in Fast_CRC32()
352 *l = _mm_crc32_u32(static_cast<unsigned int>(*l), LE_LOAD32(*p)); in Fast_CRC32()
354 *l = _mm_crc32_u32(static_cast<unsigned int>(*l), LE_LOAD32(*p)); in Fast_CRC32()
364 uint64_t l = crc ^ 0xffffffffu; in ExtendImpl() local
371 l = table0_[c] ^ (l >> 8); \ in ExtendImpl()
387 CRC32(&l, &p); in ExtendImpl()
388 CRC32(&l, &p); in ExtendImpl()
[all …]
Dthread_local.cc382 MutexLock l(Mutex()); in GetThreadLocal() local
389 MutexLock l(Mutex()); in GetThreadLocal() local
411 MutexLock l(Mutex()); in Reset() local
421 MutexLock l(Mutex()); in Swap() local
432 MutexLock l(Mutex()); in CompareAndSwap() local
441 MutexLock l(Mutex()); in Scrape() local
454 MutexLock l(Mutex()); in Fold() local
470 MutexLock l(Mutex()); in SetHandler() local
484 MutexLock l(Mutex()); in GetId() local
495 MutexLock l(Mutex()); in PeekId() local
[all …]
Drepeatable_thread.h43 InstrumentedMutexLock l(&mutex_); in cancel()
65 InstrumentedMutexLock l(&mutex_);
82 InstrumentedMutexLock l(&mutex_); in wait()
121 InstrumentedMutexLock l(&mutex_); in thread()
Dthread_list_test.cc39 std::unique_lock<std::mutex> l(mutex_); in Run() local
46 bg_cv_.wait(l); in Run()
56 std::unique_lock<std::mutex> l(mutex_); in FinishAllTasks() local
68 std::unique_lock<std::mutex> l(mutex_); in WaitUntilDone() local
70 bg_cv_.wait(l); in WaitUntilDone()
/rocksdb-6.9/tools/
Danalyze_txn_stress_test.sh39 for l in `cat /tmp/vb.txt`;
41 grep $l /tmp/va.txt > /dev/null ;
44 k=`echo $l | awk '{print $1}'`;
45 v=`echo $l | awk '{print $3}'`;
48 if [[ $v -ne $exp ]]; then echo $l; fi
50 k=`echo $l | awk '{print $1}'`;
56 for l in `cat /tmp/va.txt`;
58 k=`echo $l | awk '{print $1}'`;
/rocksdb-6.9/cache/
Dlru_cache.cc121 MutexLock l(&mutex_); in EraseUnRefEntries() local
149 MutexLock l(&mutex_); in ApplyToAllCacheEntries() local
157 MutexLock l(&mutex_); in TEST_GetLRUList() local
163 MutexLock l(&mutex_); in TEST_GetLRUSize() local
174 MutexLock l(&mutex_); in GetHighPriPoolRatio() local
267 MutexLock l(&mutex_); in SetStrictCapacityLimit() local
272 MutexLock l(&mutex_); in Lookup() local
288 MutexLock l(&mutex_); in Ref() local
296 MutexLock l(&mutex_); in SetHighPriorityPoolRatio() local
445 MutexLock l(&mutex_); in GetUsage() local
[all …]
Dsharded_cache.cc30 MutexLock l(&capacity_mutex_); in SetCapacity() local
39 MutexLock l(&capacity_mutex_); in SetStrictCapacityLimit() local
79 MutexLock l(&capacity_mutex_); in GetCapacity() local
84 MutexLock l(&capacity_mutex_); in HasStrictCapacityLimit() local
133 MutexLock l(&capacity_mutex_); in GetPrintableOptions() local
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc89 MutexLock l(&mutex_); in Append() local
232 MutexLock l(&mutex_); in NewWritableFile() local
253 MutexLock l(&mutex_); in ReopenWritableFile() local
274 MutexLock l(&mutex_); in NewRandomRWFile() local
338 MutexLock l(&mutex_); in WritableFileClosed() local
346 MutexLock l(&mutex_); in WritableFileSynced() local
357 MutexLock l(&mutex_); in WritableFileAppended() local
369 MutexLock l(&mutex_); in DropUnsyncedFileData() local
382 MutexLock l(&mutex_); in DropRandomUnsyncedFileData() local
415 MutexLock l(&mutex_); in ResetState() local
[all …]
Dfault_injection_test_env.cc243 MutexLock l(&mutex_); in NewWritableFile() local
264 MutexLock l(&mutex_); in ReopenWritableFile() local
285 MutexLock l(&mutex_); in NewRandomRWFile() local
326 MutexLock l(&mutex_); in RenameFile() local
345 MutexLock l(&mutex_); in WritableFileClosed() local
353 MutexLock l(&mutex_); in WritableFileSynced() local
364 MutexLock l(&mutex_); in WritableFileAppended() local
379 MutexLock l(&mutex_); in DropFileData() local
407 MutexLock l(&mutex_); in DeleteFilesCreatedAfterLastDirSync() local
423 MutexLock l(&mutex_); in ResetState() local
[all …]
Dtestutil.h412 MutexLock l(&mutex_); in IsSleeping()
416 MutexLock l(&mutex_); in DoSleep()
427 MutexLock l(&mutex_); in WaitUntilSleeping()
438 MutexLock l(&mutex_); in TimedWaitUntilSleeping()
447 MutexLock l(&mutex_); in WakeUp()
452 MutexLock l(&mutex_); in WaitUntilDone()
461 MutexLock l(&mutex_); in TimedWaitUntilDone()
470 MutexLock l(&mutex_); in WokenUp()
475 MutexLock l(&mutex_); in Reset()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_driver.cc23 MutexLock l(shared->GetMutex()); in ThreadBody() local
35 MutexLock l(shared->GetMutex()); in ThreadBody() local
48 MutexLock l(shared->GetMutex()); in ThreadBody() local
89 MutexLock l(shared.GetMutex()); in RunStressTest() local
145 MutexLock l(shared.GetMutex()); in RunStressTest() local
/rocksdb-6.9/db/
Ddb_filesnapshot.cc27 InstrumentedMutexLock l(&mutex_); in DisableFileDeletions() local
45 InstrumentedMutexLock l(&mutex_); in EnableFileDeletions() local
157 InstrumentedMutexLock l(&mutex_); in GetSortedWalFiles() local
169 InstrumentedMutexLock l(&mutex_); in GetCurrentWalFile() local
Dwal_manager.cc42 MutexLock l(&read_first_record_cache_mutex_); in DeleteFile() local
197 MutexLock l(&read_first_record_cache_mutex_); in PurgeObsoleteWALFiles() local
225 MutexLock l(&read_first_record_cache_mutex_); in PurgeObsoleteWALFiles() local
265 MutexLock l(&read_first_record_cache_mutex_); in PurgeObsoleteWALFiles() local
381 MutexLock l(&read_first_record_cache_mutex_); in ReadFirstRecord() local
412 MutexLock l(&read_first_record_cache_mutex_); in ReadFirstRecord() local
Dversion_builder.cc329 for (int l = 0; !found && l < num_levels_; l++) { in CheckConsistencyForDeletes() local
331 base_vstorage_->LevelFiles(l); in CheckConsistencyForDeletes()
343 for (int l = level + 1; !found && l < num_levels_; l++) { in CheckConsistencyForDeletes() local
344 auto& level_added = levels_[l].added_files; in CheckConsistencyForDeletes()
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache.cc26 MutexLock l(&mutex_); in ~CacheActivityLogger() local
40 MutexLock l(&mutex_); in StartLogging() local
61 MutexLock l(&mutex_); in StopLogging() local
74 MutexLock l(&mutex_); in ReportLookup() local
99 MutexLock l(&mutex_); in ReportAdd() local
113 MutexLock l(&mutex_); in bg_status() local
/rocksdb-6.9/memtable/
Dvectorrep.cc111 WriteLock l(&rwlock_); in Insert() local
118 ReadLock l(&rwlock_); in Contains() local
123 WriteLock l(&rwlock_); in MarkReadOnly() local
158 WriteLock l(&vrep_->rwlock_); in DoSort() local
274 ReadLock l(&rwlock_); in GetIterator() local
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer_test.cc373 std::string l; in TEST_F() local
374 ASSERT_TRUE(getline(ss, l, ',')); in TEST_F()
375 if (l.find("block") == std::string::npos) { in TEST_F()
381 user_access_only + l + unit + in TEST_F()
427 std::string l; in TEST_F() local
428 ASSERT_TRUE(getline(ss, l, ',')); in TEST_F()
429 const std::string reuse_csv_file = test_path_ + "/" + l + file_suffix; in TEST_F()
576 std::string l; in TEST_F() local
577 ASSERT_TRUE(getline(ss, l, ',')); in TEST_F()
582 const std::string filename = test_path_ + "/" + l + spatial_locality_file; in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc457 for (int l = input_level + 1; l < output_level; l++) { in SetupOtherInputs() local
458 assert(vstorage->NumLevelFiles(l) == 0); in SetupOtherInputs()
856 for (int l = 0; l <= output_level; ++l) { in SanitizeCompactionInputFilesForAllLevels() local
857 auto& current_files = levels[l].files; in SanitizeCompactionInputFilesForAllLevels()
879 if (l != 0) { in SanitizeCompactionInputFilesForAllLevels()
914 if (l == 0) { in SanitizeCompactionInputFilesForAllLevels()
945 for (int m = std::max(l, 1); m <= output_level; ++m) { in SanitizeCompactionInputFilesForAllLevels()
/rocksdb-6.9/logging/
Dauto_roll_logger.h50 MutexLock l(&mutex_); in GetLogFileSize()
60 MutexLock l(&mutex_); in Flush()
78 MutexLock l(&mutex_); in GetInfoLogLevel()
/rocksdb-6.9/include/rocksdb/utilities/
Denv_mirror.h159 Status LockFile(const std::string& f, FileLock** l) override { in LockFile() argument
164 if (as.ok()) *l = new FileLockMirror(al, bl); in LockFile()
168 Status UnlockFile(FileLock* l) override { in UnlockFile() argument
169 FileLockMirror* ml = static_cast<FileLockMirror*>(l); in UnlockFile()

1234