- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for newConnections (0.29 sec)
-
android/guava/src/com/google/common/graph/StandardMutableNetwork.java
* * @throws IllegalStateException if {@code node} is already present */ @CanIgnoreReturnValue private NetworkConnections<N, E> addNodeInternal(N node) { NetworkConnections<N, E> connections = newConnections(); checkState(nodeConnections.put(node, connections) == null); return connections; } @Override @CanIgnoreReturnValue public boolean addEdge(N nodeU, N nodeV, E edge) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 26 17:43:39 UTC 2021 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/graph/StandardMutableNetwork.java
* * @throws IllegalStateException if {@code node} is already present */ @CanIgnoreReturnValue private NetworkConnections<N, E> addNodeInternal(N node) { NetworkConnections<N, E> connections = newConnections(); checkState(nodeConnections.put(node, connections) == null); return connections; } @Override @CanIgnoreReturnValue public boolean addEdge(N nodeU, N nodeV, E edge) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 26 17:43:39 UTC 2021 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/StandardMutableValueGraph.java
* * @throws IllegalStateException if {@code node} is already present */ @CanIgnoreReturnValue private GraphConnections<N, V> addNodeInternal(N node) { GraphConnections<N, V> connections = newConnections(); checkState(nodeConnections.put(node, connections) == null); return connections; } @Override @CanIgnoreReturnValue @CheckForNull public V putEdgeValue(N nodeU, N nodeV, V value) {
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
* * @throws IllegalStateException if {@code node} is already present */ @CanIgnoreReturnValue private GraphConnections<N, V> addNodeInternal(N node) { GraphConnections<N, V> connections = newConnections(); checkState(nodeConnections.put(node, connections) == null); return connections; } @Override @CanIgnoreReturnValue @CheckForNull public V putEdgeValue(N nodeU, N nodeV, V value) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat Oct 21 01:50:30 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/test/loadbalancersim/mesh/mesh.go
s: s, networkQ: timer.NewQueue(), } } func (m *Instance) Nodes() Nodes { return m.nodes } func (m *Instance) Clients() []*Client { return m.clients } func (m *Instance) NewConnection(src *Client, dest *Node) network.Connection { // Lookup the route between the source and destination networkLatency := m.s.NetworkLatencies[RouteKey{ Src: src.Locality(), Dest: dest.Locality(), }]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 27 20:55:37 UTC 2022 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
spdyConn, err := spdystream.NewConnection(conn, true) if err != nil { defer conn.Close() return nil, err } return newConnection(spdyConn, newStreamHandler, pingPeriod, spdyConn.Ping), nil } // newConnection returns a new connection wrapping conn. newStreamHandler // will be invoked when the server receives a newly created stream from the // client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K bytes - Viewed (0) -
pkg/test/loadbalancersim/loadbalancer/weight.go
func EquallyWeightedConnectionFactory() WeightedConnectionFactory { return func(src *mesh2.Client, dest *mesh2.Node) *WeightedConnection { return &WeightedConnection{ Connection: src.Mesh().NewConnection(src, dest), Weight: 1, } } } func PriorityWeightedConnectionFactory(selectPriority PrioritySelector, priorityWeightMap map[uint32]uint32) WeightedConnectionFactory {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 2.8K bytes - Viewed (0) -
pkg/test/loadbalancersim/network/connection.go
) type Connection interface { Name() string Request(onDone func()) TotalRequests() uint64 ActiveRequests() uint64 Latency() *timeseries.Instance } func NewConnection(name string, request func(onDone func())) Connection { return &connection{ request: request, helper: NewConnectionHelper(name), } } type connection struct { request func(onDone func())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
// connection by calling UpgradeRoundTripper.Connection(). type UpgradeRoundTripper interface { http.RoundTripper // NewConnection validates the response and creates a new Connection. NewConnection(resp *http.Response) (Connection, error) } // ResponseUpgrader knows how to upgrade HTTP requests and responses to // add streaming support to them. type ResponseUpgrader interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go
return } defer srvConn.Close() spdyConn, err := spdystream.NewConnection(srvConn, true) if err != nil { srvErr <- fmt.Errorf("server: error creating spdy connection: %v", err) return } var pingsSent int64 srvSPDYConn := newConnection( spdyConn, func(stream httpstream.Stream, replySent <-chan struct{}) error { // Echo all the incoming data.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 11:58:57 UTC 2023 - 7.9K bytes - Viewed (0)