diff options
| author | tv <tv@krebsco.de> | 2026-11-02 23:07:14 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-02 23:07:14 +0100 |
| commit | 0c096a524531c180798f0712bb7100f0b7557f76 (patch) | |
| tree | 9995d95a835e4daf32dcfc3ae0c83ef5c39e589e /src/api | |
| parent | 22e539d9285626ed217c661e6a5e5d2adb12150c (diff) | |
swarm: relay links messages
Diffstat (limited to 'src/api')
| -rw-r--r-- | src/api/dashboard/mod.rs | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/api/dashboard/mod.rs b/src/api/dashboard/mod.rs index 14321a8..8d954c0 100644 --- a/src/api/dashboard/mod.rs +++ b/src/api/dashboard/mod.rs @@ -302,14 +302,13 @@ impl Graph { let replica = state.doc.read().await; members::members(&replica.doc) }; - for member in members + let members: Vec<String> = members .into_iter() .filter(|member| member != state.local_id()) .take(MAX_ASKED) - { - let state = state.clone(); - tokio::spawn(async move { links::ask(&state, &member, lease).await }); - } + .collect(); + // Those we can't reach, through peers that can (`links::ask_all`). + links::ask_all(state, members, lease).await; } } |
