Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 51 for stoppable (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java

                throw new MessageIOException(String.format("Could not write '%s'.", remoteAddress), e);
            }
        }
    
        @Override
        public void stop() {
            CompositeStoppable.stoppable(new Closeable() {
                @Override
                public void close() throws IOException {
                    flush();
                }
            }, instr, outstr, socket).stop();
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java

                    } else {
                        return object;
                    }
                }
            } finally {
                // Stop cancelling before sending end-of-input
                CompositeStoppable.stoppable(cancelForwarder, inputForwarder).stop();
            }
        }
    
        private Result<?> handleDaemonDisappearance(Build build, DaemonDiagnostics diagnostics) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 19:54:56 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  9. subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultIncludedBuildTaskGraphParallelTest.groovy

                    preparer,
                    MONITOR_POLL_TIME,
                    TimeUnit.MILLISECONDS
                )
            }
    
            void stop() {
                CompositeStoppable.stoppable(buildTaskGraph, planExecutor, workerLeaseService, coordinationService, execFactory).stop()
            }
        }
    
        private static class TestNode extends Node implements SelfExecutingNode {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  10. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintWriter.kt

         */
        fun close() {
            synchronized(this) {
                closestChangingValue?.let {
                    buildScopedSink.write(it)
                }
            }
            CompositeStoppable.stoppable(buildScopedWriter, projectScopedWriter).stop()
        }
    
        override fun scriptSourceObserved(scriptSource: ScriptSource) {
            if (isInputTrackingDisabled()) {
                return
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 32.8K bytes
    - Viewed (0)
Back to top