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

more typo

Browse Source
This commit is contained in:
iamqizhao
2016-04-18 10:42:21 -07:00
parent ee96f6b348
commit 25dd388f9a
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
transport/http2_client.go
View File

@ -234,7 +234,7 @@ func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Strea
timeout = dl.Sub(time.Now()) timeout = dl.Sub(time.Now())
} }
select { select {
case ctx.Done(): case <-ctx.Done():
return nil, ContextErr(ctx.Err()) return nil, ContextErr(ctx.Err())
default: default:
} }
@ -519,7 +519,7 @@ func (t *http2Client) Write(s *Stream, data []byte, opts *Options) error {
return err return err
} }
select { select {
case s.ctx.Done(): case <-s.ctx.Done():
t.sendQuotaPool.add(len(p)) t.sendQuotaPool.add(len(p))
if t.framer.adjustNumWriters(-1) == 0 { if t.framer.adjustNumWriters(-1) == 0 {
t.controlBuf.put(&flushIO{}) t.controlBuf.put(&flushIO{})

2
transport/http2_server.go
View File

@ -601,7 +601,7 @@ func (t *http2Server) Write(s *Stream, data []byte, opts *Options) error {
return err return err
} }
select { select {
case s.ctx.Done(): case <-s.ctx.Done():
t.sendQuotaPool.add(ps) t.sendQuotaPool.add(ps)
if t.framer.adjustNumWriters(-1) == 0 { if t.framer.adjustNumWriters(-1) == 0 {
t.controlBuf.put(&flushIO{}) t.controlBuf.put(&flushIO{})