Lines Matching refs:mem
1422 MemTable* mem = cf_mems_->GetMemTable(); in PutCFImpl() local
1423 auto* moptions = mem->GetImmutableMemTableOptions(); in PutCFImpl()
1429 mem->Add(sequence_, value_type, key, value, in PutCFImpl()
1430 concurrent_memtable_writes_, get_post_process_info(mem), in PutCFImpl()
1431 hint_per_batch_ ? &GetHintMap()[mem] : nullptr); in PutCFImpl()
1440 mem->Update(sequence_, key, value); in PutCFImpl()
1443 if (mem->UpdateCallback(sequence_, key, value)) { in PutCFImpl()
1474 mem_res = mem->Add( in PutCFImpl()
1482 mem->Add(sequence_, value_type, key, Slice(merged_value)); in PutCFImpl()
1511 MemTable* mem = cf_mems_->GetMemTable(); in DeleteImpl() local
1513 mem->Add(sequence_, delete_type, key, value, in DeleteImpl()
1514 concurrent_memtable_writes_, get_post_process_info(mem), in DeleteImpl()
1515 hint_per_batch_ ? &GetHintMap()[mem] : nullptr); in DeleteImpl()
1673 MemTable* mem = cf_mems_->GetMemTable(); in MergeCF() local
1674 auto* moptions = mem->GetImmutableMemTableOptions(); in MergeCF()
1690 size_t num_merges = mem->CountSuccessiveMergeEntries(lkey); in MergeCF()
1732 bool mem_res = mem->Add(sequence_, kTypeValue, key, new_value); in MergeCF()
1745 mem->Add(sequence_, kTypeMerge, key, value, in MergeCF()
1746 concurrent_memtable_writes_, get_post_process_info(mem)); in MergeCF()
1777 if (cfd->mem()->ShouldScheduleFlush() && in CheckMemtableFull()
1778 cfd->mem()->MarkFlushScheduled()) { in CheckMemtableFull()
1799 const MemTable* const mem = cfd->mem(); in CheckMemtableFull() local
1800 assert(mem); in CheckMemtableFull()
1802 if (mem->ApproximateMemoryUsageFast() + in CheckMemtableFull()
1953 MemTablePostProcessInfo* get_post_process_info(MemTable* mem) { in get_post_process_info() argument
1958 return &GetPostMap()[mem]; in get_post_process_info()