Lines Matching refs:write_batch

29       : write_batch(reserved_bytes, max_bytes),  in Rep()
30 comparator(index_comparator, &write_batch), in Rep()
36 ReadableWriteBatch write_batch; member
51 void SetLastEntryOffset() { last_entry_offset = write_batch.GetDataSize(); } in SetLastEntryOffset()
92 WBWIIteratorImpl iter(column_family_id, &skip_list, &write_batch, in UpdateExistingEntryWithCfId()
142 const std::string& wb_data = write_batch.Data(); in AddNewEntry()
160 write_batch.Clear(); in Clear()
179 if (write_batch.Count() == 0) { in ReBuildIndex()
184 size_t offset = WriteBatchInternal::GetFirstOffset(&write_batch); in ReBuildIndex()
186 Slice input(write_batch.Data()); in ReBuildIndex()
197 last_entry_offset = input.data() - write_batch.Data().data(); in ReBuildIndex()
251 if (s.ok() && found != write_batch.Count()) { in ReBuildIndex()
271 WriteBatch* WriteBatchWithIndex::GetWriteBatch() { return &rep->write_batch; } in GetWriteBatch()
276 return new WBWIIteratorImpl(0, &(rep->skip_list), &rep->write_batch, in NewIterator()
283 &(rep->skip_list), &rep->write_batch, in NewIterator()
292 &rep->write_batch, &rep->comparator); in NewIteratorWithBase()
300 auto wbwiii = new WBWIIteratorImpl(0, &(rep->skip_list), &rep->write_batch, in NewIteratorWithBase()
309 auto s = rep->write_batch.Put(column_family, key, value); in Put()
318 auto s = rep->write_batch.Put(key, value); in Put()
328 auto s = rep->write_batch.Delete(column_family, key); in Delete()
337 auto s = rep->write_batch.Delete(key); in Delete()
347 auto s = rep->write_batch.SingleDelete(column_family, key); in SingleDelete()
356 auto s = rep->write_batch.SingleDelete(key); in SingleDelete()
366 auto s = rep->write_batch.Merge(column_family, key, value); in Merge()
375 auto s = rep->write_batch.Merge(key, value); in Merge()
383 return rep->write_batch.PutLogData(blob); in PutLogData()
605 void WriteBatchWithIndex::SetSavePoint() { rep->write_batch.SetSavePoint(); } in SetSavePoint()
608 Status s = rep->write_batch.RollbackToSavePoint(); in RollbackToSavePoint()
620 return rep->write_batch.PopSavePoint(); in PopSavePoint()
624 rep->write_batch.SetMaxBytes(max_bytes); in SetMaxBytes()
628 return rep->write_batch.GetDataSize(); in GetDataSize()