Lines Matching refs:WriteBatch

84 struct BatchContentClassifier : public WriteBatch::Handler {
141 class TimestampAssigner : public WriteBatch::Handler {
246 WriteBatch::WriteBatch(size_t reserved_bytes, size_t max_bytes) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
254 WriteBatch::WriteBatch(size_t reserved_bytes, size_t max_bytes, size_t ts_sz) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
261 WriteBatch::WriteBatch(const std::string& rep) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
267 WriteBatch::WriteBatch(std::string&& rep) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
273 WriteBatch::WriteBatch(const WriteBatch& src) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
285 WriteBatch::WriteBatch(WriteBatch&& src) noexcept in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
293 WriteBatch& WriteBatch::operator=(const WriteBatch& src) { in operator =()
295 this->~WriteBatch(); in operator =()
296 new (this) WriteBatch(src); in operator =()
301 WriteBatch& WriteBatch::operator=(WriteBatch&& src) { in operator =()
303 this->~WriteBatch(); in operator =()
304 new (this) WriteBatch(std::move(src)); in operator =()
309 WriteBatch::~WriteBatch() { } in ~WriteBatch()
311 WriteBatch::Handler::~Handler() { } in ~Handler()
313 void WriteBatch::Handler::LogData(const Slice& /*blob*/) { in LogData()
318 bool WriteBatch::Handler::Continue() { in Continue()
322 void WriteBatch::Clear() { in Clear()
337 uint32_t WriteBatch::Count() const { return WriteBatchInternal::Count(this); } in Count()
339 uint32_t WriteBatch::ComputeContentFlags() const { in ComputeContentFlags()
355 void WriteBatch::MarkWalTerminationPoint() { in MarkWalTerminationPoint()
361 bool WriteBatch::HasPut() const { in HasPut()
365 bool WriteBatch::HasDelete() const { in HasDelete()
369 bool WriteBatch::HasSingleDelete() const { in HasSingleDelete()
373 bool WriteBatch::HasDeleteRange() const { in HasDeleteRange()
377 bool WriteBatch::HasMerge() const { in HasMerge()
398 bool WriteBatch::HasBeginPrepare() const { in HasBeginPrepare()
402 bool WriteBatch::HasEndPrepare() const { in HasEndPrepare()
406 bool WriteBatch::HasCommit() const { in HasCommit()
410 bool WriteBatch::HasRollback() const { in HasRollback()
514 Status WriteBatch::Iterate(Handler* handler) const { in Iterate()
523 Status WriteBatchInternal::Iterate(const WriteBatch* wb, in Iterate()
524 WriteBatch::Handler* handler, size_t begin, in Iterate()
727 bool WriteBatchInternal::IsLatestPersistentState(const WriteBatch* b) { in IsLatestPersistentState()
731 void WriteBatchInternal::SetAsLastestPersistentState(WriteBatch* b) { in SetAsLastestPersistentState()
735 uint32_t WriteBatchInternal::Count(const WriteBatch* b) { in Count()
739 void WriteBatchInternal::SetCount(WriteBatch* b, uint32_t n) { in SetCount()
743 SequenceNumber WriteBatchInternal::Sequence(const WriteBatch* b) { in Sequence()
747 void WriteBatchInternal::SetSequence(WriteBatch* b, SequenceNumber seq) { in SetSequence()
751 size_t WriteBatchInternal::GetFirstOffset(WriteBatch* /*b*/) { in GetFirstOffset() argument
755 Status WriteBatchInternal::Put(WriteBatch* b, uint32_t column_family_id, in Put()
787 Status WriteBatch::Put(ColumnFamilyHandle* column_family, const Slice& key, in Put()
813 Status WriteBatchInternal::Put(WriteBatch* b, uint32_t column_family_id, in Put()
840 Status WriteBatch::Put(ColumnFamilyHandle* column_family, const SliceParts& key, in Put()
846 Status WriteBatchInternal::InsertNoop(WriteBatch* b) { in InsertNoop()
851 Status WriteBatchInternal::MarkEndPrepare(WriteBatch* b, const Slice& xid, in MarkEndPrepare()
883 Status WriteBatchInternal::MarkCommit(WriteBatch* b, const Slice& xid) { in MarkCommit()
892 Status WriteBatchInternal::MarkRollback(WriteBatch* b, const Slice& xid) { in MarkRollback()
901 Status WriteBatchInternal::Delete(WriteBatch* b, uint32_t column_family_id, in Delete()
918 Status WriteBatch::Delete(ColumnFamilyHandle* column_family, const Slice& key) { in Delete()
923 Status WriteBatchInternal::Delete(WriteBatch* b, uint32_t column_family_id, in Delete()
940 Status WriteBatch::Delete(ColumnFamilyHandle* column_family, in Delete()
946 Status WriteBatchInternal::SingleDelete(WriteBatch* b, in SingleDelete()
964 Status WriteBatch::SingleDelete(ColumnFamilyHandle* column_family, in SingleDelete()
970 Status WriteBatchInternal::SingleDelete(WriteBatch* b, in SingleDelete()
988 Status WriteBatch::SingleDelete(ColumnFamilyHandle* column_family, in SingleDelete()
994 Status WriteBatchInternal::DeleteRange(WriteBatch* b, uint32_t column_family_id, in DeleteRange()
1013 Status WriteBatch::DeleteRange(ColumnFamilyHandle* column_family, in DeleteRange()
1019 Status WriteBatchInternal::DeleteRange(WriteBatch* b, uint32_t column_family_id, in DeleteRange()
1038 Status WriteBatch::DeleteRange(ColumnFamilyHandle* column_family, in DeleteRange()
1045 Status WriteBatchInternal::Merge(WriteBatch* b, uint32_t column_family_id, in Merge()
1070 Status WriteBatch::Merge(ColumnFamilyHandle* column_family, const Slice& key, in Merge()
1076 Status WriteBatchInternal::Merge(WriteBatch* b, uint32_t column_family_id, in Merge()
1100 Status WriteBatch::Merge(ColumnFamilyHandle* column_family, in Merge()
1106 Status WriteBatchInternal::PutBlobIndex(WriteBatch* b, in PutBlobIndex()
1125 Status WriteBatch::PutLogData(const Slice& blob) { in PutLogData()
1132 void WriteBatch::SetSavePoint() { in SetSavePoint()
1141 Status WriteBatch::RollbackToSavePoint() { in RollbackToSavePoint()
1167 Status WriteBatch::PopSavePoint() { in PopSavePoint()
1178 Status WriteBatch::AssignTimestamp(const Slice& ts) { in AssignTimestamp()
1183 Status WriteBatch::AssignTimestamps(const std::vector<Slice>& ts_list) { in AssignTimestamps()
1188 class MemTableInserter : public WriteBatch::Handler {
1212 WriteBatch* rebuilding_trx_;
1829 rebuilding_trx_ = new WriteBatch(); in MarkBeginPrepare()
2028 const WriteBatch* batch, ColumnFamilyMemTables* memtables, in InsertInto()
2049 Status WriteBatchInternal::SetContents(WriteBatch* b, const Slice& contents) { in SetContents()
2056 Status WriteBatchInternal::Append(WriteBatch* dst, const WriteBatch* src, in Append()