Lines Matching refs:WriteBatch
51 Status DBImpl::Write(const WriteOptions& write_options, WriteBatch* my_batch) { in Write()
57 WriteBatch* my_batch, in WriteWithCallback()
67 WriteBatch* my_batch, WriteCallback* callback, in WriteImpl()
461 WriteBatch* my_batch, WriteCallback* callback, in PipelinedWriteImpl()
600 WriteBatch* my_batch, in UnorderedWriteMemtable()
653 WriteBatch* my_batch, WriteCallback* callback, uint64_t* log_used, in WriteImplWALOnly()
950 WriteBatch* DBImpl::MergeBatch(const WriteThread::WriteGroup& write_group, in MergeBatch()
951 WriteBatch* tmp_batch, size_t* write_with_wal, in MergeBatch()
952 WriteBatch** to_be_cached_state) { in MergeBatch()
956 WriteBatch* merged_batch = nullptr; in MergeBatch()
992 IOStatus DBImpl::WriteToWAL(const WriteBatch& merged_batch, in WriteToWAL()
1033 WriteBatch* to_be_cached_state = nullptr; in WriteToWAL()
1034 WriteBatch* merged_batch = MergeBatch(write_group, &tmp_batch_, in WriteToWAL()
1101 WriteBatch tmp_batch; in ConcurrentWriteToWAL()
1103 WriteBatch* to_be_cached_state = nullptr; in ConcurrentWriteToWAL()
1104 WriteBatch* merged_batch = in ConcurrentWriteToWAL()
1476 WriteBatch* my_batch) { in ThrottleLowPriWritesIfNeeded()
1813 WriteBatch batch(key.size() + value.size() + 24); in Put()
1823 WriteBatch batch(key.size() + ts_sz + value.size() + 24, /*max_bytes=*/0, in Put()
1838 WriteBatch batch; in Delete()
1845 WriteBatch batch; in SingleDelete()
1853 WriteBatch batch; in DeleteRange()
1860 WriteBatch batch; in Merge()