241   log::Writer* log_writer = logs_.back().writer;  in WriteImpl()
272     for (auto* writer : write_group) {  in WriteImpl()  local
273       if (writer->CheckCallback(this)) {  in WriteImpl()
274         valid_batches += writer->batch_cnt;  in WriteImpl()
275         if (writer->ShouldWriteToMemtable()) {  in WriteImpl()
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()
281         if (writer->pre_release_callback) {  in WriteImpl()
354       for (auto* writer : write_group) {  in WriteImpl()  local
355         if (writer->CallbackFailed()) {  in WriteImpl()
358         writer->sequence = next_sequence;  in WriteImpl()
359         if (writer->pre_release_callback) {  in WriteImpl()
360           Status ws = writer->pre_release_callback->Callback(  in WriteImpl()
361               writer->sequence, disable_memtable, writer->log_used, index++,  in WriteImpl()
369           assert(writer->batch_cnt);  in WriteImpl()
370           next_sequence += writer->batch_cnt;  in WriteImpl()
371         } else if (writer->ShouldWriteToMemtable()) {  in WriteImpl()
372           next_sequence += WriteBatchInternal::Count(writer->batch);  in WriteImpl()
484     log::Writer* log_writer = logs_.back().writer;  in PipelinedWriteImpl()
497       for (auto writer : wal_write_group) {  in PipelinedWriteImpl()  local
498         if (writer->CheckCallback(this)) {  in PipelinedWriteImpl()
499           if (writer->ShouldWriteToMemtable()) {  in PipelinedWriteImpl()
500             writer->sequence = next_sequence;  in PipelinedWriteImpl()
501             size_t count = WriteBatchInternal::Count(writer->batch);  in PipelinedWriteImpl()
506               total_byte_size, WriteBatchInternal::ByteSize(writer->batch));  in PipelinedWriteImpl()
709   for (auto* writer : write_group) {  in WriteImplWALOnly()  local
710     if (writer->CheckCallback(this)) {  in WriteImplWALOnly()
712           total_byte_size, WriteBatchInternal::ByteSize(writer->batch));  in WriteImplWALOnly()
713       if (writer->pre_release_callback) {  in WriteImplWALOnly()
747     for (auto* writer : write_group) {  in WriteImplWALOnly()  local
748       assert(writer->batch_cnt || !seq_per_batch_);  in WriteImplWALOnly()
749       if (!writer->CallbackFailed()) {  in WriteImplWALOnly()
750         total_batch_cnt += writer->batch_cnt;  in WriteImplWALOnly()
766   for (auto* writer : write_group) {  in WriteImplWALOnly()  local
767     if (writer->CallbackFailed()) {  in WriteImplWALOnly()
770     writer->sequence = curr_seq;  in WriteImplWALOnly()
772       assert(writer->batch_cnt || !seq_per_batch_);  in WriteImplWALOnly()
773       curr_seq += writer->batch_cnt;  in WriteImplWALOnly()
775     if (!writer->disable_memtable) {  in WriteImplWALOnly()
801     for (auto* writer : write_group) {  in WriteImplWALOnly()  local
802       if (!writer->CallbackFailed() && writer->pre_release_callback) {  in WriteImplWALOnly()
803         assert(writer->sequence != kMaxSequenceNumber);  in WriteImplWALOnly()
804         Status ws = writer->pre_release_callback->Callback(  in WriteImplWALOnly()
805             writer->sequence, disable_memtable, writer->log_used, index++,  in WriteImplWALOnly()
975     for (auto writer : write_group) {  in MergeBatch()  local
976       if (!writer->CallbackFailed()) {  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()
1039     for (auto writer : write_group) {  in WriteToWAL()  local
1040       writer->log_used = logfile_number_;  in WriteToWAL()
1063       io_s = log.writer->file()->Sync(immutable_db_options_.use_fsync);  in WriteToWAL()
1113     for (auto writer : write_group) {  in ConcurrentWriteToWAL()  local
1114       writer->log_used = logfile_number_;  in ConcurrentWriteToWAL()
1121   log::Writer* log_writer = logs_.back().writer;  in ConcurrentWriteToWAL()
1711       log::Writer* cur_log_writer = logs_.back().writer;  in SwitchMemtable()