tornadocontrib/web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

reconnect -> connect

Browse Source
This commit is contained in:
Bryan Stitt 2022-09-14 03:32:38 +00:00
parent 612f5a48c1
commit 1d4d5844d0
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
web3_proxy/src/rpcs/connection.rs
View File

@ -299,7 +299,7 @@ impl Web3Connection {
) -> anyhow::Result<()> { ) -> anyhow::Result<()> {
// TODO: no-op if this called on a http provider // TODO: no-op if this called on a http provider
// websocket doesn't need the http client // websocket doesn't need the http client
info!(rpc=%self, "reconnecting"); info!(rpc=%self, "connecting");
// since this lock is held open over an await, we use tokio's locking // since this lock is held open over an await, we use tokio's locking
// TODO: timeout on this lock. if its slow, something is wrong // TODO: timeout on this lock. if its slow, something is wrong
@ -319,7 +319,7 @@ impl Web3Connection {
block_sender block_sender
.send_async((None, self.clone())) .send_async((None, self.clone()))
.await .await
.context("block_sender during reconnect clear")?; .context("block_sender during connect")?;
} }
// TODO: if this fails, keep retrying! otherwise it crashes and doesn't try again! // TODO: if this fails, keep retrying! otherwise it crashes and doesn't try again!
@ -327,7 +327,7 @@ impl Web3Connection {
*provider = Some(Arc::new(new_provider)); *provider = Some(Arc::new(new_provider));
info!(rpc=%self, "successfully reconnected"); info!(rpc=%self, "successfully connected");
Ok(()) Ok(())
} }