Use exponential timeout increase on SYN sends

ethereum · Jun 7, 2023 · 96802e9 · 96802e9
1 parent e044f91
commit 96802e9
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/conn.rs b/src/conn.rs
@@ -638,14 +638,16 @@ impl<const N: usize, P: ConnectionPeer> Connection<N, P> {
                         self.state = State::Closed { err: Some(err) };
                     } else {
                         let seq = *syn;
-                        *attempts += 1;
+                        let new_attempt_count = *attempts + 1;
+                        *attempts = new_attempt_count;
                         let packet = self.syn_packet(seq);
                         let _ = self.socket_events.send(SocketEvent::Outgoing((
                             packet.clone(),
                             self.cid.peer.clone(),
                         )));
+                        let timeout = self.config.initial_timeout * 2u32.pow(new_attempt_count.try_into().unwrap());
                         self.unacked
-                            .insert_at(seq, packet, self.config.initial_timeout);
+                            .insert_at(seq, packet, timeout);
                     }
                 }
                 Endpoint::Acceptor(..) => {}