Searched refs:closeCh (Results 576 – 593 of 593) sorted by relevance
1...<<21222324
| /dports/sysutils/istio/vault-sdk-v0.1.12/physical/etcd/ |
| H A D | etcd2.go | 429 func (c *Etcd2Lock) watchForKeyRemoval(key string, etcdIndex uint64, closeCh chan struct{}) {
467 close(closeCh)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/vault/physical/etcd/ |
| H A D | etcd2.go | 429 func (c *Etcd2Lock) watchForKeyRemoval(key string, etcdIndex uint64, closeCh chan struct{}) {
467 close(closeCh)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/igm/sockjs-go/v3/sockjs/ |
| H A D | handler.go | 115 <-sess.closeCh
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/moby/buildkit/control/ |
| H A D | control.go | 351 conn, closeCh, opts := grpchijack.Hijack(stream)
356 <-closeCh
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/moby/buildkit/control/ |
| H A D | control.go | 367 conn, closeCh, opts := grpchijack.Hijack(stream)
372 <-closeCh
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/moby/buildkit/control/ |
| H A D | control.go | 367 conn, closeCh, opts := grpchijack.Hijack(stream)
372 <-closeCh
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/moby/buildkit/control/ |
| H A D | control.go | 367 conn, closeCh, opts := grpchijack.Hijack(stream)
372 <-closeCh
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/moby/buildkit/control/ |
| H A D | control.go | 367 conn, closeCh, opts := grpchijack.Hijack(stream)
372 <-closeCh
|
| /dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/grpc/xds/internal/balancer/clusterimpl/ |
| H A D | balancer_test.go | 370 closeCh := make(chan struct{})
383 <-closeCh
413 close(closeCh)
|
| /dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/google.golang.org/grpc/xds/internal/balancer/clusterimpl/ |
| H A D | balancer_test.go | 370 closeCh := make(chan struct{})
383 <-closeCh
413 close(closeCh)
|
| /dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/grpc/xds/internal/balancer/clusterimpl/ |
| H A D | balancer_test.go | 370 closeCh := make(chan struct{})
383 <-closeCh
413 close(closeCh)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/google.golang.org/grpc/xds/internal/balancer/clusterimpl/ |
| H A D | balancer_test.go | 370 closeCh := make(chan struct{})
383 <-closeCh
413 close(closeCh)
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/ |
| H A D | peer.go | 140 closeCh chan struct{} member
332 close(p.closeCh)
375 closeCh: make(chan struct{}),
794 closeCh: make(chan struct{}),
|
| H A D | benchmark.go | 337 case <-h.closeCh:
|
| /dports/audio/pms-devel/pms-c94e3c6/vendor/github.com/blevesearch/bleve/index/scorch/ |
| H A D | introducer.go | 52 case <-s.closeCh:
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/blevesearch/bleve/v2/index/scorch/ |
| H A D | introducer.go | 67 case <-s.closeCh:
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/blevesearch/bleve/index/scorch/ |
| H A D | introducer.go | 55 case <-s.closeCh:
|
| /dports/security/keybase/client-v5.7.1/go/vendor/github.com/blevesearch/bleve/index/scorch/ |
| H A D | introducer.go | 62 case <-s.closeCh:
|
1...<<21222324