diff --git a/tests/robustness/multiclient_test/framework/snapshotter.go b/tests/robustness/multiclient_test/framework/snapshotter.go index cabb5ef53..24a4b88bb 100644 --- a/tests/robustness/multiclient_test/framework/snapshotter.go +++ b/tests/robustness/multiclient_test/framework/snapshotter.go @@ -200,7 +200,11 @@ func (mcs *MultiClientSnapshotter) createOrGetSnapshotter(ctx context.Context) ( } // Register client with server and create connection - if err := mcs.server.AuthorizeClient(c.ID); err != nil { + mcs.mu.Lock() + err = mcs.server.AuthorizeClient(c.ID) + mcs.mu.Unlock() + + if err != nil { return nil, err }