Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 79 for stoppable (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top