Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 314 for connectEnd (0.67 sec)

  1. guava/src/com/google/common/graph/NetworkConnections.java

      Set<N> adjacentNodes();
    
      Set<N> predecessors();
    
      Set<N> successors();
    
      Set<E> incidentEdges();
    
      Set<E> inEdges();
    
      Set<E> outEdges();
    
      /**
       * Returns the set of edges connecting the origin node to {@code node}. For networks without
       * parallel edges, this set cannot be of size greater than one.
       */
      Set<E> edgesConnecting(N node);
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. helm-releases/minio-5.4.0.tgz

    available connectToMinio() { SCHEME=$1 ATTEMPTS=0 LIMIT=29 # Allow 30 attempts set -e # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) SECRET=$(cat /config/rootPassword) set +e # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" $MC_COMMAND STATUS=$? until [ $STATUS = 0 ]; do ATTEMPTS=$(expr $ATTEMPTS + 1) echo \"Failed attempts:...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jan 03 05:34:47 UTC 2025
    - 21.7K bytes
    - Viewed (0)
  3. helm-releases/minio-3.6.2.tgz

    connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Mar 17 18:30:55 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  4. internal/dsync/dsync-client_test.go

    		u:    u,
    		rest: rest.NewClient(u, tr, nil),
    	}
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) IsOnline() bool {
    	// If rest client has not connected yet there is nothing to close.
    	return restClient.rest != nil
    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

       * certificate pin checks.
       */
      fun sameHostAndPort(url: HttpUrl): Boolean
    
      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
       * These steps are split so callers can call [connectTcp] on a background thread if attempting
       * multiple plans concurrently.
       */
      interface Plan {
        val isReady: Boolean
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Route.kt

     *
     *  * **HTTP proxy:** a proxy server may be explicitly configured for the client. Otherwise, the
     *    [proxy selector][java.net.ProxySelector] is used. It may return multiple proxies to attempt.
     *  * **IP address:** whether connecting directly to an origin server or a proxy, opening a socket
     *    requires an IP address. The DNS server may return multiple IP addresses to attempt.
     *
     * Each route is a specific selection of these options.
     */
    class Route(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  7. internal/kms/config.go

    // each site. Trying to replicate the KMS key ID can cause requests
    // to fail in such setups.
    func ReplicateKeyID() bool { return replicateKeyID() }
    
    // ConnectionOptions is a structure containing options for connecting
    // to a KMS.
    type ConnectionOptions struct {
    	CADir string // Path to directory (or file) containing CA certificates
    }
    
    // Connect returns a new Conn to a KMS. It uses configuration from the
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15K bytes
    - Viewed (0)
  8. src/main/java/jcifs/dcerpc/DcerpcHandle.java

            this.securityProvider = securityProvider;
        }
    
        /**
         * Gets the server hostname or address currently connected to
         * @return the server connected to
         */
        public abstract String getServer();
    
        /**
         * Gets the server hostname resolved through DFS (Distributed File System)
         * @return the server resolved by DFS
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbTransportImplTest.java

        }
    
        @Test
        @DisplayName("isDisconnected / isFailed reflect socket and state")
        void connectionStateChecks() throws Exception {
            // Arrange: simulate connected state and open socket
            setField(transport, "state", 3); // connected
            Socket s = mock(Socket.class);
            when(s.isClosed()).thenReturn(false);
            setField(transport, "socket", s);
    
            // Act & Assert
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

            // Exception path
            when(treeConnection.hasCapability(999)).thenThrow(new SmbException("Not connected"));
            SmbException ex = assertThrows(SmbException.class, () -> handle.hasCapability(999));
            assertTrue(ex.getMessage().contains("Not connected"));
        }
    
        @Test
        @DisplayName("getTreeId delegates")
        void getTreeIdDelegates() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.4K bytes
    - Viewed (0)
Back to top