- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 171 for stopCh (0.12 sec)
-
security/pkg/nodeagent/sds/sdsservice.go
b := backoff.NewExponentialBackOff(backoff.DefaultOption()) // context for both timeout and channel, whichever stops first, the context will be done ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-ret.stop: cancel() case <-ctx.Done(): } }() defer cancel() _ = b.RetryWithContext(ctx, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
src/runtime/trace.go
s.timer.sleep(int64(debug.traceadvanceperiod)) // Try to advance the trace. traceAdvance(false) } s.done <- struct{}{} }() } // stop stops a traceAdvancer and blocks until it exits. func (s *traceAdvancerState) stop() { s.timer.wake() <-s.done close(s.done) s.timer.close() } // traceAdvancePeriod is the approximate period between // new generations.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if err != nil { failure = true decomLogIf(ctx, err) stopFn(version.Size, err) continue } if err = z.decommissionObject(ctx, bi.Name, gr); err != nil { stopFn(version.Size, err) failure = true decomLogIf(ctx, err) continue } stopFn(version.Size, nil) failure = false break } if ignore { continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1) -
src/time/tick_test.go
}) } } type timer interface { Stop() bool Reset(Duration) bool } // tickerTimer is a Timer with Reset and Stop methods that return bools, // to have the same signatures as Timer. type tickerTimer struct { *Ticker stopped bool } func (t *tickerTimer) Stop() bool { pending := !t.stopped t.stopped = true t.Ticker.Stop() return pending }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
val result = copyOf(size + 1) result[result.lastIndex] = value return result as Array<String> } /** Increments [startIndex] until this string is not ASCII whitespace. Stops at [endIndex]. */ internal fun String.indexOfFirstNonAsciiWhitespace( startIndex: Int = 0, endIndex: Int = length, ): Int { for (i in startIndex until endIndex) { when (this[i]) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 11K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
// as we create them only after acquiring the leader lock // Note: stop here should be the overall pilot stop, NOT the leader election stop. We are // basically lazy loading the informer, if we stop it when we lose the lock we will never // recreate it again. client.RunAndWait(clusterStopCh) nc.Run(leaderStop) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
func (c *Controller) AddRegistryAndRun(registry serviceregistry.Instance, stop <-chan struct{}) { if stop == nil { log.Warnf("nil stop channel passed to AddRegistryAndRun for registry %s/%s", registry.Provider(), registry.Cluster()) } c.storeLock.Lock() defer c.storeLock.Unlock() c.addRegistry(registry, stop) if c.running { go registry.Run(stop) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
}) g := NewWithT(t) s, err := NewServer(args, func(s *Server) { s.kubeClient = kube.NewFakeClient() }) g.Expect(err).To(Succeed()) stop := make(chan struct{}) g.Expect(s.Start(stop)).To(Succeed()) defer func() { close(stop) s.WaitUntilCompletion() }() if c.expNewCert { if istiodCert, err := s.getIstiodCertificate(nil); istiodCert == nil || err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
// Implement EnvoyXdsServer grace shutdown s.addStartFunc("xds server", func(stop <-chan struct{}) error { log.Infof("Starting ADS server") s.XDSServer.Start(stop) return nil }) } // Wait for the stop, and do cleanups func (s *Server) waitForShutdown(stop <-chan struct{}) { go func() { <-stop close(s.internalStop) _ = s.fileWatcher.Close() if s.cacertsWatcher != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
b, err := yaml.JSONToYAML(data) if err != nil { return err } writes <- string(b) } return nil } stop := test.NewStop(t) gws := clienttest.Wrap(t, d.gateways) go tw.Run(stop) go d.Run(stop) c.RunAndWait(stop) kube.WaitForCacheSync("test", stop, d.queue.HasSynced) // Create a gateway, we should mark our ownership defaultGateway := &k8sbeta.Gateway{ ObjectMeta: metav1.ObjectMeta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0)