- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 72 for stoppable (0.17 sec)
-
subprojects/build-events/src/main/java/org/gradle/internal/build/event/DefaultBuildEventsListenerRegistry.java
subscribed.stream() .flatMap(it -> it.getListeners().stream()) .forEach(this::unsubscribe); CompositeStoppable.stoppable(subscribed).stop(); } finally { subscriptions.clear(); } } private void unsubscribe(Object listener) { listenerManager.removeListener(listener);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 19:34:01 UTC 2024 - 12.5K bytes - Viewed (0) -
subprojects/composite-builds/src/main/java/org/gradle/composite/internal/DefaultIncludedBuildTaskGraph.java
return new TaskBackedResource(workGraph, build, taskNode); }); } @Override public void close() throws IOException { CompositeStoppable.stoppable(executorService); } private <T> T withState(Function<DefaultBuildTreeWorkGraph, T> action) { DefaultBuildTreeWorkGraph workGraph = current.get(); if (workGraph == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 10:04:24 UTC 2024 - 11.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleExecuter.java
import org.gradle.api.logging.configuration.ConsoleOutput; import org.gradle.api.logging.configuration.WarningMode; import org.gradle.integtests.fixtures.RichConsoleStyling; import org.gradle.internal.concurrent.Stoppable; import org.gradle.test.fixtures.file.TestDirectoryProvider; import org.gradle.test.fixtures.file.TestFile; import org.gradle.util.GradleVersion; import org.gradle.util.internal.TextUtil; import java.io.File;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 20.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DefaultDaemonStarter.java
handle.waitForFinish(); LOGGER.debug("Gradle daemon process is now detached."); } finally { CompositeStoppable.stoppable(execActionFactory).stop(); } return daemonGreeter.parseDaemonOutput(outputConsumer.getProcessOutput(), args); } catch (GradleException e) { throw e;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 10.7K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl-provider-plugins/src/main/kotlin/org/gradle/kotlin/dsl/provider/plugins/precompiled/tasks/GeneratePrecompiledScriptPluginAccessors.kt
import org.gradle.internal.classpath.ClassPath import org.gradle.internal.classpath.DefaultClassPath import org.gradle.internal.component.local.model.OpaqueComponentIdentifier import org.gradle.internal.concurrent.CompositeStoppable.stoppable import org.gradle.internal.exceptions.LocationAwareException import org.gradle.internal.hash.HashCode import org.gradle.internal.resource.TextFileResourceLoader import org.gradle.kotlin.dsl.accessors.AccessorFormats
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:10:49 UTC 2024 - 24.8K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/SystemApplicationClassLoaderWorker.java
} finally { try { loggingManager.removeOutputEventListener(workerLogEventListener); CompositeStoppable.stoppable(connection, basicWorkerServices).stop(); loggingManager.stop(); } catch (Throwable t) { // We're failing while shutting down, so log whatever might have happened.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/ClassLoaderUtils.java
public static ClassLoader getPlatformClassLoader() { return ClassLoader.getSystemClassLoader().getParent(); } public static void tryClose(@Nullable ClassLoader classLoader) { CompositeStoppable.stoppable(classLoader).stop(); } // Used by the Gradle Play Framework Plugin. See: // https://github.com/gradle/playframework/blob/master/src/main/java/org/gradle/playframework/tools/internal/run/PlayWorkerServer.java#L72
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 11.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/DefaultCachedClasspathTransformer.java
this.classpathElementTransformFactoryForLegacy = classpathElementTransformFactoryForLegacy; } @Override public void close() { CompositeStoppable.stoppable(executor, cache).stop(); } @Override public ClassPath transform(ClassPath classPath, StandardTransform transform) { if (classPath.isEmpty()) { return classPath; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 14.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/AbstractFileLockManagerTest.groovy
metaDataProvider.processDisplayName >> 'process' contentionHandler.reservePort() >> 34 generator.asLong >> 678L } def cleanup() { CompositeStoppable.stoppable(openedLocks.toArray()).stop() } def "readFile throws integrity exception when not cleanly unlocked file"() { given: unlockUncleanly() and: def lock = createLock(lockMode)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 13.6K bytes - Viewed (0)