diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2026-02-23 12:48:26 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2026-02-23 12:48:26 +0000 |
| commit | f62ef12fb84e2210f9a0a67a5e1e574a8ee66c16 (patch) | |
| tree | ea457689e8507ae01cbf99fa4c210763f836c7ac /tests/sync/maintainer_reprocessing.rs | |
| parent | 49401286ea7413f834197e6a5b221649e10e2ad8 (diff) | |
refactor: replace inline purgatory sync registration with timer-only approach
Remove the redundant inline kind-30617 registration block from the sync
event loop and the three is_generic/recompute_new_sync_filters_for_relay
calls from confirm_batch error paths. The purgatory announcement sync
timer (run_purgatory_announcement_sync) is now the sole registration path.
Consolidate NGIT_SYNC_BATCH_WINDOW_MS and NGIT_PURGATORY_SYNC_INTERVAL_MS
into a single NGIT_TEST=1 flag that sets both timers to 200ms, replacing
two ad-hoc env vars with one reusable test-mode flag.
Diffstat (limited to 'tests/sync/maintainer_reprocessing.rs')
| -rw-r--r-- | tests/sync/maintainer_reprocessing.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/tests/sync/maintainer_reprocessing.rs b/tests/sync/maintainer_reprocessing.rs index 61d8e14..ff1eb43 100644 --- a/tests/sync/maintainer_reprocessing.rs +++ b/tests/sync/maintainer_reprocessing.rs | |||
| @@ -377,7 +377,7 @@ async fn test_multiple_maintainers_all_reprocessed() { | |||
| 377 | println!("relay_b started at {}", relay_b.url()); | 377 | println!("relay_b started at {}", relay_b.url()); |
| 378 | 378 | ||
| 379 | // Give relay_b's SyncManager time to complete the initial negentropy sync with relay_a. | 379 | // Give relay_b's SyncManager time to complete the initial negentropy sync with relay_a. |
| 380 | // The negentropy sync completes within ~200ms (NGIT_SYNC_BATCH_WINDOW_MS=200), but we | 380 | // The negentropy sync completes within ~200ms (NGIT_TEST=1 sets batch window to 200ms), but we |
| 381 | // allow extra time for slow CI environments. | 381 | // allow extra time for slow CI environments. |
| 382 | tokio::time::sleep(Duration::from_secs(3)).await; | 382 | tokio::time::sleep(Duration::from_secs(3)).await; |
| 383 | println!("✓ relay_b synced from relay_a (maintainer announcements should be in hot cache)"); | 383 | println!("✓ relay_b synced from relay_a (maintainer announcements should be in hot cache)"); |