Searched refs:kMerge (Results 1 – 6 of 6) sorted by relevance
| /rocksdb-6.9/table/ |
| D | get_context.cc | 197 assert((state_ != kMerge && parsed_key.type != kTypeMerge) || in SaveValue()
225 assert(state_ == kNotFound || state_ == kMerge); in SaveValue()
252 } else if (kMerge == state_) { in SaveValue()
290 assert(state_ == kNotFound || state_ == kMerge); in SaveValue()
293 } else if (kMerge == state_) { in SaveValue()
313 assert(state_ == kNotFound || state_ == kMerge); in SaveValue()
314 state_ = kMerge; in SaveValue()
|
| D | get_context.h | 63 kMerge, // saver contains the current merge result (the operands) enumerator
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_tool.cc | 629 type == TraceOperationType::kMerge)) { in MakeStatistics()
1684 s = WriteTraceSequence(TraceOperationType::kMerge, column_family_id, in HandleMerge()
1691 if (ta_[TraceOperationType::kMerge].sample_count >= sample_max_) { in HandleMerge()
1692 ta_[TraceOperationType::kMerge].sample_count = 0; in HandleMerge()
1694 if (ta_[TraceOperationType::kMerge].sample_count > 0) { in HandleMerge()
1695 ta_[TraceOperationType::kMerge].sample_count++; in HandleMerge()
1698 ta_[TraceOperationType::kMerge].sample_count++; in HandleMerge()
1700 if (!ta_[TraceOperationType::kMerge].enabled) { in HandleMerge()
1703 s = KeyStatsInsertion(TraceOperationType::kMerge, column_family_id, in HandleMerge()
1812 if (type == kPut || type == kMerge) { in PrintStatistics()
|
| D | trace_analyzer_tool.h | 32 kMerge = 5, enumerator
|
| D | db_bench_tool.cc | 1815 kMerge, enumerator
1830 {kMerge, "merge"},
5755 BGWriter(thread, kMerge); in SeekRandomWhileMerging()
5804 BGWriter(thread, kMerge); in ReadWhileMerging()
6324 thread->stats.FinishedOps(nullptr, db_with_cfh->db, 1, kMerge); in MergeRandom()
6367 thread->stats.FinishedOps(nullptr, db, 1, kMerge); in ReadRandomMergeRandom()
|
| /rocksdb-6.9/db/ |
| D | version_set.cc | 1759 status->ok() ? GetContext::kNotFound : GetContext::kMerge, user_key, in Get()
1808 get_context.State() != GetContext::kMerge && in Get()
1816 case GetContext::kMerge: in Get()
1849 if (GetContext::kMerge == get_context.State()) { in Get()
1899 iter->s->ok() ? GetContext::kNotFound : GetContext::kMerge, iter->ukey, in MultiGet()
1969 get_context.State() != GetContext::kMerge && in MultiGet()
1983 case GetContext::kMerge: in MultiGet()
2033 if (GetContext::kMerge == get_context.State()) { in MultiGet()
|