File tree Expand file tree Collapse file tree 1 file changed +14
-2
lines changed Expand file tree Collapse file tree 1 file changed +14
-2
lines changed Original file line number Diff line number Diff line change @@ -912,7 +912,7 @@ pub async fn try_pull(
912
912
let frame_no = sync_ctx. durable_frame_num ( ) + 1 ;
913
913
match sync_ctx. pull_frames ( generation, frame_no) . await {
914
914
Ok ( PullResult :: Frames ( frames) ) => {
915
- tracing:: trace !(
915
+ tracing:: debug !(
916
916
"pull_frames: generation={}, start_frame_no={} (batch_size={}), frame_size={}" ,
917
917
generation,
918
918
frame_no,
@@ -928,7 +928,19 @@ pub async fn try_pull(
928
928
return Err ( SyncError :: InvalidPullFrameBytes ( frames. len ( ) ) . into ( ) ) ;
929
929
}
930
930
for chunk in frames. chunks ( FRAME_SIZE ) {
931
- insert_handle. insert ( & chunk) ?;
931
+ tracing:: debug!(
932
+ "inserting frame (frame_no={})" ,
933
+ sync_ctx. durable_frame_num + 1
934
+ ) ;
935
+ let r = insert_handle. insert ( & chunk) ;
936
+ if let Err ( e) = r {
937
+ tracing:: debug!(
938
+ "insert error (frame= {}) : {:?}" ,
939
+ sync_ctx. durable_frame_num + 1 ,
940
+ e
941
+ ) ;
942
+ return Err ( e) ;
943
+ }
932
944
sync_ctx. durable_frame_num += 1 ;
933
945
}
934
946
}
You can’t perform that action at this time.
0 commit comments