Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for dequeue0 (0.18 sec)

  1. pkg/controller/garbagecollector/garbagecollector_test.go

    	t.Add(item)
    }
    func (t *trackingWorkqueue[T]) AddRateLimited(item T) {
    	t.Add(item)
    }
    func (t *trackingWorkqueue[T]) Get() (T, bool) {
    	item, shutdown := t.limiter.Get()
    	t.dequeue(item)
    	return item, shutdown
    }
    func (t *trackingWorkqueue[T]) Done(item T) {
    	t.limiter.Done(item)
    }
    func (t *trackingWorkqueue[T]) Forget(item T) {
    	t.limiter.Forget(item)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    type fakeRateLimitingQueue struct {
    	workqueue.TypedInterface[string]
    	requeues int
    	item     string
    	duration time.Duration
    }
    
    func (f *fakeRateLimitingQueue) AddRateLimited(item string) {}
    func (f *fakeRateLimitingQueue) Forget(item string) {
    	f.requeues = 0
    }
    func (f *fakeRateLimitingQueue) NumRequeues(item string) int {
    	return f.requeues
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue_test.go

    				{eventHappens: &PvAdd},
    				{podPopped: pod2},
    				{eventHappens: &NodeAdd},
    				// This pod will be requeued to backoffQ because no plugin is registered as unschedulable plugin.
    				{podEnqueued: newQueuedPodInfoForLookup(pod)},
    				{eventHappens: &CSINodeUpdate},
    				// This pod will be requeued to backoffQ because no plugin is registered as unschedulable plugin.
    				{podEnqueued: newQueuedPodInfoForLookup(pod2)},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  4. src/main/webapp/js/admin/jquery-3.6.3.min.map

    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Fri Feb 17 12:13:41 UTC 2023
    - 135.2K bytes
    - Viewed (0)
  5. src/main/webapp/js/jquery-3.6.3.min.map

    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Fri Feb 17 12:13:41 UTC 2023
    - 135.2K bytes
    - Viewed (0)
  6. src/runtime/proc.go

    	if t-h+n >= uint32(len(pp.runq)) {
    		throw("runqsteal: runq overflow")
    	}
    	atomic.StoreRel(&pp.runqtail, t+n) // store-release, makes the item available for consumption
    	return gp
    }
    
    // A gQueue is a dequeue of Gs linked through g.schedlink. A G can only
    // be on one gQueue or gList at a time.
    type gQueue struct {
    	head guintptr
    	tail guintptr
    }
    
    // empty reports whether q is empty.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
Back to top