| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | SendGrpcFrameCommand.java | 30 private final boolean endStream; field in SendGrpcFrameCommand
34 SendGrpcFrameCommand(StreamIdHolder stream, ByteBuf content, boolean endStream) { in SendGrpcFrameCommand() argument
37 this.endStream = endStream; in SendGrpcFrameCommand()
44 boolean endStream() { in endStream() method in SendGrpcFrameCommand
45 return endStream; in endStream()
50 return new SendGrpcFrameCommand(stream, content().copy(), endStream); in copy()
55 return new SendGrpcFrameCommand(stream, content().duplicate(), endStream); in duplicate()
88 return thatCmd.stream.equals(stream) && thatCmd.endStream == endStream in equals()
95 + ", endStream=" + endStream + ", content=" + content() in toString()
103 if (endStream) { in hashCode()
|
| D | NettyServerHandler.java | 615 if (cmd.endStream()) { in sendGrpcFrame()
619 encoder().writeData(ctx, cmd.streamId(), cmd.content(), 0, cmd.endStream(), promise); in sendGrpcFrame()
736 boolean endStream) throws Http2Exception { in onHeadersRead() argument
931 int padding, boolean endStream, ChannelPromise promise) { in writeData() argument
933 return super.writeData(ctx, streamId, data, padding, endStream, promise); in writeData()
938 int padding, boolean endStream, ChannelPromise promise) { in writeHeaders() argument
940 return super.writeHeaders(ctx, streamId, headers, padding, endStream, promise); in writeHeaders()
945 int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, in writeHeaders() argument
949 padding, endStream, promise); in writeHeaders()
|
| D | NettyClientHandler.java | 341 private void onHeadersRead(int streamId, Http2Headers headers, boolean endStream) { in onHeadersRead() argument
343 stream.transportHeadersReceived(headers, endStream); in onHeadersRead()
578 encoder().writeData(ctx, cmd.streamId(), cmd.content(), 0, cmd.endStream(), promise); in sendGrpcFrame()
764 boolean endStream) throws Http2Exception { in onHeadersRead() argument
765 NettyClientHandler.this.onHeadersRead(streamId, headers, endStream); in onHeadersRead()
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| D | controlbuf.go | 97 endStream bool // Valid on server side. member
115 endStream bool member
486 if !h.endStream {
487 return l.writeHeader(h.streamID, h.endStream, h.hf, h.onWrite)
496 if err := l.writeHeader(h.streamID, h.endStream, h.hf, h.onWrite); err != nil {
522 if err = l.writeHeader(str.id, hdr.endStream, hdr.hf, hdr.onWrite); err != nil {
532 func (l *loopyWriter) writeHeader(streamID uint32, endStream bool, hf []hpack.HeaderField, onWrite …
559 EndStream: endStream,
710 if err := l.framer.fr.WriteData(dataItem.streamID, dataItem.endStream, nil); err != nil {
717 …if err := l.writeHeader(trailer.streamID, trailer.endStream, trailer.hf, trailer.onWrite); err != …
[all …]
|
| D | http2_client.go | 526 endStream: false,
764 endStream: opts.Last,
1068 endStream := frame.StreamEnded()
1089 if !endStream {
1102 if !endStream {
|
| D | http2_server.go | 737 endStream: false,
788 endStream: true,
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OutboundFlowController.java | 293 Frame newFrame(Buffer data, boolean endStream) { in newFrame() argument
294 return new Frame(data, endStream); in newFrame()
348 final boolean endStream; field in OutboundFlowController.OutboundFlowState.Frame
351 Frame(Buffer data, boolean endStream) { in Frame() argument
353 this.endStream = endStream; in Frame()
388 frameWriter.data(endStream, streamId, data, bytesToWrite); in write()
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | write.go | 53 return v.endStream
55 return v.endStream
101 endStream bool member
105 return fmt.Sprintf("writeData(stream=%d, p=%d, endStream=%v)", w.streamID, len(w.p), w.endStream)
109 return ctx.Framer().WriteData(w.streamID, w.endStream, w.p)
184 endStream bool member
242 EndStream: w.endStream,
|
| D | writesched.go | 128 endStream: false,
139 endStream: wd.endStream,
|
| D | server.go | 944 func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
947 *writeArg = writeData{stream.id, data, endStream}
1642 st.endStream()
1668 func (st *stream) endStream() { func
1833 st.endStream()
2350 endStream := (rws.handlerDone && !rws.hasTrailers() && len(p) == 0) || isHeadResp
2355 endStream: endStream,
2364 if endStream {
2379 endStream := rws.handlerDone && !rws.hasTrailers()
2380 if len(p) > 0 || endStream {
[all …]
|
| D | transport.go | 836 endStream := !hasBody && !hasTrailers
837 werr := cc.writeHeaders(cs.ID, endStream, int(cc.maxFrameSize), hdrs)
993 func (cc *ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) …
1006 EndStream: endStream,
1728 rl.endStream(cs)
1923 rl.endStream(cs)
1930 func (rl *clientConnReadLoop) endStream(cs *clientStream) { func
|
| D | frame.go | 642 func (f *Framer) WriteData(streamID uint32, endStream bool, data []byte) error {
643 return f.WriteDataPadded(streamID, endStream, data, nil)
655 func (f *Framer) WriteDataPadded(streamID uint32, endStream bool, data, pad []byte) error {
673 if endStream {
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 246 protected ByteBuf grpcDataFrame(int streamId, boolean endStream, byte[] content) { in grpcDataFrame() argument
264 new DefaultHttp2FrameWriter().writeData(ctx, streamId, compressionFrame, 0, endStream, in grpcDataFrame()
269 protected final ByteBuf dataFrame(int streamId, boolean endStream, ByteBuf content) { in dataFrame() argument
274 new DefaultHttp2FrameWriter().writeData(ctx, streamId, content, 0, endStream, newPromise()); in dataFrame()
|
| D | NettyServerHandlerTest.java | 253 private void inboundDataShouldForwardToStreamListener(boolean endStream) throws Exception { in inboundDataShouldForwardToStreamListener() argument
258 ByteBuf frame = grpcDataFrame(STREAM_ID, endStream, contentAsArray()); in inboundDataShouldForwardToStreamListener()
267 if (endStream) { in inboundDataShouldForwardToStreamListener()
1050 private ByteBuf emptyGrpcFrame(int streamId, boolean endStream) throws Exception { in emptyGrpcFrame() argument
1053 return dataFrame(streamId, endStream, buf); in emptyGrpcFrame()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | Http2.java | 189 boolean endStream = (flags & FLAG_END_STREAM) != 0; in readHeaders()
202 handler.headers(false, endStream, streamId, -1, headerBlock, HeadersMode.HTTP_20_HEADERS); in readHeaders()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Http2.java | 187 boolean endStream = (flags & FLAG_END_STREAM) != 0; in readHeaders()
200 handler.headers(false, endStream, streamId, -1, headerBlock, HeadersMode.HTTP_20_HEADERS); in readHeaders()
|
| /external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/ |
| D | Http2.java | 192 boolean endStream = (flags & FLAG_END_STREAM) != 0; in readHeaders()
205 handler.headers(false, endStream, streamId, -1, headerBlock, HeadersMode.HTTP_20_HEADERS); in readHeaders()
|