- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,692 for connections (1.1 sec)
-
istioctl/pkg/writer/ztunnel/configdump/connections.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:11 UTC 2024 - 3.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/connections.go
m.byProxy[k] = connections } connections[conn.ID()] = conn } // Disconnect tracks disconnect events of ads clients. // Returns false once there are no more connections for the given proxy. func (m *adsConnections) Disconnect(conn connection) bool { m.Lock() defer m.Unlock() k := makeProxyKey(conn.Proxy()) connections := m.byProxy[k] if connections == nil { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
} /** * Adds a new incoming connection. */ public ConnectionState add(RemoteConnection<InterHubMessage> connection) { EndPointQueue queue = outgoingQueue.newEndpoint(); ConnectionState state = new ConnectionState(this, connection, queue); connections.add(state); return state; } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/StandardMutableValueGraph.java
} GraphConnections<N, V> connectionsU = nodeConnections.get(nodeU); if (connectionsU == null) { connectionsU = addNodeInternal(nodeU); } V previousValue = connectionsU.addSuccessor(nodeV, value); GraphConnections<N, V> connectionsV = nodeConnections.get(nodeV); if (connectionsV == null) { connectionsV = addNodeInternal(nodeV); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat Oct 21 01:50:30 UTC 2023 - 6.4K bytes - Viewed (0) -
guava/src/com/google/common/graph/StandardMutableValueGraph.java
} GraphConnections<N, V> connectionsU = nodeConnections.get(nodeU); if (connectionsU == null) { connectionsU = addNodeInternal(nodeU); } V previousValue = connectionsU.addSuccessor(nodeV, value); GraphConnections<N, V> connectionsV = nodeConnections.get(nodeV); if (connectionsV == null) { connectionsV = addNodeInternal(nodeV); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat Oct 21 01:50:30 UTC 2023 - 6.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* avoiding these options entirely, this class allows a connection to be attempted with modern * options and then retried without them should the attempt fail. * * ## Connection Reuse * * Each connection can carry a varying number of streams, depending on the underlying protocol being * used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DefaultGradleConnector.java
@Override public void connectionClosed(ProjectConnection connection) { synchronized (connections) { connections.remove(connection); } } @Override public void disconnect() { synchronized (connections) { stopped = true; for (DefaultProjectConnection connection : connections) { connection.disconnect(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/ConnectionSetTest.groovy
final IncomingQueue incomingQueue = new IncomingQueue(lock) final OutgoingQueue outgoingQueue = new OutgoingQueue(incomingQueue, lock) final ConnectionSet connections = new ConnectionSet(incomingQueue, outgoingQueue) def "discards queued outgoing messages when stop requested and no connections"() { def channel = new ChannelIdentifier("channel") def outgoingMessage = new ChannelMessage(channel, "payload") given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.FastFallbackExchangeFinder import okhttp3.internal.connection.ForceConnectRoutePlanner import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.connection.RealRoutePlanner import okhttp3.internal.connection.RouteDatabase /** * Manages reuse of HTTP and HTTP/2 connections for reduced network latency. HTTP requests that
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 03 20:39:41 UTC 2024 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonServerConnector.java
/** * Opens a server connection for clients to connect to communicate with a daemon. * <p> * A server connector should only be used by one daemon, and has a single use lifecycle. * Implementations must be threadsafe so that start/stop can be called from different threads. */ public interface DaemonServerConnector extends Stoppable { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0)