- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 112 for dequeue0 (0.2 sec)
-
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) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ResolveState.java
@Nullable public NodeState peek() { return queue.isEmpty() ? null : queue.getFirst(); } public NodeState pop() { NodeState next = queue.removeFirst(); return next.dequeue(); } /** * Called when a change is made to a configuration node, such that its dependency graph may now be larger than it previously was, and the node should be visited. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 16.7K 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) -
pkg/controller/volume/ephemeral/controller.go
ec.queue.AddRateLimited(key) return true } // syncHandler is invoked for each pod which might need to be processed. // If an error is returned from this function, the pod will be requeued. func (ec *ephemeralController) syncHandler(ctx context.Context, key string) error { namespace, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/controller/controller_ref_manager.go
// If the pod no longer exists, ignore the error. if errors.IsNotFound(err) { return false, nil } // Either someone else released it, or there was a transient error. // The controller should requeue and try again if it's still stale. return false, err } // Successfully released. return false, nil } // It's an orphan. if m.Controller.GetDeletionTimestamp() != nil || !match(obj) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 21.5K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
queueSkip queueingStrategy = iota // queueAfterBackoff indicates that the scheduling queue should requeue the Pod after backoff is completed. queueAfterBackoff // queueImmediately indicates that the scheduling queue should skip backoff and requeue the Pod immediately to activeQ. queueImmediately ) // isEventOfInterest returns true if the event is of interest by some plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (3) -
pkg/controller/replicaset/replica_set_test.go
manager.queue = workqueue.NewTypedRateLimitingQueue(workqueue.NewTypedMaxOfRateLimiter[string]()) manager.enqueueRS(rs) manager.processNextWorkItem(ctx) // It should have been requeued. if got, want := manager.queue.Len(), 1; got != want { t.Errorf("queue.Len() = %v, want %v", got, want) } } func TestControllerUpdateStatusWithFailure(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
delete(p.startedStaticPodsByFullname, status.fullname) } } // completeWork requeues on error or the next sync interval and then immediately executes any pending // work. func (p *podWorkers) completeWork(podUID types.UID, phaseTransition bool, syncErr error) { // Requeue the last update if the last sync returned error. switch { case phaseTransition: p.workQueue.Enqueue(podUID, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
// pod cache if a pod changes IP. IPByPods map[types.NamespacedName]string // needResync is map of IP to endpoint namespace/name. This is used to requeue endpoint // events when pod event comes. This typically happens when pod is not available // in podCache when endpoint event comes. needResync map[string]sets.Set[types.NamespacedName]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0)