Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for processNext (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top