- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 54 for enqueuePdb (0.58 sec)
-
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/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) -
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) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
} assertThat(server.requestCount).isEqualTo(0) // Confirm that the connection pool was not corrupted by making another call. This doesn't use // makeSimpleCall() because it uses the MockResponse enqueued above. val callB = client.newCall(Request(server.url("/"))) callB.execute().use { response -> assertThat(response.body.string()).isEqualTo("abc") } } private fun makeSimpleCall() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.5K 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) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
futureTasks.add(insertAt, task) // Impact the coordinator if we inserted at the front. return insertAt == 0 } /** * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls * will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K 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)