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

small fix

Browse Source
This commit is contained in:
iamqizhao
2015-04-03 16:34:18 -07:00
parent c257e93ee2
commit 51bc46aaf8
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
transport/transport_test.go
View File

@ -116,11 +116,12 @@ func (h *testStreamHandler) handleStreamMisbehave(s *Stream) {
size = http2MaxFrameLen size = http2MaxFrameLen
} }
// Drain the client side stream flow control window. // Drain the client side stream flow control window.
var err error
var sent int var sent int
for sent <= initialWindowSize { for sent <= initialWindowSize {
<-conn.writableChan <-conn.writableChan
if err = conn.framer.writeData(true, s.id, false, make([]byte, size)); err != nil { if err := conn.framer.writeData(true, s.id, false, make([]byte, size)); err != nil {
conn.writableChan <- 0
break
} }
conn.writableChan <- 0 conn.writableChan <- 0
sent += size sent += size