- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 251 for CONNECT (0.06 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt
* That may happen later by the connection pool thread. */ fun cancel() /** * Carries an exchange. This is usually a connection, but it could also be a connect plan for * CONNECT tunnels. Note that CONNECT tunnels are significantly less capable than connections. */ interface Carrier { val route: Route fun trackFailure( call: RealCall, e: IOException?, )
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 3.3K bytes - Viewed (0) -
cmd/prepare-storage.go
if errors.Is(err, errDiskNotFound) && verboseLogging { if globalEndpoints.NEndpoints() > 1 { logger.Info("Unable to connect to %s: %v, will be retried", endpoints[i], isServerResolvable(endpoints[i], time.Second)) } else { logger.Fatal(err, "Unable to connect to %s: %v", endpoints[i], isServerResolvable(endpoints[i], time.Second)) } } else { if globalEndpoints.NEndpoints() > 1 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
src/test/java/jcifs/util/transport/TransportTest.java
class ConnectionLifecycleTests { @Test @DisplayName("connect should return true if already connected") void shouldReturnTrueIfAlreadyConnected() throws TransportException { transport.setState(3); // Connected assertTrue(transport.connect(1000)); } @Test @DisplayName("connect should throw TransportException on connection failure")Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponse.java
import jcifs.internal.TreeConnectResponse; import jcifs.internal.smb2.ServerMessageBlock2; import jcifs.internal.smb2.ServerMessageBlock2Response; import jcifs.internal.util.SMBUtil; /** * SMB2 Tree Connect response message. * * This response contains information about the connected * tree, including share type and capabilities. * * @author mbechler */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeHandleImpl.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 11.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from // the pool. We have a better chance of matching thanks to connection coalescing. val pooled2 = planReusePooledConnection(connect, connect.routes) if (pooled2 != null) return pooled2 return connect } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 12K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaProvider.java
} @Override public RdmaConnection connect(String hostname, int port) throws IOException { InetSocketAddress remoteAddress = new InetSocketAddress(hostname, port); RdmaConnection connection = createConnection(remoteAddress, null); connection.connect(); return connection; } @OverrideRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 5.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
if (waitForState(transport) == 2) { // finished connecting return null; } // failure to connect throw new SmbException("Tree disconnected while waiting for connection"); } if (before == 2) { // concurrently connected
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 30K bytes - Viewed (0) -
guava/src/com/google/common/graph/Network.java
Graph<N> asGraph(); // // Network properties // /** * Returns true if the edges in this network are directed. Directed edges connect a {@link * EndpointPair#source() source node} to a {@link EndpointPair#target() target node}, while * undirected edges connect a pair of nodes to each other. */ boolean isDirected(); /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 22:03:02 UTC 2025 - 22.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
delegate!!.bind(localAddr) } @Throws(IOException::class) override fun connect(remoteAddr: SocketAddress) { delegate!!.connect(remoteAddr) } @Throws(IOException::class) override fun connect( remoteAddr: SocketAddress, timeout: Int, ) { delegate!!.connect(remoteAddr, timeout) } override fun isInputShutdown(): Boolean = delegate!!.isInputShutdown
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.4K bytes - Viewed (0)