- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 284 for connectEnd (0.06 sec)
-
android/guava/src/com/google/common/graph/GraphConnections.java
* the edge connecting the two nodes. */ @CanIgnoreReturnValue @CheckForNull V removeSuccessor(N node); /** * Add {@code node} as a predecessor to the origin node. In the case of an undirected graph, it * also becomes a successor. Associates {@code value} with the edge connecting the two nodes. */ void addPredecessor(N node, V value); /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 26 17:43:39 UTC 2021 - 2.4K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
break; } i += n; } return i; } /* * state values * 0 - not connected * 1 - connecting * 2 - run connected * 3 - connected * 4 - error * 5 - disconnecting * 6 - disconnected/invalid */ protected volatile int state = 0; protected String name = "Transport" + id++;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 01 18:12:21 UTC 2020 - 24.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteDatabase.kt
val failedRoutes: Set<Route> @Synchronized get() = _failedRoutes.toSet() /** Records a failure connecting to [failedRoute]. */ @Synchronized fun failed(failedRoute: Route) { _failedRoutes.add(failedRoute) } /** Records success connecting to [route]. */ @Synchronized fun connected(route: Route) { _failedRoutes.remove(route) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 1.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTree.java
import jcifs.smb1.Config; import jcifs.smb1.UniAddress; import jcifs.smb1.netbios.NbtAddress; class SmbTree { private static int tree_conn_counter; /* 0 - not connected * 1 - connecting * 2 - connected * 3 - disconnecting */ int connectionState; int tid; String share; String service = "?????"; String service0; SmbSession session;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
private static final Logger log = LoggerFactory.getLogger(SmbTreeImpl.class); private static AtomicLong TREE_CONN_COUNTER = new AtomicLong(); /* * 0 - not connected * 1 - connecting * 2 - connected * 3 - disconnecting */ private final AtomicInteger connectionState = new AtomicInteger(); private final String share; private final String service0;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Jan 05 13:06:39 UTC 2023 - 29.6K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/EventListener;->callEnd(Lokhttp3/Call;)V HSPLokhttp3/EventListener;->callFailed(Lokhttp3/Call;Ljava/io/IOException;)V HSPLokhttp3/EventListener;->callStart(Lokhttp3/Call;)V HSPLokhttp3/EventListener;->connectEnd(Lokhttp3/Call;Ljava/net/InetSocketAddress;Ljava/net/Proxy;Lokhttp3/Protocol;)V HSPLokhttp3/EventListener;->connectStart(Lokhttp3/Call;Ljava/net/InetSocketAddress;Ljava/net/Proxy;)V
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
} override fun connectTlsEtc(): ConnectResult { check(rawSocket != null) { "TCP not connected" } check(!isReady) { "already connected" } val connectionSpecs = route.address.connectionSpecs var retryTlsConnection: ConnectPlan? = null var success = false // Tell the call about the connecting call so async cancels work. user.addPlanToCancel(this) try {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
} else -> { events += "plan $id TCP connected" connectState = ConnectState.TCP_CONNECTED ConnectResult(this) } } } override fun connectTlsEtc(): ConnectResult { check(connectState == ConnectState.TCP_CONNECTED) events += "plan $id TLS connecting..." taskFaker.sleep(tlsConnectDelayNanos) return when {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} if (connectResult.isSuccess) { // We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.8K bytes - Viewed (0) -
docs/ftp/README.md
--sftp="address=:8022" --sftp="ssh-private-key=/home/miniouser/.ssh/id_rsa" ... ... ``` Following example shows connecting via ftp client using `minioadmin` credentials, and list a bucket named `runner`: ``` ftp localhost -P 8021 Connected to localhost. 220 Welcome to MinIO FTP Server Name (localhost:user): minioadmin 331 User name ok, password required Password: 230 Password ok, continue
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 06:41:25 UTC 2024 - 7.8K bytes - Viewed (0)