Lines Matching defs:http2ClientConn
751 MarkDead(*http2ClientConn)
989 func http2filterOutClientConn(in []*http2ClientConn, exclude *http2ClientConn) []*http2ClientConn {
7474 type http2ClientConn struct { struct
7475 t *http2Transport member
7476 tconn net.Conn // usually *tls.Conn, except specialized impls
7477 tlsState *tls.ConnectionState // nil only for specialized impls
7478 reused uint32 // whether conn is being reused; atomic
7479 singleUse bool // whether being used for a single http.Request
7480 getConnCalled bool // used by clientConnPool
7483 readerDone chan struct{} // closed on error
7484 readerErr error // set before readerDone is closed
7486 idleTimeout time.Duration // or 0 for never
7487 idleTimer http2timer
7489 mu sync.Mutex // guards following
7490 cond *sync.Cond // hold mu; broadcast on flow/closed changes
7491 flow http2outflow // our conn-level flow control quota (cs.outflow is per stream)
7492 inflow http2inflow // peer's conn-level flow control
7493 doNotReuse bool // whether conn is marked to not be reused for any future requests
7494 closing bool
7495 closed bool
7496 …enSettings bool // true if we've seen a settings frame, false otherwise
7497 wantSettingsAck bool // we sent a SETTINGS frame and haven't heard back
7498 goAway *http2GoAwayFrame // if non-nil, the GoAwayFrame we received
7499 goAwayDebug string // goAway frame's debug data, retained as a string
7500 streams map[uint32]*http2clientStream // client-initiated
7501 streamsReserved int // incr by ReserveNewRequest; decr on RoundTrip
7502 nextStreamID uint32
7503 … // requests blocked and waiting to be sent because len(streams) == maxConcurrentStreams
7504 pings map[[8]byte]chan struct{} // in flight ping data to notification channel
7505 br *bufio.Reader
7506 lastActive time.Time
7507 lastIdle time.Time // time last idle
7509 maxFrameSize uint32
7510 maxConcurrentStreams uint32
7511 peerMaxHeaderListSize uint64
7512 peerMaxHeaderTableSize uint32
7513 initialWindowSize uint32
7518 reqHeaderMu chan struct{}
7523 wmu sync.Mutex
7524 bw *bufio.Writer
7525 fr *http2Framer
7526 werr error // first write error that has occurred
7527 hbuf bytes.Buffer // HPACK encoder writes into this
7528 henc *hpack.Encoder
8010 func (cc *http2ClientConn) healthCheck() {
8027 func (cc *http2ClientConn) SetDoNotReuse() {
8033 func (cc *http2ClientConn) setGoAway(f *http2GoAwayFrame) {
8073 func (cc *http2ClientConn) CanTakeNewRequest() bool {
8082 func (cc *http2ClientConn) ReserveNewRequest() bool {
8126 func (cc *http2ClientConn) State() http2ClientConnState {
8153 func (cc *http2ClientConn) idleState() http2clientConnIdleState {
8159 func (cc *http2ClientConn) idleStateLocked() (st http2clientConnIdleState) {
8181 func (cc *http2ClientConn) canTakeNewRequestLocked() bool {
8188 func (cc *http2ClientConn) tooIdleLocked() bool {
8202 func (cc *http2ClientConn) onIdleTimeout() {
8206 func (cc *http2ClientConn) closeConn() {
8214 func (cc *http2ClientConn) forceCloseConn() {
8224 func (cc *http2ClientConn) closeIfIdle() {
8241 func (cc *http2ClientConn) isDoNotReuseAndIdle() bool {
8250 func (cc *http2ClientConn) Shutdown(ctx context.Context) error {
8288 func (cc *http2ClientConn) sendGoAway() error {
8314 func (cc *http2ClientConn) closeForError(err error) {
8328 func (cc *http2ClientConn) Close() error {
8335 func (cc *http2ClientConn) closeForLostPing() {
8364 func (cc *http2ClientConn) responseHeaderTimeout() time.Duration {
8404 func (cc *http2ClientConn) decrStreamReservations() {
8410 func (cc *http2ClientConn) decrStreamReservationsLocked() {
8416 func (cc *http2ClientConn) RoundTrip(req *Request) (*Response, error) {
8420 …cc *http2ClientConn) roundTrip(req *Request, streamf func(*http2clientStream)) (*Response, error) {
8810 func (cc *http2ClientConn) awaitOpenSlotForStreamLocked(cs *http2clientStream) error {
8832 …tp2ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) error {
9107 …deHeaders(req *Request, addGzipHeader bool, trailers string, contentLength int64) ([]byte, error) {
9297 func (cc *http2ClientConn) encodeTrailers(trailer Header) ([]byte, error) {
9327 func (cc *http2ClientConn) writeHeader(name, value string) {
9341 func (cc *http2ClientConn) addStreamLocked(cs *http2clientStream) {
9353 func (cc *http2ClientConn) forgetStreamID(id uint32) {
9388 func (cc *http2ClientConn) readLoop() {
9462 func (cc *http2ClientConn) countReadFrameError(err error) {
10171 func (cc *http2ClientConn) Ping(ctx context.Context) error {
10248 func (cc *http2ClientConn) writeStreamReset(streamID uint32, code http2ErrCode, err error) {
10264 func (cc *http2ClientConn) logf(format string, args ...interface{}) {
10268 func (cc *http2ClientConn) vlogf(format string, args ...interface{}) {
10401 func http2traceGotConn(req *Request, cc *http2ClientConn, reused bool) {