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) DataSize() int {
82 if wd, ok := wr.write.(*writeData); ok {
98 func (wr FrameWriteRequest) Consume(n int32) (FrameWriteRequest, FrameWriteRequest, int) {
102 wd, ok := wr.write.(*writeData)
104 return wr, empty, 1
108 allowed := wr.stream.flow.available()
112 if wr.stream.sc.maxFrameSize < allowed {
113 allowed = wr.stream.sc.maxFrameSize
119 wr.stream.flow.take(allowed)
121 stream: wr.stream,
135 stream: wr.stream,
141 done: wr.done,
148 wr.stream.flow.take(int32(len(wd.p)))
149 return wr, empty, 1
153 func (wr FrameWriteRequest) String() string {
155 if s, ok := wr.write.(fmt.Stringer); ok {
158 des = fmt.Sprintf("%T", wr.write)
160 …return fmt.Sprintf("[FrameWriteRequest stream=%d, ch=%v, writer=%v]", wr.StreamID(), wr.done != ni…
165 func (wr *FrameWriteRequest) replyToWriter(err error) {
166 if wr.done == nil {
170 case wr.done <- err:
172 panic(fmt.Sprintf("unbuffered done channel passed in for type %T", wr.write))
174 wr.write = nil // prevent use (assume it's tainted after wr.done send)
184 func (q *writeQueue) push(wr FrameWriteRequest) {
185 q.s = append(q.s, wr)
192 wr := q.s[0]
197 return wr