opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

testing: fix race caused by successful Accept on a shutdown server (#2321)

Browse Source
This commit is contained in:
lyuxuan
2018-10-04 13:26:25 -07:00
committed by GitHub
parent 30f4150eec
commit 179dc63634
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/channelz_test.go
View File

@ -1526,6 +1526,7 @@ func TestCZSubChannelConnectivityState(t *testing.T) {
defer cleanup() defer cleanup()
r.InitialAddrs([]resolver.Address{{Addr: te.srvAddr}}) r.InitialAddrs([]resolver.Address{{Addr: te.srvAddr}})
te.resolverScheme = r.Scheme() te.resolverScheme = r.Scheme()
te.customDialOptions = []grpc.DialOption{grpc.WithWaitForHandshake()}
cc := te.clientConn() cc := te.clientConn()
defer te.tearDown() defer te.tearDown()
tc := testpb.NewTestServiceClient(cc) tc := testpb.NewTestServiceClient(cc)
@ -1621,6 +1622,7 @@ func TestCZChannelConnectivityState(t *testing.T) {
defer cleanup() defer cleanup()
r.InitialAddrs([]resolver.Address{{Addr: te.srvAddr}}) r.InitialAddrs([]resolver.Address{{Addr: te.srvAddr}})
te.resolverScheme = r.Scheme() te.resolverScheme = r.Scheme()
te.customDialOptions = []grpc.DialOption{grpc.WithWaitForHandshake()}
cc := te.clientConn() cc := te.clientConn()
defer te.tearDown() defer te.tearDown()
tc := testpb.NewTestServiceClient(cc) tc := testpb.NewTestServiceClient(cc)