blockworks-foundation
/
lite-rpc
mirror of https://github.com/blockworks-foundation/lite-rpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

continue on handshake error

This commit is contained in:
GroovieGermanikus 2023-09-02 14:22:36 +02:00
parent 2b6b34add8
commit 0002f0bc60
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
quic-forward-proxy/src/inbound/proxy_listener.rs
View File

@ -6,7 +6,7 @@ use crate::tls_self_signed_pair_generator::SelfSignedTlsConfigProvider;
use crate::util::FALLBACK_TIMEOUT;
use anyhow::{anyhow, bail, Context};
use log::{debug, error, info, trace, warn};
use quinn::{Connection, Endpoint, ServerConfig, VarInt};
use quinn::{Connecting, Endpoint, ServerConfig, VarInt};
use solana_sdk::packet::PACKET_DATA_SIZE;
use std::net::SocketAddr;
use std::sync::Arc;
@ -46,8 +46,7 @@ impl ProxyListener {
while let Some(connecting) = endpoint.accept().await {
let forwarder_channel_copy = forwarder_channel.clone();
tokio::spawn(async move {
let connection = connecting.await.context("handshake").unwrap();
match Self::accept_client_connection(connection, forwarder_channel_copy).await {
match Self::accept_client_connection(connecting, forwarder_channel_copy).await {
Ok(()) => {
debug!("connection handles correctly");
}
@ -88,9 +87,11 @@ impl ProxyListener {
#[tracing::instrument(skip_all, level = "debug")]
async fn accept_client_connection(
client_connection: Connection,
client_conn_handshake: Connecting,
forwarder_channel: Sender<ForwardPacket>,
) -> anyhow::Result<()> {
let client_connection = client_conn_handshake.await.context("handshake")?;
debug!(
"inbound connection established, client {}",
client_connection.remote_address()