diff --git a/config.json b/config.json index 1636187..c09fa3d 100644 --- a/config.json +++ b/config.json @@ -1,17 +1,11 @@ { - "libpath": "target/debug/libquic_geyser_plugin.so", + "libpath": "target/release/libquic_geyser_plugin.so", "quic_plugin": { "address": "0.0.0.0:10800", "compression_parameters": { "compression_type": { "Lz4Fast": 8 } - }, - "number_of_retries": 100, - "quic_parameters": { - "connection_timeout": 30, - "max_number_of_streams_per_client": 16384, - "recieve_window_size": 1000000 } } } diff --git a/plugin/src/quic_plugin.rs b/plugin/src/quic_plugin.rs index 621709d..d31dee6 100644 --- a/plugin/src/quic_plugin.rs +++ b/plugin/src/quic_plugin.rs @@ -60,6 +60,7 @@ impl GeyserPlugin for QuicGeyserPlugin { } if config.rpc_server.enable { + log::info!("Creating runtime"); let runtime = Runtime::new().map_err(|error| GeyserPluginError::Custom(Box::new(error)))?; let port = config.rpc_server.port; @@ -69,8 +70,10 @@ impl GeyserPlugin for QuicGeyserPlugin { runtime.block_on(async move { let snapshot_creator = SnapshotCreator::new(snapshot_config, compression_params); + log::info!("geyser plugin Start listening"); snapshot_creator.start_listening(server_rx); + log::info!("start serving"); let rpc_server = RpcServerImpl::new(snapshot_creator); if let Err(e) = RpcServerImpl::start_serving(rpc_server, port).await { log::error!("Error starting http server: {e:?}"); @@ -79,7 +82,7 @@ impl GeyserPlugin for QuicGeyserPlugin { self.runtime = Some(runtime); } self.quic_server = Some(quic_server); - + log::info!("geyser plugin loaded ok ()"); Ok(()) } diff --git a/plugin/src/rpc_server.rs b/plugin/src/rpc_server.rs index acf8897..770250d 100644 --- a/plugin/src/rpc_server.rs +++ b/plugin/src/rpc_server.rs @@ -64,7 +64,6 @@ impl RpcServerImpl { log::info!("HTTP Server started at {http_addr:?}"); http_server_handle.stopped().await; log::error!("QUIC GEYSER PLUGIN HTTP SERVER STOPPED"); - panic!("QUIC GEYSER PLUGIN HTTP SERVER STOPPED") }); Ok(()) } diff --git a/server/src/quiche_server_loop.rs b/server/src/quiche_server_loop.rs index 1c2cf26..de40d9b 100644 --- a/server/src/quiche_server_loop.rs +++ b/server/src/quiche_server_loop.rs @@ -350,33 +350,33 @@ fn create_client_task( std::thread::spawn(move || { while !quit.load(std::sync::atomic::Ordering::Relaxed) { std::thread::sleep(Duration::from_secs(1)); - log::info!("---------------------------------"); - log::info!( + log::debug!("---------------------------------"); + log::debug!( "number of loop : {}", number_of_loops.swap(0, std::sync::atomic::Ordering::Relaxed) ); - log::info!( + log::debug!( "number of packets read : {}", number_of_meesages_from_network .swap(0, std::sync::atomic::Ordering::Relaxed) ); - log::info!( + log::debug!( "number of packets write : {}", number_of_meesages_to_network.swap(0, std::sync::atomic::Ordering::Relaxed) ); - log::info!( + log::debug!( "number_of_readable_streams : {}", number_of_readable_streams.swap(0, std::sync::atomic::Ordering::Relaxed) ); - log::info!( + log::debug!( "number_of_writable_streams : {}", number_of_writable_streams.swap(0, std::sync::atomic::Ordering::Relaxed) ); - log::info!( + log::debug!( "messages_added : {}", messages_added.swap(0, std::sync::atomic::Ordering::Relaxed) ); - log::info!( + log::debug!( "messages in queue to be sent : {}", messages_in_queue.load(std::sync::atomic::Ordering::Relaxed) );