diff options
| author | tv <tv@krebsco.de> | 2026-10-24 16:18:58 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-24 16:18:58 +0200 |
| commit | 396927c20677fc458334d7dcbee1c4330f91652c (patch) | |
| tree | 439ccfdd31da3a17c33af55d0a302bacc9036f71 /src/swarm/source.rs | |
| parent | ec15182174e5f6f6e3990d3b0ae0d6149e64fef0 (diff) | |
add chunked download and use it during rejoin
Diffstat (limited to 'src/swarm/source.rs')
| -rw-r--r-- | src/swarm/source.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/swarm/source.rs b/src/swarm/source.rs index 4025f0e..378c40a 100644 --- a/src/swarm/source.rs +++ b/src/swarm/source.rs @@ -199,7 +199,7 @@ pub(crate) fn finished(state: &AppState, from: &str) { } /// After giving up a source: let every peer be considered again. -fn resync_everyone(state: &AppState) { +pub(crate) fn resync_everyone(state: &AppState) { let state = state.clone(); tokio::spawn(async move { let peers: Vec<String> = state.peer_states.read().await.keys().cloned().collect(); |
