- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 121 for dequeue1 (0.17 sec)
-
pkg/controller/deployment/deployment_controller.go
if d.UID != controllerRef.UID { // The controller we found with this Name is not the same one that the // ControllerRef points to. return nil } return d } // worker runs a worker thread that just dequeues items, processes them, and marks them done. // It enforces that the syncHandler is never invoked concurrently with the same key. func (dc *DeploymentController) worker(ctx context.Context) { for dc.processNextWorkItem(ctx) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
src/runtime/export_test.go
s.acquiretime = 0 s.ticket = 0 t.semTable.rootFor(addr).queue(addr, s, false) } // Dequeue simulates dequeuing a waiter for a semaphore (or lock) at addr. // // Returns true if there actually was a waiter to be dequeued. func (t *SemTable) Dequeue(addr *uint32) bool { s, _, _ := t.semTable.rootFor(addr).dequeue(addr) if s != nil { releaseSudog(s) return true } return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
src/main/webapp/js/admin/adminlte.min.js.map
DEBAR).show().delay(10).queue(function(){\n $('body').addClass(ClassName.CONTROL_SIDEBAR_SLIDE).delay(300).queue(function(){\n $('html').removeClass(ClassName.CONTROL_SIDEBAR_ANIMATE)\n $(this).dequeue()\n })\n $(this).dequeue()\n })\n } else {\n $('body').addClass(ClassName.CONTROL_SIDEBAR_OPEN)\n }\n\n const expandedEvent = $.Event(Event.EXPANDED)\n $(this._element).trigger(expandedEvent)\n }\n\n toggle() {\n...
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Wed Feb 12 07:55:41 UTC 2020 - 77K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/doc.go
// the last request in the queue. While the queue is empty and has a // request executing: the last virtual finish time is the queue’s // virtual start time. When a request is dequeued for service the // queue’s virtual start time is advanced by G. When a request // finishes being served, and the actual service time was S, the // queue’s virtual start time is decremented by G - S.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 12:33:30 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
}, cidrSynced: deletedServiceCIDR.Name, actions: [][]string{{"patch", "servicecidrs", ""}}, }, { name: "service CIDR being deleted but within the grace period must be requeued not remove the finalizer", // TODO: assert is actually requeued cidrs: []*networkingapiv1alpha1.ServiceCIDR{ deletingServiceCIDR, }, cidrSynced: deletingServiceCIDR.Name, actions: [][]string{}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
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) -
pkg/controller/replicaset/replica_set_utils.go
updatedRS, updateErr = c.UpdateStatus(context.TODO(), rs, metav1.UpdateOptions{}) if updateErr == nil { return updatedRS, nil } // Stop retrying if we exceed statusUpdateRetries - the replicaSet will be requeued with a rate limit. if i >= statusUpdateRetries { break } // Update the ReplicaSet with the latest resource version for the next poll
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
return nil, qs.isIdleLocked() } // ======================================================================== // Step 2: // The next step is to invoke the method that dequeues as much // as possible. // This method runs a loop, as long as there are non-empty // queues and the number currently executing is less than the // assured concurrency value. The body of the loop uses the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
pkg/controller/deployment/rollback.go
// rollbackToTemplate compares the templates of the provided deployment and replica set and // updates the deployment with the replica set template in case they are different. It also // cleans up the rollback spec so subsequent requeues of the deployment won't end up in here. func (dc *DeploymentController) rollbackToTemplate(ctx context.Context, d *apps.Deployment, rs *apps.ReplicaSet) (bool, error) { logger := klog.FromContext(ctx) performedRollback := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
_, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err } svm, err := rv.svmListers.Get(name) if apierrors.IsNotFound(err) { // no work to do, don't fail and requeue return nil } if err != nil { return err } // working with copy to avoid race condition between this and migration controller toBeProcessedSVM := svm.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0)