mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-08 20:11:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Revert most txpool errors to Warn (#1095)

Browse Source 
Less radical variant of PR #1094
This commit is contained in:
Andrew Ashikhmin 2023-09-01 19:03:41 +02:00 committed by GitHub
parent b08f183139
commit 82448e2ede
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
txpool/fetch.go
View File

@ -122,7 +122,7 @@ func (f *Fetch) ConnectCore() {
time.Sleep(3 * time.Second)
continue
}
f.logger.Debug("[txpool.handleStateChanges]", "err", err)
f.logger.Warn("[txpool.handleStateChanges]", "err", err)
}
}
}()
@ -141,7 +141,7 @@ func (f *Fetch) receiveMessageLoop(sentryClient sentry.SentryClient) {
continue
}
// Report error and wait more
f.logger.Debug("[txpool.recvMessage] sentry not ready yet", "err", err)
f.logger.Warn("[txpool.recvMessage] sentry not ready yet", "err", err)
continue
}
@ -150,7 +150,7 @@ func (f *Fetch) receiveMessageLoop(sentryClient sentry.SentryClient) {
time.Sleep(3 * time.Second)
continue
}
f.logger.Debug("[txpool.recvMessage]", "err", err)
f.logger.Warn("[txpool.recvMessage]", "err", err)
}
}
}
@ -192,12 +192,7 @@ func (f *Fetch) receiveMessage(ctx context.Context, sentryClient sentry.SentryCl
time.Sleep(3 * time.Second)
continue
}
if rlp.IsRLPError(err) {
f.logger.Debug("[txpool.fetch] Handling incoming message", "msg", req.Id.String(), "err", err)
} else {
f.logger.Debug("[txpool.fetch] Handling incoming message", "msg", req.Id.String(), "err", err)
}
f.logger.Debug("[txpool.fetch] Handling incoming message", "msg", req.Id.String(), "err", err)
}
if f.wg != nil {
f.wg.Done()
@ -402,7 +397,7 @@ func (f *Fetch) receivePeerLoop(sentryClient sentry.SentryClient) {
continue
}
f.logger.Debug("[txpool.recvPeers]", "err", err)
f.logger.Warn("[txpool.recvPeers]", "err", err)
}
}
}