introduce per-transport sync reply timeout

1 files changed, 7 insertions, 1 deletions

diff --git a/src/main.rs b/src/main.rs
index f170434..6c37872 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -188,6 +188,12 @@ async fn main() -> Result<()> {
         .map(|(_, transport)| transport.delivery_limit())
         .max()
         .unwrap_or_default();
+    // An answer may come over any of them.
+    let sync_reply_timeout = transports
+        .iter()
+        .map(|(_, transport)| transport.sync_reply_timeout())
+        .max()
+        .unwrap_or(state::SYNC_REPLY_TIMEOUT);
     let mut transports = transports.into_iter();
     let (scheme, transport) = transports.next().context("No transports")?;
 
@@ -209,7 +215,7 @@ async fn main() -> Result<()> {
         initial_epoch,
         initial_doc,
         earlier_actors,
-        timing: state::Timing::from_keepalive(args.keepalive, delivery_limit)
+        timing: state::Timing::new(args.keepalive, sync_reply_timeout, delivery_limit)
             .with_probe_max(args.dormant_probe_max),
         neighbours_k: args.neighbours,
         alias: args.alias.clone(),