@ -1155,9 +1155,6 @@ Status DBImpl::WriteLevel0TableForRecovery(int job_id, ColumnFamilyData* cfd,
cfd - > ioptions ( ) - > compression_opts , paranoid_file_checks , Env : : IO_HIGH ,
cfd - > ioptions ( ) - > compression_opts , paranoid_file_checks , Env : : IO_HIGH ,
& table_properties ) ;
& table_properties ) ;
LogFlush ( db_options_ . info_log ) ;
LogFlush ( db_options_ . info_log ) ;
mutex_ . Lock ( ) ;
}
}
Log ( InfoLogLevel : : DEBUG_LEVEL , db_options_ . info_log ,
Log ( InfoLogLevel : : DEBUG_LEVEL , db_options_ . info_log ,
" [%s] [WriteLevel0TableForRecovery] "
" [%s] [WriteLevel0TableForRecovery] "
" Level-0 table #% " PRIu64 " : % " PRIu64 " bytes %s " ,
" Level-0 table #% " PRIu64 " : % " PRIu64 " bytes %s " ,
@ -1170,7 +1167,9 @@ Status DBImpl::WriteLevel0TableForRecovery(int job_id, ColumnFamilyData* cfd,
& event_logger_ , job_id , meta . fd . GetNumber ( ) , meta . fd . GetFileSize ( ) ,
& event_logger_ , job_id , meta . fd . GetNumber ( ) , meta . fd . GetFileSize ( ) ,
table_properties ) ;
table_properties ) ;
}
}
mutex_ . Lock ( ) ;
}
}
ReleaseFileNumberFromPendingOutputs ( pending_outputs_inserted_elem ) ;
ReleaseFileNumberFromPendingOutputs ( pending_outputs_inserted_elem ) ;
// Note that if file_size is zero, the file has been deleted and
// Note that if file_size is zero, the file has been deleted and