- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 3,944 for connections (0.14 sec)
-
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) -
releasenotes/notes/35059.yaml
apiVersion: release-notes/v2 kind: feature area: traffic-management issue: - 34855 releaseNotes: - | **Added** support for envoy to track active connections during drain and quit if active connections become zero instead of waiting for entire drain duration. This is disabled by default and can be enabled by setting
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Oct 08 06:31:19 UTC 2021 - 396 bytes - Viewed (0) -
releasenotes/notes/agent-xds-proxy.yaml
apiVersion: release-notes/v2 kind: feature area: networking issue: [] releaseNotes: - | **Updated** XDS connections from Envoy will be proxied through the Istio sidecar agent. Doing so allows for consolidation of multiple connections from a pod to Istiod into a single connection, in addition to other planned future improvements. This feature (and change) is transparent to users and is enabled by default.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 13 03:21:34 UTC 2020 - 551 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) -
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) -
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/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
// which can satisfy a larger policy val connection = routePlanner.plans.first().connection val http2Connection = connectHttp2(peer, connection, 5) setPolicy(pool, address, ConnectionPool.AddressPolicy(5)) assertThat(pool.connectionCount()).isEqualTo(1) // Decrease the connection's max so that another connection is needed
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0)