- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 479 for coordinator (0.15 sec)
-
tensorflow/cc/training/queue_runner_test.cc
#include "tensorflow/cc/training/queue_runner.h" #include <string> #include <vector> #include "tensorflow/cc/framework/scope.h" #include "tensorflow/cc/ops/standard_ops.h" #include "tensorflow/cc/training/coordinator.h" #include "tensorflow/core/framework/graph.pb.h" #include "tensorflow/core/framework/tensor.h" #include "tensorflow/core/framework/tensor_shape.h" #include "tensorflow/core/framework/types.pb.h"
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Sep 21 06:27:51 UTC 2019 - 14.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
@Test fun onlyOneCoordinatorWaitingToStartFutureTasks() { // Enqueueing the red task starts a coordinator thread. redQueue.execute("red task", 100.µs) { log += "red:run@${taskFaker.nanoTime}" } assertThat(taskFaker.executeCallCount).isEqualTo(1) // Enqueueing the blue task doesn't need a 2nd coordinator yet. blueQueue.execute("blue task", 200.µs) { log += "blue:run@${taskFaker.nanoTime}" }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
src/testing/fuzz.go
return !t.Failed() } switch f.fuzzContext.mode { case fuzzCoordinator: // Fuzzing is enabled, and this is the test process started by 'go test'. // Act as the coordinator process, and coordinate workers to perform the // actual fuzzing. corpusTargetDir := filepath.Join(corpusDir, f.name) cacheTargetDir := filepath.Join(*fuzzCacheDir, f.name) err := f.fuzzContext.deps.CoordinateFuzzing(
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 22.9K bytes - Viewed (0) -
build-logic/performance-testing/src/main/kotlin/gradlebuild/performance/tasks/DetermineBaselines.kt
} else { determinedBaselines = forkPointCommitBaseline() } println("Determined baseline is: ${determinedBaselines.get()}") } /** * Coordinator build doesn't resolve to real commit version, they just pass "flakiness-detection-commit" as it is to worker build * "flakiness-detection-commit" is resolved to real commit id in worker build to disable build cache. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 21 09:29:24 UTC 2023 - 4.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanTest.groovy
executionPlan?.close() new DefaultExecutionPlan(Path.ROOT.toString(), taskNodeFactory, new OrdinalGroupFactory(), dependencyResolver, accessHierarchies.outputHierarchy, accessHierarchies.destroyableHierarchy, coordinator) } def "schedules tasks in dependency order"() { given: Task a = task("a") Task b = task("b", dependsOn: [a]) Task c = task("c", dependsOn: [b, a])
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 35.5K bytes - Viewed (0) -
src/testing/internal/testdeps/deps.go
// to all processes in that group. This is not the case on Windows. // If the worker is interrupted, return quickly and without error. // If only the coordinator process is interrupted, it tells each worker // process to stop by closing its "fuzz_in" pipe. ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt) defer cancel() err := fuzz.RunFuzzWorker(ctx, fn)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 14:01:23 UTC 2024 - 6.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/AbstractExecutionPlanSpec.groovy
private def locks = new ArrayList<MockLock>() private def acquired = new HashSet<MockLock>() def thisBuild = backing.gradle def project = project() def nodeValidator = Mock(NodeValidator) def coordinator = new DefaultResourceLockCoordinationService() protected Set<ProjectInternal> getLockedProjects() { return locks.findAll { it.locked }.collect { it.project } as Set }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 24 11:56:02 UTC 2023 - 7.3K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/report/AbstractTablePageGenerator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 15.8K bytes - Viewed (0) -
src/cmd/dist/test.go
"cmd/internal/testdir": true, } // Fast path to avoid the ~1 second of `go list std cmd` when // the caller lists specific tests to run. (as the continuous // build coordinator does). if len(t.runNames) > 0 { for _, name := range t.runNames { if !strings.Contains(name, ":") { t.registerStdTest(name) } else if strings.HasSuffix(name, ":racebench") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/coordination.k8s.io.v1.Lease.yaml
apiVersion: coordination.k8s.io/v1 kind: Lease metadata: annotations: annotationsKey: annotationsValue creationTimestamp: "2008-01-01T01:01:01Z" deletionGracePeriodSeconds: 10 deletionTimestamp: "2009-01-01T01:01:01Z" finalizers: - finalizersValue generateName: generateNameValue generation: 7 labels: labelsKey: labelsValue managedFields: - apiVersion: apiVersionValue fieldsType: fieldsTypeValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 1K bytes - Viewed (0)