Add error handling in multiple files

evmcore/tx_cacher.go

@@ -20,6 +20,7 @@ import (
 	"runtime"
 
 	"github.com/ethereum/go-ethereum/core/types"
+	"github.com/ethereum/go-ethereum/log"
 )
 
 // senderCacher is a concurrent transaction sender recoverer and cacher.
@@ -62,7 +63,9 @@ func newTxSenderCacher(threads int) *txSenderCacher {
 func (cacher *txSenderCacher) cache() {
 	for task := range cacher.tasks {
 		for i := 0; i < len(task.txs); i += task.inc {
-			types.Sender(task.signer, task.txs[i])
+			if _, err := types.Sender(task.signer, task.txs[i]); err != nil {
+				log.Warn("Failed to recover sender", "err", err)
+			}
 		}
 	}
 }

evmcore/tx_pool.go

@@ -1654,7 +1654,9 @@ func (pool *TxPool) demoteUnexecutables() {
 			log.Trace("Demoting pending transaction", "hash", hash)
 
 			// Internal shuffle shouldn't touch the lookup set.
-			pool.enqueueTx(hash, tx, false, false)
+			if _, err := pool.enqueueTx(hash, tx, false, false); err != nil {
+				log.Warn("Failed to re-enqueue invalidated transaction", "hash", hash, "err", err)
+			}
 		}
 		pool.priced.Removed(len(olds) + len(drops)) // invalid are only moved into queue
 		pendingGauge.Dec(int64(len(olds) + len(drops) + len(invalids)))
@@ -1669,7 +1671,10 @@ func (pool *TxPool) demoteUnexecutables() {
 				log.Error("Demoting invalidated transaction", "hash", hash)
 
 				// Internal shuffle shouldn't touch the lookup set.
-				pool.enqueueTx(hash, tx, false, false)
+				if _, err := pool.enqueueTx(hash, tx, false, false); err != nil {
+					log.Warn("Failed to re-enqueue invalidated transaction", "hash", hash, "err", err)
+				}
+
 			}
 			pendingGauge.Dec(int64(len(gapped)))
 		}

gossip/handler.go

@@ -697,7 +697,10 @@ func (h *handler) handleMsg(p *peer) error {
 	if msg.Size > protocolMaxMsgSize {
 		return errResp(ErrMsgTooLarge, "%v > %v", msg.Size, protocolMaxMsgSize)
 	}
-	defer msg.Discard()
+	defer func() {
+		// dicard is a writte operation into io.Discard, it cannot return an error
+		_ = msg.Discard()
+	}()
 	// Acquire semaphore for serialized messages
 	eventsSizeEst := dag.Metric{
 		Num:  1,
@@ -1153,9 +1156,16 @@ func (h *handler) peerInfoCollectionLoop(stop <-chan struct{}) {
 			for _, peer := range peers {
 				// If we do not have the peer's end-point or it is too old, request it.
 				if info := peer.endPoint.Load(); info == nil || time.Since(info.timestamp) > h.config.Protocol.PeerEndPointUpdatePeriod {
-					peer.SendEndPointUpdateRequest()
+					if err := peer.SendEndPointUpdateRequest(); err != nil {
+						log.Warn("Failed to send end-point update request", "peer", peer.id, "err", err)
+						// If the end-point update request fails, do not send the peer info request.
+						continue
+					}
+				}
+
+				if err := peer.SendPeerInfoRequest(); err != nil {
+					log.Warn("Failed to send peer info request", "peer", peer.id, "err", err)
 				}
-				peer.SendPeerInfoRequest()
 			}
 
 			// Drop a redundant connection if there are too many connections.

utils/file.go

@@ -16,11 +16,11 @@ func OpenFile(path string, isSyncMode bool) *os.File {
 	if isSyncMode {
 		sync = os.O_SYNC
 	}
-	fh, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE|sync, 0666)
+	fileHandle, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE|sync, 0666)
 	if err != nil {
 		log.Crit("Failed to open file", "file", path, "err", err)
 	}
-	return fh
+	return fileHandle
 }
 
 func FileExists(path string) bool {