From c1ce6904c43d2c67f84cc2df7404bc003795c6ba Mon Sep 17 00:00:00 2001 From: Ekaterina Pavlova Date: Thu, 28 Nov 2024 14:46:43 +0300 Subject: [PATCH] network: discard bFetcherQueue earlier Discard `bFetcherQueue` to avoid persisting new blocks during termination before service Shutdown. Signed-off-by: Ekaterina Pavlova --- pkg/network/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/network/server.go b/pkg/network/server.go index 24aa8614d..2f7a81051 100644 --- a/pkg/network/server.go +++ b/pkg/network/server.go @@ -331,6 +331,7 @@ func (s *Server) Shutdown() { } s.log.Info("shutting down server", zap.Int("peers", s.PeerCount())) if s.ServerConfig.NeoFSBlockFetcherCfg.Enabled { + s.bFetcherQueue.Discard() s.blockFetcher.Shutdown() } for _, tr := range s.transports { @@ -341,7 +342,6 @@ func (s *Server) Shutdown() { } s.bQueue.Discard() s.bSyncQueue.Discard() - s.bFetcherQueue.Discard() s.serviceLock.RLock() for _, svc := range s.services { svc.Shutdown()