Package io.grpc.netty
Class NettyServerStream.TransportState
java.lang.Object
io.grpc.internal.AbstractStream.TransportState
io.grpc.internal.AbstractServerStream.TransportState
io.grpc.netty.NettyServerStream.TransportState
- All Implemented Interfaces:
ApplicationThreadDeframer.TransportExecutor
,ApplicationThreadDeframerListener.TransportExecutor
,MessageDeframer.Listener
,StreamIdHolder
- Enclosing class:
NettyServerStream
public static class NettyServerStream.TransportState
extends AbstractServerStream.TransportState
implements StreamIdHolder
This should only be called from the transport thread.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final io.netty.channel.EventLoop
private final NettyServerHandler
private final io.netty.handler.codec.http2.Http2Stream
private final io.perfmark.Tag
Fields inherited from class io.grpc.internal.AbstractStream.TransportState
DEFAULT_ONREADY_THRESHOLD
-
Constructor Summary
ConstructorsConstructorDescriptionTransportState
(NettyServerHandler handler, io.netty.channel.EventLoop eventLoop, io.netty.handler.codec.http2.Http2Stream http2Stream, int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, String methodName) -
Method Summary
Modifier and TypeMethodDescriptionvoid
bytesRead
(int processedBytes) Called when the given number of bytes has been read from the input source of the deframer.void
deframeFailed
(Throwable cause) Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.private void
handleWriteFutureFailures
(io.netty.channel.ChannelFuture future) protected void
http2ProcessingFailed
(Status status) Called to process a failure in HTTP/2 processing.int
id()
Returns the id.(package private) void
inboundDataReceived
(io.netty.buffer.ByteBuf frame, boolean endOfStream) private void
onWriteFrameData
(io.netty.channel.ChannelFuture future, int numMessages, int numBytes) void
io.perfmark.Tag
tag()
Methods inherited from class io.grpc.internal.AbstractServerStream.TransportState
complete, deframerClosed, inboundDataReceived, listener, onStreamAllocated, setListener, transportReportStatus
Methods inherited from class io.grpc.internal.AbstractStream.TransportState
closeDeframer, deframe, getStatsTraceContext, getTransportTracer, isStreamDeallocated, messagesAvailable, onSentBytes, onStreamDeallocated, requestMessagesFromDeframerForTesting, setDecompressor, setFullStreamDecompressor
-
Field Details
-
http2Stream
private final io.netty.handler.codec.http2.Http2Stream http2Stream -
handler
-
eventLoop
private final io.netty.channel.EventLoop eventLoop -
tag
private final io.perfmark.Tag tag
-
-
Constructor Details
-
TransportState
public TransportState(NettyServerHandler handler, io.netty.channel.EventLoop eventLoop, io.netty.handler.codec.http2.Http2Stream http2Stream, int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, String methodName)
-
-
Method Details
-
runOnTransportThread
- Specified by:
runOnTransportThread
in interfaceApplicationThreadDeframerListener.TransportExecutor
-
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 interfaceMessageDeframer.Listener
- Parameters:
processedBytes
- the number of bytes read from the deframer's input source.
-
deframeFailed
Description copied from interface:MessageDeframer.Listener
Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.- Specified by:
deframeFailed
in interfaceMessageDeframer.Listener
- Parameters:
cause
- the actual failure
-
onWriteFrameData
private void onWriteFrameData(io.netty.channel.ChannelFuture future, int numMessages, int numBytes) -
handleWriteFutureFailures
private void handleWriteFutureFailures(io.netty.channel.ChannelFuture future) -
http2ProcessingFailed
Called to process a failure in HTTP/2 processing. -
inboundDataReceived
void inboundDataReceived(io.netty.buffer.ByteBuf frame, boolean endOfStream) -
id
public int id()Description copied from interface:StreamIdHolder
Returns the id.- Specified by:
id
in interfaceStreamIdHolder
-
tag
public io.perfmark.Tag tag()- Specified by:
tag
in interfaceStreamIdHolder
-