diff options
| author | tv <tv@krebsco.de> | 2026-10-23 18:42:05 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-23 18:42:05 +0200 |
| commit | 8e14a2dce416b682be2a14721a70fa9712519bb7 (patch) | |
| tree | a1a57db36ba5955d0ef25bfb4540e5c0e8397b00 /src/swarm | |
| parent | c32d3ef7bda4353875f28c6ce09f3dce736c4ced (diff) | |
announce epochs by sync instead of ping
Diffstat (limited to 'src/swarm')
| -rw-r--r-- | src/swarm/sync.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index 2c2079a..567b1ea 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -149,6 +149,10 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str, retry_delivery: bool .collect(); peer_state.expect_sync_reply(sent, Instant::now()); } + if message.is_some() { + // It carries our epoch. + peer_state.epoch_unannounced = false; + } (epoch, message) }; let Some(message) = message else { |
