separates out routing shreds from establishing connections

Currently each outgoing shred will attempt to establish a connection if one does not already exist. This is very wasteful and consumes many tokio tasks if the remote node is down or unresponsive. The commit decouples routing packets from establishing connections by adding a buffering channel for each remote address. Outgoing packets are always sent down this channel to be processed once the connection is established. If connecting attempt fails, all packets already pushed to the channel are dropped at once, reducing the number of attempts to make a connection if the remote node is down or unresponsive.
solana-labs · Oct 9, 2023 · c0ffb78 · c0ffb78
1 parent c924719
commit c0ffb78
Show file tree

Hide file tree

Showing 2 changed files with 131 additions and 102 deletions.
diff --git a/turbine/src/cluster_nodes.rs b/turbine/src/cluster_nodes.rs
@@ -423,7 +423,7 @@ impl From<Pubkey> for NodeId {
 
 #[inline]
 pub(crate) fn get_broadcast_protocol(_: &ShredId) -> Protocol {
-    Protocol::UDP
+    Protocol::QUIC
 }
 
 pub fn make_test_cluster<R: Rng>(