- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for dequeue0 (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// entropy as it shuffle-shards the request into a queue. The // descr1 and descr2 values play no role in the logic but appear // in log messages. This method always returns quickly (without // waiting for the request to be dequeued). If this method // returns a nil Request value then caller should reject the // request and the returned bool indicates whether the QueueSet // was idle at the moment of the return. Otherwise idle==false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
src/runtime/tracebuf.go
func (q *traceBufQueue) push(buf *traceBuf) { buf.link = nil if q.head == nil { q.head = buf } else { q.tail.link = buf } q.tail = buf } // pop dequeues from the queue of buffers. func (q *traceBufQueue) pop() *traceBuf { buf := q.head if buf == nil { return nil } q.head = buf.link if q.head == nil { q.tail = nil } buf.link = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/certificates/cleaner/cleaner.go
defer logger.Info("Shutting down CSR cleaner controller") for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ccc.worker, pollingInterval) } <-ctx.Done() } // worker runs a thread that dequeues CSRs, handles them, and marks them done. func (ccc *CSRCleanerController) worker(ctx context.Context) { logger := klog.FromContext(ctx) csrs, err := ccc.csrLister.List(labels.Everything()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 8K bytes - Viewed (0) -
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/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) -
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) -
prepare_stmt.go
// prepare completed defer close(cacheStmt.prepared) // Reason why cannot lock conn.PrepareContext // suppose the maxopen is 1, g1 is creating record and g2 is querying record. // 1. g1 begin tx, g1 is requeue because of waiting for the system call, now `db.ConnPool` db.numOpen == 1. // 2. g2 select lock `conn.PrepareContext(ctx, query)`, now db.numOpen == db.maxOpen , wait for release.
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Thu Mar 28 08:47:39 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/scheduler/rate_limited_queue.go
// interval should be used. type ActionFunc func(TimedValue) (bool, time.Duration) // Try processes the queue.Ends prematurely if RateLimiter forbids an // action and leak is true. Otherwise, requeues the item to be // processed. Each value is processed once if fn returns true, // otherwise it is added back to the queue. The returned remaining is // used to identify the minimum time to execute the next item in the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 8.2K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
_, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err } svm, err := svmc.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 a copy to avoid race condition between this and resource version controller toBeProcessedSVM := svm.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0)