Home
last modified time | relevance | path

Searched refs:mem (Results 1 – 25 of 46) sorted by relevance

12

/rocksdb-6.9/db/
Ddb_memtable_test.cc150 res = mem->Add(seq, kTypeValue, "key", "value2"); in TEST_F()
152 res = mem->Add(seq, kTypeValue, "key", "value2"); in TEST_F()
155 res = mem->Add(seq, kTypeMerge, "key", "value2"); in TEST_F()
161 res = mem->Add(seq, kTypeDeletion, "key", ""); in TEST_F()
179 delete mem; in TEST_F()
188 res = mem->Add(seq, kTypeValue, "key_1", "value"); in TEST_F()
190 res = mem->Add(seq, kTypeValue, "key_1", "value"); in TEST_F()
192 delete mem; in TEST_F()
204 delete mem; in TEST_F()
230 bool res = mem->Add(0, kTypeValue, "key", value); in TEST_F()
[all …]
Dmemtable_list_test.cc237 mem->Ref(); in TEST_F()
271 list.Add(mem, &to_delete); in TEST_F()
354 mem->Ref(); in TEST_F()
377 list.Add(mem, &to_delete); in TEST_F()
546 mem->SetID(memtable_id++); in TEST_F()
547 mem->Ref(); in TEST_F()
558 tables.push_back(mem); in TEST_F()
813 MemTable* mem = in TEST_F() local
816 mem->SetID(memtable_id++); in TEST_F()
817 mem->Ref(); in TEST_F()
[all …]
Dflush_job_test.cc261 mem->SetID(i); in TEST_F()
262 mem->Ref(); in TEST_F()
263 new_mems.emplace_back(mem); in TEST_F()
264 memtable_ids.push_back(mem->GetID()); in TEST_F()
275 for (auto mem : new_mems) { in TEST_F() local
276 cfd->imm()->Add(mem, &to_delete); in TEST_F()
335 MemTable* mem = cfd->ConstructNewMemtable( in TEST_F() local
337 mem->SetID(i); in TEST_F()
338 mem->Ref(); in TEST_F()
343 mem->Add(curr_seqno++, kTypeValue, key, value); in TEST_F()
[all …]
Dwrite_batch.cc1422 MemTable* mem = cf_mems_->GetMemTable(); in PutCFImpl() local
1440 mem->Update(sequence_, key, value); in PutCFImpl()
1474 mem_res = mem->Add( in PutCFImpl()
1511 MemTable* mem = cf_mems_->GetMemTable(); in DeleteImpl() local
1673 MemTable* mem = cf_mems_->GetMemTable(); in MergeCF() local
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()
[all …]
Dmemtable.cc283 prefix_extractor_(mem.prefix_extractor_), in MemTableIterator()
284 comparator_(mem.comparator_), in MemTableIterator()
290 iter_ = mem.range_del_table_->GetIterator(arena); in MemTableIterator()
294 bloom_ = mem.bloom_filter_.get(); in MemTableIterator()
295 iter_ = mem.table_->GetDynamicPrefixIterator(arena); in MemTableIterator()
297 iter_ = mem.table_->GetIterator(arena); in MemTableIterator()
608 MemTable* mem; member
648 s->mem->GetInternalKeyComparator().user_comparator(); in SaveValue()
686 s->mem->GetLock(s->key->user_key())->ReadLock(); in SaveValue()
713 s->mem->GetLock(s->key->user_key())->ReadUnlock(); in SaveValue()
[all …]
Dfile_indexer.cc89 char* mem = arena->AllocateAligned(num_levels_ * sizeof(int32_t)); in UpdateIndex() local
90 level_rb_ = new (mem) int32_t[num_levels_]; in UpdateIndex()
106 mem = arena->AllocateAligned(upper_size * sizeof(IndexUnit)); in UpdateIndex()
107 index_level.index_units = new (mem) IndexUnit[upper_size]; in UpdateIndex()
Darena_wrapped_db_iter.cc42 auto mem = arena_.AllocateAligned(sizeof(DBIter)); in Init() local
43 db_iter_ = new (mem) DBIter(env, read_options, cf_options, mutable_cf_options, in Init()
Dmemtable_list.h357 MemTable* mem = *it; in AssignAtomicFlushSeq() local
358 if (mem->atomic_flush_seqno_ == kMaxSequenceNumber) { in AssignAtomicFlushSeq()
359 mem->atomic_flush_seqno_ = seq; in AssignAtomicFlushSeq()
Drepair.cc401 MemTable* mem = cfd->mem(); in ConvertLogToTable() local
402 if (mem->IsEmpty()) { in ConvertLogToTable()
411 ScopedArenaIterator iter(mem->NewIterator(ro, &arena)); in ConvertLogToTable()
421 mem->NewRangeTombstoneIterator(ro, kMaxSequenceNumber); in ConvertLogToTable()
Dmemtable_list.cc755 MemTable* mem = *it; in RemoveOldMemTables() local
756 if (mem->GetNextLogNumber() > log_number) { in RemoveOldMemTables()
759 old_memtables.push_back(mem); in RemoveOldMemTables()
763 MemTable* mem = *it; in RemoveOldMemTables() local
764 current_->Remove(mem, to_delete); in RemoveOldMemTables()
Dwrite_batch_test.cc33 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in PrintContents() local
35 mem->Ref(); in PrintContents()
37 ColumnFamilyMemTablesDefault cf_mems_default(mem); in PrintContents()
52 iter = mem->NewIterator(ReadOptions(), &arena); in PrintContents()
55 iter = mem->NewRangeTombstoneIterator(ReadOptions(), in PrintContents()
126 delete mem->Unref(); in PrintContents()
Dcolumn_family.cc431 MemTable* m = mem->Unref(); in Cleanup()
447 mem = new_mem; in Init()
451 mem->Ref(); in Init()
696 auto mem_prep_log = mem()->GetMinLogContainingPrepSection(); in OldestLogToKeep()
1080 super_version->mem->NewIterator(read_opts, &arena)); in RangesOverlapWithMemtables()
1087 super_version->mem->NewRangeTombstoneIterator(read_opts, read_seq); in RangesOverlapWithMemtables()
1538 return current_->mem(); in GetMemTable()
Dwrite_batch_internal.h42 explicit ColumnFamilyMemTablesDefault(MemTable* mem) in ColumnFamilyMemTablesDefault() argument
43 : ok_(false), mem_(mem) {} in ColumnFamilyMemTablesDefault()
/rocksdb-6.9/include/rocksdb/
Dwrite_buffer_manager.h65 void ReserveMem(size_t mem) { in ReserveMem() argument
67 ReserveMemWithCache(mem); in ReserveMem()
69 memory_used_.fetch_add(mem, std::memory_order_relaxed); in ReserveMem()
72 memory_active_.fetch_add(mem, std::memory_order_relaxed); in ReserveMem()
77 void ScheduleFreeMem(size_t mem) { in ScheduleFreeMem() argument
79 memory_active_.fetch_sub(mem, std::memory_order_relaxed); in ScheduleFreeMem()
82 void FreeMem(size_t mem) { in FreeMem() argument
84 FreeMemWithCache(mem); in FreeMem()
86 memory_used_.fetch_sub(mem, std::memory_order_relaxed); in FreeMem()
99 void ReserveMemWithCache(size_t mem);
[all …]
/rocksdb-6.9/memtable/
Dwrite_buffer_manager.cc79 void WriteBufferManager::ReserveMemWithCache(size_t mem) { in ReserveMemWithCache() argument
86 size_t new_mem_used = memory_used_.load(std::memory_order_relaxed) + mem; in ReserveMemWithCache()
98 (void)mem; in ReserveMemWithCache()
102 void WriteBufferManager::FreeMemWithCache(size_t mem) { in FreeMemWithCache() argument
108 size_t new_mem_used = memory_used_.load(std::memory_order_relaxed) - mem; in FreeMemWithCache()
127 (void)mem; in FreeMemWithCache()
Dhash_linklist_rep.cc509 char* mem = allocator_->AllocateAligned(sizeof(Pointer) * bucket_size, in HashLinkListRep() local
512 buckets_ = new (mem) Pointer[bucket_size]; in HashLinkListRep()
523 char* mem = allocator_->AllocateAligned(sizeof(Node) + len); in Allocate() local
524 Node* x = new (mem) Node(); in Allocate()
599 auto* mem = allocator_->AllocateAligned(sizeof(BucketHeader)); in Insert() local
600 header = new (mem) BucketHeader(first, 1); in Insert()
634 SkipListBucketHeader* new_skip_list_header = new (mem) in Insert()
781 auto mem = alloc_arena->AllocateAligned(sizeof(FullListIterator)); in GetIterator() local
782 return new (mem) FullListIterator(list, new_arena); in GetIterator()
791 auto mem = alloc_arena->AllocateAligned(sizeof(DynamicIterator)); in GetDynamicPrefixIterator() local
[all …]
Dhash_skiplist_rep.cc243 auto mem = allocator->AllocateAligned( in HashSkipListRep() local
245 buckets_ = new (mem) std::atomic<Bucket*>[bucket_size]; in HashSkipListRep()
318 auto mem = arena->AllocateAligned(sizeof(Iterator)); in GetIterator() local
319 return new (mem) Iterator(list, true, new_arena); in GetIterator()
327 auto mem = arena->AllocateAligned(sizeof(DynamicIterator)); in GetDynamicPrefixIterator() local
328 return new (mem) DynamicIterator(*this); in GetDynamicPrefixIterator()
Dvectorrep.cc270 char* mem = nullptr; in GetIterator() local
272 mem = arena->AllocateAligned(sizeof(Iterator)); in GetIterator()
281 return new (mem) Iterator(this, bucket_, compare_); in GetIterator()
289 return new (mem) Iterator(nullptr, tmp, compare_); in GetIterator()
Dskiplistrep.cc260 void *mem = in GetIterator() local
263 return new (mem) SkipListRep::LookaheadIterator(*this); in GetIterator()
265 void *mem = in GetIterator() local
268 return new (mem) SkipListRep::Iterator(&skip_list_); in GetIterator()
/rocksdb-6.9/java/rocksjni/
Dwrite_batch_test.cc49 ROCKSDB_NAMESPACE::MemTable* mem = new ROCKSDB_NAMESPACE::MemTable( in Java_org_rocksdb_WriteBatchTest_getContents() local
53 mem->Ref(); in Java_org_rocksdb_WriteBatchTest_getContents()
55 ROCKSDB_NAMESPACE::ColumnFamilyMemTablesDefault cf_mems_default(mem); in Java_org_rocksdb_WriteBatchTest_getContents()
62 mem->NewIterator(ROCKSDB_NAMESPACE::ReadOptions(), &arena)); in Java_org_rocksdb_WriteBatchTest_getContents()
134 delete mem->Unref(); in Java_org_rocksdb_WriteBatchTest_getContents()
/rocksdb-6.9/docs/_posts/
D2014-05-14-lock.markdown12 …rstand terms used below, like SST tables or mem tables). SST tables are immutable after being writ…
16 * Increase or decrease reference counters of mem tables and SST tables
19 …k meta data structures, before and after finishing compactions, flushes and new mem table creations
27 … every read operation, mutex was acquired, and reference counters for each mem table and each SST …
29 …mem table and SST tables, so that readers only need to increase the reference counters for this si…
/rocksdb-6.9/table/
Diterator.cc181 auto mem = arena->AllocateAligned(sizeof(EmptyInternalIterator<TValue>)); in NewErrorInternalIterator() local
182 return new (mem) EmptyInternalIterator<TValue>(status); in NewErrorInternalIterator()
202 auto mem = arena->AllocateAligned(sizeof(EmptyInternalIterator<TValue>)); in NewEmptyInternalIterator() local
203 return new (mem) EmptyInternalIterator<TValue>(Status::OK()); in NewEmptyInternalIterator()
Dmerging_iterator.cc420 auto mem = arena->AllocateAligned(sizeof(MergingIterator)); in NewMergingIterator() local
421 return new (mem) MergingIterator(cmp, list, n, true, prefix_seek_mode); in NewMergingIterator()
429 auto mem = arena->AllocateAligned(sizeof(MergingIterator)); in MergeIteratorBuilder() local
431 new (mem) MergingIterator(comparator, nullptr, 0, true, prefix_seek_mode); in MergeIteratorBuilder()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc1340 if (!cfd->mem()->IsEmpty()) { in HandleWriteBufferFull()
1343 uint64_t seq = cfd->mem()->GetCreationSeq(); in HandleWriteBufferFull()
1361 if (cfd->mem()->IsEmpty()) { in HandleWriteBufferFull()
1511 if (cfd_stats != nullptr && !cfd_stats->mem()->IsEmpty()) { in MaybeFlushStatsCF()
1587 if (!cfd->mem()->IsEmpty()) { in ScheduleFlushes()
1673 memtable_info.num_entries = cfd->mem()->num_entries(); in SwitchMemtable()
1674 memtable_info.num_deletes = cfd->mem()->num_deletes(); in SwitchMemtable()
1758 if (loop_cfd->mem()->GetFirstSequenceNumber() == 0 && in SwitchMemtable()
1763 loop_cfd->mem()->SetCreationSeq(versions_->LastSequence()); in SwitchMemtable()
1767 cfd->mem()->SetNextLogNumber(logfile_number_); in SwitchMemtable()
[all …]
Ddb_impl_open.cc967 status = WriteLevel0TableForRecovery(job_id, cfd, cfd->mem(), edit); in RecoverLogFiles()
1064 assert(cfd->mem()->GetFirstSequenceNumber() == 0); in RecoverLogFiles()
1073 if (cfd->mem()->GetFirstSequenceNumber() != 0) { in RecoverLogFiles()
1078 status = WriteLevel0TableForRecovery(job_id, cfd, cfd->mem(), edit); in RecoverLogFiles()
1099 if (flushed || cfd->mem()->GetFirstSequenceNumber() == 0) { in RecoverLogFiles()
1193 MemTable* mem, VersionEdit* edit) { in WriteLevel0TableForRecovery() argument
1207 ScopedArenaIterator iter(mem->NewIterator(ro, &arena)); in WriteLevel0TableForRecovery()
1238 mem->NewRangeTombstoneIterator(ro, kMaxSequenceNumber); in WriteLevel0TableForRecovery()
1536 if (!cfd->mem()->IsSnapshotSupported()) { in Open()
1540 !cfd->mem()->IsMergeOperatorSupported()) { in Open()

12