[xds_client_lock] xds/client: hold authority mutex before making a ne…

…w authority
grpc · Apr 29, 2022 · a428cd3 · a428cd3
1 parent dc86d5d
commit a428cd3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/xds/internal/xdsclient/loadreport.go b/xds/internal/xdsclient/loadreport.go
@@ -28,7 +28,9 @@ import (
 // It returns a Store for the user to report loads, a function to cancel the
 // load reporting stream.
 func (c *clientImpl) ReportLoad(server *bootstrap.ServerConfig) (*load.Store, func()) {
+	c.authorityMu.Lock()
 	a, err := c.newAuthority(server)
+	c.authorityMu.Unlock()
 	if err != nil {
 		c.logger.Infof("xds: failed to connect to the control plane to do load reporting for authority %q: %v", server, err)
 		return nil, func() {}