- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 230 for enqueued (0.22 sec)
-
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
t.Fatalf("expected pod to be queued to backoffQ, but it was not") } if q.activeQ.Len() == 0 && test.expectedQ == activeQ { t.Fatalf("expected pod to be queued to activeQ, but it was not") } if q.unschedulablePods.get(test.podInfo.Pod) == nil && test.expectedQ == unschedulablePods { t.Fatalf("expected pod to be queued to unschedulablePods, but it was not") } }) }
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/Dispatcher.kt
if (existingCall.host == host) return existingCall } return null } /** * Cancel all calls currently enqueued or executing. Includes calls executed both * [synchronously][Call.execute] and [asynchronously][Call.enqueue]. */ fun cancelAll() { this.withLock { for (call in readyAsyncCalls) { call.call.cancel() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
if key == "" || done { t.Error("failed to enqueue StatefulSet") } else if expectedKey, _ := controller.KeyFunc(set1); expectedKey != key { t.Errorf("expected StatefulSet key %s found %s", expectedKey, key) } ssc.queue.Done(key) ssc.addPod(logger, pod2) key, done = ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
src/runtime/mwbbuf.go
start := uintptr(unsafe.Pointer(&pp.wbBuf.buf[0])) n := (pp.wbBuf.next - start) / unsafe.Sizeof(pp.wbBuf.buf[0]) ptrs := pp.wbBuf.buf[:n] // Poison the buffer to make extra sure nothing is enqueued // while we're processing the buffer. pp.wbBuf.next = 0 if useCheckmark { // Slow path for checkmark mode. for _, ptr := range ptrs { shade(ptr) } pp.wbBuf.reset() return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K 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/daemon/daemon_controller_test.go
manager.enqueueDaemonSet = func(ds *apps.DaemonSet) { if ds.Name == "ds" { enqueued = true } } enqueued = false manager.updateNode(logger, c.oldNode, c.newNode) if enqueued != c.shouldEnqueue { t.Errorf("Test case: '%s', expected: %t, got: %t", c.test, c.shouldEnqueue, enqueued) } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
* Scripts [response] to be returned to a request made in sequence. The first request is * served by the first enqueued response; the second request by the second enqueued response; and * so on. * * @throws ClassCastException if the default dispatcher has been * replaced with [setDispatcher][dispatcher]. */ fun enqueue(response: MockResponse) = (dispatcher as QueueDispatcher).enqueueResponse(response) /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
} /** * Returns true if the request contains conditions that save the server from sending a response * that the client has locally. When a request is enqueued with its own conditions, the built-in * response cache won't be used. */ private fun hasConditions(request: Request): Boolean =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12K bytes - Viewed (0)