@ -161,8 +161,7 @@ Status DBImpl::WriteImpl(const WriteOptions& write_options,
RecordTick ( stats_ , WRITE_WITH_WAL ) ;
}
StopWatch write_sw ( immutable_db_options_ . clock , immutable_db_options_ . stats ,
DB_WRITE ) ;
StopWatch write_sw ( immutable_db_options_ . clock , stats_ , DB_WRITE ) ;
write_thread_ . JoinBatchGroup ( & w ) ;
if ( w . state = = WriteThread : : STATE_PARALLEL_MEMTABLE_WRITER ) {
@ -472,8 +471,7 @@ Status DBImpl::PipelinedWriteImpl(const WriteOptions& write_options,
uint64_t * log_used , uint64_t log_ref ,
bool disable_memtable , uint64_t * seq_used ) {
PERF_TIMER_GUARD ( write_pre_and_post_process_time ) ;
StopWatch write_sw ( immutable_db_options_ . clock , immutable_db_options_ . stats ,
DB_WRITE ) ;
StopWatch write_sw ( immutable_db_options_ . clock , stats_ , DB_WRITE ) ;
WriteContext write_context ;
@ -629,8 +627,7 @@ Status DBImpl::UnorderedWriteMemtable(const WriteOptions& write_options,
SequenceNumber seq ,
const size_t sub_batch_cnt ) {
PERF_TIMER_GUARD ( write_pre_and_post_process_time ) ;
StopWatch write_sw ( immutable_db_options_ . clock , immutable_db_options_ . stats ,
DB_WRITE ) ;
StopWatch write_sw ( immutable_db_options_ . clock , stats_ , DB_WRITE ) ;
WriteThread : : Writer w ( write_options , my_batch , callback , log_ref ,
false /*disable_memtable*/ ) ;
@ -685,8 +682,7 @@ Status DBImpl::WriteImplWALOnly(
WriteThread : : Writer w ( write_options , my_batch , callback , log_ref ,
disable_memtable , sub_batch_cnt , pre_release_callback ) ;
RecordTick ( stats_ , WRITE_WITH_WAL ) ;
StopWatch write_sw ( immutable_db_options_ . clock , immutable_db_options_ . stats ,
DB_WRITE ) ;
StopWatch write_sw ( immutable_db_options_ . clock , stats_ , DB_WRITE ) ;
write_thread - > JoinBatchGroup ( & w ) ;
assert ( w . state ! = WriteThread : : STATE_PARALLEL_MEMTABLE_WRITER ) ;