Home
last modified time | relevance | path

Searched refs:numConcurrent (Results 1 – 25 of 78) sorted by relevance

1234

/dports/databases/tile38/tile38-1.12.0/vendor/github.com/garyburd/redigo/redisx/
H A Dconnmux_test.go154 const numConcurrent = 10 const
167 wg.Add(numConcurrent)
171 for i := 0; i < numConcurrent; i++ {
189 p := redis.Pool{Dial: redistest.Dial, MaxIdle: numConcurrent}
193 conns := make([]redis.Conn, numConcurrent)
206 wg.Add(numConcurrent)
210 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/databases/redis_exporter/redis_exporter-1.33.0/vendor/github.com/gomodule/redigo/redisx/
H A Dconnmux_test.go156 const numConcurrent = 10 const
169 wg.Add(numConcurrent)
173 for i := 0; i < numConcurrent; i++ {
190 p := redis.Pool{Dial: redisx.DialTest, MaxIdle: numConcurrent}
194 conns := make([]redis.Conn, numConcurrent)
207 wg.Add(numConcurrent)
211 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/gomodule/redigo/redisx/
H A Dconnmux_test.go154 const numConcurrent = 10 const
167 wg.Add(numConcurrent)
171 for i := 0; i < numConcurrent; i++ {
189 p := redis.Pool{Dial: redistest.Dial, MaxIdle: numConcurrent}
193 conns := make([]redis.Conn, numConcurrent)
206 wg.Add(numConcurrent)
210 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/gomodule/redigo/redisx/
H A Dconnmux_test.go154 const numConcurrent = 10 const
167 wg.Add(numConcurrent)
171 for i := 0; i < numConcurrent; i++ {
189 p := redis.Pool{Dial: redistest.Dial, MaxIdle: numConcurrent}
193 conns := make([]redis.Conn, numConcurrent)
206 wg.Add(numConcurrent)
210 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/garyburd/redigo/redisx/
H A Dconnmux_test.go154 const numConcurrent = 10 const
167 wg.Add(numConcurrent)
171 for i := 0; i < numConcurrent; i++ {
189 p := redis.Pool{Dial: redistest.Dial, MaxIdle: numConcurrent}
193 conns := make([]redis.Conn, numConcurrent)
206 wg.Add(numConcurrent)
210 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/sysutils/docker-registry/distribution-2.7.1/vendor/github.com/garyburd/redigo/redigo-535138d7bcd7/redisx/
H A Dconnmux_test.go154 const numConcurrent = 10 const
167 wg.Add(numConcurrent)
171 for i := 0; i < numConcurrent; i++ {
189 p := redis.Pool{Dial: redistest.Dial, MaxIdle: numConcurrent}
193 conns := make([]redis.Conn, numConcurrent)
206 wg.Add(numConcurrent)
210 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/gomodule/redigo/redisx/
H A Dconnmux_test.go153 const numConcurrent = 10 const
166 wg.Add(numConcurrent)
170 for i := 0; i < numConcurrent; i++ {
188 p := redis.Pool{Dial: redisx.DialTest, MaxIdle: numConcurrent}
192 conns := make([]redis.Conn, numConcurrent)
205 wg.Add(numConcurrent)
209 for i := 0; i < numConcurrent; i++ {
233 wg.Add(numConcurrent)
239 for i := 0; i < numConcurrent; i++ {
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/garyburd/redigo/redisx/
H A Dconnmux_test.go154 const numConcurrent = 10 const
167 wg.Add(numConcurrent)
171 for i := 0; i < numConcurrent; i++ {
189 p := redis.Pool{Dial: redistest.Dial, MaxIdle: numConcurrent}
193 conns := make([]redis.Conn, numConcurrent)
206 wg.Add(numConcurrent)
210 for i := 0; i < numConcurrent; i++ {
234 wg.Add(numConcurrent)
240 for i := 0; i < numConcurrent; i++ {
/dports/www/aria2/aria2-1.36.0/src/
H A DDHTTaskExecutor.cc47 DHTTaskExecutor::DHTTaskExecutor(int numConcurrent) in DHTTaskExecutor() argument
48 : numConcurrent_(numConcurrent) in DHTTaskExecutor()
H A DDHTTaskExecutor.h55 DHTTaskExecutor(int numConcurrent);
/dports/devel/mingw32-gcc/gcc-4.8.1/libgo/go/net/
H A Dtcp_test.go33 numConcurrent := runtime.GOMAXPROCS(-1) * 16
36 conns = numConcurrent
91 sem := make(chan bool, numConcurrent)
/dports/lang/gcc6-aux/gcc-6-20180516/libgo/go/net/
H A Dtcp_test.go65 numConcurrent := runtime.GOMAXPROCS(-1) * 2
68 conns = numConcurrent
101 serverSem := make(chan bool, numConcurrent)
128 clientSem := make(chan bool, numConcurrent)
153 for i := 0; i < numConcurrent; i++ {
/dports/lang/gnat_util/gcc-6-20180516/libgo/go/net/
H A Dtcp_test.go65 numConcurrent := runtime.GOMAXPROCS(-1) * 2
68 conns = numConcurrent
101 serverSem := make(chan bool, numConcurrent)
128 clientSem := make(chan bool, numConcurrent)
153 for i := 0; i < numConcurrent; i++ {
/dports/devel/tinygo/tinygo-0.14.1/llvm-project/llgo/third_party/gofrontend/libgo/go/net/
H A Dtcp_test.go65 numConcurrent := runtime.GOMAXPROCS(-1) * 2
68 conns = numConcurrent
101 serverSem := make(chan bool, numConcurrent)
128 clientSem := make(chan bool, numConcurrent)
153 for i := 0; i < numConcurrent; i++ {
/dports/lang/gcc48/gcc-4.8.5/libgo/go/net/
H A Dtcp_test.go62 numConcurrent := runtime.GOMAXPROCS(-1) * 16
65 conns = numConcurrent
120 sem := make(chan bool, numConcurrent)
/dports/net/google-cloud-sdk-app-engine-go/platform/google_appengine/goroot-1.9/src/net/
H A Dtcpsock_test.go67 numConcurrent := runtime.GOMAXPROCS(-1) * 2
70 conns = numConcurrent
103 serverSem := make(chan bool, numConcurrent)
130 clientSem := make(chan bool, numConcurrent)
155 for i := 0; i < numConcurrent; i++ {
/dports/lang/gcc8/gcc-8.5.0/libgo/go/net/
H A Dtcpsock_test.go68 numConcurrent := runtime.GOMAXPROCS(-1) * 2
71 conns = numConcurrent
104 serverSem := make(chan bool, numConcurrent)
131 clientSem := make(chan bool, numConcurrent)
156 for i := 0; i < numConcurrent; i++ {
/dports/lang/gcc10/gcc-10.3.0/libgo/go/net/
H A Dtcpsock_test.go70 numConcurrent := runtime.GOMAXPROCS(-1) * 2
73 conns = numConcurrent
106 serverSem := make(chan bool, numConcurrent)
133 clientSem := make(chan bool, numConcurrent)
158 for i := 0; i < numConcurrent; i++ {
/dports/devel/riscv64-none-elf-gcc/gcc-8.4.0/libgo/go/net/
H A Dtcpsock_test.go68 numConcurrent := runtime.GOMAXPROCS(-1) * 2
71 conns = numConcurrent
104 serverSem := make(chan bool, numConcurrent)
131 clientSem := make(chan bool, numConcurrent)
156 for i := 0; i < numConcurrent; i++ {
/dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/net/
H A Dtcpsock_test.go70 numConcurrent := runtime.GOMAXPROCS(-1) * 2
73 conns = numConcurrent
106 serverSem := make(chan bool, numConcurrent)
133 clientSem := make(chan bool, numConcurrent)
158 for i := 0; i < numConcurrent; i++ {
/dports/devel/arm-none-eabi-gcc/gcc-8.4.0/libgo/go/net/
H A Dtcpsock_test.go68 numConcurrent := runtime.GOMAXPROCS(-1) * 2
71 conns = numConcurrent
104 serverSem := make(chan bool, numConcurrent)
131 clientSem := make(chan bool, numConcurrent)
156 for i := 0; i < numConcurrent; i++ {
/dports/lang/gcc12-devel/gcc-12-20211205/libgo/go/net/
H A Dtcpsock_test.go71 numConcurrent := runtime.GOMAXPROCS(-1) * 2
74 conns = numConcurrent
107 serverSem := make(chan bool, numConcurrent)
134 clientSem := make(chan bool, numConcurrent)
159 for i := 0; i < numConcurrent; i++ {
/dports/lang/gcc11-devel/gcc-11-20211009/libgo/go/net/
H A Dtcpsock_test.go70 numConcurrent := runtime.GOMAXPROCS(-1) * 2
73 conns = numConcurrent
106 serverSem := make(chan bool, numConcurrent)
133 clientSem := make(chan bool, numConcurrent)
158 for i := 0; i < numConcurrent; i++ {
/dports/lang/gcc9-devel/gcc-9-20211007/libgo/go/net/
H A Dtcpsock_test.go70 numConcurrent := runtime.GOMAXPROCS(-1) * 2
73 conns = numConcurrent
106 serverSem := make(chan bool, numConcurrent)
133 clientSem := make(chan bool, numConcurrent)
158 for i := 0; i < numConcurrent; i++ {
/dports/devel/riscv32-unknown-elf-gcc/gcc-8.4.0/libgo/go/net/
H A Dtcpsock_test.go68 numConcurrent := runtime.GOMAXPROCS(-1) * 2
71 conns = numConcurrent
104 serverSem := make(chan bool, numConcurrent)
131 clientSem := make(chan bool, numConcurrent)
156 for i := 0; i < numConcurrent; i++ {

1234