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

reducing log level, adding more logs for plugin loading

This commit is contained in:
godmodegalactus 2024-07-12 16:28:57 +02:00
parent fb59cb7aa5
commit e54af6aa9d
No known key found for this signature in database
GPG Key ID: 22DA4A30887FDA3C
4 changed files with 13 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
config.json
View File

@ -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
}
}
}

5
plugin/src/quic_plugin.rs
View File

@ -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(())
}

1
plugin/src/rpc_server.rs
View File

@ -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(())
}

16
server/src/quiche_server_loop.rs
View File

@ -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)
);