Fix concurrent map writes in integration network shutdown (#2410)

iotaledger · Aug 31, 2022 · a19d286 · a19d286
1 parent c9029d3
commit a19d286
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tools/integration-tests/tester/framework/network.go b/tools/integration-tests/tester/framework/network.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"log"
+	"sync"
 	"time"
 
 	"github.com/cockroachdb/errors"
@@ -219,10 +220,13 @@ func (n *Network) Shutdown(ctx context.Context) error {
 
 	// stop all peers in parallel
 	var eg errgroup.Group
+	var exitStatusMutex sync.Mutex
 	for _, peer := range n.peers {
 		peer := peer // capture range variable
 		eg.Go(func() error {
 			status, err := peer.Shutdown(ctx)
+			exitStatusMutex.Lock()
+			defer exitStatusMutex.Unlock()
 			exitStatus[peer.Name()] = status
 			return err
 		})