- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 3,308 for connections (0.23 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/NtlmAuthenticator.groovy
NtlmConnectionAuthentication connectionAuth = connections[HttpConnection.currentConnection] if (connectionAuth == null) { connectionAuth = new NtlmConnectionAuthentication(challenge: new byte[8]) new Random().nextBytes(connectionAuth.challenge) connections[HttpConnection.currentConnection] = connectionAuth } if (connectionAuth.failed) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.2K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/StandardValueGraph.java
GraphConnections<N, V> connectionsU = nodeConnections.get(nodeU); return (connectionsU != null) && connectionsU.successors().contains(nodeV); } @CheckForNull private final V edgeValueOrDefaultInternal(N nodeU, N nodeV, @CheckForNull V defaultValue) { GraphConnections<N, V> connectionsU = nodeConnections.get(nodeU); V value = (connectionsU == null) ? null : connectionsU.value(nodeV);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 6.1K bytes - Viewed (0) -
mkdocs.yml
plugins: - search - redirects: redirect_maps: # Redirect all feature pages to features/* 'caching.md': 'features/caching.md' 'calls.md': 'features/calls.md' 'connections.md': 'features/connections.md' 'events.md': 'features/events.md' 'https.md': 'features/events.md' 'interceptors.md': 'features/interceptors.md' 'r8_proguard.md': 'features/r8_proguard.md'
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Nov 20 15:26:12 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup.go
if err != nil { klog.ErrorS(err, "Failed to delete nodeport-related endpoint connections", "servicePortName", epSvcPair.ServicePortName) } } err = ct.ClearEntriesForNAT(svcInfo.ClusterIP().String(), endpointIP, v1.ProtocolUDP) if err != nil { klog.ErrorS(err, "Failed to delete endpoint connections", "servicePortName", epSvcPair.ServicePortName) } for _, extIP := range svcInfo.ExternalIPs() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ConnectionAcceptor.java
public interface ConnectionAcceptor extends AsyncStoppable { Address getAddress(); /** * Stops accepting incoming connections. */ @Override void requestStop(); /** * Stops accepting incoming connections and blocks until the accept action has completed executing for any queued connections. */ @Override void stop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
BoundedDispatch<String> handler = Mock() def connection1 = new TestConnection() def connection2 = new TestConnection() given: hub.addHandler("channel", handler) hub.addConnection(connection1) hub.addConnection(connection2) when: operation.request {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/IncomingConnector.java
@ServiceScope(Scope.Global.class) public interface IncomingConnector { /** * Starts listening for incoming connections. Assigns an arbitrary address for the endpoint. * * @param action the action to execute on incoming connection. The supplied action is not required to be thread-safe. * @param allowRemote If true, only allow connections from remote machines. If false, allow only from the local machine.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/envoy/agent.go
break graceful_loop } log.Warnf("Retrying (%d attempt) to obtain active connections...", retryCount) continue graceful_loop } if ac == -1 { log.Info("downstream_cx_active are not available. This either means there are no downstream connection established yet" + " or the stats are not enabled. Skipping active connections check...") a.abortCh <- errAbort break graceful_loop }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcConnectionMonitorTarget.java
return; } try { // Close expired connections clientConnectionManager.closeExpiredConnections(); // Close idle connections clientConnectionManager.closeIdleConnections(idleConnectionTimeout, TimeUnit.MILLISECONDS); } catch (final Exception e) { logger.warn("A connection monitoring exception occurs.", e); } }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* * * **Stale pooled connections.** The [ConnectionPool] reuses sockets * to decrease request latency, but these connections will occasionally time out. * * * **Unreachable proxy servers.** A [ProxySelector] can be used to * attempt multiple proxy servers in sequence, eventually falling back to a direct * connection. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0)