This commit is contained in:
iamqizhao 2015-05-27 16:03:26 -07:00
Родитель c3c8cfb2da
Коммит 5f91fa6426
1 изменённых файлов: 2 добавлений и 2 удалений

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

@ -80,7 +80,7 @@ type http2Client struct {
// sendQuotaPool provides flow control to outbound message.
sendQuotaPool *quotaPool
// streamsQuota limits the max number of concurrent streams.
streamsQuota *quotaPool
streamsQuota *quotaPool
// The scheme used: https if TLS is on, http otherwise.
scheme string
@ -251,7 +251,7 @@ func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Strea
}
// Returns the quota balance back.
if q > 1 {
t.streamsQuota.add(q-1)
t.streamsQuota.add(q - 1)
}
}
t.mu.Unlock()