- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 66 for QUEUE (0.05 sec)
-
pkg/scheduler/internal/queue/scheduling_queue.go
queue := p.requeuePodViaQueueingHint(logger, pInfo, hint, UnscheduledPodUpdate.Label) if queue != unschedulablePods { logger.V(5).Info("Pod moved to an internal scheduling queue because the Pod is updated", "pod", klog.KObj(newPod), "event", PodUpdate, "queue", queue) p.unschedulablePods.delete(usPodInfo.Pod, gated) } if queue == activeQ { p.cond.Broadcast() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (3) -
src/internal/trace/order.go
name string // parentID is the parent ID of the active task. parentID TaskID } // queue implements a growable ring buffer with a queue API. type queue[T any] struct { start, end int buf []T } // push adds a new event to the back of the queue. func (q *queue[T]) push(value T) { if q.end-q.start == len(q.buf) { q.grow() } q.buf[q.end%len(q.buf)] = value
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/index/suffixarray/sais2.go
} // Negative j is a work queue entry; rewrite to positive j for final suffix array. j = -j sa[i] = int64(j) // Index j was on work queue (encoded as -j but now decoded), // meaning k := j-1 is L-type, // so we can now place k correctly into sa. // If k-1 is S-type, queue -k for processing later in this loop. // If k-1 is L-type (text[k-1] > text[k]), queue k to save for the caller.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 23:57:18 UTC 2024 - 52.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
} queue := &queue{ requestsWaiting: newRequestFIFO(), requestsExecuting: sets.New[*request](), } r := &request{ qs: qs, queue: queue, workEstimate: qs.completeWorkEstimate(&test.workEstimate), } rOther := &request{qs: qs, queue: queue} qs.totRequestsExecuting = 111 qs.totSeatsInUse = 222
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
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/scheduler/framework/plugins/noderesources/fit_test.go
expectedHint: framework.Queue, expectedErr: true, }, "backoff-wrong-new-object": { pod: &v1.Pod{}, newObj: "not-a-pod", enableInPlacePodVerticalScaling: true, expectedHint: framework.Queue, expectedErr: true, }, "queue-on-other-pod-deleted": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) { super(referent, queue); this.entry = entry; } @Override public E getEntry() { return entry; } @Override public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) { return new WeakValueReferenceImpl<>(queue, get(), entry); } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
return } // Requests are always added to queue with resyncPeriod delay. If there's already // request for the HPA in the queue then a new request is always dropped. Requests spend resync // interval in queue so HPAs are processed every resync interval. a.queue.AddRateLimited(key) // Register HPA in the hpaSelectors map if it's not present yet. Attaching the Nothing selector
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) { super(referent, queue); this.entry = entry; } @Override public E getEntry() { return entry; } @Override public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) { return new WeakValueReferenceImpl<>(queue, get(), entry); } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Synchronized.java
} static <E extends @Nullable Object> Queue<E> queue(Queue<E> queue, @CheckForNull Object mutex) { return (queue instanceof SynchronizedQueue) ? queue : new SynchronizedQueue<E>(queue, mutex); } static class SynchronizedQueue<E extends @Nullable Object> extends SynchronizedCollection<E> implements Queue<E> { SynchronizedQueue(Queue<E> delegate, @CheckForNull Object mutex) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 53.4K bytes - Viewed (0)