Home
last modified time | relevance | path

Searched refs:stopCh (Results 1 – 25 of 2066) sorted by relevance

12345678910>>...83

/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go22 stopCh := make(chan struct{})
25 logger, clock, outCh, stopCh)
117 close(stopCh)
151 close(stopCh)
163 close(stopCh)
207 close(stopCh)
227 close(stopCh)
284 close(stopCh)
365 close(stopCh)
475 close(stopCh)
[all …]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go22 stopCh := make(chan struct{})
25 logger, clock, outCh, stopCh)
117 close(stopCh)
151 close(stopCh)
163 close(stopCh)
207 close(stopCh)
227 close(stopCh)
284 close(stopCh)
365 close(stopCh)
475 close(stopCh)
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go22 stopCh := make(chan struct{})
25 logger, clock, outCh, stopCh)
117 close(stopCh)
151 close(stopCh)
163 close(stopCh)
207 close(stopCh)
227 close(stopCh)
284 close(stopCh)
365 close(stopCh)
475 close(stopCh)
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go22 stopCh := make(chan struct{})
25 logger, clock, outCh, stopCh)
117 close(stopCh)
151 close(stopCh)
163 close(stopCh)
207 close(stopCh)
227 close(stopCh)
284 close(stopCh)
365 close(stopCh)
475 close(stopCh)
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go22 stopCh := make(chan struct{})
25 logger, clock, outCh, stopCh)
117 close(stopCh)
151 close(stopCh)
163 close(stopCh)
207 close(stopCh)
227 close(stopCh)
284 close(stopCh)
365 close(stopCh)
475 close(stopCh)
[all …]
/dports/sysutils/serf/serf-0.8.5/serf/
H A Dsnapshot_test.go22 stopCh := make(chan struct{})
25 logger, clock, outCh, stopCh)
117 close(stopCh)
151 close(stopCh)
163 close(stopCh)
207 close(stopCh)
227 close(stopCh)
284 close(stopCh)
365 close(stopCh)
475 close(stopCh)
[all …]
/dports/games/libretro-scummvm/scummvm-7b1e929/devtools/skycpt/
H A Dcpthelp.cpp37 char *stopCh; in getInfo() local
38 uint16 res = (uint16)strtoul(line, &stopCh, 16); in getInfo()
39 assert(line != stopCh); in getInfo()
40 assert((stopCh[0] == ':') && (stopCh[1] == ':')); in getInfo()
41 stopCh += 2; in getInfo()
42 strcpy(nameDest, stopCh); in getInfo()
81 char *stopCh; in isEndOfObject() local
82 uint16 idVal = (uint16)strtoul(line, &stopCh, 16); in isEndOfObject()
83 assert(stopCh != line); in isEndOfObject()
84 if (strcmp(stopCh, "::ENDS")) in isEndOfObject()
H A Dcptcompiler.cpp74 char *stopCh; in processMainLists() local
77 assert((stopCh[0] == ':') && (stopCh[1] == ':')); in processMainLists()
116 char *stopCh; in processCpts() local
119 assert((stopCh[0] == '-') && (stopCh[1] == '>')); in processCpts()
171 assert((stopCh[0] == '-') && (stopCh[1] == '>')); in processTurntabs()
250 char *stopCh; in processSymlinks() local
253 assert((stopCh[0] == ':') && (stopCh[1] == ':')); in processSymlinks()
408 uint16 eId = (uint16)strtoul(stopCh + 1, &stopCh, 10); in doCompile()
411 uint16 elemNo = (uint16)strtoul(stopCh + 2, &stopCh, 10); in doCompile()
413 stopCh = strstr(stopCh, "0x") + 2; in doCompile()
[all …]
/dports/games/scummvm/scummvm-2.5.1/devtools/skycpt/
H A Dcpthelp.cpp37 char *stopCh; in getInfo() local
38 uint16 res = (uint16)strtoul(line, &stopCh, 16); in getInfo()
39 assert(line != stopCh); in getInfo()
40 assert((stopCh[0] == ':') && (stopCh[1] == ':')); in getInfo()
41 stopCh += 2; in getInfo()
42 strcpy(nameDest, stopCh); in getInfo()
81 char *stopCh; in isEndOfObject() local
82 uint16 idVal = (uint16)strtoul(line, &stopCh, 16); in isEndOfObject()
83 assert(stopCh != line); in isEndOfObject()
84 if (strcmp(stopCh, "::ENDS")) in isEndOfObject()
H A Dcptcompiler.cpp74 char *stopCh; in processMainLists() local
77 assert((stopCh[0] == ':') && (stopCh[1] == ':')); in processMainLists()
116 char *stopCh; in processCpts() local
119 assert((stopCh[0] == '-') && (stopCh[1] == '>')); in processCpts()
171 assert((stopCh[0] == '-') && (stopCh[1] == '>')); in processTurntabs()
250 char *stopCh; in processSymlinks() local
253 assert((stopCh[0] == ':') && (stopCh[1] == ':')); in processSymlinks()
408 uint16 eId = (uint16)strtoul(stopCh + 1, &stopCh, 10); in doCompile()
411 uint16 elemNo = (uint16)strtoul(stopCh + 2, &stopCh, 10); in doCompile()
413 stopCh = strstr(stopCh, "0x") + 2; in doCompile()
[all …]
/dports/sysutils/istio/istio-1.6.7/galley/pkg/server/components/
H A Dconfigmap_test.go37 defer close(stopCh)
65 defer close(stopCh)
97 defer close(stopCh)
111 stopCh := make(chan struct{})
112 defer close(stopCh)
113 checker, err := watchAccessList(stopCh, file)
141 stopCh := make(chan struct{})
142 defer close(stopCh)
197 defer close(stopCh)
244 stopCh := make(chan struct{})
[all …]
/dports/sysutils/istio/istio-1.6.7/mixer/adapter/kubernetesenv/
H A Dcache_test.go52 stopCh := make(chan struct{})
54 defer close(stopCh)
55 go c.Run(stopCh)
56 if !cache.WaitForCacheSync(stopCh, c.HasSynced) {
96 stopCh := make(chan struct{})
98 defer close(stopCh)
99 go c.Run(stopCh)
100 if !cache.WaitForCacheSync(stopCh, c.HasSynced) {
151 stopCh := make(chan struct{})
153 defer close(stopCh)
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go32 stopCh := make(chan struct{})
131 close(stopCh)
141 stopCh = make(chan struct{})
176 close(stopCh)
181 stopCh = make(chan struct{})
188 close(stopCh)
241 close(stopCh)
251 stopCh = make(chan struct{})
272 close(stopCh)
329 close(stopCh)
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/serf/serf-0.7.0/serf/
H A Dsnapshot_test.go32 stopCh := make(chan struct{})
131 close(stopCh)
141 stopCh = make(chan struct{})
176 close(stopCh)
181 stopCh = make(chan struct{})
188 close(stopCh)
241 close(stopCh)
251 stopCh = make(chan struct{})
272 close(stopCh)
329 close(stopCh)
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/serf/serf/
H A Dsnapshot_test.go32 stopCh := make(chan struct{})
131 close(stopCh)
141 stopCh = make(chan struct{})
176 close(stopCh)
181 stopCh = make(chan struct{})
188 close(stopCh)
241 close(stopCh)
251 stopCh = make(chan struct{})
272 close(stopCh)
329 close(stopCh)
[all …]
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
88 JitterUntil(f, period, 0.0, true, stopCh)
107 JitterUntil(f, period, 0.0, false, stopCh)
136 case <-stopCh:
165 case <-stopCh:
372 case <-stopCh:
375 return PollUntil(interval, condition, stopCh)
399 stopCh := make(chan struct{})
400 defer close(stopCh)
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
88 JitterUntil(f, period, 0.0, true, stopCh)
107 JitterUntil(f, period, 0.0, false, stopCh)
136 case <-stopCh:
165 case <-stopCh:
372 case <-stopCh:
375 return PollUntil(interval, condition, stopCh)
399 stopCh := make(chan struct{})
400 defer close(stopCh)
[all …]
/dports/devel/mutagen/mutagen-0.11.8/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
88 JitterUntil(f, period, 0.0, true, stopCh)
107 JitterUntil(f, period, 0.0, false, stopCh)
136 case <-stopCh:
165 case <-stopCh:
372 case <-stopCh:
375 return PollUntil(interval, condition, stopCh)
399 stopCh := make(chan struct{})
400 defer close(stopCh)
[all …]
/dports/sysutils/docker/docker-ce-18.09.5/components/cli/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
87 func Until(f func(), period time.Duration, stopCh <-chan struct{}) {
88 JitterUntil(f, period, 0.0, true, stopCh)
97 func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
98 JitterUntil(f, period, 0.0, false, stopCh)
117 case <-stopCh:
146 case <-stopCh:
290 return WaitFor(poller(interval, 0), condition, stopCh)
306 case <-stopCh:
[all …]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
87 func Until(f func(), period time.Duration, stopCh <-chan struct{}) {
88 JitterUntil(f, period, 0.0, true, stopCh)
97 func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
98 JitterUntil(f, period, 0.0, false, stopCh)
117 case <-stopCh:
146 case <-stopCh:
290 return WaitFor(poller(interval, 0), condition, stopCh)
306 case <-stopCh:
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
87 func Until(f func(), period time.Duration, stopCh <-chan struct{}) {
88 JitterUntil(f, period, 0.0, true, stopCh)
97 func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
98 JitterUntil(f, period, 0.0, false, stopCh)
117 case <-stopCh:
146 case <-stopCh:
290 return WaitFor(poller(interval, 0), condition, stopCh)
306 case <-stopCh:
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
87 func Until(f func(), period time.Duration, stopCh <-chan struct{}) {
88 JitterUntil(f, period, 0.0, true, stopCh)
97 func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
98 JitterUntil(f, period, 0.0, false, stopCh)
117 case <-stopCh:
146 case <-stopCh:
290 return WaitFor(poller(interval, 0), condition, stopCh)
306 case <-stopCh:
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
87 func Until(f func(), period time.Duration, stopCh <-chan struct{}) {
88 JitterUntil(f, period, 0.0, true, stopCh)
97 func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
98 JitterUntil(f, period, 0.0, false, stopCh)
117 case <-stopCh:
146 case <-stopCh:
290 return WaitFor(poller(interval, 0), condition, stopCh)
306 case <-stopCh:
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/vendor/k8s.io/apimachinery/pkg/util/wait/
H A Dwait.go52 func (g *Group) StartWithChannel(stopCh <-chan struct{}, f func(stopCh <-chan struct{})) {
54 f(stopCh)
87 func Until(f func(), period time.Duration, stopCh <-chan struct{}) {
88 JitterUntil(f, period, 0.0, true, stopCh)
97 func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
98 JitterUntil(f, period, 0.0, false, stopCh)
117 case <-stopCh:
146 case <-stopCh:
290 return WaitFor(poller(interval, 0), condition, stopCh)
306 case <-stopCh:
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/volume/
H A Dattach_detach_test.go185 go ctrl.Run(stopCh)
186 defer close(stopCh)
261 go ctrl.Run(stopCh)
286 close(stopCh)
331 go ctrl.Run(stopCh)
356 close(stopCh)
514 go ctrl.Run(stopCh)
545 close(stopCh)
600 go ctrl.Run(stopCh)
601 go pvCtrl.Run(stopCh)
[all …]

12345678910>>...83