introduce per-transport sync reply timeout

1 files changed, 8 insertions, 0 deletions

diff --git a/src/transport/tor.rs b/src/transport/tor.rs
index 26dab14..7ecd624 100644
--- a/src/transport/tor.rs
+++ b/src/transport/tor.rs
@@ -76,6 +76,8 @@ const CONNECT_TIMEOUT: Duration = Duration::from_secs(60);
 const HANDSHAKE_TIMEOUT: Duration = Duration::from_secs(30);
 /// How long a message may take, before what its size adds (`stream_timeout`).
 const STREAM_TIMEOUT: Duration = Duration::from_secs(30);
+/// The first wait for an answer to a sync message (`Transport::sync_reply_timeout`).
+const SYNC_REPLY_TIMEOUT: Duration = Duration::from_secs(30);
 /// The slowest a message is expected to go over Tor, in bytes per second.
 const MIN_RATE: u64 = 64 << 10;
 /// Messages read and not handled yet, at most.
@@ -569,6 +571,12 @@ impl Transport for TorTransport {
         stream_timeout(MAX_MESSAGE)
     }
 
+    /// Round trips over Tor take a second or more, and the first message to a peer
+    /// waits for a connection (`CONNECT_TIMEOUT`, `HANDSHAKE_TIMEOUT`).
+    fn sync_reply_timeout(&self) -> Duration {
+        SYNC_REPLY_TIMEOUT
+    }
+
     fn local_addresses(&self) -> Vec<String> {
         vec![self.shared.local_id.clone()]
     }