Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 171 for stopCh (0.26 sec)

  1. pkg/kubelet/certificate/kubelet.go

    	var ctx context.Context
    	ctx, m.cancelFn = context.WithCancel(context.Background())
    	go m.dynamicCertificateContent.Run(ctx, 1)
    }
    
    // Stop stops watching the certificate and key files
    func (m *kubeletServerCertificateDynamicFileManager) Stop() {
    	if m.cancelFn != nil {
    		m.cancelFn()
    	}
    }
    
    // ServerHealthy always returns true since the file manager doesn't communicate with any server
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 03:07:16 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. src/runtime/gc_test.go

    		start := time.Now()
    		runtime.ReadMemStats(&ms)
    		latencies = append(latencies, time.Since(start))
    	}
    	// Make sure to stop the timer before we wait! The load created above
    	// is very heavy-weight and not easy to stop, so we could end up
    	// confusing the benchmarking framework for small b.N.
    	b.StopTimer()
    	stop()
    
    	// Disable the default */op metrics.
    	// ns/op doesn't mean anything because it's an average, but we
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 05 22:33:52 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  3. platforms/documentation/docs/src/docs/userguide/optimizing-performance/gradle_daemon.adoc

    [[sec:stopping_an_existing_daemon]]
    == Stop Daemon
    
    It can be helpful to stop the Daemon when troubleshooting or debugging a failure.
    
    Daemons automatically stop given any of the following conditions:
    
    * Available system memory is low
    * Daemon has been idle for 3 hours
    
    To stop running Daemon processes, use the following command:
    
    ----
    $ gradle --stop
    ----
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 12:43:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/phases/join/kubelet.go

    		}
    	}
    
    	// Configure the kubelet. In this short timeframe, kubeadm is trying to stop/restart the kubelet
    	// Try to stop the kubelet service so no race conditions occur when configuring it
    	if !data.DryRun() {
    		klog.V(1).Infoln("[kubelet-start] Stopping the kubelet")
    		kubeletphase.TryStopKubelet()
    	} else {
    		fmt.Println("[kubelet-start] Would stop the kubelet")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/dra/plugin/noderesources.go

    // all responses that it gets for processing in the sync method. It keeps
    // retrying until an error or EOF response indicates that no further data is
    // going to be sent, then watch resources of the plugin stops until it
    // re-registers.
    func (c *nodeResourcesController) monitorPlugin(ctx context.Context, active *activePlugin, driverName string, pluginInstance *plugin) {
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 20:12:53 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. platforms/core-execution/build-cache-local/src/integTest/groovy/org/gradle/caching/local/internal/AbstractBuildCacheCleanupIntegrationTest.groovy

        }
    
        private long initializeHome() {
            executer.requireIsolatedDaemons() // needs to stop daemon
            requireOwnGradleUserHomeDir() // needs its own journal
            run() // Make sure cache directory is initialized
            run '--stop' // ensure daemon does not cache file access times in memory
            return gcFile().makeOlder().lastModified()
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 14 16:53:17 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. platforms/jvm/testing-junit-platform/src/main/java/org/gradle/api/internal/tasks/testing/junitplatform/JUnitPlatformTestClassProcessor.java

            testClassExecutor = new CollectAllTestClassesExecutor(threadSafeResultProcessor);
            return testClassExecutor;
        }
    
        @Override
        public void stop() {
            testClassExecutor.processAllTestClasses();
            launcherSession.close();
            super.stop();
        }
    
        private class CollectAllTestClassesExecutor implements Action<String> {
            private final List<Class<?>> testClasses = new ArrayList<>();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 15:59:04 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java

            }
        }
    
        @Override
        public void stop() {
            CompositeStoppable.stoppable(new Closeable() {
                @Override
                public void close() throws IOException {
                    flush();
                }
            }, instr, outstr, socket).stop();
        }
    
        private static class SocketInputStream extends InputStream {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  9. 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.
                    unrecoverableErrorHandler.execute(t);
                }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  10. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintWriter.kt

                )
            )
        }
    
        /**
         * Stops all writers.
         *
         * **MUST ALWAYS BE CALLED**
         */
        fun close() {
            synchronized(this) {
                closestChangingValue?.let {
                    buildScopedSink.write(it)
                }
            }
            CompositeStoppable.stoppable(buildScopedWriter, projectScopedWriter).stop()
        }
    
    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