- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for CanTakeNewRequest (0.19 sec)
-
src/net/http/omithttp2.go
} type http2clientConnPool struct { 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) }
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
} } } // CanTakeNewRequest reports whether the connection can take a new request, // meaning it has not been closed or received or sent a GOAWAY. // // If the caller is going to immediately make a new request on this // connection, use ReserveNewRequest instead. func (cc *http2ClientConn) CanTakeNewRequest() bool { cc.mu.Lock() defer cc.mu.Unlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0)