| /rocksdb-6.9/db/ |
| D | memtable_list.cc | 32 memlist_.push_front(m); in AddMemTable()
38 if (m->Unref()) { in UnrefMemTable()
39 to_delete->push_back(m); in UnrefMemTable()
55 m->Ref(); in MemTableListVersion()
60 m->Ref(); in MemTableListVersion()
260 AddMemTable(m); in Add()
269 memlist_.remove(m); in Remove()
271 m->MarkFlushed(); in Remove()
343 MemTable* m = *it; in PickMemtablesToFlush() local
379 m->edit_.Clear(); in RollbackMemtableFlush()
[all …]
|
| D | memtable_list_test.cc | 318 delete m; in TEST_F()
514 delete m; in TEST_F()
720 m->Ref(); in TEST_F()
721 ASSERT_EQ(m, m->Unref()); in TEST_F()
722 delete m; in TEST_F()
763 m->Ref(); in TEST_F()
764 ASSERT_EQ(m, m->Unref()); in TEST_F()
765 delete m; in TEST_F()
918 m->Ref(); in TEST_F()
919 ASSERT_EQ(m, m->Unref()); in TEST_F()
[all …]
|
| D | flush_job.cc | 178 MemTable* m = mems_[0]; in PickMemTable() local
179 edit_ = m->GetEdits(); in PickMemTable()
321 for (MemTable* m : mems_) { in WriteLevel0Table()
325 cfd_->GetName().c_str(), job_context_->job_id, m->GetNextLogNumber()); in WriteLevel0Table()
326 memtables.push_back(m->NewIterator(ro, &arena)); in WriteLevel0Table()
328 m->NewRangeTombstoneIterator(ro, kMaxSequenceNumber); in WriteLevel0Table()
332 total_num_entries += m->num_entries(); in WriteLevel0Table()
333 total_num_deletes += m->num_deletes(); in WriteLevel0Table()
334 total_data_size += m->get_data_size(); in WriteLevel0Table()
335 total_memory_usage += m->ApproximateMemoryUsage(); in WriteLevel0Table()
|
| D | memtable_list.h | 147 void Add(MemTable* m, autovector<MemTable*>* to_delete);
149 void Remove(MemTable* m, autovector<MemTable*>* to_delete);
161 void AddMemTable(MemTable* m);
163 void UnrefMemTable(autovector<MemTable*>* to_delete, MemTable* m);
265 const autovector<MemTable*>& m, LogsWithPrepTracker* prep_tracker,
274 void Add(MemTable* m, autovector<MemTable*>* to_delete);
|
| D | forward_iterator.cc | 296 for (auto* m : imm_iters_) { in Cleanup() local
297 DeleteIterator(m, true /* is_arena */); in Cleanup()
383 auto* m = imm_iters_[i]; in SeekInternal() local
384 seek_to_first ? m->SeekToFirst() : m->Seek(internal_key); in SeekInternal()
385 if (!m->status().ok()) { in SeekInternal()
386 immutable_status_ = m->status(); in SeekInternal()
387 } else if (m->Valid()) { in SeekInternal()
388 immutable_min_heap_.push(m); in SeekInternal()
680 for (auto* m : imm_iters_) { in RenewIterators() local
681 DeleteIterator(m, true /* is_arena */); in RenewIterators()
|
| D | flush_job_test.cc | 213 for (auto& m : to_delete) { in TEST_F() local
214 delete m; in TEST_F()
310 for (auto m : to_delete) { in TEST_F() local
311 delete m; in TEST_F()
419 for (auto m : to_delete) { in TEST_F() local
420 delete m; in TEST_F()
468 for (auto& m : to_delete) { in TEST_F() local
469 delete m; in TEST_F()
|
| D | job_context.h | 201 for (auto m : memtables_to_free) { in Clean() local
202 delete m; in Clean() local
|
| D | column_family.cc | 431 MemTable* m = mem->Unref(); in Cleanup() local
432 if (m != nullptr) { in Cleanup()
434 assert(*memory_usage >= m->ApproximateMemoryUsage()); in Cleanup()
435 *memory_usage -= m->ApproximateMemoryUsage(); in Cleanup()
436 to_delete.push_back(m); in Cleanup()
628 for (MemTable* m : to_delete) { in ~ColumnFamilyData()
629 delete m; in ~ColumnFamilyData()
|
| D | corruption_test.cc | 222 for (const auto& m : metadata) { in CorruptTableFileAtLevel() local
223 if (m.level == level) { in CorruptTableFileAtLevel()
224 CorruptFile(dbname_ + "/" + m.name, offset, bytes_to_corrupt); in CorruptTableFileAtLevel()
|
| /rocksdb-6.9/util/ |
| D | murmurhash.cc | 45 k *= m; in MurmurHash64A()
47 k *= m; in MurmurHash64A()
50 h *= m; in MurmurHash64A()
64 h *= m; in MurmurHash64A()
68 h *= m; in MurmurHash64A()
109 k *= m; in MurmurHash2()
111 k *= m; in MurmurHash2()
113 h *= m; in MurmurHash2()
127 h *= m; in MurmurHash2()
134 h *= m; in MurmurHash2()
[all …]
|
| D | dynamic_bloom_test.cc | 188 for (uint32_t m = 1; m <= 8; ++m) { in TEST_F() local
190 const uint32_t num_keys = m * 8 * 1024 * 1024; in TEST_F()
191 fprintf(stderr, "testing %" PRIu32 "M keys\n", m * 8); in TEST_F()
230 for (uint32_t m = 1; m <= m_limit; ++m) { in TEST_F() local
232 const uint32_t num_keys = m * 8 * 1024 * 1024; in TEST_F()
233 fprintf(stderr, "testing %" PRIu32 "M keys\n", m * 8); in TEST_F()
|
| D | hash.cc | 22 const uint32_t m = 0xc6a4a793; in Hash() local
25 uint32_t h = static_cast<uint32_t>(seed ^ (n * m)); in Hash()
32 h *= m; in Hash()
53 h *= m; in Hash()
|
| D | crc32c.cc | 367 #define ALIGN(n, m) ((n + ((1 << m) - 1)) & ~((1 << m) - 1)) in ExtendImpl() argument
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 2410 assert(m); in BackgroundCallCompaction()
2546 m->done = true; in BackgroundCompaction()
2551 m->cfd->GetName().c_str(), m->input_level, in BackgroundCompaction()
2572 (m->begin ? m->begin->DebugString().c_str() : "(begin)"), in BackgroundCompaction()
2573 (m->end ? m->end->DebugString().c_str() : "(end)"), in BackgroundCompaction()
2574 ((m->done || m->manual_end == nullptr) in BackgroundCompaction()
2910 m->done = true; in BackgroundCompaction()
2926 m->done = true; in BackgroundCompaction()
2928 if (!m->done) { in BackgroundCompaction()
2936 m->tmp_storage = *m->manual_end; in BackgroundCompaction()
[all …]
|
| /rocksdb-6.9/examples/ |
| D | compaction_filter_example.cc | 20 for (const ROCKSDB_NAMESPACE::Slice& m : merge_in.operand_list) { in FullMergeV2() local
21 fprintf(stderr, "Merge(%s)\n", m.ToString().c_str()); in FullMergeV2()
23 assert(m.ToString() != "bad"); in FullMergeV2()
24 merge_out->new_value.assign(m.data(), m.size()); in FullMergeV2()
|
| /rocksdb-6.9/monitoring/ |
| D | histogram_windowing.cc | 169 uint64_t m = window_stats_[i].min(); in SwapHistoryBucket() local
170 if (m < new_min) new_min = m; in SwapHistoryBucket()
180 uint64_t m = window_stats_[i].max(); in SwapHistoryBucket() local
181 if (m > new_max) new_max = m; in SwapHistoryBucket()
|
| /rocksdb-6.9/build_tools/ |
| D | amalgamate.py | 61 m = include_re.match(text)
62 if m:
63 filename = m.groups()[0]
|
| /rocksdb-6.9/port/ |
| D | port_posix.cc | 209 void *m; in cacheline_aligned_alloc()
210 errno = posix_memalign(&m, CACHE_LINE_SIZE, size); in cacheline_aligned_alloc()
211 return errno ? nullptr : m; in cacheline_aligned_alloc()
|
| /rocksdb-6.9/CMakeFiles/3.30.5/ |
| D | CMakeCXXCompiler.cmake | 48 set(CMAKE_CXX_SOURCE_FILE_EXTENSIONS C;M;c++;cc;cpp;cxx;m;mm;mpp;CPP;ixx;cppm;ccm;cxxm;c++m)
91 set(CMAKE_CXX_IMPLICIT_LINK_LIBRARIES "c++;m;gcc;gcc_s;c;gcc;gcc_s")
|
| /rocksdb-6.9/table/block_based/ |
| D | filter_policy.cc | 741 BloomFilterPolicy::Mode m; in NewBloomFilterPolicy() local
743 m = BloomFilterPolicy::kDeprecatedBlock; in NewBloomFilterPolicy()
745 m = BloomFilterPolicy::kAuto; in NewBloomFilterPolicy()
749 m) != BloomFilterPolicy::kAllUserModes.end()); in NewBloomFilterPolicy()
750 return new BloomFilterPolicy(bits_per_key, m); in NewBloomFilterPolicy()
|
| D | data_block_hash_index_test.cc | 194 std::unordered_map<std::string, uint8_t> m; in TEST() local
203 m[key] = restart_point; in TEST()
227 if (m.count(key)) { in TEST()
228 ASSERT_TRUE(m[key] == restart_point); in TEST()
242 std::unordered_map<std::string, uint8_t> m; in TEST() local
|
| /rocksdb-6.9/tools/advisor/ |
| D | README.md | 44 python3 -m advisor.rule_parser_example --rules_spec=advisor/rules.ini --rocksdb_options=test/input_…
71 python3 -m advisor.rule_parser_example --help
95 python3 -m unittest -v test.test_db_log_parser
|
| /rocksdb-6.9/options/ |
| D | cf_options.cc | 181 for (const auto m : max_bytes_for_level_multiplier_additional) { in Dump() local
182 snprintf(buf, sizeof(buf), "%d, ", m); in Dump()
|
| /rocksdb-6.9/java/ |
| D | jdb_bench.sh | 13 java -server -d$PLATFORM -XX:NewSize=4m -XX:+AggressiveOpts -Djava.library.path=target -cp "${ROCKS…
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 4997 Message m; in EscapeXml() local
5003 m << "<"; in EscapeXml()
5021 m << '"'; in EscapeXml()
5405 Message m; in EscapeJson() local
5416 m << "\\b"; in EscapeJson()
5419 m << "\\t"; in EscapeJson()
5422 m << "\\n"; in EscapeJson()
5425 m << "\\f"; in EscapeJson()
5428 m << "\\r"; in EscapeJson()
5434 m << ch; in EscapeJson()
[all …]
|