Searched refs:GetDataSize (Results 1 – 12 of 12) sorted by relevance
34 if (data_offset == GetDataSize()) { in GetEntryFromDataOffset()39 if (data_offset > GetDataSize()) { in GetEntryFromDataOffset()
459 void SetLastEntryOffset() { last_entry_offset = write_batch.GetDataSize(); } in SetLastEntryOffset()1061 size_t WriteBatchWithIndex::GetDataSize() const { in GetDataSize() function in ROCKSDB_NAMESPACE::WriteBatchWithIndex1062 return rep->write_batch.GetDataSize(); in GetDataSize()
253 write_batch_.GetDataSize() > in MaybeFlushWriteBatchToDB()473 size_t curr_boundary = trailing_batch ? wb.GetWriteBatch()->GetDataSize() in FlushWriteBatchWithSavePointToDB()814 unflushed_save_points_->push_back(write_batch_.GetDataSize()); in SetSavePoint()
282 assert(write_batch_.GetDataSize() == WriteBatchInternal::kHeader);
252 size_t GetDataSize() const;
216 savepoint_(batch->GetDataSize(), batch->Count(), in LocalSavePoint()
356 wal_term_point_.size = GetDataSize(); in MarkWalTerminationPoint()1138 GetDataSize(), Count(), content_flags_.load(std::memory_order_relaxed))); in SetSavePoint()
1578 *size = b->rep.GetDataSize(); in rocksdb_writebatch_data()1823 *size = wb->GetDataSize(); in rocksdb_writebatch_wi_data()
5840 if (batch.GetDataSize() > write_size) { in TEST_F()5845 (batch.GetDataSize() / 1024 / 1024)); in TEST_F()
284 size_t GetDataSize() const { return rep_.size(); } in GetDataSize() function
501 auto data_size = wb->GetDataSize(); in Java_org_rocksdb_WriteBatch_getDataSize()
1498 my_batch->GetDataSize(), Env::IO_HIGH, nullptr /* stats */, in ThrottleLowPriWritesIfNeeded()