From 4f2bd217f4b9451ef71653e259c75e1e3afc5f43 Mon Sep 17 00:00:00 2001
From: "alex.sharov" <AskAlexSharov@gmail.com>
Date: Wed, 17 Jul 2024 09:53:37 +0700
Subject: [PATCH] save

---
 erigon-lib/txpool/fetch.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/erigon-lib/txpool/fetch.go b/erigon-lib/txpool/fetch.go
index 4545dd48485..108dfe2f5d9 100644
--- a/erigon-lib/txpool/fetch.go
+++ b/erigon-lib/txpool/fetch.go
@@ -184,12 +184,15 @@ func (f *Fetch) receiveMessage(ctx context.Context, sentryClient sentry.SentryCl
 			}
 			return fmt.Errorf("txpool.receiveMessage: %w", err)
 		}
+		if req == nil {
+			return nil
+		}
 		if err = f.handleInboundMessage(streamCtx, req, sentryClient); err != nil {
 			if grpcutil.IsRetryLater(err) || grpcutil.IsEndOfStream(err) {
 				time.Sleep(3 * time.Second)
 				continue
 			}
-			f.logger.Debug("[txpool.fetch] Handling incoming message", "msg", string(req.Data), "reqID", req.Id.String(), "err", err)
+			f.logger.Debug("[txpool.fetch] Handling incoming message", "reqID", req.Id.String(), "err", err)
 		}
 		if f.wg != nil {
 			f.wg.Done()