adds QUIC endpoint specific for turbine connections

Working towards separating out turbine QUIC from TPU.

Author: behzadnouri

Cargo.lock

@@ -38,7 +38,7 @@ use {
     tokio::{sync::OnceCell, time::timeout},
 };
 
-struct SkipServerVerification;
+pub struct SkipServerVerification;
 
 impl SkipServerVerification {
     pub fn new() -> Arc<Self> {

programs/sbf/Cargo.lock

@@ -190,18 +190,22 @@ fn prune_unstaked_connection_table(
     }
 }
 
-fn get_connection_stake(
-    connection: &Connection,
-    staked_nodes: &RwLock<StakedNodes>,
-) -> Option<(Pubkey, u64, u64, u64, u64)> {
+pub fn get_remote_pubkey(connection: &Connection) -> Option<Pubkey> {
     // Use the client cert only if it is self signed and the chain length is 1.
-    let pubkey = connection
+    connection
         .peer_identity()?
         .downcast::<Vec<rustls::Certificate>>()
         .ok()
         .filter(|certs| certs.len() == 1)?
         .first()
-        .and_then(get_pubkey_from_tls_certificate)?;
+        .and_then(get_pubkey_from_tls_certificate)
+}
+
+fn get_connection_stake(
+    connection: &Connection,
+    staked_nodes: &RwLock<StakedNodes>,
+) -> Option<(Pubkey, u64, u64, u64, u64)> {
+    let pubkey = get_remote_pubkey(connection)?;
     debug!("Peer public key is {pubkey:?}");
     let staked_nodes = staked_nodes.read().unwrap();
     Some((

quic-client/src/nonblocking/quic_client.rs

@@ -28,7 +28,7 @@ use {
 pub const MAX_STAKED_CONNECTIONS: usize = 2000;
 pub const MAX_UNSTAKED_CONNECTIONS: usize = 500;
 
-struct SkipClientVerification;
+pub struct SkipClientVerification;
 
 impl SkipClientVerification {
     pub fn new() -> Arc<Self> {

streamer/src/nonblocking/quic.rs

@@ -11,13 +11,18 @@ edition = { workspace = true }
 
 [dependencies]
 bincode = { workspace = true }
+bytes = { workspace = true }
 crossbeam-channel = { workspace = true }
+futures = { workspace = true }
 itertools = { workspace = true }
 log = { workspace = true }
 lru = { workspace = true }
+quinn = { workspace = true }
 rand = { workspace = true }
 rand_chacha = { workspace = true }
 rayon = { workspace = true }
+rcgen = { workspace = true }
+rustls = { workspace = true }
 solana-client = { workspace = true }
 solana-entry = { workspace = true }
 solana-gossip = { workspace = true }
@@ -34,6 +39,7 @@ solana-runtime = { workspace = true }
 solana-sdk = { workspace = true }
 solana-streamer = { workspace = true }
 thiserror = { workspace = true }
+tokio = { workspace = true }
 
 [dev-dependencies]
 matches = { workspace = true }

streamer/src/quic.rs

@@ -2,6 +2,7 @@
 
 pub mod broadcast_stage;
 pub mod cluster_nodes;
+pub mod quic_endpoint;
 pub mod retransmit_stage;
 pub mod sigverify_shreds;