- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for newConnections (0.48 sec)
-
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/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) -
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) -
security/pkg/nodeagent/sds/sdsservice.go
// StreamSecrets serves SDS discovery requests and SDS push requests func (s *sdsservice) StreamSecrets(stream sds.SecretDiscoveryService_StreamSecretsServer) error { return xds.Stream(&Context{ BaseConnection: xds.NewConnection("", stream), s: s, w: &Watch{}, }) } func (s *sdsservice) DeltaSecrets(stream sds.SecretDiscoveryService_DeltaSecretsServer) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/client/tests/remotecommand_test.go
t *testing.T } func (u *fakeUpgrader) RoundTrip(req *http.Request) (*http.Response, error) { u.called = true u.req = req return u.resp, u.err } func (u *fakeUpgrader) NewConnection(resp *http.Response) (httpstream.Connection, error) { if u.checkResponse && u.resp != resp { u.t.Errorf("response objects passed did not match: %#v", resp) } return u.conn, u.connErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 10.2K bytes - Viewed (0) -
internal/grid/manager.go
if host == o.Local { if found { return nil, fmt.Errorf("grid: local host found multiple times") } found = true // No connection to local. continue } m.targets[host] = newConnection(connectionParams{ ctx: ctx, id: m.ID, local: o.Local, remote: host, dial: o.Dialer, handlers: &m.handlers, auth: o.AddAuth,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper_test.go
} } client := &http.Client{Transport: spdyTransport} resp, err := client.Do(req) var conn httpstream.Connection if err == nil { conn, err = spdyTransport.NewConnection(resp) } haveErr := err != nil if e, a := testCase.shouldError, haveErr; e != a { t.Fatalf("shouldError=%t, got %t: %v", e, a, err) } if testCase.shouldError { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 32.7K bytes - Viewed (0) -
pkg/xds/server.go
reqChan chan *discovery.DiscoveryRequest // errorChan is used to process error during discovery request processing. errorChan chan error } func NewConnection(peerAddr string, stream DiscoveryStream) Connection { return Connection{ pushChannel: make(chan any), initialized: make(chan struct{}), stop: make(chan struct{}),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
internal/grid/connection.go
outgoingBytes func(n int64) // Record outgoing bytes. publisher *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType] blockConnect chan struct{} } // newConnection will create an unconnected connection to a remote. func newConnection(o connectionParams) *Connection { c := &Connection{ state: StateUnconnected, Remote: o.remote, Local: o.local,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
} // Else fallback based on type return xds.IsWildcardTypeURL(w.TypeUrl) } func newDeltaConnection(peerAddr string, stream DeltaDiscoveryStream) *Connection { return &Connection{ Connection: xds.NewConnection(peerAddr, nil), deltaStream: stream, deltaReqChan: make(chan *discovery.DeltaDiscoveryRequest, 1), } } // To satisfy methods that need DiscoveryRequest. Not suitable for real usage
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)