- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 800 for queuesa (0.27 sec)
-
pkg/scheduler/eventhandlers.go
events = append(events, queue.NodeSpecUnschedulableChange) } if nodeAllocatableChanged(newNode, oldNode) { events = append(events, queue.NodeAllocatableChange) } if nodeLabelsChanged(newNode, oldNode) { events = append(events, queue.NodeLabelChange) } if nodeTaintsChanged(newNode, oldNode) { events = append(events, queue.NodeTaintChange) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K 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) -
src/runtime/sigqueue_plan9.go
func sendNote(s *byte) bool { if !sig.inuse { return false } // Add signal to outgoing queue. if !sig.q.push(s) { return false } lock(&sig.lock) if sig.sleeping { sig.sleeping = false notewakeup(&sig.note) } unlock(&sig.lock) return true } // Called to receive the next queued signal. // Must only be called from a single goroutine at a time. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta1/defaults.go
func SetDefaults_QueuingConfiguration(cfg *v1beta1.QueuingConfiguration) { if cfg.HandSize == 0 { cfg.HandSize = PriorityLevelConfigurationDefaultHandSize } if cfg.Queues == 0 { cfg.Queues = PriorityLevelConfigurationDefaultQueues } if cfg.QueueLengthLimit == 0 { cfg.QueueLengthLimit = PriorityLevelConfigurationDefaultQueueLengthLimit }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 00:47:58 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 9K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
if !qm.running { return } // we're waiting until after the informer start that happens once all the controllers are initialized. This ensures // that they don't get unexpected events on their work queues. <-qm.informersStarted monitors := qm.monitors started := 0 for _, monitor := range monitors { if monitor.stopCh == nil { monitor.stopCh = make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
} } // complete optionally requeues key, then calls queue.Done(key) func retryOrForget[T comparable](logger klog.Logger, queue workqueue.TypedRateLimitingInterface[T], key T, requeue bool, maxRetries int) { if !requeue { queue.Forget(key) return } requeueCount := queue.NumRequeues(key) if requeueCount < maxRetries { queue.AddRateLimited(key) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 finished run in 0 µs: task one", ) } /** * The runner doesn't hold references to its queues! Otherwise we'd need a mechanism to clean them * up when they're no longer needed and that's annoying. Instead the task runner only tracks which * queues have work scheduled. */ @Test fun activeQueuesContainsOnlyQueuesWithScheduledTasks() { redQueue.execute("task one", 100.µs) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
pkg/apis/flowcontrol/validation/validation.go
} // validate input arguments for shuffle-sharding if queuing.Queues <= 0 { allErrs = append(allErrs, field.Invalid(fldPath.Child("queues"), queuing.Queues, "must be positive")) } else if queuing.Queues > priorityLevelConfigurationQueuingMaxQueues { allErrs = append(allErrs, field.Invalid(fldPath.Child("queues"), queuing.Queues, fmt.Sprintf("must not be greater than %d", priorityLevelConfigurationQueuingMaxQueues))) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 26.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
om.setsIndexer.Add(set1) om.setsIndexer.Add(set2) om.setsIndexer.Add(set3) // Make pod an orphan. Expect matching sets to be queued. pod.OwnerReferences = nil ssc.addPod(logger, pod) if got, want := ssc.queue.Len(), 2; got != want { t.Errorf("queue.Len() = %v, want %v", got, want) } } func TestStatefulSetControllerAddPodNoSet(t *testing.T) { logger, ctx := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0)