This commit is contained in:
iamqizhao 2016-09-27 17:09:57 -07:00
Родитель b531d0156b
Коммит b9111902e2
1 изменённых файлов: 1 добавлений и 2 удалений

Просмотреть файл

@ -373,8 +373,7 @@ func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Strea
if callHdr.SendCompress != "" {
t.hEnc.WriteField(hpack.HeaderField{Name: "grpc-encoding", Value: callHdr.SendCompress})
}
dl, ok := ctx.Deadline()
if ok {
if dl, ok := ctx.Deadline(); ok {
// Send out timeout regardless its value. The server can detect timeout context by itself.
timeout := dl.Sub(time.Now())
t.hEnc.WriteField(hpack.HeaderField{Name: "grpc-timeout", Value: encodeTimeout(timeout)})