- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for QUEUE (0.05 sec)
-
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
private final BlockingQueue<String> queue; public EnableWrites(BlockingQueue<String> queue, long tMinus) { super(tMinus); assertFalse(queue.isEmpty()); assertFalse(queue.offer("shouldBeRejected")); this.queue = queue; } @Override protected void doAction() { assertNotNull(queue.remove()); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
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) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
queue.flushBackoffQCompleted(logger) } moveClockForward = func(t *testing.T, logger klog.Logger, queue *PriorityQueue, _ *framework.QueuedPodInfo) { queue.clock.(*testingclock.FakeClock).Step(2 * time.Second) } flushUnschedulerQ = func(t *testing.T, logger klog.Logger, queue *PriorityQueue, _ *framework.QueuedPodInfo) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
revision string handlers []TagHandler queue controllers.Queue webhooks kclient.Client[*admissionregistrationv1.MutatingWebhookConfiguration] index *kclient.Index[string, *admissionregistrationv1.MutatingWebhookConfiguration] } func NewTagWatcher(client kube.Client, revision string) TagWatcher { p := &tagWatcher{ revision: revision, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go
"backoff-wrong-old-object": { pod: &v1.Pod{}, oldObj: "not-a-pod", expectedHint: framework.Queue, expectedErr: true, }, "backoff-wrong-new-object": { pod: &v1.Pod{}, newObj: "not-a-pod", expectedHint: framework.Queue, expectedErr: true, }, "skip-queue-on-other-pod-updated": { pod: st.MakePod().Name("p").SchedulingGates([]string{"foo", "bar"}).UID("uid0").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
revision string // kinds keeps track of all cache handlers for known types kinds map[config.GroupVersionKind]kclient.Untyped kindsMu sync.RWMutex queue queue.Instance // a flag indicates whether this client has been run, it is to prevent run queue twice started *atomic.Bool // handlers defines a list of event handlers per-type handlers map[config.GroupVersionKind][]model.EventHandler
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10TypeProvider.kt
result.add(initialClass) val queue = ArrayDeque<ClassDescriptor>() queue.addLast(initialClass) while (queue.isNotEmpty()) { val current = queue.removeFirst() val supertypes = DescriptorUtils.getSuperclassDescriptors(current) supertypes.filterNotTo(queue) { it !in result } result.addAll(supertypes) }
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 23.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
_, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err } if modifiedPod.UID != pod.UID { // If the update event is not for targetPod, it wouldn't make targetPod schedulable. return framework.QueueSkip, nil } if len(modifiedPod.Spec.SchedulingGates) == 0 { return framework.Queue, nil } return framework.QueueSkip, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go
expectedHint: framework.Queue, wantErr: true, }, { name: "backoff-wrong-old-object", newObj: nodeWithTaints("nodeA", []v1.Taint{{Key: "dedicated", Value: "user1", Effect: "NoSchedule"}}), oldObj: "not-a-node", expectedHint: framework.Queue, wantErr: true, }, { name: "skip-queue-on-untoleratedtaint-node-added",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 17.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
private void weaklyReferenceQueue() { frq = new FinalizableReferenceQueue(); queueReference = new WeakReference<>(frq.queue); /* * Queue and clear a reference for good measure. We test later on that * the finalizer thread stopped, but we should test that it actually * started first. */ reference =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0)