- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for Coordinator (0.19 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
entry: entry, crasherMsg: resp.Err, coverageData: resp.CoverageData, canMinimize: canMinimize, } w.coordinator.resultC <- result case input := <-w.coordinator.minimizeC: // Received input to minimize from coordinator. result, err := w.minimize(ctx, input) if err != nil { // Error minimizing. Send back the original input. If it didn't cause
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
// crashing inputs. keepCoverage []byte } // coordinator holds channels that workers can use to communicate with // the coordinator. type coordinator struct { opts CoordinateFuzzingOpts // startTime is the time we started the workers after loading the corpus. // Used for logging. startTime time.Time // inputC is sent values to fuzz by the coordinator. Any worker may receive
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) -
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) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/WithExternalRepository.groovy
server.insertHandler(context) server.start() } catch (IllegalArgumentException ignored) { server = null // repository not found, probably running on coordinator. If not, error will be caught later } } void stopServer() { server?.stop() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.1K bytes - Viewed (0)