/dports/security/vault/vault-1.8.2/vendor/github.com/couchbase/gocbcore/v9/ |
H A D | testdocs_test.go | 24 waitCh := make(chan error, td.numDocs) 42 waitCh <- err 50 err := <-waitCh 59 waitCh := make(chan error, td.numDocs) 67 waitCh <- err 72 err := <-waitCh
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/google.golang.org/grpc/grpclb/ |
H A D | grpclb.go | 79 waitCh chan struct{} member 330 close(b.waitCh) 331 b.waitCh = nil 380 if b.waitCh == nil { 382 b.waitCh = ch 384 ch = b.waitCh 421 if b.waitCh == nil { 423 b.waitCh = ch 425 ch = b.waitCh 440 if b.waitCh != nil { [all …]
|
/dports/www/eden/eden-0.7.4/vendor/github.com/cloudfoundry/bosh-utils/system/ |
H A D | exec_process.go | 25 waitCh chan Result member 39 if p.waitCh != nil { 44 p.waitCh = make(chan Result, 1) 47 p.waitCh <- p.wait() 50 return p.waitCh
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/supervisor/ |
H A D | supervisor.go | 157 waitCh := make(chan struct{}) 158 go func(cmd *exec.Cmd, waitCh chan struct{}) { 160 close(waitCh) 165 }(cmd, waitCh) 167 monitorChan <- monitorProcess{pid: pid, wait: waitCh} 178 case <-waitCh: 185 <-waitCh
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/supervisor/ |
H A D | supervisor.go | 151 waitCh := make(chan struct{}) 152 go func(cmd *exec.Cmd, waitCh chan struct{}) { 154 close(waitCh) 159 }(cmd, waitCh) 161 monitorChan <- monitorProcess{pid: pid, wait: waitCh} 172 case <-waitCh: 179 <-waitCh
|
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/supervisor/ |
H A D | supervisor.go | 157 waitCh := make(chan struct{}) 158 go func(cmd *exec.Cmd, waitCh chan struct{}) { 160 close(waitCh) 165 }(cmd, waitCh) 167 monitorChan <- monitorProcess{pid: pid, wait: waitCh} 178 case <-waitCh: 185 <-waitCh
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/helper/pluginutils/singleton/ |
H A D | future.go | 11 waitCh chan struct{} member 21 waitCh: make(chan struct{}), 38 <-f.waitCh 53 close(f.waitCh)
|
/dports/sysutils/nomad/nomad-1.1.0/helper/pluginutils/singleton/ |
H A D | future.go | 11 waitCh chan struct{} member 21 waitCh: make(chan struct{}), 38 <-f.waitCh 53 close(f.waitCh)
|
/dports/net/bosh-cli/bosh-cli-5.5.0/vendor/github.com/cloudfoundry/bosh-utils/system/ |
H A D | exec_process.go | 26 waitCh chan Result member 41 if p.waitCh != nil { 46 p.waitCh = make(chan Result, 1) 49 p.waitCh <- p.wait() 52 return p.waitCh
|
/dports/misc/concourse/concourse-6.7.2/vendor/code.cloudfoundry.org/credhub-cli/vendor/github.com/cloudfoundry/bosh-utils/system/ |
H A D | exec_process.go | 26 waitCh chan Result member 41 if p.waitCh != nil { 46 p.waitCh = make(chan Result, 1) 49 p.waitCh <- p.wait() 52 return p.waitCh
|
/dports/sysutils/istio/istio-1.6.7/vendor/contrib.go.opencensus.io/exporter/stackdriver/ |
H A D | trace_test.go | 79 waitCh := make(chan struct{}) 108 close(waitCh) 112 case <-waitCh: 152 waitCh := make(chan struct{}) 155 <-waitCh 161 close(waitCh)
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/executors/custom/command/ |
H A D | command.go | 36 waitCh chan error member 67 waitCh: make(chan error), 83 case err = <-c.waitCh: 88 KillAndWait(c.cmd, c.waitCh) 110 c.waitCh <- err
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/bootstrap/ |
H A D | bootstrap_test.go | 95 func waitWithTimeout(t *testing.T, waitCh <-chan error, timeout time.Duration) error { 99 case waitErr := <-waitCh: 109 waitCh := make(chan error) 110 go func() { waitCh <- b.Wait(2 * time.Second) }() 114 err := waitWithTimeout(t, waitCh, 1*time.Second) 126 waitCh := make(chan error) 127 go func() { waitCh <- b.Wait(2 * time.Second) }() 136 waitErr := waitWithTimeout(t, waitCh, 1*time.Second) 223 waitCh := make(chan error) 224 go func() { waitCh <- b.Wait(gracefulWait) }() [all …]
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/helpers/process/ |
H A D | killer.go | 31 KillAndWait(command Commander, waitCh chan error) error 66 func (kw *osKillWait) KillAndWait(command Commander, waitCh chan error) error { 80 case err := <-waitCh: 86 case err := <-waitCh:
|
H A D | mock_KillWaiter.go | 13 func (_m *MockKillWaiter) KillAndWait(command Commander, waitCh chan error) error { 14 ret := _m.Called(command, waitCh) 18 r0 = rf(command, waitCh)
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/bootstrap/ |
H A D | bootstrap_test.go | 95 func waitWithTimeout(t *testing.T, waitCh <-chan error, timeout time.Duration) error { 99 case waitErr := <-waitCh: 109 waitCh := make(chan error) 110 go func() { waitCh <- b.Wait(2 * time.Second) }() 114 err := waitWithTimeout(t, waitCh, 1*time.Second) 126 waitCh := make(chan error) 127 go func() { waitCh <- b.Wait(2 * time.Second) }() 136 waitErr := waitWithTimeout(t, waitCh, 1*time.Second) 223 waitCh := make(chan error) 224 go func() { waitCh <- b.Wait(gracefulWait) }() [all …]
|
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/bootstrap/ |
H A D | bootstrap_test.go | 97 func waitWithTimeout(t *testing.T, waitCh <-chan error, timeout time.Duration) error { 101 case waitErr := <-waitCh: 114 waitCh := make(chan error) 115 go func() { waitCh <- b.Wait(2 * time.Second) }() 119 err := waitWithTimeout(t, waitCh, 1*time.Second) 134 waitCh := make(chan error) 135 go func() { waitCh <- b.Wait(2 * time.Second) }() 144 waitErr := waitWithTimeout(t, waitCh, 1*time.Second) 240 waitCh := make(chan error) 241 go func() { waitCh <- b.Wait(gracefulWait) }() [all …]
|
/dports/net/inlets/inlets-3.0.2/vendor/github.com/prometheus/client_golang/client_golang-1.4.0/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 55 <-waitCh 77 close(waitCh) 95 waitCh = make(chan struct{}) 105 <-waitCh 142 close(waitCh)
|
/dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/github.com/prometheus/client_golang/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 55 <-waitCh 77 close(waitCh) 95 waitCh = make(chan struct{}) 105 <-waitCh 142 close(waitCh)
|
/dports/net/rclone/rclone-1.57.0/vendor/github.com/prometheus/client_golang/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 55 <-waitCh 77 close(waitCh) 95 waitCh = make(chan struct{}) 105 <-waitCh 142 close(waitCh)
|
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/client_golang/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 50 <-waitCh 72 close(waitCh) 91 waitCh = make(chan struct{}) 101 <-waitCh 138 close(waitCh)
|
/dports/security/vault/vault-1.8.2/vendor/github.com/prometheus/client_golang/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 55 <-waitCh 77 close(waitCh) 95 waitCh = make(chan struct{}) 105 <-waitCh 142 close(waitCh)
|
/dports/databases/redis_exporter/redis_exporter-1.33.0/vendor/github.com/prometheus/client_golang/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 55 <-waitCh 77 close(waitCh) 95 waitCh = make(chan struct{}) 105 <-waitCh 142 close(waitCh)
|
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/prometheus/client_golang/client_golang-0.9.4/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 50 <-waitCh 72 close(waitCh) 91 waitCh = make(chan struct{}) 101 <-waitCh 138 close(waitCh)
|
/dports/dns/prometheus-dnssec-exporter/prometheus-dnssec-exporter-caa7d89/vendor/github.com/prometheus/client_golang/prometheus/ |
H A D | go_collector_test.go | 28 waitCh = make(chan struct{}) 55 <-waitCh 77 close(waitCh) 95 waitCh = make(chan struct{}) 105 <-waitCh 142 close(waitCh)
|