- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,340 for connector (0.16 sec)
-
src/syscall/tables_wasip1.go
EALREADY: "Socket already connected", EBADF: "Bad file number", EBADMSG: "Trying to read unreadable message", EBUSY: "Device or resource busy", ECANCELED: "Operation canceled.", ECHILD: "No child processes", ECONNABORTED: "Connection aborted", ECONNREFUSED: "Connection refused", ECONNRESET: "Connection reset by peer",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 20:58:35 UTC 2023 - 6.5K bytes - Viewed (0) -
pkg/registry/core/node/rest/proxy.go
) // ProxyREST implements the proxy subresource for a Node type ProxyREST struct { Store *genericregistry.Store Connection client.ConnectionInfoGetter ProxyTransport http.RoundTripper } // Implement Connecter var _ = rest.Connecter(&ProxyREST{}) var proxyMethods = []string{"GET", "POST", "PUT", "PATCH", "DELETE", "HEAD", "OPTIONS"} // New returns an empty nodeProxyOptions object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 19 13:59:13 UTC 2022 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
import java.io.Closeable import java.io.IOException import java.util.concurrent.LinkedBlockingDeque import okhttp3.internal.concurrent.TaskFaker import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RoutePlanner import okhttp3.internal.connection.RoutePlanner.ConnectResult class FakeRoutePlanner( val factory: TestValueFactory = TestValueFactory(), val taskFaker: TaskFaker = factory.taskFaker,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
override fun connectionConnectEnd( connection: Connection, route: Route, ) { poolConnectionListener.connectEnd(connection, route, call) } override fun connectionAcquired(connection: Connection) { eventListener.connectionAcquired(call, connection) } override fun acquireConnectionNoEvents(connection: RealConnection) { call.acquireConnectionNoEvents(connection) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
src/net/internal/socktest/sys_windows.go
return so.Err } sw.stats.getLocked(so.Cookie).Connected++ return nil } // ConnectEx wraps [syscall.ConnectEx]. func (sw *Switch) ConnectEx(s syscall.Handle, sa syscall.Sockaddr, b *byte, n uint32, nwr *uint32, o *syscall.Overlapped) (err error) { so := sw.sockso(s) if so == nil { return syscall.ConnectEx(s, sa, b, n, nwr, o) } sw.fmu.RLock() f, _ := sw.fltab[FilterConnect]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
*/ package okhttp3.internal.connection import java.io.IOException import okhttp3.Address import okhttp3.HttpUrl /** * Policy on choosing which connection to use for an exchange and any retries that follow. This uses * the following strategies: * * 1. If the current call already has a connection that can satisfy the request it is used. Using
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 4.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r56/TestLauncherDebugTestsCrossVersionTest.groovy
} """ } def "build fails if debugger is not ready"() { setup: // port is assigned but not connected def port = jdwpClient.port when: withConnection { connection -> connection.newTestLauncher() .withJvmTestClasses("example.MyTest") .debugTestsOn(port) .run() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/SmbTransportPool.java
* whether to acquire an unshared connection * @param forceSigning * whether to enforce SMB signing on this connection * @return a transport connection to the target */ SmbTransport getSmbTransport ( CIFSContext tc, Address address, int port, boolean exclusive, boolean forceSigning ); /** * Get transport connection, with local binding * * @param tc
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun May 17 09:02:44 UTC 2020 - 6.3K bytes - Viewed (0) -
istioctl/pkg/kubeinject/testdata/mesh-config.yaml
# diagnostic information from Envoy. See # https://lyft.github.io/envoy/docs/operations/admin.html # for more details proxyAdminPort: 15000 # # Zipkin trace collector zipkinAddress: "" # # Statsd metrics collector converts statsd metrics into Prometheus metrics. statsdUdpAddress: "" # # Mutual TLS authentication between sidecars and istio control plane. controlPlaneAuthPolicy: NONE #
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/StaleDaemonAddressException.java
* limitations under the License. */ package org.gradle.launcher.daemon.client; /** * Thrown when connected to a stale daemon address. * * This is thrown instead of using an initial handshake on the connection, to avoid the latency of a round trip to the * daemon before starting the build. */ public class StaleDaemonAddressException extends DaemonConnectionException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1K bytes - Viewed (0)