- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 231 for coordinator (0.23 sec)
-
tensorflow/cc/training/coordinator.cc
limitations under the License. ==============================================================================*/ #include "tensorflow/cc/training/coordinator.h" namespace tensorflow { Coordinator::Coordinator() : Coordinator(std::vector<error::Code>()) {} Coordinator::Coordinator(const std::vector<error::Code>& clean_stop_errors) : should_stop_(false) { if (clean_stop_errors.empty()) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy
coordinator.getIdleMillis() == 0L } } def "idle millis is > 0 when daemon is idle"() { when: coordinator.updateActivityTimestamp() sleep(10) then: idle coordinator.getIdleMillis() > 0 } boolean isNotStopped() { return coordinator.state != Stopped && coordinator.state != ForceStopped }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 16.3K bytes - Viewed (0) -
tensorflow/cc/BUILD
"//tensorflow/core:test", "//tensorflow/core:test_main", "//tensorflow/core:testlib", ], ) cc_library( name = "coordinator", srcs = ["training/coordinator.cc"], hdrs = ["training/coordinator.h"], deps = [ "//tensorflow/core:lib", "//tensorflow/core:lib_internal", "//tensorflow/core:protos_all_cc", ], ) tf_cc_test(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 27 18:00:18 UTC 2024 - 23.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
// Queue a task to interrupt the waiting coordinator. serialTaskQueue += object : SerialTask { override fun start() { taskRunner.assertThreadHoldsLock() waitingCoordinatorInterrupted = true val coordinatorTask = waitingCoordinatorTask ?: error("no coordinator waiting") currentTask = coordinatorTask
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
src/internal/fuzz/worker.go
// If a test process terminates unexpectedly while fuzzing, coordinate will // attempt to restart and continue unless the termination can be attributed // to an interruption (from a timer or the user). // // While looping, coordinate receives inputs from the coordinator, passes // those inputs to the worker process, then passes the results back to // the coordinator. func (w *worker) coordinate(ctx context.Context) error { // Main event loop.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
src/internal/fuzz/fuzz.go
// the coordinator's combined set. When minimizing, the worker should find an // input that preserves at least one of these bits. keepCoverage is nil for // crashing inputs. keepCoverage []byte } // coordinator holds channels that workers can use to communicate with // the coordinator. type coordinator struct { opts CoordinateFuzzingOpts
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 34.1K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
result->reset(new QueueRunner()); return (*result)->Init(queue_runner_def); } Status QueueRunner::New(const QueueRunnerDef& queue_runner_def, Coordinator* coord, std::unique_ptr<QueueRunner>* result) { result->reset(new QueueRunner()); (*result)->coord_ = coord; return (*result)->Init(queue_runner_def); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
val latch = CountDownLatch(1) override fun runOnce(): Long { latch.countDown() return -1L } } /** Adds [task] to run in [delayNanos]. Returns true if the coordinator is impacted. */ internal fun scheduleAndDecide( task: Task, delayNanos: Long, recurrence: Boolean, ): Boolean { task.initQueue(this) val now = taskRunner.backend.nanoTime()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockCoordinationService.java
* {@link InternalTransformer} should return a {@link org.gradle.internal.resources.ResourceLockState.Disposition} * that tells the resource coordinator how to proceed: * * FINISHED - All locks were acquired, release the state lock * FAILED - One or more locks were not acquired, roll back any locks that were acquired and release the state lock
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 2.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
return readyTask } // Notify the coordinator of a task that's coming up soon. coordinatorWaiting -> { if (minDelayNanos < coordinatorWakeUpAt - now) { backend.coordinatorNotify(this@TaskRunner) } return null } // No other thread is coordinating. Become the coordinator! else -> { coordinatorWaiting = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0)