Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 251 for CONNECT (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. src/main/java/jcifs/smb/SmbTreeHandleImpl.java

                return transport.isSMB2();
            } catch (final SmbException e) {
                log.debug("Failed to connect for determining SMB2 support", e);
                return false;
            }
        }
    
        /**
         * @return whether this tree handle uses SMB3
         */
        public boolean isSMB3() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  6. 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)
  7. 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;
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top