- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,605 for connectTo (2.86 sec)
-
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) -
src/database/sql/driver/driver.go
// // If a [Conn] implements [Validator], then the IsValid method is called // before returning the connection to the connection pool. If an entry in the // connection pool implements [SessionResetter], then ResetSession // is called before reusing the connection for another query. If a connection is // never returned to the connection pool but is immediately reused, then // ResetSession is called prior to reuse but IsValid is not called.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 09:04:12 UTC 2023 - 20.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ToolingApiRemoteIntegrationTest.groovy
@Issue('https://github.com/gradle/gradle/issues/15405') def "calling disconnect on uninitialized connection does not trigger wrapper download"() { when: def connector = toolingApi.connector() connector.useDistribution(URI.create("http://localhost:${server.port}/custom-dist.zip")) connector.connect() connector.disconnect() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 10.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ToolingApiShutdownIntegrationTest.groovy
GradleConnector connector = GradleConnector.newConnector().useGradleVersion("6.8-20201118175938+0000"); // can be changed to latest release after 6.8 is available ProjectConnection connection = connector.forProjectDirectory(projectLocation).connect(); connection.newBuild().forTasks("help").run(new ResultHandler<Void>() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 3.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/TcpOutgoingConnector.java
private static final int CONNECT_TIMEOUT = 10000; @Override public ConnectCompletion connect(Address destinationAddress) throws org.gradle.internal.remote.internal.ConnectException { if (!(destinationAddress instanceof InetEndpoint)) { throw new IllegalArgumentException(String.format("Cannot create a connection to address of unknown type: %s.", destinationAddress)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 4.8K 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) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertEvents( "plan 1 TCP connected", "plan 0 cancel", "plan 1 TLS connecting...", "plan 1 TLS connect failed", "plan 2 TCP connecting...", "plan 2 TCP connected", "plan 2 TLS connecting...", "plan 2 TLS connected", ) taskFaker.advanceUntil(270.ms) assertEvents( "plan 0 TCP connect canceled", )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonServerConnector.java
*/ package org.gradle.launcher.daemon.server; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.remote.Address; /** * Opens a server connection for clients to connect to communicate with a daemon. * <p> * A server connector should only be used by one daemon, and has a single use lifecycle. * Implementations must be threadsafe so that start/stop can be called from different threads. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0) -
src/net/internal/socktest/switch.go
Opened uint64 // number of sockets opened Connected uint64 // number of sockets connected Listened uint64 // number of sockets listened Accepted uint64 // number of sockets accepted Closed uint64 // number of sockets closed OpenFailed uint64 // number of sockets open failed ConnectFailed uint64 // number of sockets connect failed ListenFailed uint64 // number of sockets listen failed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
// Every time envoy makes a fresh connection to the agent, we reestablish a new connection to the upstream xds // This ensures that a new connection between istiod and agent doesn't end up consuming pending messages from envoy // as the new connection may not go to the same istiod. Vice versa case also applies.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0)