| /dports/net/traefik/traefik-2.6.1/vendor/github.com/hashicorp/serf/serf/ |
| H A D | snapshot.go | 79 waitCh chan struct{} member
142 waitCh: make(chan struct{}),
190 <-s.waitCh
315 close(s.waitCh)
|
| /dports/net/traefik/traefik-2.6.1/vendor/github.com/Microsoft/hcsshim/ |
| H A D | container.go | 60 waitCh chan struct{} member
136 container.waitCh = make(chan struct{})
139 close(container.waitCh)
147 case <-container.waitCh:
|
| H A D | process.go | 16 waitCh chan struct{} member
46 process.waitCh = make(chan struct{})
49 close(process.waitCh)
57 case <-process.waitCh:
|
| /dports/net/traefik/traefik-2.6.1/pkg/middlewares/tcp/inflightconn/ |
| H A D | inflight_conn_test.go | 16 waitCh := make(chan struct{})
26 <-waitCh
48 close(waitCh)
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/vflux/client/ |
| H A D | fillset_test.go | 31 waitCh chan struct{} member
37 i.waitCh <- struct{}{}
56 case <-i.waitCh:
66 waitCh: make(chan struct{}),
|
| /dports/misc/fq/fq-0.0.2/internal/ctxreadseeker/ |
| H A D | ctxreadseeker.go | 16 waitCh chan struct{} member
24 waitCh: make(chan struct{}),
43 r.waitCh <- struct{}{}
56 case <-r.waitCh:
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/test/acceptance/ |
| H A D | helpers_test.go | 293 waitCh := make(chan struct{})
299 close(waitCh)
304 <-waitCh
309 if err := spec.WaitUntilRequestSucceeds(waitCh); err != nil {
|
| /dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/database/sql/ |
| H A D | fakedb_test.go | 50 waitCh chan struct{} member
282 if d.waitCh != nil {
284 <-d.waitCh
285 d.waitCh = nil
|
| H A D | sql_test.go | 3827 drv.waitCh = make(chan struct{}, 1)
3851 drv.waitCh <- struct{}{}
|
| /dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/net/ |
| H A D | lookup_test.go | 1128 waitCh := make(chan struct{})
1134 close(waitCh)
1137 case <-waitCh:
|
| /dports/lang/gcc12-devel/gcc-12-20211205/libgo/go/database/sql/ |
| H A D | sql_test.go | 3819 drv.waitCh = make(chan struct{}, 1)
3843 drv.waitCh <- struct{}{}
|
| H A D | fakedb_test.go | 50 waitCh chan struct{} member
269 if d.waitCh != nil {
271 <-d.waitCh
272 d.waitCh = nil
|
| /dports/lang/gcc12-devel/gcc-12-20211205/libgo/go/net/ |
| H A D | lookup_test.go | 1121 waitCh := make(chan struct{})
1127 close(waitCh)
1130 case <-waitCh:
|
| /dports/net-im/dendrite/dendrite-0.5.1/cmd/dendrite-monolith-server/ |
| H A D | main_test.go | 34 waitCh := make(chan int, 1)
38 close(waitCh)
47 case <-waitCh:
|
| /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/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/net/rclone/rclone-1.57.0/backend/cache/ |
| H A D | cache_internal_test.go | 1250 waitCh := make(chan error)
1260 waitCh <- errors.Errorf("Timed out waiting for background upload: %v", remote)
1268 waitCh <- err
1273 waitCh <- state.Error
1277 waitCh <- errors.Errorf("Too many attempts to wait for the background upload: %v", remote)
1279 return waitCh
1282 func (r *run) completeBackgroundUpload(t *testing.T, remote string, waitCh chan error) {
1289 case err = <-waitCh:
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/ |
| H A D | client_test.go | 3210 waitCh := make(chan struct{})
3216 <-waitCh
3235 close(waitCh)
|
| /dports/devel/etcd34/etcd-3.4.18/vendor/google.golang.org/grpc/ |
| H A D | balancer.go | 247 close(rr.waitCh)
248 rr.waitCh = nil
310 if rr.waitCh == nil {
312 rr.waitCh = ch
314 ch = rr.waitCh
351 if rr.waitCh == nil {
353 rr.waitCh = ch
355 ch = rr.waitCh
376 if rr.waitCh != nil {
377 close(rr.waitCh)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/ingester/ |
| H A D | transfer_test.go | 186 waitCh := make(chan bool)
188 client := &testTransferChunksClient{ch: chunkCh, resp: respCh, wait: waitCh}
213 close(waitCh)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/coreos/go-systemd/sdjournal/ |
| H A D | read.go | 204 var waitCh = make(chan int, 1)
234 waitCh <- status
241 case e := <-waitCh:
|
| /dports/lang/gcc11-devel/gcc-11-20211009/libgo/go/database/sql/ |
| H A D | fakedb_test.go | 50 waitCh chan struct{} member
260 if d.waitCh != nil {
262 <-d.waitCh
263 d.waitCh = nil
|
| H A D | sql_test.go | 3795 drv.waitCh = make(chan struct{}, 1)
3819 drv.waitCh <- struct{}{}
|
| /dports/lang/gcc11-devel/gcc-11-20211009/libgo/go/net/ |
| H A D | lookup_test.go | 1120 waitCh := make(chan struct{})
1126 close(waitCh)
1129 case <-waitCh:
|
| /dports/lang/gcc10-devel/gcc-10-20211008/libgo/go/database/sql/ |
| H A D | fakedb_test.go | 50 waitCh chan struct{}
260 if d.waitCh != nil {
262 <-d.waitCh
263 d.waitCh = nil
|