- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for Coordinator (0.19 sec)
-
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/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) -
SECURITY.md
If you have not received a reply to your email within 48 hours or you have not heard from the security team for the past five days please contact the security team directly: - Primary security coordinator: ******@****.*** - Secondary coordinator: ******@****.*** - If you receive no response: ******@****.*** ### Disclosure Process MinIO uses the following disclosure process:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Feb 12 00:51:25 UTC 2022 - 2.2K 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) -
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) -
src/internal/fuzz/worker_test.go
for i := 0; i < b.N; i++ { ws.m = newMutator() mem.setValue(encodedVals) mem.header().count = 0 ws.fuzz(context.Background(), fuzzArgs{Limit: 1}) } } // BenchmarkWorkerPing acts as the coordinator and measures the time it takes // a worker to respond to N pings. This is a rough measure of our RPC latency. func BenchmarkWorkerPing(b *testing.B) { if race.Enabled { b.Skip("TODO(48504): fix and re-enable") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 4.8K 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)