- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,943 for connections (0.16 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/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) -
manifests/addons/dashboards/lib/queries.libsonnet
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kubelet/prober/scale_test.go
t.Logf("UNKNOWN state for %v", result) default: } } }() wg.Wait() // log the number of connections received in each pod for debugging test failures. for _, pod := range fakePods { n := pod.connections() t.Logf("Number of connections %d", n) } }) } } func newProbe(handler v1.ProbeHandler) *v1.Probe { return &v1.Probe{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0) -
istioctl/pkg/kubeinject/testdata/mesh-config.yaml
# process should be kept alive after an occasional reload. drainDuration: 2s # # The mode used to redirect inbound connections to Envoy. This setting # has no effect on outbound traffic: iptables REDIRECT is always used for # outbound connections. # If "REDIRECT", use iptables REDIRECT to NAT and redirect to Envoy. # The "REDIRECT" mode loses source addresses during redirection.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnectionTest.groovy
def connection = new TestConnection() given: connectCompletion.create(_) >> connection when: connectionBuilder.connect() connectionBuilder.addOutgoing(Worker) then: def e = thrown(GradleException) e.message == "Cannot add outgoing message transmitter after connection established." cleanup: connection?.stop()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4K bytes - Viewed (0) -
internal/http/server.go
// DefaultShutdownTimeout - default shutdown timeout to gracefully shutdown server. DefaultShutdownTimeout = 5 * time.Second // DefaultIdleTimeout for idle inactive connections DefaultIdleTimeout = 30 * time.Second // DefaultReadHeaderTimeout for very slow inactive connections DefaultReadHeaderTimeout = 30 * time.Second // DefaultMaxHeaderBytes - default maximum HTTP header size in bytes. DefaultMaxHeaderBytes = 1 * humanize.MiByte )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0)