- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 72 for stoppable (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
} return tlsConfig, nil } // Serve runs the secure http server. It fails only if certificates cannot be loaded or the initial listen call fails. // The actual server loop (stoppable by closing stopCh) runs in a go routine, i.e. Serve does not block. // It returns a stoppedCh that is closed when all non-hijacked active requests have been processed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
platforms/jvm/language-groovy/src/main/java/org/gradle/api/internal/tasks/compile/ApiGroovyCompiler.java
compilerGroovyLoader.discardTypesFrom(astTransformClassLoader); //Discard the compile loader compileClasspathLoader.shutdown(); CompositeStoppable.stoppable(classPathLoader, astTransformClassLoader).stop(); } } /** * Returns true if the exception is fatal, unrecoverable for the incremental compilation. Example of such error: * <pre>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 20.7K bytes - Viewed (0) -
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) -
subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultIncludedBuildTaskGraphParallelTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 20.6K bytes - Viewed (0) -
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) -
platforms/software/testing-base/src/main/java/org/gradle/api/tasks/testing/AbstractTestTask.java
} else { testReporter.generateReport(testResultsProvider, html.getOutputLocation().getAsFile().getOrNull()); } } finally { CompositeStoppable.stoppable(testResultsProvider).stop(); testReporter = null; } } /** * Sets the test name patterns to be included in execution.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 18:49:01 UTC 2024 - 27.6K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/main/java/org/gradle/api/tasks/testing/Test.java
forkOptions.systemProperty(TestWorker.WORKER_TMPDIR_SYS_PROPERTY, new File(getTemporaryDir(), "work")); try { super.executeTests(); } finally { CompositeStoppable.stoppable(getTestFramework()); } } @Override protected TestExecuter<JvmTestExecutionSpec> createTestExecuter() { if (testExecuter == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 42.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/services/internal/DefaultBuildServicesRegistryTest.groovy
def provider3 = registerService("three", StoppableServiceImpl) when: def notStoppable = provider1.get() def stoppable1 = provider2.get() def stoppable2 = provider3.get() then: ServiceImpl.instances == [notStoppable, stoppable1, stoppable2] when: buildFinished() then: ServiceImpl.instances == [notStoppable] }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 16.4K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/apply.go
} if len(versionSkewErrs.Skippable) > 0 { // Return the error if the user hasn't specified the --force flag if !flags.force { return errors.Errorf("the --version argument is invalid due to these errors:\n\n%v\nCan be bypassed if you pass the --force flag", kubeadmutil.FormatErrMsg(versionSkewErrs.Skippable)) } // Soft errors found, but --force was specified
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 03:55:23 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/policy_test.go
} // Otherwise, just move on with the next test return } if len(actualSkewErrs.Skippable) != rt.expectedSkippableErrs { t.Errorf("failed TestEnforceVersionPolicies\n\texpected skippable errors: %d\n\tgot skippable errors: %d\n%#v\n%#v", rt.expectedSkippableErrs, len(actualSkewErrs.Skippable), *rt.vg, actualSkewErrs) } if len(actualSkewErrs.Mandatory) != rt.expectedMandatoryErrs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 03:17:05 UTC 2023 - 9.9K bytes - Viewed (0)