- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 314 for connectEnd (0.65 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/main/java/jcifs/dcerpc/DcerpcHandle.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 15.9K bytes - Viewed (0) -
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 & AssertRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
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)