- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for processNext (0.17 sec)
-
pkg/controlplane/controller/legacytokentracking/controller.go
c.queue.Add(queueKey) <-stopCh klog.Info("Ending legacy_token_tracking_controller") } func (c *Controller) runWorker() { for c.processNext() { } } func (c *Controller) processNext() bool { key, quit := c.queue.Get() if quit { return false } defer c.queue.Done(key) if err := c.syncConfigMap(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
} go wait.UntilWithContext(ctx, rv.worker, time.Second) <-ctx.Done() } func (rv *ResourceVersionController) worker(ctx context.Context) { for rv.processNext(ctx) { } } func (rv *ResourceVersionController) processNext(ctx context.Context) bool { key, quit := rv.queue.Get() if quit { return false } defer rv.queue.Done(key) err := rv.sync(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
go wait.UntilWithContext(ctx, svmc.worker, time.Second) } <-ctx.Done() } func (svmc *SVMController) worker(ctx context.Context) { for svmc.processNext(ctx) { } } func (svmc *SVMController) processNext(ctx context.Context) bool { key, quit := svmc.queue.Get() if quit { return false } defer svmc.queue.Done(key) err := svmc.sync(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
serviceCIDRs = append(serviceCIDRs, v.UnsortedList()...) } return serviceCIDRs } func (c *Controller) worker(ctx context.Context) { for c.processNext(ctx) { } } func (c *Controller) processNext(ctx context.Context) bool { key, quit := c.queue.Get() if quit { return false } defer c.queue.Done(key) err := c.sync(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/snapshot/impl/AbstractValueProcessor.java
} if (value instanceof Short) { return visitor.shortValue((Short) value); } } if (value instanceof Set) { return processSet((Set<?>) value, visitor); } if (value instanceof Map) { return processMap((Map<?, ?>) value, visitor); } if (valueClass.isArray()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 05 19:08:37 UTC 2024 - 10K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/regalloc.go
e.s.f.Fatalf("process.OpLoadReg targeting g: " + c.LongString()) } } } // processDest generates code to put value vid into location loc. Returns true // if progress was made. func (e *edgeState) processDest(loc Location, vid ID, splice **Value, pos src.XPos) bool { pos = pos.WithNotStmt() occupant := e.contents[loc] if occupant.vid == vid {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:49:56 UTC 2023 - 87.2K bytes - Viewed (0)