- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 4,772 for startm (0.25 sec)
-
pkg/envoy/agent.go
activeConnectionsURL := fmt.Sprintf("http://%s/stats?usedonly&filter=downstream_cx_active$", adminHost) stats, err := http.DoHTTPGetWithTimeout(activeConnectionsURL, 2*time.Second) if err != nil { return -1, fmt.Errorf("unable to get listener stats from Envoy : %v", err) } if stats.Len() == 0 { return -1, nil } activeConnections := 0 for stats.Len() > 0 { line, _ := stats.ReadString('\n')
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerControl.java
*/ package org.gradle.process.internal.worker; import org.gradle.process.ExecResult; public interface WorkerControl { /** * Starts the worker process, blocking until successfully started. */ WorkerProcess start(); /** * Requests that the worker complete all work and stop. Blocks until the worker process has stopped. */ ExecResult stop(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:54:37 UTC 2024 - 1.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/types.go
) // Manager manages all the DRA resource plugins running on a node. type Manager interface { // Start starts the reconcile loop of the manager. // This will ensure that all claims are unprepared even if pods get deleted unexpectedly. Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error // PrepareResources prepares resources for a pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 2.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DeploymentHandle.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 11 20:41:54 UTC 2018 - 1.2K bytes - Viewed (0) -
src/net/http/example_filesystem_test.go
// It is used to wrap the Readdir method of http.File so that we can // remove files and directories that start with a period from its output. type dotFileHidingFile struct { http.File } // Readdir is a wrapper around the Readdir method of the embedded File // that filters out all files that start with a period in their name. func (f dotFileHidingFile) Readdir(n int) (fis []fs.FileInfo, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 20 02:32:42 UTC 2020 - 2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DeploymentRegistry.java
import javax.annotation.Nullable; /** * A registry of deployment handles. * * @since 4.2 */ @ThreadSafe public interface DeploymentRegistry { /** * Creates and starts a given deployment handle in the registry. * * @param name name of deployment * @param changeBehavior how the deployment responds to potential changes * @param handleType type of deployment handle
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Mar 23 06:23:31 UTC 2019 - 2.4K bytes - Viewed (0) -
src/runtime/debug/example_monitor_test.go
if err != nil { log.Fatalf("StdinPipe: %v", err) } debug.SetCrashOutput(pipe.(*os.File), debug.CrashOptions{}) // (this conversion is safe) if err := cmd.Start(); err != nil { log.Fatalf("can't start monitor: %v", err) } // Now return and start the application proper...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:19:04 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/ByteOutput.java
this.file = file; bufferedOutputStream = new ResettableBufferedOutputStream(new RandomAccessFileOutputStream(file)); } /** * Starts writing to the given offset. Can be beyond the current length of the file. */ public DataOutputStream start(long offset) throws IOException { file.seek(offset); bufferedOutputStream.clear();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReuseIntegrationTest.groovy
waitFor("started") daemons.daemon.assertBusy() client.kill() daemons.daemon.becomesCanceled() when: def build = executer.withTasks("help").withArguments("--info").start() ConcurrentTestUtil.poll { assert build.standardOutput.contains(DaemonMessages.WAITING_ON_CANCELED) } release("block")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 10.1K bytes - Viewed (0)