/dports/databases/tile38/tile38-1.12.0/vendor/github.com/garyburd/redigo/redisx/ |
H A D | connmux_test.go | 154 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 D | connmux_test.go | 156 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 D | connmux_test.go | 154 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 D | connmux_test.go | 154 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 D | connmux_test.go | 154 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 D | connmux_test.go | 154 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 D | connmux_test.go | 153 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 D | connmux_test.go | 154 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 D | DHTTaskExecutor.cc | 47 DHTTaskExecutor::DHTTaskExecutor(int numConcurrent) in DHTTaskExecutor() argument 48 : numConcurrent_(numConcurrent) in DHTTaskExecutor()
|
H A D | DHTTaskExecutor.h | 55 DHTTaskExecutor(int numConcurrent);
|
/dports/devel/mingw32-gcc/gcc-4.8.1/libgo/go/net/ |
H A D | tcp_test.go | 33 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 D | tcp_test.go | 65 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 D | tcp_test.go | 65 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 D | tcp_test.go | 65 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 D | tcp_test.go | 62 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 D | tcpsock_test.go | 67 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 D | tcpsock_test.go | 68 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 D | tcpsock_test.go | 70 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 D | tcpsock_test.go | 68 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 D | tcpsock_test.go | 70 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 D | tcpsock_test.go | 68 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 D | tcpsock_test.go | 71 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 D | tcpsock_test.go | 70 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 D | tcpsock_test.go | 70 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 D | tcpsock_test.go | 68 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++ {
|