Lines Matching refs:wr
31 Push(wr FrameWriteRequest)
36 Pop() (wr FrameWriteRequest, ok bool)
65 func (wr FrameWriteRequest) StreamID() uint32 {
66 if wr.stream == nil {
67 if se, ok := wr.write.(StreamError); ok {
76 return wr.stream.id
81 func (wr FrameWriteRequest) isControl() bool {
82 return wr.stream == nil
87 func (wr FrameWriteRequest) DataSize() int {
88 if wd, ok := wr.write.(*writeData); ok {
104 func (wr FrameWriteRequest) Consume(n int32) (FrameWriteRequest, FrameWriteRequest, int) {
108 wd, ok := wr.write.(*writeData)
110 return wr, empty, 1
114 allowed := wr.stream.flow.available()
118 if wr.stream.sc.maxFrameSize < allowed {
119 allowed = wr.stream.sc.maxFrameSize
125 wr.stream.flow.take(allowed)
127 stream: wr.stream,
141 stream: wr.stream,
147 done: wr.done,
154 wr.stream.flow.take(int32(len(wd.p)))
155 return wr, empty, 1
159 func (wr FrameWriteRequest) String() string {
161 if s, ok := wr.write.(fmt.Stringer); ok {
164 des = fmt.Sprintf("%T", wr.write)
166 …return fmt.Sprintf("[FrameWriteRequest stream=%d, ch=%v, writer=%v]", wr.StreamID(), wr.done != ni…
171 func (wr *FrameWriteRequest) replyToWriter(err error) {
172 if wr.done == nil {
176 case wr.done <- err:
178 panic(fmt.Sprintf("unbuffered done channel passed in for type %T", wr.write))
180 wr.write = nil // prevent use (assume it's tainted after wr.done send)
190 func (q *writeQueue) push(wr FrameWriteRequest) {
191 q.s = append(q.s, wr)
198 wr := q.s[0]
203 return wr