- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 121 for dequeue1 (0.18 sec)
-
pkg/scheduler/framework/interface.go
// and Pods rejected by these plugins are requeued based on this extension point. // Failures from other extension points are regarded as temporal errors (e.g., network failure), // and the scheduler requeue Pods without this extension point - always requeue Pods to activeQ after backoff. // This is because such temporal errors cannot be resolved by specific cluster events,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
src/runtime/select.go
if casi >= nsends { sg = c.sendq.dequeue() if sg != nil { goto recv } if c.qcount > 0 { goto bufrecv } if c.closed != 0 { goto rclose } } else { if raceenabled { racereadpc(c.raceaddr(), casePC(casi), chansendpc) } if c.closed != 0 { goto sclose } sg = c.recvq.dequeue() if sg != nil { goto send }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// a virtual event was produced and will be handled by processGraphChanges, no need to requeue this node return forgetItem } else if err == namespacedOwnerOfClusterScopedObjectErr { // a cluster-scoped object referring to a namespaced owner is an error that will not resolve on retry, no need to requeue this node return forgetItem } else if err != nil { if _, ok := err.(*restMappingError); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/fifo_list.go
// returns a removeFromFIFOFunc function that can be used to remove the // request from the list Enqueue(*request) removeFromFIFOFunc // Dequeue pulls out the oldest request from the list. Dequeue() (*request, bool) // Peek returns the oldest request without removing it. Peek() (*request, bool) // Length returns the number of requests in the list. Length() int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 16:05:53 UTC 2021 - 3.9K bytes - Viewed (0) -
src/internal/fuzz/queue_test.go
want := 0 for _, r := range []int{1, 2, 3, 5, 8, 13, 21} { s := make([]int, 0, r) for i := 0; i < r; i++ { if got, ok := q.dequeue(); !ok { t.Fatalf("after removing %d of %d elements, could not dequeue", i+1, r) } else if got != want { t.Fatalf("after removing %d of %d elements, got %d; want %d", i+1, r, got, want) } else { s = append(s, got.(int)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 02 17:58:51 UTC 2021 - 1.6K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
return } p.pending[con] = pushRequest p.queue = append(p.queue, con) // Signal waiters on Dequeue that a new item is available p.cond.Signal() } // Remove a proxy from the queue. If there are no proxies ready to be removed, this will block func (p *PushQueue) Dequeue() (con *Connection, request *model.PushRequest, shutdown bool) { p.cond.L.Lock() defer p.cond.L.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0) -
.github/workflows/team-triage-stale.yml
name: 'Requeue stale team-triage items' on: schedule: # Execute every day at 00:05 to avoid conflicts with other workflows - cron: '5 0 * * *' permissions: {} jobs: requeue: permissions: issues: write pull-requests: write runs-on: ubuntu-latest steps: - uses: actions/stale@v9 with: operations-per-run: 50 remove-stale-when-updated: false
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 835 bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
return } // always requeue resyncs just in case if oldCRD.ResourceVersion == newCRD.ResourceVersion { c.enqueue(newCRD) return } // If the only difference is in the terminating condition, then there's no reason to requeue here. This controller // is likely to be the originator, so requeuing would hot-loop us. Failures are requeued by the workqueue directly.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// the Pod status which in turn will trigger a requeue of the owning replica set thus // having its status updated with the newly available replica. For now, we can fake the // update by resyncing the controller MinReadySeconds after the it is requeued because // a Pod transitioned to Ready. // Note that this still suffers from #29229, we are just moving the problem one level
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
syncHandler func(groupVersion schema.GroupVersion) error syncedInitialSet chan struct{} // queue is where incoming work is placed to de-dup and to allow "easy" rate limited requeues on errors // this is actually keyed by a groupVersion queue workqueue.TypedRateLimitingInterface[schema.GroupVersion] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0)