Searched refs:StreamID (Results 1 – 14 of 14) sorted by relevance
| /external/grpc-grpc/tools/http2_interop/ |
| D | frameheader.go | 14 StreamID anonMember
43 StreamID: StreamID(binary.BigEndian.Uint32(b[5:9]) & 0x7fffffff),
54 if fh.StreamID < 0 {
55 return nil, fmt.Errorf("Invalid Stream ID: %v", fh.StreamID)
65 binary.BigEndian.PutUint32(buf[5:], uint32(fh.StreamID)|res)
70 type StreamID int32 type
|
| D | goaway.go | 12 StreamID anonMember
39 StreamID: StreamID(binary.BigEndian.Uint32(raw[0:4]) & 0x7fffffff),
49 binary.BigEndian.PutUint32(raw[:4], uint32(f.StreamID))
|
| D | http2interop.go | 127 StreamID: 1,
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | frame.go | 169 StreamID uint32 member
205 if h.StreamID != 0 {
206 fmt.Fprintf(buf, " stream=%d", h.StreamID)
245 StreamID: binary.BigEndian.Uint32(buf[5:]) & (1<<31 - 1),
546 fh.Type, fh.StreamID,
549 if fh.StreamID != fr.lastHeaderStream {
552 fh.StreamID, fr.lastHeaderStream))
555 …rn fr.connError(ErrCodeProtocol, fmt.Sprintf("unexpected CONTINUATION for stream %d", fh.StreamID))
563 fr.lastHeaderStream = fh.StreamID
592 if fh.StreamID == 0 {
[all …]
|
| D | errors.go | 65 StreamID uint32 member
71 return StreamError{StreamID: id, Code: code}
76 return fmt.Sprintf("stream error: stream ID %d; %v; %v", e.StreamID, e.Code, e.Cause)
78 return fmt.Sprintf("stream error: stream ID %d; %v", e.StreamID, e.Code)
|
| D | write.go | 119 StreamID uint32 member
123 return ctx.Framer().WriteRSTStream(hp.StreamID, ErrCodeInternal)
129 return ctx.Framer().WriteRSTStream(se.StreamID, se.Code)
240 StreamID: w.streamID,
289 StreamID: w.streamID,
308 StreamID: w.streamID,
|
| D | writesched.go | 65 func (wr FrameWriteRequest) StreamID() uint32 { func
72 return se.StreamID
160 …return fmt.Sprintf("[FrameWriteRequest stream=%d, ch=%v, writer=%v]", wr.StreamID(), wr.done != ni…
|
| D | server.go | 1035 if wr.StreamID() != 0 {
1037 if state, _ := sc.state(wr.StreamID()); state == stateClosed && !isReset {
1157 if st, ok := sc.streams[v.StreamID]; ok {
1272 if st, ok := sc.streams[se.StreamID]; ok {
1377 if f.StreamID != 0 {
1395 case f.StreamID != 0: // stream-level flow control
1396 state, st := sc.state(f.StreamID)
1413 return streamError(f.StreamID, ErrCodeFlowControl)
1427 state, st := sc.state(f.StreamID)
1438 sc.closeStream(st, streamError(f.StreamID, f.ErrCode))
[all …]
|
| D | transport.go | 1004 StreamID: streamID,
1489 if cs := cc.streamByID(se.StreamID, false); cs != nil {
1552 cs := cc.streamByID(f.StreamID, false)
1572 defer cc.forgetStreamID(f.StreamID)
1574 cc.forgetStreamID(f.StreamID)
1599 cs.cc.writeStreamReset(f.StreamID, ErrCodeProtocol, err)
1835 cs := cc.streamByID(f.StreamID, f.StreamEnded())
1841 if f.StreamID >= neverSent {
1867 StreamID: f.StreamID,
1876 StreamID: f.StreamID,
[all …]
|
| D | writesched_random.go | 47 id := wr.StreamID()
|
| D | writesched_priority.go | 386 if id := wr.StreamID(); id == 0 {
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| D | http2_server.go | 289 streamID := frame.Header().StreamID
440 s := t.activeStreams[se.StreamID]
446 streamID: se.StreamID,
493 s, ok := t.activeStreams[f.Header().StreamID]
688 streamID: f.Header().StreamID,
|
| D | http2_client.go | 787 s, ok := t.activeStreams[f.Header().StreamID]
1049 streamID: f.Header().StreamID,
1145 s := t.activeStreams[se.StreamID]
|
| D | controlbuf.go | 557 StreamID: streamID,
|