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 final io.netty.channel.EventLoop	eventLoop
private final NettyServerHandler	handler
private final io.netty.handler.codec.http2.Http2Stream	http2Stream
private final io.perfmark.Tag	tag

Fields inherited from class 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, String methodName)

Method Summary

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(Throwable cause)	Called when a MessageDeframer.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(Runnable r)
io.perfmark.Tag	tag()

Methods inherited from class AbstractServerStream.TransportState

complete, deframerClosed, inboundDataReceived, listener, onStreamAllocated, setListener, transportReportStatus

Methods inherited from class AbstractStream.TransportState

closeDeframer, deframe, getStatsTraceContext, getTransportTracer, isStreamDeallocated, messagesAvailable, onSentBytes, onStreamDeallocated, requestMessagesFromDeframerForTesting, setDecompressor, setFullStreamDecompressor

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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 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

public void runOnTransportThread(Runnable r)

Specified by:

runOnTransportThread in interface ApplicationThreadDeframerListener.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 interface MessageDeframer.Listener

Parameters:

processedBytes - the number of bytes read from the deframer's input source.

deframeFailed

public void deframeFailed(Throwable cause)

Description copied from interface: MessageDeframer.Listener

Called when a MessageDeframer.deframe(ReadableBuffer) operation failed.

Specified by:

deframeFailed in interface MessageDeframer.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 interface StreamIdHolder

tag

public io.perfmark.Tag tag()

Specified by:

tag in interface StreamIdHolder