- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for enqueuePdb (0.17 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) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val messageAndCloseQueue = ArrayDeque<Any>() /** The total size in bytes of enqueued but not yet transmitted messages. */ private var queueSize = 0L /** True if we've enqueued a close frame. No further message frames will be enqueued. */ private var enqueuedClose = false /** The close code from the peer, or -1 if this web socket has not yet read a close frame. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K 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_test.go
}() // The controller is blocked because the reconcile function sends on an // unbuffered channel. require.False(t, myController.HasSynced()) // Wait for all enqueued reconciliations require.NoError(t, waitForReconcile(initialObject)) // Now it is safe to wait for it to Sync require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.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/jit/xla_device.h
std::unique_ptr<AsyncValueAllocator> pjrt_allocator_ TF_GUARDED_BY(mu_); // Stream associated with this device. Operations enqueued on this // stream are executed on the device. Operations include data // copying back and forth between CPU and the device, and // computations enqueued by XLA. std::shared_ptr<se::Stream> stream_ TF_GUARDED_BY(mu_); // If false, only stream_ is valid and all computation and transfers use
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 13.4K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
} server.enqueue(MockResponse().setBody("enqueued in the background")) }.start() val connection = server.url("/").toUrl().openConnection() val inputStream = connection.getInputStream() val reader = BufferedReader(InputStreamReader(inputStream, StandardCharsets.UTF_8)) assertThat(reader.readLine()).isEqualTo("enqueued in the background") } @Test fun nonHexadecimalChunkSize() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
} server.enqueue( MockResponse.Builder() .body("enqueued in the background") .build(), ) }.start() val connection = server.url("/").toUrl().openConnection() val reader = BufferedReader(InputStreamReader(connection!!.getInputStream(), UTF_8)) assertThat(reader.readLine()).isEqualTo("enqueued in the background") } @Test fun nonHexadecimalChunkSize() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 scheduled after 100 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", ) } /** Inspect how many runnables have been enqueued. If none then we're truly sequential. */ @Test fun singleQueueIsSerial() { redQueue.execute("task one", 100.µs) { log += "one:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}" }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) ssc.addPod(logger, pod) ssc.queue.ShutDown() key, _ := ssc.queue.Get() if key != "" { t.Errorf("StatefulSet enqueued key for Pod with no Set %s", key) } } func TestStatefulSetControllerUpdatePod(t *testing.T) { logger, ctx := ktesting.NewTestContext(t) ssc, _, om, _ := newFakeStatefulSetController(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0)