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

Merge pull request #263 from awpr/close_header_chan

Browse Source 
Close the header channel if a stream is reset while waiting for headers.
This commit is contained in:
Qi Zhao
2015-07-29 15:52:35 -07:00
parent 7d81e8054f 7555ac5659
commit 94cb75a92e
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
transport/http2_client.go
View File

@ -581,6 +581,10 @@ func (t *http2Client) handleRSTStream(f *http2.RSTStreamFrame) {
return return
} }
s.state = streamDone s.state = streamDone
if !s.headerDone {
close(s.headerChan)
s.headerDone = true
}
s.statusCode, ok = http2RSTErrConvTab[http2.ErrCode(f.ErrCode)] s.statusCode, ok = http2RSTErrConvTab[http2.ErrCode(f.ErrCode)]
if !ok { if !ok {
grpclog.Println("transport: http2Client.handleRSTStream found no mapped gRPC status for the received http2 error ", f.ErrCode) grpclog.Println("transport: http2Client.handleRSTStream found no mapped gRPC status for the received http2 error ", f.ErrCode)