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
Fields Modifier and Type Field Description private io.netty.channel.EventLoop
eventLoop
private NettyServerHandler
handler
private io.netty.handler.codec.http2.Http2Stream
http2Stream
private io.perfmark.Tag
tag
-
Fields inherited from class io.grpc.internal.AbstractStream.TransportState
DEFAULT_ONREADY_THRESHOLD
-
-
Constructor Summary
Constructors Constructor Description 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 Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
bytesRead(int processedBytes)
Called when the given number of bytes has been read from the input source of the deframer.void
deframeFailed(java.lang.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
runOnTransportThread(java.lang.Runnable r)
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 Detail
-
http2Stream
private final io.netty.handler.codec.http2.Http2Stream http2Stream
-
handler
private final NettyServerHandler handler
-
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
-
runOnTransportThread
public void runOnTransportThread(java.lang.Runnable r)
- 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
public void deframeFailed(java.lang.Throwable cause)
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
protected void http2ProcessingFailed(Status status)
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
-
-