Lines Matching refs:batch

73   static Status Put(WriteBatch* batch, uint32_t column_family_id,
76 static Status Put(WriteBatch* batch, uint32_t column_family_id,
79 static Status Delete(WriteBatch* batch, uint32_t column_family_id,
82 static Status Delete(WriteBatch* batch, uint32_t column_family_id,
85 static Status SingleDelete(WriteBatch* batch, uint32_t column_family_id,
88 static Status SingleDelete(WriteBatch* batch, uint32_t column_family_id,
98 static Status Merge(WriteBatch* batch, uint32_t column_family_id,
101 static Status Merge(WriteBatch* batch, uint32_t column_family_id,
104 static Status PutBlobIndex(WriteBatch* batch, uint32_t column_family_id,
107 static Status MarkEndPrepare(WriteBatch* batch, const Slice& xid,
111 static Status MarkRollback(WriteBatch* batch, const Slice& xid);
113 static Status MarkCommit(WriteBatch* batch, const Slice& xid);
115 static Status InsertNoop(WriteBatch* batch);
118 static uint32_t Count(const WriteBatch* batch);
121 static void SetCount(WriteBatch* batch, uint32_t n);
124 static SequenceNumber Sequence(const WriteBatch* batch);
128 static void SetSequence(WriteBatch* batch, SequenceNumber seq);
132 static size_t GetFirstOffset(WriteBatch* batch);
134 static Slice Contents(const WriteBatch* batch) { in Contents() argument
135 return Slice(batch->rep_); in Contents()
138 static size_t ByteSize(const WriteBatch* batch) { in ByteSize() argument
139 return batch->rep_.size(); in ByteSize()
142 static Status SetContents(WriteBatch* batch, const Slice& contents);
175 const WriteBatch* batch, ColumnFamilyMemTables* memtables,
214 explicit LocalSavePoint(WriteBatch* batch) in LocalSavePoint() argument
215 : batch_(batch), in LocalSavePoint()
216 savepoint_(batch->GetDataSize(), batch->Count(), in LocalSavePoint()
217 batch->content_flags_.load(std::memory_order_relaxed)) in LocalSavePoint()