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

Update test to work according to changes made to maxStreams behavior. (#1137)

Browse Source
This commit is contained in:
MakMukhi
2017-03-22 13:52:10 -07:00
committed by dfawley
parent c5a5dbc500
commit 9d8d0c6e0a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
transport/transport_test.go
View File

@ -626,9 +626,9 @@ func TestMaxStreams(t *testing.T) {
t.Fatalf("Client has not received the max stream setting in 5 seconds.") t.Fatalf("Client has not received the max stream setting in 5 seconds.")
} }
cc.mu.Lock() cc.mu.Lock()
// cc.streamsQuota should be initialized once receiving the 1st setting frame from // cc.maxStreams should be equal to 1 after having received settings frame from
// the server. // server.
if cc.streamsQuota != nil { if cc.maxStreams == 1 {
cc.mu.Unlock() cc.mu.Unlock()
select { select {
case <-cc.streamsQuota.acquire(): case <-cc.streamsQuota.acquire():