Home
last modified time | relevance | path

Searched refs:waitCh (Results 126 – 150 of 526) sorted by relevance

12345678910>>...22

/dports/security/vault/vault-1.8.2/vendor/github.com/couchbase/gocbcore/v9/
H A Dtestdocs_test.go24 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 Dgrpclb.go79 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 Dexec_process.go25 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 Dsupervisor.go157 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 Dsupervisor.go151 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 Dsupervisor.go157 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 Dfuture.go11 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 Dfuture.go11 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 Dexec_process.go26 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 Dexec_process.go26 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 Dtrace_test.go79 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 Dcommand.go36 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 Dbootstrap_test.go95 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 Dkiller.go31 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 Dmock_KillWaiter.go13 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 Dbootstrap_test.go95 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 Dbootstrap_test.go97 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 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 Dgo_collector_test.go28 waitCh = make(chan struct{})
55 <-waitCh
77 close(waitCh)
95 waitCh = make(chan struct{})
105 <-waitCh
142 close(waitCh)

12345678910>>...22