/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/serf/ |
H A D | snapshot_test.go | 22 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 D | snapshot_test.go | 22 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 D | snapshot_test.go | 22 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 D | snapshot_test.go | 22 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 D | snapshot_test.go | 22 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 D | snapshot_test.go | 22 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 D | cpthelp.cpp | 37 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 D | cptcompiler.cpp | 74 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 D | cpthelp.cpp | 37 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 D | cptcompiler.cpp | 74 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 D | configmap_test.go | 37 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 D | cache_test.go | 52 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 D | snapshot_test.go | 32 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 D | snapshot_test.go | 32 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 D | snapshot_test.go | 32 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | wait.go | 52 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 D | attach_detach_test.go | 185 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 …]
|