- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 277 for enqueue0 (0.13 sec)
-
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/util/flowcontrol/fairqueuing/queueset/fifo_list.go
// // Note that a fifo, including the removeFromFIFOFuncs returned from Enqueue, // is not safe for concurrent use by multiple goroutines. type fifo interface { // Enqueue enqueues the specified request into the list and // returns a removeFromFIFOFunc function that can be used to remove the // request from the list Enqueue(*request) removeFromFIFOFunc // Dequeue pulls out the oldest request from the list.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 16:05:53 UTC 2021 - 3.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
/** * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock * response is ready. */ @Test fun dispatchBlocksWaitingForEnqueue() { Thread { try { Thread.sleep(1000) } catch (ignored: InterruptedException) { } server.enqueue( MockResponse.Builder() .body("enqueued in the background") .build(), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
} /** * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock * response is ready. */ @Test fun dispatchBlocksWaitingForEnqueue() { Thread { try { Thread.sleep(1000) } catch (ignored: InterruptedException) { } server.enqueue(MockResponse().setBody("enqueued in the background")) }.start()
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/README.md
// instance for every unit test. MockWebServer server = new MockWebServer(); // Schedule some responses. server.enqueue(new MockResponse().setBody("hello, world!")); server.enqueue(new MockResponse().setBody("sup, bra?")); server.enqueue(new MockResponse().setBody("yo dog")); // Start the server. server.start(); // Ask the server for its URL. You'll need this to make HTTP requests.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Dec 17 15:34:10 UTC 2023 - 5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
} open fun setFailFast(failFastResponse: MockResponse?) { this.failFastResponse = failFastResponse } @ExperimentalOkHttpApi companion object { /** * Enqueued on shutdown to release threads waiting on [dispatch]. Note that this response * isn't transmitted because the connection is closed before this response is returned. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
// to validate and enqueue a request for the queueSet/QueueSet: // 1) Start with shuffle sharding, to pick a queue. // 2) Reject current request if there is not enough concurrency shares and // we are at max queue length // 3) If not rejected, create a request and enqueue // returns the enqueud request on a successful enqueue // returns nil in the case that there is no available concurrency or
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
src/runtime/mwbbuf.go
// // See mbarrier.go for algorithmic details on the write barrier. This // file deals only with the buffer. // // The write barrier has a fast path and a slow path. The fast path // simply enqueues to a per-P write barrier buffer. It's written in // assembly and doesn't clobber any general purpose registers, so it // doesn't have the usual overheads of a Go call. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
} logger.V(4).Info("Orphan Pod objectMeta updated.", "pod", klog.KObj(oldPod), "oldObjectMeta", oldPod.ObjectMeta, "curObjectMeta", curPod.ObjectMeta) for _, rs := range rss { rsc.enqueueRS(rs) } } } // When a pod is deleted, enqueue the replica set that manages the pod and update its expectations. // obj could be an *v1.Pod, or a DeletionFinalStateUnknown marker item.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.h
/*** MEMCPY CALLBACKS ***/ // Enqueues a memcpy operation onto stream, with a host destination location // `host_dst` and a device memory source, with target size `size`. void (*memcpy_dtoh)(const SP_Device* device, SP_Stream stream, void* host_dst, const SP_DeviceMemoryBase* device_src, uint64_t size, TF_Status* status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 24 08:40:35 UTC 2022 - 21.6K bytes - Viewed (0)