- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for getWorker (0.14 sec)
-
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/WorkerDaemonFactoryTest.groovy
} def "getting a worker daemon does not assume client use"() { when: factory.getWorker(requirement); then: 0 * clientsManager._ } def "new client is created when daemon is executed and no idle clients found"() { when: factory.getWorker(requirement).execute(spec) then: 1 * clientsManager.reserveIdleClient(options) >> null
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:57:50 UTC 2024 - 4K bytes - Viewed (0) -
pkg/filewatcher/filewatcher.go
ws, cleanedPath, _, err := fw.getWorker(path) if err != nil { return err } if err = ws.worker.addPath(cleanedPath); err == nil { ws.count++ } return err } // Stop watching a path func (fw *fileWatcher) Remove(path string) error { fw.mu.Lock() defer fw.mu.Unlock() ws, cleanedPath, parentPath, err := fw.getWorker(path) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/DefaultWorkerExecutorTest.groovy
1 * executionQueue.submit(_) >> { args -> task = args[0] } when: task.getExecution().run() then: 1 * workerDaemonFactory.getWorker(_) >> worker 1 * worker.execute(_, _) >> { spec, buildOperation -> assert spec.implementationClass == TestExecutable.class return new DefaultWorkResult(true, null) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 11 15:27:52 UTC 2024 - 8.3K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerFactory.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.workers.internal; public interface WorkerFactory { BuildOperationAwareWorker getWorker(WorkerRequirement workerRequirement);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 768 bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
return result == results.Success } // if there is a startup probe which hasn't run yet, the container is not // started. if _, exists := m.getWorker(pod.UID, containerStatus.Name, startup); exists { return false } // there is no startup probe, so the container is started. return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonFactory.java
this.buildOperationRunner = buildOperationRunner; this.workerDaemonClientCancellationHandler = workerDaemonClientCancellationHandler; } @Override public BuildOperationAwareWorker getWorker(WorkerRequirement workerRequirement) { return new AbstractWorker(buildOperationRunner) { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 13:20:59 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/IsolatedClassloaderWorkerFactory.java
this.actionExecutionSpecFactory = actionExecutionSpecFactory; this.instantiatorFactory = instantiatorFactory; } @Override public BuildOperationAwareWorker getWorker(WorkerRequirement workerRequirement) { return new AbstractWorker(buildOperationRunner) { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 3.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerProcessBuilder.java
@Override WorkerProcessBuilder sharedPackages(Iterable<String> packages); @Override WorkerProcessBuilder sharedPackages(String... packages); Action<? super WorkerProcessContext> getWorker(); void setImplementationClasspath(List<URL> implementationClasspath); void setImplementationModulePath(List<URL> implementationModulePath); void enableJvmMemoryInfoPublishing(boolean shouldPublish);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 12:13:32 UTC 2024 - 2.6K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/NoIsolationWorkerFactory.java
public void setWorkerExecutor(WorkerExecutor workerExecutor) { this.workerExecutor = workerExecutor; } @Override public BuildOperationAwareWorker getWorker(WorkerRequirement workerRequirement) { final WorkerExecutor workerExecutor = this.workerExecutor; final ClassLoader contextClassLoader = ((FixedClassLoaderWorkerRequirement) workerRequirement).getContextClassLoader();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/jvm/language-jvm/src/main/java/org/gradle/api/internal/tasks/compile/daemon/AbstractIsolatedCompilerWorkerExecutor.java
IsolatedClassLoaderWorkerRequirement workerRequirement = getIsolatedWorkerRequirement(daemonForkOptions); BuildOperationAwareWorker worker = workerFactory.getWorker(workerRequirement); return worker.execute(actionExecutionSpecFactory.newIsolatedSpec("compiler daemon", CompilerWorkAction.class, parameters, workerRequirement, true)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 19 13:37:02 UTC 2023 - 4.1K bytes - Viewed (0)