Package io.grpc.netty

Class NettyServerStream.TransportState

    • Field Detail

      • http2Stream

        private final io.netty.handler.codec.http2.Http2Stream http2Stream
      • eventLoop

        private final io.netty.channel.EventLoop eventLoop
      • tag

        private final io.perfmark.Tag tag
    • Constructor Detail

      • TransportState

        public TransportState​(NettyServerHandler handler,
                              io.netty.channel.EventLoop eventLoop,
                              io.netty.handler.codec.http2.Http2Stream http2Stream,
                              int maxMessageSize,
                              StatsTraceContext statsTraceCtx,
                              TransportTracer transportTracer,
                              java.lang.String methodName)
    • Method Detail

      • bytesRead

        public void bytesRead​(int processedBytes)
        Description copied from interface: MessageDeframer.Listener
        Called when the given number of bytes has been read from the input source of the deframer. This is typically used to indicate to the underlying transport that more data can be accepted.
        Specified by:
        bytesRead in interface MessageDeframer.Listener
        Parameters:
        processedBytes - the number of bytes read from the deframer's input source.
      • onWriteFrameData

        private void onWriteFrameData​(io.netty.channel.ChannelFuture future,
                                      int numMessages,
                                      int numBytes)
      • handleWriteFutureFailures

        private void handleWriteFutureFailures​(io.netty.channel.ChannelFuture future)
      • http2ProcessingFailed

        protected void http2ProcessingFailed​(Status status)
        Called to process a failure in HTTP/2 processing.
      • inboundDataReceived

        void inboundDataReceived​(io.netty.buffer.ByteBuf frame,
                                 boolean endOfStream)