Lines Matching defs:http2clientStream

7533 type http2clientStream struct {  struct
7534 	cc *http2ClientConn
7537 	ctx       context.Context
7538 	reqCancel <-chan struct{}
7540 	trace         *httptrace.ClientTrace // or nil
7541 	ID            uint32
7542 	bufPipe       http2pipe // buffered pipe with the flow-controlled response payload
7543 	requestedGzip bool
7544 	isHead        bool
7546 	abortOnce sync.Once
7547 	abort     chan struct{} // closed to signal stream should end immediately
7548 	abortErr  error         // set if abort is closed
7550 	peerClosed chan struct{} // closed when the peer sends an END_STREAM flag
7551 	donec      chan struct{} // closed after the stream is in the closed state
7552 	on100      chan struct{} // buffered; written to if a 100 is received
7554 	respHeaderRecv chan struct{} // closed when headers are received
7555 	res            *Response     // set if respHeaderRecv is closed
7557 	flow        http2outflow // guarded by cc.mu
7558 	inflow      http2inflow  // guarded by cc.mu
7559 	bytesRemain int64        // -1 means unknown; owned by transportResponseBody.Read
7560 	readErr     error        // sticky read error; owned by transportResponseBody.Read
7562 	reqBody              io.ReadCloser
7563 	reqBodyContentLength int64         // -1 means unknown
7564 	reqBodyClosed        chan struct{} // guarded by cc.mu; non-nil on Close, closed when done
7567 	sentEndStream bool // sent an END_STREAM flag to the peer
7568 	sentHeaders   bool
7571 	firstByte    bool  // got the first response byte
7572 	pastHeaders  bool  // got first MetaHeadersFrame (actual headers)
7573 	pastTrailers bool  // got optional second MetaHeadersFrame (trailers)
7574 	num1xx       uint8 // number of 1xx responses seen
7575 	readClosed   bool  // peer sent an END_STREAM flag
7576 	readAborted  bool  // read loop reset the stream
7578 	trailer    Header  // accumulated trailers
7579 	resTrailer *Header // client's Response.Trailer
7586 func (cs *http2clientStream) get1xxTraceFunc() func(int, textproto.MIMEHeader) error {
7593 func (cs *http2clientStream) abortStream(err error) {
7599 func (cs *http2clientStream) abortStreamLocked(err error) {
7614 func (cs *http2clientStream) abortRequestBodyWrite() {
7624 func (cs *http2clientStream) closeReqBodyLocked() {
8549 func (cs *http2clientStream) doRequest(req *Request, streamf func(*http2clientStream)) {
8562 … (cs *http2clientStream) writeRequest(req *Request, streamf func(*http2clientStream)) (err error) {
8691 func (cs *http2clientStream) encodeAndWriteHeaders(req *Request) error {
8738 func (cs *http2clientStream) cleanupWriteRequest(err error) {
8873 func (cs *http2clientStream) frameScratchBufferLen(maxFrameSize int) int {
8915 func (cs *http2clientStream) writeRequestBody(req *Request) (err error) {
9051 func (cs *http2clientStream) awaitFlowControl(maxBytes int) (taken int32, err error) {
10011 func (cs *http2clientStream) copyTrailers() {