| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_server.go | 67 shutdownChan chan struct{} member
197 shutdownChan: make(chan struct{}),
706 if _, err := wait(s.ctx, nil, nil, t.shutdownChan, t.writableChan); err != nil {
762 if _, err := wait(s.ctx, nil, nil, t.shutdownChan, t.writableChan); err != nil {
837 sq, err := wait(s.ctx, nil, nil, t.shutdownChan, s.sendQuotaPool.acquire())
842 tq, err := wait(s.ctx, nil, nil, t.shutdownChan, t.sendQuotaPool.acquire())
983 case <-t.shutdownChan:
1001 case <-t.shutdownChan:
1054 case <-t.shutdownChan:
1057 case <-t.shutdownChan:
[all …]
|
| H A D | http2_client.go | 63 shutdownChan chan struct{} member
214 shutdownChan: make(chan struct{}),
409 sq, err := wait(ctx, nil, nil, t.shutdownChan, t.streamsQuota.acquire())
417 if _, err := wait(ctx, nil, nil, t.shutdownChan, t.writableChan); err != nil {
627 close(t.shutdownChan)
707 sq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, s.sendQuotaPool.acquire())
1262 case <-t.shutdownChan:
1265 case <-t.shutdownChan:
1292 case <-t.shutdownChan:
1311 case <-t.shutdownChan:
[all …]
|
| /dports/ftp/sftpgo/sftpgo-2.2.0/vendor/github.com/mhale/smtpd/ |
| H A D | smtpd.go | 103 shutdownChan chan struct{} // let the sessions know we are shutting down member
253 if srv.shutdownChan == nil {
254 srv.shutdownChan = make(chan struct{})
257 return srv.shutdownChan
263 if srv.shutdownChan == nil {
264 srv.shutdownChan = make(chan struct{})
268 case <-srv.shutdownChan:
270 close(srv.shutdownChan)
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/docker/distribution/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/devel/etcd/etcd-2.3.8/Godeps/_workspace/src/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/distribution/distribution-2.7.0/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/sysutils/docker-registry/distribution-2.7.1/vendor/google.golang.org/grpc/grpc-go-d3ddb4469d5a/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/sysutils/docker-registry/distribution-2.7.1/vendor/google.golang.org/grpc/ |
| H A D | clientconn.go | 262 shutdownChan chan struct{} member
283 shutdownChan: make(chan struct{}),
514 case <-cc.shutdownChan:
586 if cc.shutdownChan != nil {
587 close(cc.shutdownChan)
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/mattbaird/elastigo/elastigo-2fe47fd29e4b/lib/ |
| H A D | corebulk.go | 71 shutdownChan chan chan struct{} member
133 b.shutdownChan = make(chan chan struct{})
144 ch := <-b.shutdownChan
155 b.shutdownChan <- ch
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/mattbaird/elastigo/lib/ |
| H A D | corebulk.go | 71 shutdownChan chan chan struct{} member
133 b.shutdownChan = make(chan chan struct{})
144 ch := <-b.shutdownChan
155 b.shutdownChan <- ch
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/service/ |
| H A D | collector.go | 86 shutdownChan chan struct{} member
195 close(col.shutdownChan)
219 col.shutdownChan = make(chan struct{})
226 case <-col.shutdownChan:
|
| /dports/databases/tile38/tile38-1.12.0/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_client.go | 63 shutdownChan chan struct{} member
213 shutdownChan: make(chan struct{}),
403 sq, err := wait(ctx, nil, nil, t.shutdownChan, t.streamsQuota.acquire())
411 if _, err := wait(ctx, nil, nil, t.shutdownChan, t.writableChan); err != nil {
631 close(t.shutdownChan)
704 sq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, s.sendQuotaPool.acquire())
1304 case <-t.shutdownChan:
1307 case <-t.shutdownChan:
1334 case <-t.shutdownChan:
1353 case <-t.shutdownChan:
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_client.go | 72 shutdownChan chan struct{} member
184 shutdownChan: make(chan struct{}),
317 sq, err := wait(ctx, nil, nil, t.shutdownChan, t.streamsQuota.acquire())
326 if _, err := wait(ctx, nil, nil, t.shutdownChan, t.writableChan); err != nil {
500 close(t.shutdownChan)
575 sq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, s.sendQuotaPool.acquire())
581 tq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, t.sendQuotaPool.acquire())
615 if _, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, t.writableChan); err != nil {
1026 case <-t.shutdownChan:
1029 case <-t.shutdownChan:
|
| /dports/sysutils/sensu-go/sensu-go-5.11.1/backend/eventd/ |
| H A D | eventd.go | 65 shutdownChan chan struct{} member
101 shutdownChan: make(chan struct{}, 1),
151 case <-e.shutdownChan:
397 close(e.shutdownChan)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/golang/gddo/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_client.go | 59 shutdownChan chan struct{} member
207 shutdownChan: make(chan struct{}),
284 go loopyWriter(t.controlBuf, t.shutdownChan, t.itemHandler)
396 sq, err := wait(ctx, nil, nil, t.shutdownChan, t.streamsQuota.acquire())
604 close(t.shutdownChan)
661 case <-t.shutdownChan:
683 sq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, quotaChan)
688 tq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, t.sendQuotaPool.acquire())
1271 case <-t.shutdownChan:
1290 case <-t.shutdownChan:
[all …]
|
| /dports/www/miniflux/v2-2.0.35/vendor/github.com/golang/gddo/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_client.go | 59 shutdownChan chan struct{} member
207 shutdownChan: make(chan struct{}),
284 go loopyWriter(t.controlBuf, t.shutdownChan, t.itemHandler)
396 sq, err := wait(ctx, nil, nil, t.shutdownChan, t.streamsQuota.acquire())
604 close(t.shutdownChan)
661 case <-t.shutdownChan:
683 sq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, quotaChan)
688 tq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, t.sendQuotaPool.acquire())
1271 case <-t.shutdownChan:
1290 case <-t.shutdownChan:
[all …]
|
| /dports/sysutils/jest/jest-f76bc46/vendor/github.com/golang/gddo/vendor/google.golang.org/grpc/transport/ |
| H A D | http2_client.go | 59 shutdownChan chan struct{} member
207 shutdownChan: make(chan struct{}),
284 go loopyWriter(t.controlBuf, t.shutdownChan, t.itemHandler)
396 sq, err := wait(ctx, nil, nil, t.shutdownChan, t.streamsQuota.acquire())
604 close(t.shutdownChan)
661 case <-t.shutdownChan:
683 sq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, quotaChan)
688 tq, err := wait(s.ctx, s.done, s.goAway, t.shutdownChan, t.sendQuotaPool.acquire())
1271 case <-t.shutdownChan:
1290 case <-t.shutdownChan:
[all …]
|