aboutsummaryrefslogtreecommitdiffstats
path: root/src/transport
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport')
-rw-r--r--src/transport/libp2p/tests.rs1
-rw-r--r--src/transport/mod.rs8
-rw-r--r--src/transport/mycelium/mod.rs1
-rw-r--r--src/transport/paths.rs1
-rw-r--r--src/transport/sim.rs1
-rw-r--r--src/transport/wire.rs10
6 files changed, 2 insertions, 20 deletions
diff --git a/src/transport/libp2p/tests.rs b/src/transport/libp2p/tests.rs
index 7bedeaa..9f013c2 100644
--- a/src/transport/libp2p/tests.rs
+++ b/src/transport/libp2p/tests.rs
@@ -60,7 +60,6 @@ fn status() -> ParsedMessage {
syncs_with_you: false,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
})
}
diff --git a/src/transport/mod.rs b/src/transport/mod.rs
index 899f4b8..fb198ec 100644
--- a/src/transport/mod.rs
+++ b/src/transport/mod.rs
@@ -206,10 +206,6 @@ pub(crate) struct Status {
/// STATUS answered only if the recipient's heads differ. Most announcements reach a
/// neighbour that has the changes already, which has nothing to tell.
pub(crate) announcing: bool,
- /// The sender wants the recipient's changes as soon as the recipient applies them,
- /// sent as sync messages (an eager link, `swarm::relay`), not only announced. Every
- /// STATUS says so, or not, again: one lost changes nothing for long.
- pub(crate) eager: bool,
/// Whom the sender reaches (`swarm::reach`): the pair keys (`topology::pair_key`)
/// of the members it has an active session with, sorted. In keepalive STATUSes and
/// their replies, and when it changed; not in announcements of heads (None).
@@ -473,10 +469,6 @@ pub(crate) struct Link {
pub(crate) rtt_us: Option<u32>,
/// Silent for long (`peers.md`, dormancy).
pub(crate) dormant: bool,
- /// Eager links (`swarm::relay`): the member sends the peer its changes as it applies
- /// them (the peer asked), and the peer the member (the member asked).
- pub(crate) eager_to: bool,
- pub(crate) eager_from: bool,
/// The peer's other transports (`swarm::links::MAX_OTHERS` at most): where else
/// it proved itself, those paths up.
pub(crate) others: Vec<OtherPath>,
diff --git a/src/transport/mycelium/mod.rs b/src/transport/mycelium/mod.rs
index 76ef8cd..3e33a9f 100644
--- a/src/transport/mycelium/mod.rs
+++ b/src/transport/mycelium/mod.rs
@@ -718,7 +718,6 @@ mod tests {
syncs_with_you: true,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
};
let payload = wire::encode(&ParsedMessage::StatusReply(status.clone())).unwrap();
diff --git a/src/transport/paths.rs b/src/transport/paths.rs
index 3e595ab..6f0a892 100644
--- a/src/transport/paths.rs
+++ b/src/transport/paths.rs
@@ -1514,7 +1514,6 @@ mod tests {
syncs_with_you: false,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
})
}
diff --git a/src/transport/sim.rs b/src/transport/sim.rs
index c9e45fb..906d60a 100644
--- a/src/transport/sim.rs
+++ b/src/transport/sim.rs
@@ -388,7 +388,6 @@ mod tests {
syncs_with_you: false,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
})
}
diff --git a/src/transport/wire.rs b/src/transport/wire.rs
index 8e3baa6..67f6de0 100644
--- a/src/transport/wire.rs
+++ b/src/transport/wire.rs
@@ -14,7 +14,7 @@ use super::{EncodedMessage, MessageKind, ParsedMessage};
/// The wire format's version, the first byte of every payload. Bump it with every change
/// to a message type or a codec (`golden_bytes` fails then).
-pub(crate) const VERSION: u8 = 22;
+pub(crate) const VERSION: u8 = 23;
/// What the second byte of a payload says.
fn tag(kind: MessageKind) -> u8 {
@@ -370,7 +370,6 @@ pub(crate) fn samples() -> Vec<ParsedMessage> {
syncs_with_you: true,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
};
let proof = IdentityProof {
@@ -447,8 +446,6 @@ pub(crate) fn samples() -> Vec<ParsedMessage> {
down: false,
rtt_us: Some(1500),
dormant: false,
- eager_to: true,
- eager_from: false,
others: vec![crate::transport::OtherPath {
transport: "mycelium".into(),
rtt_us: None,
@@ -556,7 +553,6 @@ mod tests {
syncs_with_you: false,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
};
let decoded =
@@ -582,7 +578,6 @@ mod tests {
syncs_with_you: true,
leaving: false,
announcing: false,
- eager: false,
reaches: None,
};
assert!(decode(&encode(&ParsedMessage::Status(status)).unwrap()).is_err());
@@ -682,12 +677,11 @@ mod tests {
syncs_with_you: false,
leaving: false,
announcing: true,
- eager: false,
reaches: None,
});
assert_eq!(
hex(&encode(&status).unwrap()),
- format!("{v}03999290c400{epoch_hex}01c3c2c2c3c2c0")
+ format!("{v}03989290c400{epoch_hex}01c3c2c2c3c0")
);
let who = ParsedMessage::Who(IdentityProof {