- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for Coordinator (0.15 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) -
tensorflow/cc/training/coordinator.h
/// its queue. virtual bool IsRunning() const = 0; }; /// Coordinator class manages the termination of a collection of QueueRunners. /// Without a coordinator, QueueRunners have to be joined in a specific order; /// otherwise the QueueRunner::Join() could sometimes hang. The /// Coordinator::RequestStop() plays the key role which notifies all running /// threads under a coordinator to stop. This function could be called by any /// thread or any client.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K 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) -
platforms/software/resources-sftp/src/integTest/groovy/org/gradle/integtests/resolve/resource/sftp/SftpClientReuseIntegrationTest.groovy
@Rule final SFTPServer sftpServer = new SFTPServer(temporaryFolder) @Rule final BlockingHttpServer coordinator = new BlockingHttpServer() def "does not attempt to reuse a client that has been disconnected"() { coordinator.start() buildFile << """ ${sftpTask} task firstUse(type: SftpTask) { credentials = creds
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 3K 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) -
ci/official/wheel_test/test_import_api_packages.py
self.packages_for_skip = [ "tensorflow.distribute.cluster_resolver", "tensorflow.lite.experimental.authoring", "tensorflow.distribute.experimental.coordinator", "tensorflow.summary.experimental", "tensorflow.distribute.coordinator", "tensorflow.distribute.experimental.partitioners", ] def test_import_runtime(self): """Try to import all packages from api packages file one by one."""
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 13 15:52:07 UTC 2023 - 3.3K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_limit_dup_entry.txt
# FuzzA attempts to cause the mutator to create duplicate inputs that generate # new coverage. Previously this would trigger a corner case when the fuzzer # had an execution limit, causing it to deadlock and sit in the coordinator # loop indefinitely, failing to exit once the limit had been exhausted. go test -fuzz=FuzzA -fuzztime=100x -parallel=1 -- go.mod -- module m go 1.16 -- fuzz_test.go -- package fuzz_test
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 27 01:16:19 UTC 2023 - 725 bytes - Viewed (0)