type golang.org/x/net/http2.FrameWriteRequest
58 uses
golang.org/x/net/http2 (current package)
server.go#L276: wantWriteFrameCh: make(chan FrameWriteRequest, 8),
server.go#L426: wantWriteFrameCh chan FrameWriteRequest // from handlers -> serve
server.go#L719: wr FrameWriteRequest // what was written (or attempted)
server.go#L727: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L791: sc.writeFrame(FrameWriteRequest{
server.go#L938: sc.writeFrame(FrameWriteRequest{
server.go#L1015: err := sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L1058: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1078: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1142: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1276: sc.startFrameWrite(FrameWriteRequest{
server.go#L1286: sc.startFrameWrite(FrameWriteRequest{write: writeSettingsAck{}})
server.go#L1299: sc.startFrameWrite(FrameWriteRequest{write: flushFrameWriter{}})
server.go#L1363: sc.writeFrame(FrameWriteRequest{write: se})
server.go#L1504: sc.writeFrame(FrameWriteRequest{write: writePingAck{f}})
server.go#L1857: st.sc.writeFrameFromHandler(FrameWriteRequest{write: StreamError{
server.go#L2306: sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L2347: if err := sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L2370: sc.writeFrameFromHandler(FrameWriteRequest{
server.go#L2425: sc.writeFrame(FrameWriteRequest{
server.go#L3115: sc.writeFrame(FrameWriteRequest{
writesched.go#L14: type FrameWriteRequest struct {
writesched.go#L33: func (wr FrameWriteRequest) StreamID() uint32 {
writesched.go#L49: func (wr FrameWriteRequest) isControl() bool {
writesched.go#L55: func (wr FrameWriteRequest) DataSize() int {
writesched.go#L72: func (wr FrameWriteRequest) Consume(n int32) (FrameWriteRequest, FrameWriteRequest, int) {
writesched.go#L73: var empty FrameWriteRequest
writesched.go#L94: consumed := FrameWriteRequest{
writesched.go#L108: rest := FrameWriteRequest{
writesched.go#L127: func (wr FrameWriteRequest) String() string {
writesched.go#L139: func (wr *FrameWriteRequest) replyToWriter(err error) {
writesched.go#L167: currQueue []FrameWriteRequest
writesched.go#L168: nextQueue []FrameWriteRequest
writesched.go#L178: func (q *writeQueue) push(wr FrameWriteRequest) {
writesched.go#L182: func (q *writeQueue) shift() FrameWriteRequest {
writesched.go#L190: q.currQueue[q.currPos] = FrameWriteRequest{}
writesched.go#L195: func (q *writeQueue) peek() *FrameWriteRequest {
writesched.go#L209: func (q *writeQueue) consume(n int32) (FrameWriteRequest, bool) {
writesched.go#L211: return FrameWriteRequest{}, false
writesched.go#L216: return FrameWriteRequest{}, false
writesched.go#L230: q.currQueue[i] = FrameWriteRequest{}
writesched.go#L233: q.nextQueue[i] = FrameWriteRequest{}
writesched_common.go#L31: Push(wr FrameWriteRequest)
writesched_common.go#L37: Pop() (wr FrameWriteRequest, ok bool)
writesched_priority_rfc7540.go#L353: func (ws *priorityWriteSchedulerRFC7540) Push(wr FrameWriteRequest) {
writesched_priority_rfc7540.go#L373: func (ws *priorityWriteSchedulerRFC7540) Pop() (wr FrameWriteRequest, ok bool) {
writesched_priority_rfc9218.go#L152: func (ws *priorityWriteSchedulerRFC9218) Push(wr FrameWriteRequest) {
writesched_priority_rfc9218.go#L171: func (ws *priorityWriteSchedulerRFC9218) Pop() (FrameWriteRequest, bool) {
writesched_priority_rfc9218.go#L225: return FrameWriteRequest{}, false
writesched_random.go#L51: func (ws *randomWriteScheduler) Push(wr FrameWriteRequest) {
writesched_random.go#L65: func (ws *randomWriteScheduler) Pop() (FrameWriteRequest, bool) {
writesched_random.go#L80: return FrameWriteRequest{}, false
writesched_roundrobin.go#L82: func (ws *roundRobinWriteScheduler) Push(wr FrameWriteRequest) {
writesched_roundrobin.go#L101: func (ws *roundRobinWriteScheduler) Pop() (FrameWriteRequest, bool) {
writesched_roundrobin.go#L107: return FrameWriteRequest{}, false
writesched_roundrobin.go#L120: return FrameWriteRequest{}, false