Home
last modified time | relevance | path

Searched refs:m (Results 1 – 25 of 41) sorted by relevance

12

/rocksdb-6.9/db/
Dmemtable_list.cc32 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 …]
Dmemtable_list_test.cc318 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 …]
Dflush_job.cc178 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()
Dmemtable_list.h147 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);
Dforward_iterator.cc296 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()
Dflush_job_test.cc213 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()
Djob_context.h201 for (auto m : memtables_to_free) { in Clean() local
202 delete m; in Clean() local
Dcolumn_family.cc431 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()
Dcorruption_test.cc222 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/
Dmurmurhash.cc45 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 …]
Ddynamic_bloom_test.cc188 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()
Dhash.cc22 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()
Dcrc32c.cc367 #define ALIGN(n, m) ((n + ((1 << m) - 1)) & ~((1 << m) - 1)) in ExtendImpl() argument
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc2410 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/
Dcompaction_filter_example.cc20 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/
Dhistogram_windowing.cc169 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/
Damalgamate.py61 m = include_re.match(text)
62 if m:
63 filename = m.groups()[0]
/rocksdb-6.9/port/
Dport_posix.cc209 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/
DCMakeCXXCompiler.cmake48 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/
Dfilter_policy.cc741 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()
Ddata_block_hash_index_test.cc194 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/
DREADME.md44 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/
Dcf_options.cc181 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/
Djdb_bench.sh13 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/
Dgtest-all.cc4997 Message m; in EscapeXml() local
5003 m << "&lt;"; 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 …]

12