diff options
| author | tv <tv@krebsco.de> | 2026-10-26 05:54:53 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 05:54:53 +0100 |
| commit | 13abdec6dd79529143acefeaf9f8f4ac394c2db5 (patch) | |
| tree | 895419552afd3323636d334a6684d8423361e7ad /src/transport/wire.rs | |
| parent | 355f6db0b15e623a18626ac90c8baed10f23bef5 (diff) | |
number handshakes
This prevents late hellos from resetting the session.
Diffstat (limited to 'src/transport/wire.rs')
| -rw-r--r-- | src/transport/wire.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/transport/wire.rs b/src/transport/wire.rs index 8a8cbb8..e055393 100644 --- a/src/transport/wire.rs +++ b/src/transport/wire.rs @@ -271,6 +271,7 @@ mod tests { auth: vec![1, 2, 3], ready: true, run_id: [4; 16], + handshake: 7, }); let ParsedMessage::Hello(decoded) = decode(&encode(&hello).unwrap()).unwrap() else { panic!("not a HELLO"); @@ -279,6 +280,7 @@ mod tests { assert_eq!((decoded.epoch, decoded.epoch_seq), (epoch, 1)); assert_eq!(decoded.auth, vec![1, 2, 3]); assert_eq!(decoded.run_id, [4; 16]); + assert_eq!(decoded.handshake, 7); let reply = ParsedMessage::HelloReply(HelloReply { swarm_id: "swarm".into(), |
