diff options
| author | tv <tv@krebsco.de> | 2026-11-01 19:57:54 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 19:57:54 +0100 |
| commit | 15a44cb7c8f08d2ddfe9fdf3812f4c9fd5f0aef8 (patch) | |
| tree | ed2449d6e8426676b8820740360b68a915e2e92a /src/simtest/mod.rs | |
| parent | 9ce725c5a2ded3f9b585568003c9e75c5934158a (diff) | |
add restart tests
Diffstat (limited to 'src/simtest/mod.rs')
| -rw-r--r-- | src/simtest/mod.rs | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/src/simtest/mod.rs b/src/simtest/mod.rs index 81bddb5..61c81d1 100644 --- a/src/simtest/mod.rs +++ b/src/simtest/mod.rs @@ -144,6 +144,30 @@ impl Sim { } } +impl Sim { + /// Restarts node `id`: its process is gone, as if it crashed (`SimNet::restart`: + /// what it still sends is lost), and a new one starts on the same ID, as + /// [`start_with`](Self::start_with) starts one. Nothing carries over but what + /// `adjust` gives it (its node key, under the identity layer, by its name). + pub(crate) fn restart_with( + &self, + id: &str, + seeds: &[&str], + start: Start, + adjust: impl FnOnce(&mut NodeConfig), + ) -> AppState { + { + let mut nodes = self.nodes.lock().unwrap(); + for (_, old) in nodes.iter().filter(|(name, _)| name == id) { + old.closing.send_replace(true); + } + nodes.retain(|(name, _)| name != id); + } + self.net.restart(id); + self.start_with(id, seeds, start, adjust) + } +} + /// Logs to the test output if `RUST_LOG` is set. fn init_logging() { if std::env::var_os("RUST_LOG").is_some() { |
