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-07-28 17:00:35 -07:00
parent bdccc897b0
commit 3aeeefd6e7
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
transport/control.go
View File

@ -104,9 +104,13 @@ type quotaPool struct {
// newQuotaPool creates a quotaPool which has quota q available to consume. // newQuotaPool creates a quotaPool which has quota q available to consume.
func newQuotaPool(q int) *quotaPool { func newQuotaPool(q int) *quotaPool {
qb := &quotaPool{c: make(chan int, 1)} qb := &quotaPool{
c: make(chan int, 1),
}
if q > 0 { if q > 0 {
qb.c <- q qb.c <- q
} else {
qb.quota = q
} }
return qb return qb
} }