From 9a817eb4b1b996b1b1c66695badfdfb2ff7effb6 Mon Sep 17 00:00:00 2001 From: Fred Carle Date: Thu, 6 Jun 2024 21:16:19 -0400 Subject: [PATCH] fix missing wait group increment --- net/server.go | 1 + 1 file changed, 1 insertion(+) diff --git a/net/server.go b/net/server.go index 7c673c261d..94d791854f 100644 --- a/net/server.go +++ b/net/server.go @@ -247,6 +247,7 @@ func (s *server) PushLog(ctx context.Context, req *pb.PushLogRequest) (*pb.PushL bp.wg.Wait() if s.peer.db.Events().DAGMerges.HasValue() { wg := &sync.WaitGroup{} + wg.Add(1) s.peer.db.Events().DAGMerges.Value().Publish(events.DAGMerge{ Cid: cid, SchemaRoot: string(req.Body.SchemaRoot),