diff options
| author | tv <tv@krebsco.de> | 2026-10-31 06:50:07 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 06:50:07 +0100 |
| commit | 32c788b4d6245abebafb250b005a211fcbeac32c (patch) | |
| tree | 01a5bdb8d92cfd3dc6e7e52ad44021873d905a71 /src/transport/identity.rs | |
| parent | cd848f2a502a0b06e0a420d5575adbf68ded9ab1 (diff) | |
pong carries time
Diffstat (limited to 'src/transport/identity.rs')
| -rw-r--r-- | src/transport/identity.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/transport/identity.rs b/src/transport/identity.rs index 7ce8832..eb7bb93 100644 --- a/src/transport/identity.rs +++ b/src/transport/identity.rs @@ -244,12 +244,14 @@ impl Book { impl IdentityTransport { /// Over `transport`, whose addresses have `config.scheme`, and `config.more`. - /// `firewall`: the debug firewall, if any, which paths applies by address. + /// `firewall`: the debug firewall, if any, which paths applies by address; `clock`: + /// the node's wall clock (`Paths::new`). pub(crate) fn new( transport: Arc<dyn Transport>, config: IdentityConfig, traffic: Arc<Traffic>, firewall: Option<Arc<Firewall>>, + clock: Arc<crate::clock::Clock>, ) -> Self { let node_id = config.key.id(); let shared = Arc::new_cyclic(|shared: &std::sync::Weak<Shared>| { @@ -261,6 +263,7 @@ impl IdentityTransport { .collect(), Some(Arc::clone(&traffic)), firewall.is_some().then_some(gate), + clock, )), firewall, key: config.key, |
