Lines Matching refs:batch
375 assert(w->batch != nullptr); in JoinBatchGroup()
410 assert(leader->batch != nullptr); in EnterAsBatchGroupLeader()
413 size_t size = WriteBatchInternal::ByteSize(leader->batch); in EnterAsBatchGroupLeader()
460 if (w->batch == nullptr) { in EnterAsBatchGroupLeader()
471 auto batch_size = WriteBatchInternal::ByteSize(w->batch); in EnterAsBatchGroupLeader()
490 assert(leader->batch != nullptr); in EnterAsMemTableWriter()
493 size_t size = WriteBatchInternal::ByteSize(leader->batch); in EnterAsMemTableWriter()
509 if (!allow_concurrent_memtable_write_ || !leader->batch->HasMerge()) { in EnterAsMemTableWriter()
517 if (w->batch == nullptr) { in EnterAsMemTableWriter()
521 if (w->batch->HasMerge()) { in EnterAsMemTableWriter()
526 auto batch_size = WriteBatchInternal::ByteSize(w->batch); in EnterAsMemTableWriter()
542 last_writer->sequence + WriteBatchInternal::Count(last_writer->batch) - 1; in EnterAsMemTableWriter()
738 assert(w != nullptr && w->batch == nullptr); in EnterUnbatched()