Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for idleState (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top