- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for newConnections (0.18 sec)
-
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) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(c1.socket().isClosed).isFalse() } @Test fun cleanupPrioritizesEarliestEviction() { val pool = factory.newConnectionPool() val c1 = factory.newConnection(pool, routeA1, 75L) val c2 = factory.newConnection(pool, routeB1, 50L) // Running at time 75, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(75L)).isEqualTo(75L)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K 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) -
pilot/pkg/xds/pushqueue_test.go
} case <-time.After(time.Millisecond * 500): t.Fatalf("Timed out") } } func TestProxyQueue(t *testing.T) { proxies := make([]*Connection, 0, 100) for p := 0; p < 100; p++ { conn := newConnection("", nil) conn.SetID(fmt.Sprintf("proxy-%d", p)) proxies = append(proxies, conn) } t.Run("simple add and remove", func(t *testing.T) { t.Parallel() p := NewPushQueue() defer p.ShutDown()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
if err != nil { conn.Close() return nil, err } s.conn = conn return resp, nil } // NewConnection validates the upgrade response, creating and returning a new // httpstream.Connection if there were no errors. func (s *SpdyRoundTripper) NewConnection(resp *http.Response) (httpstream.Connection, error) { connectionHeader := strings.ToLower(resp.Header.Get(httpstream.HeaderConnection))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
inner class FakePlan( val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY val connection = factory.newConnection( pool = pool, route = factory.newRoute(address), idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null var retryTaken = false
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
var hostnameVerifier: HostnameVerifier? = HttpsURLConnection.getDefaultHostnameVerifier() var uriHost: String = "example.com" var uriPort: Int = 1 fun newConnection( pool: RealConnectionPool, route: Route, idleAtNanos: Long = Long.MAX_VALUE, taskRunner: TaskRunner = this.taskRunner, ): RealConnection { val result = RealConnection.newTestConnection(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 7.7K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
pushRequest *model.PushRequest // function to call once a push is finished. This must be called or future changes may be blocked. done func() } func newConnection(peerAddr string, stream DiscoveryStream) *Connection { return &Connection{ Connection: xds.NewConnection(peerAddr, stream), } } func (conn *Connection) Initialize(node *core.Node) error { return conn.s.initConnection(node, conn, conn.ids) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
"istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/util/sets" ) func createProxies(n int) []*Connection { proxies := make([]*Connection, 0, n) for p := 0; p < n; p++ { conn := newConnection("", &fakeStream{}) conn.SetID(fmt.Sprintf("proxy-%v", p)) proxies = append(proxies, conn) } return proxies } func wgDoneOrTimeout(wg *sync.WaitGroup, timeout time.Duration) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0)