diff options
| author | tv <tv@krebsco.de> | 2026-11-01 20:34:59 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 20:34:59 +0100 |
| commit | 7f018573730dc57f9608fe41faa54b44abba841d (patch) | |
| tree | 1c77e9b4756dc92ce1088acb6e8d3e44eee712f9 /src/state/host.rs | |
| parent | 7b8a6c75a13547bc9e541a6a9fcba01b0df06188 (diff) | |
bootstrap: replace pull by progress notify
Diffstat (limited to 'src/state/host.rs')
| -rw-r--r-- | src/state/host.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/state/host.rs b/src/state/host.rs index e7921e4..5751998 100644 --- a/src/state/host.rs +++ b/src/state/host.rs @@ -330,6 +330,7 @@ impl Host for AppState { .expect("rejoin task panicked") }; state.publish_change(); + state.join_progress.notify_one(); if resumed { crate::swarm::peer::announce(&state); } @@ -360,6 +361,7 @@ impl Host for AppState { .expect("rejoin task panicked") }; state.after_epoch_switch().await; + state.join_progress.notify_one(); if resumed { crate::swarm::peer::announce(&state); } |
