From 06484b8145531337a9192f29d249a30a9a77c0af Mon Sep 17 00:00:00 2001 From: simlecode <69969590+simlecode@users.noreply.github.com> Date: Tue, 25 Oct 2022 18:09:17 +0800 Subject: [PATCH] fix: fix memory leak --- service/events.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/service/events.go b/service/events.go index 4b8e9c44..8339b941 100644 --- a/service/events.go +++ b/service/events.go @@ -16,6 +16,9 @@ type NodeEvents struct { } func (nd *NodeEvents) listenHeadChangesOnce(ctx context.Context) error { + ctx, cancel := context.WithCancel(ctx) + defer cancel() + notifs, err := nd.client.ChainNotify(ctx) if err != nil { return err @@ -48,7 +51,7 @@ func (nd *NodeEvents) listenHeadChangesOnce(ctx context.Context) error { } if err := nd.msgService.ProcessNewHead(ctx, apply); err != nil { - return fmt.Errorf("process new head error: %v", err) + nd.log.Errorf("process new head error: %v", err) } } return nil