| /dports/security/vuls/vuls-0.13.7/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/net/drive/drive-0.4.0/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
98 case <-p.workerCh:
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/security/vuls/vuls-0.13.7/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
98 case <-p.workerCh:
|
| /dports/net/bosh-cli/bosh-cli-5.5.0/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/www/gitea/gitea-1.16.5/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/security/acmetool/acmetool-0.2.1/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
98 case <-p.workerCh:
|
| /dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/sysutils/hcloud/cli-1.21.0/vendor/github.com/cheggaaa/pb/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
100 case <-p.workerCh:
|
| /dports/devel/etcd34/etcd-3.4.18/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
98 case <-p.workerCh:
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/vendor/gopkg.in/cheggaaa/pb.v1/ |
| H A D | pool.go | 36 workerCh chan struct{} member
59 p.workerCh = make(chan struct{})
73 close(p.workerCh)
98 case <-p.workerCh:
|
| /dports/security/keybase/client-v5.7.1/go/kbfs/libkbfs/ |
| H A D | block_retrieval_queue.go | 137 workerCh channels.Channel member
182 workerCh: NewInfiniteChannelWrapper(),
193 config.blockGetter(), q, q.workerCh))
206 func (brq *blockRetrievalQueue) sendWork(workerCh channels.Channel) {
211 case workerCh.In() <- struct{}{}:
290 workerCh := brq.workerCh
292 workerCh = brq.throttledWorkCh
294 workerCh = brq.prefetchWorkerCh
296 brq.sendWork(workerCh)
723 brq.workerCh.Close()
|
| /dports/sysutils/restic/restic-0.12.1/internal/ui/ |
| H A D | backup.go | 42 workerCh chan fileWorkerMessage member
71 workerCh: make(chan fileWorkerMessage),
122 case m := <-b.workerCh:
213 case b.workerCh <- fileWorkerMessage{filename: filename}:
289 case b.workerCh <- fileWorkerMessage{filename: item, done: true}:
302 case b.workerCh <- fileWorkerMessage{filename: item, done: true}:
335 case b.workerCh <- fileWorkerMessage{done: true, filename: item}:
|
| /dports/sysutils/restic/restic-0.12.1/internal/ui/json/ |
| H A D | backup.go | 43 workerCh chan fileWorkerMessage member
74 workerCh: make(chan fileWorkerMessage),
136 case m := <-b.workerCh:
219 case b.workerCh <- fileWorkerMessage{filename: filename}:
242 case b.workerCh <- fileWorkerMessage{filename: item, done: true}:
257 case b.workerCh <- fileWorkerMessage{filename: item, done: true}:
314 case b.workerCh <- fileWorkerMessage{done: true, filename: item}:
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/_examples/custom_engine_tarantool/tntengine/ |
| H A D | broker.go | 600 workerCh := make(chan pubSubMessage, tarantoolPubSubWorkerChannelSize)
601 workers[i] = workerCh
615 }(workerCh)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/ |
| H A D | broker_redis.go | 731 workerCh := make(chan redis.Message, redisPubSubWorkerChannelSize)
732 workers[i] = workerCh
751 }(workerCh)
|