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

fix stream message attempt counter

This commit is contained in:
GroovieGermanikus 2024-03-11 17:56:16 +01:00
parent 37ed49c210
commit 813931f210
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/grpc_subscription_autoreconnect_streams.rs
View File

@ -66,7 +66,7 @@ pub fn create_geyser_reconnecting_stream(
}
});
(ConnectionState::Connecting(attempt + 1, connection_task), Message::Connecting(attempt + 1))
(ConnectionState::Connecting(attempt + 1, connection_task), Message::Connecting(attempt))
}
ConnectionState::Connecting(attempt, connection_task) => {
@ -77,7 +77,7 @@ pub fn create_geyser_reconnecting_stream(
Ok(Err(geyser_error)) => {
// ATM we consider all errors recoverable
warn!("subscribe failed on {} - retrying: {:?}", grpc_source, geyser_error);
(ConnectionState::WaitReconnect(attempt + 1), Message::Connecting(attempt + 1))
(ConnectionState::WaitReconnect(attempt + 1), Message::Connecting(attempt))
},
Err(geyser_grpc_task_error) => {
panic!("task aborted - should not happen :{geyser_grpc_task_error}");