Skip to content

Commit 4349fa9

Browse files
authored
Create CMX nodes sequentially (#2184)
1 parent 4d1d294 commit 4349fa9

File tree

1 file changed

+6
-21
lines changed

1 file changed

+6
-21
lines changed

e2e/cluster/cmx/cluster.go

Lines changed: 6 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ import (
1414
"time"
1515

1616
"github.com/google/uuid"
17-
"golang.org/x/sync/errgroup"
1817
)
1918

2019
type ClusterInput struct {
@@ -59,27 +58,13 @@ func NewCluster(in *ClusterInput) *Cluster {
5958
}
6059
c.network = network
6160

62-
g := new(errgroup.Group)
63-
var mu sync.Mutex
64-
6561
for i := range c.Nodes {
66-
func(i int) {
67-
g.Go(func() error {
68-
node, err := NewNode(in, i, network.ID)
69-
if err != nil {
70-
return fmt.Errorf("create node %d: %w", i, err)
71-
}
72-
in.T.Logf("node%d created with ID %s", i, node.ID)
73-
mu.Lock()
74-
c.Nodes[i] = *node
75-
mu.Unlock()
76-
return nil
77-
})
78-
}(i)
79-
}
80-
81-
if err := g.Wait(); err != nil {
82-
in.T.Fatalf("failed to create nodes: %v", err)
62+
node, err := NewNode(in, i, network.ID)
63+
if err != nil {
64+
in.T.Fatalf("create node %d: %v", i, err)
65+
}
66+
in.T.Logf("node%d created with ID %s", i, node.ID)
67+
c.Nodes[i] = *node
8368
}
8469

8570
return c

0 commit comments

Comments
 (0)