File tree Expand file tree Collapse file tree 2 files changed +9
-5
lines changed Expand file tree Collapse file tree 2 files changed +9
-5
lines changed Original file line number Diff line number Diff line change @@ -401,7 +401,7 @@ impl Database {
401
401
let max_frame_no = conn. wal_frame_count ( ) ;
402
402
403
403
let generation = 1 ; // TODO: Probe from WAL.
404
- let start_frame_no = sync_ctx. durable_frame_num + 1 ;
404
+ let start_frame_no = sync_ctx. durable_frame_num ( ) + 1 ;
405
405
let end_frame_no = max_frame_no;
406
406
407
407
let mut frame_no = start_frame_no;
Original file line number Diff line number Diff line change @@ -2,10 +2,10 @@ use crate::Result;
2
2
3
3
const DEFAULT_MAX_RETRIES : usize = 5 ;
4
4
pub struct SyncContext {
5
- pub sync_url : String ,
6
- pub auth_token : Option < String > ,
7
- pub max_retries : usize ,
8
- pub durable_frame_num : u32 ,
5
+ sync_url : String ,
6
+ auth_token : Option < String > ,
7
+ max_retries : usize ,
8
+ durable_frame_num : u32 ,
9
9
}
10
10
11
11
impl SyncContext {
@@ -92,4 +92,8 @@ impl SyncContext {
92
92
nr_retries += 1 ;
93
93
}
94
94
}
95
+
96
+ pub ( crate ) fn durable_frame_num ( & self ) -> u32 {
97
+ self . durable_frame_num
98
+ }
95
99
}
You can’t perform that action at this time.
0 commit comments