Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for CanTakeNewRequest (0.19 sec)

  1. 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)
  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

    		}
    	}
    }
    
    // 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)
Back to top