- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,943 for connections (0.33 sec)
-
guava/src/com/google/common/graph/StandardNetwork.java
} final NetworkConnections<N, E> checkedConnections(N node) { NetworkConnections<N, E> connections = nodeConnections.get(node); if (connections == null) { checkNotNull(node); throw new IllegalArgumentException(String.format(NODE_NOT_IN_GRAPH, node)); } return connections; } final N checkedReferenceNode(E edge) { N referenceNode = edgeToReferenceNode.get(edge);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 6.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
/** * Request immediate close of connection without even reading the request. Use to simulate buggy * SSL servers closing connections in response to unrecognized TLS extensions. */ object DisconnectAtStart : SocketPolicy /** * Close connection after reading the request but before writing the response. Use this to * simulate late connection pool failures. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/loader/CachingToolingImplementationLoaderTest.groovy
0 * _._ } def "close connections when closed"() { def connection1 = Mock(ConsumerConnection) def connection2 = Mock(ConsumerConnection) def distribution1 = Mock(Distribution) def distribution2 = Mock(Distribution) given: target.create(distribution1, loggerFactory, progressListener, params, cancellationToken) >> connection1
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 09:39:07 UTC 2024 - 5.4K bytes - Viewed (0) -
pilot/pkg/xds/statusgen.go
} return res, model.DefaultXdsLogDetails, nil } // isSidecar ad-hoc method to see if connection represents a sidecar func isProxy(con *Connection) bool { return con != nil && con.proxy != nil && con.proxy.Metadata != nil && con.proxy.Metadata.ProxyConfig != nil } func isZtunnel(con *Connection) bool { return con != nil && con.proxy != nil && con.proxy.Metadata != nil &&
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 23:30:28 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/cmd/pilot-agent/options/options.go
5*time.Second, "The minimum duration for which agent waits before it checks for active connections and terminates proxy "+ "when number of active connections become zero").Get() exitOnZeroActiveConnectionsEnv = env.Register("EXIT_ON_ZERO_ACTIVE_CONNECTIONS", false, "When set to true, terminates proxy when number of active connections become zero during draining").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 09 19:21:50 UTC 2024 - 8.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/api.go
ValidFrom string `json:"validFrom"` ExpirationTime string `json:"expirationTime"` } type WorkloadState struct { State string `json:"state,omitempty"` Connections WorkloadConnections `json:"connections,omitempty"` Info WorkloadInfo `json:"info"` } type WorkloadConnections struct { Inbound []InboundConnection `json:"inbound"` Outbound []OutboundConnection `json:"outbound"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 5.5K bytes - Viewed (0) -
src/runtime/netpoll_fake.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Fake network poller for js/wasm. // Should never be used, because js/wasm network connections do not honor "SetNonblock". //go:build js && wasm package runtime func netpollinit() { } func netpollIsPollDescriptor(fd uintptr) bool { return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 15:45:57 UTC 2023 - 664 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/MessagingServer.java
/** * A {@code MessagingServer} allows the creation of multiple bi-directional uni-cast connections. */ @ServiceScope(Scope.Global.class) public interface MessagingServer { /** * Creates an endpoint that peers can connect to. Assigns an arbitrary address. * * @param action The action to execute when a connection has been established. * @return The local address of the endpoint, for the peer to connect to.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/authentication.go
// connections open (i.e. basically degrade them to the // performance of http1 with keep-alive disabled). if utilfeature.DefaultFeatureGate.Enabled(genericfeatures.UnauthenticatedHTTP2DOSMitigation) && req.ProtoMajor == 2 && isAnonymousUser(resp.User) { // limit this connection to just this request, // and then send a GOAWAY and tear down the TCP connection
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 6.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt
package okhttp3 import java.net.InetAddress import java.net.InetSocketAddress import java.net.Socket import java.net.SocketAddress import okhttp3.internal.platform.Platform /** * A [SocketFactory] that redirects connections to [defaultAddress] or specific overridden address via [set]. */ class SpecificHostSocketFactory( val defaultAddress: InetSocketAddress?, ) : DelegatingSocketFactory(getDefault()) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0)