File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -471,25 +471,33 @@ impl Database {
471471 let mut frame_no = sync_ctx. durable_frame_num ( ) + 1 ;
472472 let conn = self . connect ( ) ?;
473473 conn. wal_insert_begin ( ) ?;
474+
475+ let mut err = None ;
476+
474477 loop {
475478 match sync_ctx. pull_one_frame ( generation, frame_no) . await {
476479 Ok ( frame) => {
477480 conn. wal_insert_frame ( & frame) ?;
478481 frame_no += 1 ;
479482 }
480483 Err ( e) => {
481- println ! ( "pull_one_frame error: {:?}" , e) ;
484+ tracing:: debug!( "pull_one_frame error: {:?}" , e) ;
485+ err. replace ( e) ;
482486 break ;
483487 }
484488 }
485-
486489 }
487490 conn. wal_insert_end ( ) ?;
488491 sync_ctx. write_metadata ( ) . await ?;
489- Ok ( crate :: database:: Replicated {
490- frame_no : None ,
491- frames_synced : 1 ,
492- } )
492+
493+ if let Some ( err) = err {
494+ Err ( err)
495+ } else {
496+ Ok ( crate :: database:: Replicated {
497+ frame_no : None ,
498+ frames_synced : 1 ,
499+ } )
500+ }
493501 }
494502
495503 pub ( crate ) fn path ( & self ) -> & str {
You can’t perform that action at this time.
0 commit comments