Package io.grpc.netty

Class NettyClientStream.TransportState

    • Field Detail

      • methodName

        private final java.lang.String methodName
      • eventLoop

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

        private int id
      • http2Stream

        private io.netty.handler.codec.http2.Http2Stream http2Stream
      • tag

        private io.perfmark.Tag tag
    • Method Detail

      • setId

        public void setId​(int id)
      • setNonExistent

        void setNonExistent()
        Marks the stream state as if it had never existed. This can happen if the stream is cancelled after it is created, but before it has been started.
      • isNonExistent

        boolean isNonExistent()
      • setHttp2Stream

        public void setHttp2Stream​(io.netty.handler.codec.http2.Http2Stream http2Stream)
        Sets the underlying Netty Http2Stream for this stream. This must be called in the context of the transport thread.
      • http2Stream

        @Nullable
        public io.netty.handler.codec.http2.Http2Stream http2Stream()
        Gets the underlying Netty Http2Stream for this stream.
      • statusFromFailedFuture

        protected abstract Status statusFromFailedFuture​(io.netty.channel.ChannelFuture f)
        Intended to be overridden by NettyClientTransport, which has more information about failures. May only be called from event loop.
      • onWriteFrameData

        private void onWriteFrameData​(io.netty.channel.ChannelFuture future,
                                      int numMessages,
                                      int numBytes)
      • 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.
      • transportHeadersReceived

        void transportHeadersReceived​(io.netty.handler.codec.http2.Http2Headers headers,
                                      boolean endOfStream)
      • transportDataReceived

        void transportDataReceived​(io.netty.buffer.ByteBuf frame,
                                   boolean endOfStream)
      • tag

        public final io.perfmark.Tag tag()
        Specified by:
        tag in interface StreamIdHolder