mirror of https://github.com/grpc/grpc-go.git
xds: fix TestServer_Security_WithValidAndInvalidSecurityConfiguration data race (#8269)
This commit is contained in:
parent
2640dd7b09
commit
82e25c77f2
|
|
@ -84,11 +84,12 @@ type servingModeChangeHandler struct {
|
|||
logger interface {
|
||||
Logf(format string, args ...any)
|
||||
}
|
||||
currentMode connectivity.ServingMode
|
||||
currentErr error
|
||||
// Access to the below fields are guarded by this mutex.
|
||||
mu sync.Mutex
|
||||
modeCh chan connectivity.ServingMode
|
||||
errCh chan error
|
||||
currentMode connectivity.ServingMode
|
||||
currentErr error
|
||||
}
|
||||
|
||||
func newServingModeChangeHandler(t *testing.T) *servingModeChangeHandler {
|
||||
|
|
|
|||
|
|
@ -457,8 +457,8 @@ func (s) TestServer_Security_WithValidAndInvalidSecurityConfiguration(t *testing
|
|||
// it does not enter "serving" mode.
|
||||
select {
|
||||
case <-time.After(2 * defaultTestShortTimeout):
|
||||
case <-modeChangeHandler2.modeCh:
|
||||
if modeChangeHandler2.currentMode == connectivity.ServingModeServing {
|
||||
case mode := <-modeChangeHandler2.modeCh:
|
||||
if mode == connectivity.ServingModeServing {
|
||||
t.Fatal("Server changed to serving mode when not expected to")
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue