- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for Coordinator (0.74 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) -
subprojects/core/src/main/java/org/gradle/internal/composite/DefaultBuildIncluder.java
private final BuildInclusionCoordinator coordinator; private final PublicBuildPath publicBuildPath; private final Instantiator instantiator; private final GradleInternal gradle; private final List<BuildDefinition> pluginBuildDefinitions = new ArrayList<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 13 02:04:28 UTC 2022 - 4.1K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_io_error.txt
# Test that when the coordinator experiences an I/O error communicating # with a worker, the coordinator stops the worker and reports the error. # The coordinator should not record a crasher. # # We simulate an I/O error in the test by writing garbage to fuzz_out. # This is unlikely, but possible. It's difficult to simulate interruptions # due to ^C and EOF errors which are more common. We don't report those. [short] skip [!fuzz] skip env GOCACHE=$WORK/cache
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 2.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/configuration/BuildTreePreparingProjectsPreparer.java
private final ProjectsPreparer delegate; private final BuildInclusionCoordinator coordinator; private final BuildSourceBuilder buildSourceBuilder; private final BuildLoader buildLoader; public BuildTreePreparingProjectsPreparer(ProjectsPreparer delegate, BuildLoader buildLoader, BuildInclusionCoordinator coordinator, BuildSourceBuilder buildSourceBuilder) { this.delegate = delegate;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 01 14:00:32 UTC 2023 - 4.6K 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) -
tensorflow/cc/training/coordinator_test.cc
namespace tensorflow { namespace { using error::Code; void WaitForStopThread(Coordinator* coord, Notification* about_to_wait, Notification* done) { about_to_wait->Notify(); coord->WaitForStop(); done->Notify(); } TEST(CoordinatorTest, TestStopAndWaitOnStop) { Coordinator coord; EXPECT_EQ(coord.ShouldStop(), false); Notification about_to_wait; Notification done;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 23 09:10:43 UTC 2023 - 6.9K 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/cmd/go/testdata/script/test_fuzz_mutator.txt
[!fuzz] skip # Test basic fuzzing mutator behavior. # # fuzz_test.go has two fuzz targets (FuzzA, FuzzB) which both add a seed value. # Each fuzz function writes the input to a log file. The coordinator and worker # use separate log files. check_logs.go verifies that the coordinator only # tests seed values and the worker tests mutated values on the fuzz target. [short] skip env GOCACHE=$WORK/cache go test -fuzz=FuzzA -fuzztime=100x -parallel=1 -log=fuzz
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 3.7K bytes - Viewed (0)