type net/http/internal/http2.FrameWriteRequest
53 uses
net/http/internal/http2 (current package)
server.go#L271: wantWriteFrameCh: make(chan FrameWriteRequest, 8),
server.go#L416: wantWriteFrameCh chan FrameWriteRequest // from handlers -> serve
server.go#L710: wr FrameWriteRequest // what was written (or attempted)
server.go#L718: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L782: sc.writeFrame(FrameWriteRequest{
server.go#L929: sc.writeFrame(FrameWriteRequest{
server.go#L1006: err := sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L1049: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1069: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1133: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1282: sc.startFrameWrite(FrameWriteRequest{
server.go#L1292: sc.startFrameWrite(FrameWriteRequest{write: writeSettingsAck{}})
server.go#L1308: sc.startFrameWrite(FrameWriteRequest{write: flushFrameWriter{}})
server.go#L1372: sc.writeFrame(FrameWriteRequest{write: se})
server.go#L1513: sc.writeFrame(FrameWriteRequest{write: writePingAck{f}})
server.go#L1858: st.sc.writeFrameFromHandler(FrameWriteRequest{write: StreamError{
server.go#L2316: sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L2357: if err := sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L2380: sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L2435: sc.writeFrame(FrameWriteRequest{
server.go#L3133: sc.writeFrame(FrameWriteRequest{
writesched.go#L31: Push(wr FrameWriteRequest)
writesched.go#L37: Pop() (wr FrameWriteRequest, ok bool)
writesched.go#L50: type FrameWriteRequest struct {
writesched.go#L69: func (wr FrameWriteRequest) StreamID() uint32 {
writesched.go#L85: func (wr FrameWriteRequest) isControl() bool {
writesched.go#L91: func (wr FrameWriteRequest) DataSize() int {
writesched.go#L108: func (wr FrameWriteRequest) Consume(n int32) (FrameWriteRequest, FrameWriteRequest, int) {
writesched.go#L109: var empty FrameWriteRequest
writesched.go#L131: consumed := FrameWriteRequest{
writesched.go#L145: rest := FrameWriteRequest{
writesched.go#L164: func (wr FrameWriteRequest) String() string {
writesched.go#L176: func (wr *FrameWriteRequest) replyToWriter(err error) {
writesched.go#L204: currQueue []FrameWriteRequest
writesched.go#L205: nextQueue []FrameWriteRequest
writesched.go#L215: func (q *writeQueue) push(wr FrameWriteRequest) {
writesched.go#L219: func (q *writeQueue) shift() FrameWriteRequest {
writesched.go#L227: q.currQueue[q.currPos] = FrameWriteRequest{}
writesched.go#L232: func (q *writeQueue) peek() *FrameWriteRequest {
writesched.go#L246: func (q *writeQueue) consume(n int32) (FrameWriteRequest, bool) {
writesched.go#L248: return FrameWriteRequest{}, false
writesched.go#L253: return FrameWriteRequest{}, false
writesched.go#L267: q.currQueue[i] = FrameWriteRequest{}
writesched.go#L270: q.nextQueue[i] = FrameWriteRequest{}
writesched_priority_rfc9218.go#L150: func (ws *priorityWriteSchedulerRFC9218) Push(wr FrameWriteRequest) {
writesched_priority_rfc9218.go#L169: func (ws *priorityWriteSchedulerRFC9218) Pop() (FrameWriteRequest, bool) {
writesched_priority_rfc9218.go#L223: return FrameWriteRequest{}, false
writesched_roundrobin.go#L80: func (ws *roundRobinWriteScheduler) Push(wr FrameWriteRequest) {
writesched_roundrobin.go#L99: func (ws *roundRobinWriteScheduler) Pop() (FrameWriteRequest, bool) {
writesched_roundrobin.go#L105: return FrameWriteRequest{}, false
writesched_roundrobin.go#L118: return FrameWriteRequest{}, false