fix missing wait group increment

sourcenetwork · Jun 7, 2024 · 9a817eb · 9a817eb
1 parent d2eebb7
commit 9a817eb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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),