Skip to content

Commit c07dd2f

Browse files
authored
[storage/qmdb] Coordinate state sync finalization (#3439)
1 parent 921c288 commit c07dd2f

7 files changed

Lines changed: 553 additions & 44 deletions

File tree

examples/sync/src/bin/client.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,8 @@ where
150150
apply_batch_size: 1024,
151151
max_outstanding_requests: config.max_outstanding_requests,
152152
update_rx: Some(update_receiver),
153+
finish_rx: None,
154+
reached_target_tx: None,
153155
max_retained_roots: 8,
154156
};
155157

@@ -214,6 +216,8 @@ where
214216
apply_batch_size: 1024,
215217
max_outstanding_requests: config.max_outstanding_requests,
216218
update_rx: Some(update_receiver),
219+
finish_rx: None,
220+
reached_target_tx: None,
217221
max_retained_roots: 8,
218222
};
219223

@@ -275,6 +279,8 @@ where
275279
apply_batch_size: 1024,
276280
max_outstanding_requests: config.max_outstanding_requests,
277281
update_rx: Some(update_receiver),
282+
finish_rx: None,
283+
reached_target_tx: None,
278284
max_retained_roots: 8,
279285
};
280286

storage/fuzz/fuzz_targets/qmdb_any_fixed_sync.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,8 @@ async fn test_sync<
130130
let sync_config: sync::engine::Config<FixedDb, R> = sync::engine::Config {
131131
context: context.with_label("sync").with_attribute("id", sync_id),
132132
update_rx: None,
133+
finish_rx: None,
134+
reached_target_tx: None,
133135
db_config,
134136
fetch_batch_size: NZU64!((fetch_batch_size % 100) + 1),
135137
target,

0 commit comments

Comments
 (0)