type golang.org/x/net/http2.ClientConn
77 uses
golang.org/x/net/http2 (current package)
client_conn_pool.go#L38: conns map[string][]*ClientConn // key is host:port
client_conn_pool.go#L40: keys map[*ClientConn][]string
client_conn_pool.go#L44: func (p *clientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
client_conn_pool.go#L53: func (p *clientConnPool) getClientConn(req *http.Request, addr string, dialOnMiss bool) (*ClientConn, error) {
client_conn_pool.go#L109: res *ClientConn // valid after done is closed
client_conn_pool.go#L204: func (p *clientConnPool) addConnLocked(key string, cc *ClientConn) {
client_conn_pool.go#L211: p.conns = make(map[string][]*ClientConn)
client_conn_pool.go#L214: p.keys = make(map[*ClientConn][]string)
client_conn_pool.go#L220: func (p *clientConnPool) MarkDead(cc *ClientConn) {
client_conn_pool.go#L254: func filterOutClientConn(in []*ClientConn, exclude *ClientConn) []*ClientConn {
client_conn_pool.go#L274: func (p noDialClientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
clientconn.go#L12: func (cc *ClientConn) RoundTrip(req *http.Request) (*http.Response, error) {
clientconn.go#L17: func (cc *ClientConn) SetDoNotReuse() {
clientconn.go#L26: func (cc *ClientConn) CanTakeNewRequest() bool {
clientconn.go#L33: func (cc *ClientConn) ReserveNewRequest() bool {
clientconn.go#L38: func (cc *ClientConn) State() ClientConnState {
clientconn.go#L43: func (cc *ClientConn) Shutdown(ctx context.Context) error {
clientconn.go#L50: func (cc *ClientConn) Close() error {
clientconn.go#L55: func (cc *ClientConn) Ping(ctx context.Context) error {
transport.go#L79: newclientconn func(*ClientConn)
transport.go#L187: type ClientConn struct {
transport.go#L285: cc *ClientConn
transport.go#L422: func (t *Transport) dialClientConn(ctx context.Context, addr string, singleUse bool) (*ClientConn, error) {
transport.go#L461: func (t *Transport) newUserClientConn(c net.Conn) (*ClientConn, error) {
transport.go#L465: func (t *Transport) newClientConn(c net.Conn, singleUse bool, internalStateHook func()) (*ClientConn, error) {
transport.go#L467: cc := &ClientConn{
transport.go#L558: func (cc *ClientConn) healthCheck() {
transport.go#L574: func (cc *ClientConn) setDoNotReuse() {
transport.go#L580: func (cc *ClientConn) setGoAway(f *GoAwayFrame) {
transport.go#L615: func (cc *ClientConn) canTakeNewRequest() bool {
transport.go#L621: func (cc *ClientConn) reserveNewRequest() bool {
transport.go#L631: func (cc *ClientConn) state() ClientConnState {
transport.go#L658: func (cc *ClientConn) idleState() clientConnIdleState {
transport.go#L664: func (cc *ClientConn) idleStateLocked() (st clientConnIdleState) {
transport.go#L701: func (cc *ClientConn) isUsableLocked() bool {
transport.go#L716: func (cc *ClientConn) canReserveLocked() bool {
transport.go#L728: func (cc *ClientConn) currentRequestCountLocked() int {
transport.go#L732: func (cc *ClientConn) canTakeNewRequestLocked() bool {
transport.go#L738: func (cc *ClientConn) availableLocked() int {
transport.go#L747: func (cc *ClientConn) tooIdleLocked() bool {
transport.go#L761: func (cc *ClientConn) onIdleTimeout() {
transport.go#L765: func (cc *ClientConn) closeConn() {
transport.go#L774: func (cc *ClientConn) forceCloseConn() {
transport.go#L784: func (cc *ClientConn) closeIfIdle() {
transport.go#L802: func (cc *ClientConn) stopIdleTimer() {
transport.go#L808: func (cc *ClientConn) isDoNotReuseAndIdle() bool {
transport.go#L816: func (cc *ClientConn) shutdown(ctx context.Context) error {
transport.go#L853: func (cc *ClientConn) sendGoAway() error {
transport.go#L879: func (cc *ClientConn) closeForError(err error) {
transport.go#L890: func (cc *ClientConn) close() error {
transport.go#L896: func (cc *ClientConn) closeForLostPing() {
transport.go#L908: func (cc *ClientConn) responseHeaderTimeout() time.Duration {
transport.go#L932: func (cc *ClientConn) decrStreamReservations() {
transport.go#L938: func (cc *ClientConn) decrStreamReservationsLocked() {
transport.go#L944: func (cc *ClientConn) roundTrip(req *http.Request) (*http.Response, error) {
transport.go#L948: func (cc *ClientConn) internalRoundTrip(req *http.Request, streamf func(*clientStream)) (*http.Response, error) {
transport.go#L1383: func (cc *ClientConn) awaitOpenSlotForStreamLocked(cs *clientStream) error {
transport.go#L1410: func (cc *ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) error {
transport.go#L1666: func (cc *ClientConn) encodeTrailers(trailer http.Header) ([]byte, error) {
transport.go#L1696: func (cc *ClientConn) writeHeader(name, value string) {
transport.go#L1710: func (cc *ClientConn) addStreamLocked(cs *clientStream) {
transport.go#L1722: func (cc *ClientConn) forgetStreamID(id uint32) {
transport.go#L1753: cc *ClientConn
transport.go#L1757: func (cc *ClientConn) readLoop() {
transport.go#L1844: func (cc *ClientConn) countReadFrameError(err error) {
transport.go#L2608: func (cc *ClientConn) ping(ctx context.Context) error {
transport.go#L2693: func (cc *ClientConn) writeStreamReset(streamID uint32, code ErrCode, ping bool, err error) {
transport.go#L2714: func (cc *ClientConn) logf(format string, args ...interface{}) {
transport.go#L2718: func (cc *ClientConn) vlogf(format string, args ...interface{}) {
transport.go#L2899: cc *ClientConn
transport.go#L2955: func (cc *ClientConn) maybeCallStateHook() {
transport.go#L2984: func traceGotConn(req *http.Request, cc *ClientConn, reused bool) {
transport_common.go#L175: GetClientConn(req *http.Request, addr string) (*ClientConn, error)
transport_common.go#L176: MarkDead(*ClientConn)
transport_common.go#L241: func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error) {