- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for idleState (0.17 sec)
-
src/net/http/omithttp2.go
mu *sync.Mutex conns map[string][]*http2clientConn } type http2clientConn struct{} type http2clientConnIdleState struct { canTakeNewRequest bool } func (cc *http2clientConn) idleState() http2clientConnIdleState { return http2clientConnIdleState{} } func http2configureTransports(*Transport) (*http2Transport, error) { panic(noHTTP2) } func http2isNoCachedConnError(err error) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 20:51:27 UTC 2023 - 1.9K bytes - Viewed (0) -
src/net/http/export_test.go
pool := noDialPool.http2clientConnPool pool.mu.Lock() defer pool.mu.Unlock() for k, ccs := range pool.conns { for _, cc := range ccs { if cc.idleState().canTakeNewRequest { ret = append(ret, k) } } } slices.Sort(ret) return ret } func (t *Transport) IdleConnCountForTesting(scheme, addr string) int { t.idleMu.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0) -
src/net/http/h2_bundle.go
// clientConnIdleState describes the suitability of a client // connection to initiate a new RoundTrip request. type http2clientConnIdleState struct { canTakeNewRequest bool } func (cc *http2ClientConn) idleState() http2clientConnIdleState { cc.mu.Lock() defer cc.mu.Unlock() return cc.idleStateLocked() } func (cc *http2ClientConn) idleStateLocked() (st http2clientConnIdleState) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0)