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:27:08 -07:00
parent 62db7e596e
commit c257e93ee2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
transport/transport_test.go
View File

@ -115,7 +115,7 @@ func (h *testStreamHandler) handleStreamMisbehave(s *Stream) {
if s.Method() == "foo.MaxFrame" { if s.Method() == "foo.MaxFrame" {
size = http2MaxFrameLen size = http2MaxFrameLen
} }
// Drain the client flow control window. // Drain the client side stream flow control window.
var err error var err error
var sent int var sent int
for sent <= initialWindowSize { for sent <= initialWindowSize {
@ -123,7 +123,7 @@ func (h *testStreamHandler) handleStreamMisbehave(s *Stream) {
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 conn.writableChan <- 0
sent += 1 sent += size
} }
} }