- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for enqueuePdb (0.19 sec)
-
pkg/controller/disruption/disruption.go
logger.V(4).Info("Add DB", "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) } func (dc *DisruptionController) updateDB(logger klog.Logger, old, cur interface{}) { // TODO(mml) ignore updates where 'old' is equivalent to 'cur'. pdb := cur.(*policy.PodDisruptionBudget) logger.V(4).Info("Update DB", "podDisruptionBudget", klog.KObj(pdb)) dc.enqueuePdb(logger, pdb) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
pendingAttemptToDelete: []*node{ makeNode(badSecretReferenceWithDeploymentUID, virtual), // virtual parent enqueued for delete attempt makeNode(goodChildPod, withOwners(deployment1apps)), // good child enqueued for delete attempt }, }), // 7,8: process pending delete of virtual parent processAttemptToDelete(1), assertState(state{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
c, _, err := f.newController(ctx) if err != nil { t.Fatalf("error creating Deployment controller: %v", err) } enqueued := false c.enqueueDeployment = func(d *apps.Deployment) { if d.Name == "foo" { enqueued = true } } c.deletePod(logger, pod) if !enqueued { t.Errorf("expected deployment %q to be queued after pod deletion", foo.Name) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: c.options.Name}, ) // Forcefully shutdown workqueue. Drop any enqueued items. // Important to do this in a `defer` at the start of `Run`. // Otherwise, if there are any early returns without calling this, we // would never shut down the workqueue defer c.queue.ShutDown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
public void testThatFinalizerStops() { weaklyReferenceQueue(); GcFinalization.awaitClear(queueReference); } /** If we don't keep a strong reference to the reference object, it won't be enqueued. */ @Nullable FinalizableWeakReference<Object> reference; /** Create the FRQ in a method that goes out of scope so that we're sure it will be reclaimed. */ private void weaklyReferenceQueue() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0) -
src/internal/weak/pointer_test.go
} runtime.KeepAlive(bt) // bt is no longer referenced. // // Run one cycle to queue the finalizer. runtime.GC() if wt.Strong() != nil { t.Errorf("weak pointer did not go nil when finalizer was enqueued") } // Wait for the finalizer to run. <-done // The weak pointer should still be nil after the finalizer runs. runtime.GC() if wt.Strong() != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 3.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} private enum class ResumePriority { /** Resumes as soon as the condition is satisfied. */ BeforeOtherTasks, /** Resumes after the already-enqueued tasks. */ AfterEnqueuedTasks, /** Resumes after all other tasks, including tasks enqueued while yielding. */ AfterOtherTasks, } /** Returns the task that was started, or null if there were no tasks to start. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/reconfig_batch_op.mlir
// RUN: tf-tfrt-opt -split-input-file -tfrt-reconfig-batch-op="tfrt-min-num-batch-threads=2 tfrt-min-max-enqueued-batches=3" %s | FileCheck %s --dump-input=always // ----- // The num_batch_threads is lowered bound to 2 from the original attribute of 1 // CHECK-LABEL: func private @batched_function func.func private @batched_function(%arg0: tensor<1x3xf32>) -> tensor<1x3xf32> { %2 = "tf.Identity"(%arg0) : (tensor<1x3xf32>) -> tensor<1x3xf32>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 17:38:34 UTC 2024 - 5.2K bytes - Viewed (0) -
cmd/data-scanner_test.go
t.Fatalf("Failed with err: %v", err) } if len(gots) != len(wants) { t.Fatalf("Expected %d objects but got %d", len(wants), len(gots)) } // Close expiry state's channel to inspect object versions enqueued for expiration close(workers[0]) wg.Wait() for _, obj := range expired { switch obj.ObjectV.VersionID { case uuids[2].String(), uuids[3].String(), uuids[4].String(): default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 03 11:18:58 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
{ PluginName: "fooPlugin1", QueueingHintFn: queueHintReturnQueue, }, }, }, }, }, { name: "Pod, registered in inFlightPods, is enqueued back to activeQ", isSchedulingQueueHintEnabled: true, initialPods: []*v1.Pod{pod, pod2}, actions: []action{ // This won't be added to inFlightEvents because no inFlightPods at this point.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)