type golang.org/x/net/http2.ClientConn
62 uses
golang.org/x/net/http2 (current package)
client_conn_pool.go#L25: GetClientConn(req *http.Request, addr string) (*ClientConn, error)
client_conn_pool.go#L26: MarkDead(*ClientConn)
client_conn_pool.go#L48: conns map[string][]*ClientConn // key is host:port
client_conn_pool.go#L50: keys map[*ClientConn][]string
client_conn_pool.go#L54: func (p *clientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
client_conn_pool.go#L63: func (p *clientConnPool) getClientConn(req *http.Request, addr string, dialOnMiss bool) (*ClientConn, error) {
client_conn_pool.go#L119: res *ClientConn // valid after done is closed
client_conn_pool.go#L214: func (p *clientConnPool) addConnLocked(key string, cc *ClientConn) {
client_conn_pool.go#L221: p.conns = make(map[string][]*ClientConn)
client_conn_pool.go#L224: p.keys = make(map[*ClientConn][]string)
client_conn_pool.go#L230: func (p *clientConnPool) MarkDead(cc *ClientConn) {
client_conn_pool.go#L264: func filterOutClientConn(in []*ClientConn, exclude *ClientConn) []*ClientConn {
client_conn_pool.go#L284: func (p noDialClientConnPool) GetClientConn(req *http.Request, addr string) (*ClientConn, error) {
transport.go#L195: newclientconn func(*ClientConn)
transport.go#L312: type ClientConn struct {
transport.go#L396: cc *ClientConn
transport.go#L709: func (t *Transport) dialClientConn(ctx context.Context, addr string, singleUse bool) (*ClientConn, error) {
transport.go#L772: func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error) {
transport.go#L776: func (t *Transport) newClientConn(c net.Conn, singleUse bool) (*ClientConn, error) {
transport.go#L778: cc := &ClientConn{
transport.go#L867: func (cc *ClientConn) healthCheck() {
transport.go#L884: func (cc *ClientConn) SetDoNotReuse() {
transport.go#L890: func (cc *ClientConn) setGoAway(f *GoAwayFrame) {
transport.go#L930: func (cc *ClientConn) CanTakeNewRequest() bool {
transport.go#L939: func (cc *ClientConn) ReserveNewRequest() bool {
transport.go#L983: func (cc *ClientConn) State() ClientConnState {
transport.go#L1010: func (cc *ClientConn) idleState() clientConnIdleState {
transport.go#L1016: func (cc *ClientConn) idleStateLocked() (st clientConnIdleState) {
transport.go#L1058: func (cc *ClientConn) currentRequestCountLocked() int {
transport.go#L1062: func (cc *ClientConn) canTakeNewRequestLocked() bool {
transport.go#L1069: func (cc *ClientConn) tooIdleLocked() bool {
transport.go#L1083: func (cc *ClientConn) onIdleTimeout() {
transport.go#L1087: func (cc *ClientConn) closeConn() {
transport.go#L1095: func (cc *ClientConn) forceCloseConn() {
transport.go#L1105: func (cc *ClientConn) closeIfIdle() {
transport.go#L1123: func (cc *ClientConn) isDoNotReuseAndIdle() bool {
transport.go#L1132: func (cc *ClientConn) Shutdown(ctx context.Context) error {
transport.go#L1169: func (cc *ClientConn) sendGoAway() error {
transport.go#L1195: func (cc *ClientConn) closeForError(err error) {
transport.go#L1209: func (cc *ClientConn) Close() error {
transport.go#L1215: func (cc *ClientConn) closeForLostPing() {
transport.go#L1227: func (cc *ClientConn) responseHeaderTimeout() time.Duration {
transport.go#L1251: func (cc *ClientConn) decrStreamReservations() {
transport.go#L1257: func (cc *ClientConn) decrStreamReservationsLocked() {
transport.go#L1263: func (cc *ClientConn) RoundTrip(req *http.Request) (*http.Response, error) {
transport.go#L1267: func (cc *ClientConn) roundTrip(req *http.Request, streamf func(*clientStream)) (*http.Response, error) {
transport.go#L1697: func (cc *ClientConn) awaitOpenSlotForStreamLocked(cs *clientStream) error {
transport.go#L1724: func (cc *ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) error {
transport.go#L1980: func (cc *ClientConn) encodeTrailers(trailer http.Header) ([]byte, error) {
transport.go#L2010: func (cc *ClientConn) writeHeader(name, value string) {
transport.go#L2024: func (cc *ClientConn) addStreamLocked(cs *clientStream) {
transport.go#L2036: func (cc *ClientConn) forgetStreamID(id uint32) {
transport.go#L2067: cc *ClientConn
transport.go#L2071: func (cc *ClientConn) readLoop() {
transport.go#L2171: func (cc *ClientConn) countReadFrameError(err error) {
transport.go#L2928: func (cc *ClientConn) Ping(ctx context.Context) error {
transport.go#L3012: func (cc *ClientConn) writeStreamReset(streamID uint32, code ErrCode, ping bool, err error) {
transport.go#L3033: func (cc *ClientConn) logf(format string, args ...interface{}) {
transport.go#L3037: func (cc *ClientConn) vlogf(format string, args ...interface{}) {
transport.go#L3167: func traceGotConn(req *http.Request, cc *ClientConn, reused bool) {