Lines Matching refs:batch

276           total_count += WriteBatchInternal::Count(writer->batch);  in WriteImpl()
277 parallel = parallel && !writer->batch->HasMerge(); in WriteImpl()
280 total_byte_size, WriteBatchInternal::ByteSize(writer->batch)); in WriteImpl()
372 next_sequence += WriteBatchInternal::Count(writer->batch); in WriteImpl()
501 size_t count = WriteBatchInternal::Count(writer->batch); in PipelinedWriteImpl()
506 total_byte_size, WriteBatchInternal::ByteSize(writer->batch)); in PipelinedWriteImpl()
712 total_byte_size, WriteBatchInternal::ByteSize(writer->batch)); in WriteImplWALOnly()
961 leader->batch->GetWalTerminationPoint().is_cleared()) { in MergeBatch()
965 merged_batch = leader->batch; in MergeBatch()
977 WriteBatchInternal::Append(merged_batch, writer->batch, in MergeBatch()
979 if (WriteBatchInternal::IsLatestPersistentState(writer->batch)) { in MergeBatch()
981 *to_be_cached_state = writer->batch; in MergeBatch()
1036 if (merged_batch == write_group.leader->batch) { in WriteToWAL()
1110 if (merged_batch == write_group.leader->batch) { in ConcurrentWriteToWAL()
1813 WriteBatch batch(key.size() + value.size() + 24); in Put() local
1814 Status s = batch.Put(column_family, key, value); in Put()
1818 return Write(opt, &batch); in Put()
1823 WriteBatch batch(key.size() + ts_sz + value.size() + 24, /*max_bytes=*/0, in Put() local
1825 Status s = batch.Put(column_family, key, value); in Put()
1829 s = batch.AssignTimestamp(*ts); in Put()
1833 return Write(opt, &batch); in Put()
1838 WriteBatch batch; in Delete() local
1839 batch.Delete(column_family, key); in Delete()
1840 return Write(opt, &batch); in Delete()
1845 WriteBatch batch; in SingleDelete() local
1846 batch.SingleDelete(column_family, key); in SingleDelete()
1847 return Write(opt, &batch); in SingleDelete()
1853 WriteBatch batch; in DeleteRange() local
1854 batch.DeleteRange(column_family, begin_key, end_key); in DeleteRange()
1855 return Write(opt, &batch); in DeleteRange()
1860 WriteBatch batch; in Merge() local
1861 Status s = batch.Merge(column_family, key, value); in Merge()
1865 return Write(opt, &batch); in Merge()