- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 343 for connect0 (0.14 sec)
-
src/os/exec/exec.go
Stdin io.Reader // Stdout and Stderr specify the process's standard output and error. // // If either is nil, Run connects the corresponding file descriptor // to the null device (os.DevNull). // // If either is an *os.File, the corresponding output from the process // is connected directly to that file. // // Otherwise, during the execution of the command a separate goroutine
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/test/groovy/org/gradle/api/internal/tasks/testing/worker/TestWorkerTest.groovy
1 * connection.addOutgoing(TestResultProcessor) >> resultProcessor 1 * connection.addIncoming(RemoteTestClassProcessor, worker) 1 * connection.useParameterSerializers(_) 1 * connection.connect() >> { start { worker.startProcessing() worker.processTestClass(test) thread.block() instant.stopped worker.stop()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/grid/benchmark_test.go
})) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload) errFatal(err) // Wait for all to connect // Parallel writes per server. b.Run("bytes", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) { defer timeout(60 * time.Second)()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
pilot/test/xds/fake.go
adscConn.Close() }) return adscConn } // Connect starts an ADS connection to the server using adsc. It will automatically be cleaned up when the test ends // watch can be configured to determine the resources to watch initially, and wait can be configured to determine what // resources we should initially wait for. func (f *FakeDiscoveryServer) Connect(p *model.Proxy, watch []string, wait []string) *adsc.ADSC { f.t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
platforms/software/resources/src/main/java/org/gradle/internal/resource/connector/ResourceConnectorFactory.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.resource.connector; import org.gradle.authentication.Authentication; import org.gradle.internal.resource.transfer.ExternalResourceConnector; import org.gradle.internal.service.scopes.Scope;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go
conn, err := tls.Dial("tcp", addr, &tls.Config{ RootCAs: roots, ServerName: test.ServerName, // used for SNI in the client HELLO packet }) if err != nil { t.Fatalf("failed to connect: %v", err) } defer conn.Close() // check returned server certificate sig := x509CertSignature(conn.ConnectionState().PeerCertificates[0]) gotCertIndex, found := signatures[sig] if !found {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 15:52:39 UTC 2024 - 13.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/IncomingConnector.java
* @param allowRemote If true, only allow connections from remote machines. If false, allow only from the local machine. * @return the address of the endpoint which the connector is listening on. */ ConnectionAcceptor accept(Action<ConnectCompletion> action, boolean allowRemote);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheServices.kt
import org.gradle.internal.extensions.core.add import org.gradle.internal.nativeintegration.filesystem.FileSystem import org.gradle.internal.resource.connector.ResourceConnectorFactory import org.gradle.internal.resource.connector.ResourceConnectorSpecification import org.gradle.internal.resource.transfer.ExternalResourceConnector import org.gradle.internal.service.Provides
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 8.2K bytes - Viewed (0) -
src/net/http/transport.go
// ProxyConnectHeader optionally specifies headers to send to // proxies during CONNECT requests. // To set the header dynamically, see GetProxyConnectHeader. ProxyConnectHeader Header // GetProxyConnectHeader optionally specifies a func to return // headers to send to proxyURL during a CONNECT request to the // ip:port target. // If it returns an error, the Transport's RoundTrip fails with
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
cni/README.md
- currently implemented for k8s only - on pod add, determines whether pod should have netns setup to redirect to Istio proxy. See [cmdAdd](#cmdadd-workflow) for detailed logic. - it connects to K8S using the kubeconfig and JWT token copied from install-cni to get Pod and Namespace. Since this is a short-running command, each invocation creates a new connection.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 03 19:29:42 UTC 2024 - 12.3K bytes - Viewed (0)