- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 423 for coordinator (0.2 sec)
-
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) -
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) -
tensorflow/cc/training/queue_runner.h
// future. static Status New(const QueueRunnerDef& queue_runner_def, std::unique_ptr<QueueRunner>* result); /// Creates a new QueueRunner with a coordinator, see coordinator.h for usage. static Status New(const QueueRunnerDef& queue_runner_def, Coordinator* coord, std::unique_ptr<QueueRunner>* result); /// Adds a callback that the queue runner will call when it detects an error.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K 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/mem.go
) // sharedMem manages access to a region of virtual memory mapped from a file, // shared between multiple processes. The region includes space for a header and // a value of variable length. // // When fuzzing, the coordinator creates a sharedMem from a temporary file for // each worker. This buffer is used to pass values to fuzz between processes. // Care must be taken to manage access to shared memory across processes;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 28 03:44:27 UTC 2022 - 4.5K 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) -
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)