| /rocksdb-6.9/file/ |
| D | filename.cc | 73 assert(number > 0); in LogFileName()
78 assert(number > 0); in LogFileName()
83 assert(number > 0); in BlobFileName()
127 return number; in TableFileNameToNumber()
264 *number = 0; in ParseFileName()
267 *number = 0; in ParseFileName()
270 *number = 0; in ParseFileName()
276 *number = 0; in ParseFileName()
298 *number = num; in ParseFileName()
309 *number = num; in ParseFileName()
[all …]
|
| D | filename.h | 55 extern std::string LogFileName(const std::string& dbname, uint64_t number);
57 extern std::string LogFileName(uint64_t number);
59 extern std::string BlobFileName(const std::string& bdirname, uint64_t number);
62 const std::string& blob_dir, uint64_t number);
75 extern std::string MakeTableFileName(uint64_t number);
89 uint64_t number, uint32_t path_id);
101 uint64_t number);
114 extern std::string TempFileName(const std::string& dbname, uint64_t number);
152 uint64_t number);
163 extern bool ParseFileName(const std::string& filename, uint64_t* number,
[all …]
|
| /rocksdb-6.9/db/ |
| D | filename_test.cc | 24 uint64_t number; in TEST_F() local
34 uint64_t number; in TEST_F() member
67 ASSERT_EQ(cases[i].number, number) << f; in TEST_F()
125 uint64_t number; in TEST_F() local
132 ASSERT_EQ(0U, number); in TEST_F()
138 ASSERT_EQ(0U, number); in TEST_F()
144 ASSERT_EQ(192U, number); in TEST_F()
153 ASSERT_EQ(200U, number); in TEST_F()
159 ASSERT_EQ(100U, number); in TEST_F()
165 ASSERT_EQ(999U, number); in TEST_F()
[all …]
|
| D | wal_manager.cc | 43 read_first_record_cache_.erase(number); in DeleteFile()
176 uint64_t number; in PurgeObsoleteWALFiles() local
198 read_first_record_cache_.erase(number); in PurgeObsoleteWALFiles()
226 read_first_record_cache_.erase(number); in PurgeObsoleteWALFiles()
293 uint64_t number; in GetSortedWalsOfType() local
382 auto itr = read_first_record_cache_.find(number); in ReadFirstRecord()
391 s = ReadFirstLine(fname, number, sequence); in ReadFirstRecord()
402 s = ReadFirstLine(archived_file, number, sequence); in ReadFirstRecord()
418 Status WalManager::GetLiveWalFile(uint64_t number, in GetLiveWalFile() argument
424 if (!number) { in GetLiveWalFile()
[all …]
|
| D | wal_manager.h | 59 void ArchiveWALFile(const std::string& fname, uint64_t number);
61 Status DeleteFile(const std::string& fname, uint64_t number);
63 Status GetLiveWalFile(uint64_t number, std::unique_ptr<LogFile>* log_file);
65 Status TEST_ReadFirstRecord(const WalFileType type, const uint64_t number, in TEST_ReadFirstRecord() argument
67 return ReadFirstRecord(type, number, sequence); in TEST_ReadFirstRecord()
70 Status TEST_ReadFirstLine(const std::string& fname, const uint64_t number, in TEST_ReadFirstLine() argument
72 return ReadFirstLine(fname, number, sequence); in TEST_ReadFirstLine()
84 Status ReadFirstRecord(const WalFileType type, const uint64_t number,
87 Status ReadFirstLine(const std::string& fname, const uint64_t number,
|
| D | options_file_test.cc | 29 uint64_t number; in UpdateOptionsFiles() local
33 if (ParseFileName(filename, &number, &type) && type == kOptionsFile) { in UpdateOptionsFiles()
46 uint64_t number; in VerifyOptionsFileName() local
49 if (ParseFileName(filename, &number, &type) && type == kOptionsFile) { in VerifyOptionsFileName()
85 uint64_t number; in TEST_F() local
89 ASSERT_TRUE(ParseFileName(options_file_name, &number, &type, nullptr)); in TEST_F()
91 ASSERT_EQ(number, kOptionsFileNum); in TEST_F()
95 ASSERT_TRUE(ParseFileName(temp_options_file_name, &number, &type, nullptr)); in TEST_F()
99 ASSERT_EQ(number, kTempOptionsFileNum); in TEST_F()
|
| D | version_edit.cc | 87 uint64_t PackFileNumberAndPathId(uint64_t number, uint64_t path_id) { in PackFileNumberAndPathId() argument
88 assert(number <= kFileNumberMask); in PackFileNumberAndPathId()
89 return number | (path_id * (kFileNumberMask + 1)); in PackFileNumberAndPathId()
339 uint64_t number = 0; in DecodeNewFile4From() local
344 if (GetLevel(input, &level, &msg) && GetVarint64(input, &number) && in DecodeNewFile4From()
516 uint64_t number = 0; in DecodeFrom() local
518 deleted_files_.insert(std::make_pair(level, number)); in DecodeFrom()
528 uint64_t number = 0; in DecodeFrom() local
534 f.fd = FileDescriptor(number, 0, file_size); in DecodeFrom()
544 uint64_t number = 0; in DecodeFrom() local
[all …]
|
| D | version_builder.cc | 334 if (f->fd.GetNumber() == number) { in CheckConsistencyForDeletes()
345 auto got = level_added.find(number); in CheckConsistencyForDeletes()
355 auto got = level_added.find(number); in CheckConsistencyForDeletes()
361 fprintf(stderr, "not found %" PRIu64 "\n", number); in CheckConsistencyForDeletes()
441 const auto number = del_file.second; in Apply() local
443 levels_[level].deleted_files.insert(number); in Apply()
444 CheckConsistencyForDeletes(edit, number, level); in Apply()
452 if (invalid_levels_[level].erase(number) == 0) { in Apply()
471 uint64_t number = new_file.second.fd.GetNumber(); in Apply() local
473 if (lvls.count(number) == 0) { in Apply()
[all …]
|
| D | db_info_dumper.cc | 26 uint64_t number = 0; in DumpDBFileSummary() local
42 if (!ParseFileName(file, &number, &type)) { in DumpDBFileSummary()
85 if (ParseFileName(file, &number, &type)) { in DumpDBFileSummary()
109 if (ParseFileName(file, &number, &type)) { in DumpDBFileSummary()
|
| D | wal_manager_test.cc | 170 uint64_t number; in GetLogDirSize() local
172 if (ParseFileName(f, &number, &type) && type == kLogFile) { in GetLogDirSize()
186 uint64_t number; in ListSpecificFiles() local
189 if (ParseFileName(files[i], &number, &type)) { in ListSpecificFiles()
191 file_numbers.push_back(number); in ListSpecificFiles()
|
| D | version_edit.h | 35 extern uint64_t PackFileNumberAndPathId(uint64_t number, uint64_t path_id);
52 FileDescriptor(uint64_t number, uint32_t path_id, uint64_t _file_size) in FileDescriptor()
53 : FileDescriptor(number, path_id, _file_size, kMaxSequenceNumber, 0) {} in FileDescriptor()
55 FileDescriptor(uint64_t number, uint32_t path_id, uint64_t _file_size, in FileDescriptor()
58 packed_number_and_path_id(PackFileNumberAndPathId(number, path_id)), in FileDescriptor()
|
| D | repair.cc | 290 uint64_t number; in FindFiles() local
293 if (ParseFileName(filenames[i], &number, &type)) { in FindFiles()
297 if (number + 1 > next_file_number_) { in FindFiles()
298 next_file_number_ = number + 1; in FindFiles()
301 logs_.push_back(number); in FindFiles()
303 table_fds_.emplace_back(number, static_cast<uint32_t>(path_id), in FindFiles()
|
| D | corruption_test.cc | 200 uint64_t number; in Corrupt() local
205 if (ParseFileName(filenames[i], &number, &type) && in Corrupt()
207 static_cast<int>(number) > picked_number) { // Pick latest file in Corrupt()
209 picked_number = static_cast<int>(number); in Corrupt()
|
| D | obsolete_files_test.cc | 72 uint64_t number; in CheckFileTypeCounts() local
74 if (ParseFileName(file, &number, &type)) { in CheckFileTypeCounts()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 139 uint64_t number; in FindObsoleteFiles() local
149 !ShouldPurge(number)) { in FindObsoleteFiles()
193 earliest.number); in FindObsoleteFiles()
369 uint64_t number; in PurgeObsoleteFiles() local
375 if (number > optsfile_num1) { in PurgeObsoleteFiles()
377 optsfile_num1 = number; in PurgeObsoleteFiles()
379 optsfile_num2 = number; in PurgeObsoleteFiles()
393 uint64_t number; in PurgeObsoleteFiles() local
419 files_to_del.insert(number); in PurgeObsoleteFiles()
437 if (number != 0) { in PurgeObsoleteFiles()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Env.java | 54 public Env setBackgroundThreads(final int number) { in setBackgroundThreads() argument
55 return setBackgroundThreads(number, Priority.LOW); in setBackgroundThreads()
80 public Env setBackgroundThreads(final int number, final Priority priority) { in setBackgroundThreads() argument
81 setBackgroundThreads(nativeHandle_, number, priority.getValue()); in setBackgroundThreads()
107 public Env incBackgroundThreadsIfNeeded(final int number, in incBackgroundThreadsIfNeeded() argument
109 incBackgroundThreadsIfNeeded(nativeHandle_, number, priority.getValue()); in incBackgroundThreadsIfNeeded()
154 final long handle, final int number, final byte priority); in setBackgroundThreads() argument
160 final int number, final byte priority); in incBackgroundThreadsIfNeeded() argument
|
| /rocksdb-6.9/tools/ |
| D | write_stress.cc | 251 uint64_t number; in Run() local
253 if (!ParseFileName(file.name, &number, "LOG", &type)) { in Run()
257 sst_file_numbers.insert(number); in Run()
264 uint64_t number; in Run() local
266 if (!ParseFileName(child, &number, "LOG", &type)) { in Run()
270 if (sst_file_numbers.find(number) == sst_file_numbers.end()) { in Run()
|
| /rocksdb-6.9/hdfs/ |
| D | env_hdfs.h | 147 void SetBackgroundThreads(int number, Priority pri = LOW) override {
148 posixEnv->SetBackgroundThreads(number, pri);
155 void IncBackgroundThreadsIfNeeded(int number, Priority pri) override { in IncBackgroundThreadsIfNeeded() argument
156 posixEnv->IncBackgroundThreadsIfNeeded(number, pri); in IncBackgroundThreadsIfNeeded()
159 std::string TimeToString(uint64_t number) override { in TimeToString() argument
160 return posixEnv->TimeToString(number); in TimeToString()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-07-23-dynamic-level.markdown | 26 …number. However, there is a catch here: how to make sure the last level’s size is 1000GB, the same…
|
| D | 2017-03-02-rocksdb-5-2-1-released.markdown | 9 * NewLRUCache() will determine number of shard bits automatically based on capacity, if the user do…
14 * Added new function GetApproximateMemTableStats that approximates both number of records and size …
|
| D | 2018-02-05-rocksdb-5-10-2-released.markdown | 15 …nters, `key_lock_wait_count` and `key_lock_wait_time`, which measure the number of times transacti…
20 * Fix performance issue in `IngestExternalFile()` affecting databases with large number of SST file…
|
| D | 2014-06-27-avoid-expensive-locks-in-get.markdown | 32 …global super version number. Subsequent reads simply compare the local super version number agains…
|
| D | 2014-09-12-cuckoo.markdown | 56 …number of hash functions required and hence the number of memory accesses. In our experiments, wit…
|
| /rocksdb-6.9/ |
| D | HISTORY.md | 157 * Fixed a number of data races in BlobDB.
160 * Fix a bug in file ingestion caused by incorrect file number allocation when the number of column …
197 …ifies the number of bytes to prefetch when reading the log. This is mostly useful for reading a re…
331 * `TableProperties::num_entries` and `TableProperties::num_deletions` now also account for number o…
337 * The counter stat `number.block.not_compressed` now also counts blocks not compressed due to poor …
453 * Add a new ticker stat rocksdb.number.multiget.keys.found to count number of keys successfully rea…
471 * Fsync after writing global seq number to the ingestion file in ExternalSstFileIngestionJob.
533 * Fix buffer overrun in backup engine for DBs with huge number of files.
549 * Fix performance issue in `IngestExternalFile()` affecting databases with large number of SST file…
684 * Added new function GetApproximateMemTableStats that approximates both number of records and size …
[all …]
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_impl.cc | 261 uint64_t number; in CreateCustomCheckpoint() local
263 bool ok = ParseFileName(live_files[i], &number, &type); in CreateCustomCheckpoint()
484 uint64_t number; in ExportFilesInMetaData() local
486 const auto ok = ParseFileName(file_metadata.name, &number, &type); in ExportFilesInMetaData()
|