Class Http2ClientStreamTransportState

java.lang.Object

io.grpc.internal.AbstractStream.TransportState

io.grpc.internal.AbstractClientStream.TransportState

io.grpc.internal.Http2ClientStreamTransportState

All Implemented Interfaces:

ApplicationThreadDeframer.TransportExecutor, ApplicationThreadDeframerListener.TransportExecutor, MessageDeframer.Listener

Direct Known Subclasses:

NettyClientStream.TransportState

public abstract class Http2ClientStreamTransportState
extends AbstractClientStream.TransportState

Base implementation for client streams using HTTP2 as the transport.

Field Summary

Fields

Modifier and Type	Field	Description
private Charset	errorCharset
private boolean	headersReceived
private static final InternalMetadata.TrustedAsciiMarshaller<Integer>	HTTP_STATUS_MARSHALLER	Metadata marshaller for HTTP status lines.
private static final Metadata.Key<Integer>	HTTP2_STATUS
private Status	transportError	When non-null, transportErrorMetadata must also be non-null.
private Metadata	transportErrorMetadata

Fields inherited from class AbstractStream.TransportState

DEFAULT_ONREADY_THRESHOLD

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Http2ClientStreamTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions options)

Method Summary

Modifier and Type	Method	Description
private static Charset	extractCharset(Metadata headers)	Inspect the raw metadata and figure out what charset is being used.
protected abstract void	http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers)	Called to process a failure in HTTP/2 processing.
private Status	statusFromTrailers(Metadata trailers)	Extract the response status from trailers.
private static void	stripTransportDetails(Metadata metadata)	Strip HTTP transport implementation details so they don't leak via metadata into the application layer.
protected void	transportDataReceived(ReadableBuffer frame, boolean endOfStream)	Called by subclasses whenever a data frame is received from the transport.
protected void	transportHeadersReceived(Metadata headers)	Called by subclasses whenever Headers are received from the transport.
protected void	transportTrailersReceived(Metadata trailers)	Called by subclasses for the terminal trailer metadata on a stream.
private Status	validateInitialMetadata(Metadata headers)	Inspect initial headers to make sure they conform to HTTP and gRPC, returning a Status on failure.

Methods inherited from class AbstractClientStream.TransportState

deframerClosed, inboundDataReceived, inboundHeadersReceived, inboundTrailersReceived, isOutboundClosed, listener, setListener, transportReportStatus, transportReportStatus

Methods inherited from class AbstractStream.TransportState

closeDeframer, deframe, getStatsTraceContext, getTransportTracer, isStreamDeallocated, messagesAvailable, onSentBytes, onStreamAllocated, onStreamDeallocated, optimizeForDirectExecutor, requestMessagesFromDeframerForTesting, setDecompressor, setFullStreamDecompressor, setMaxInboundMessageSize, setOnReadyThreshold

Methods inherited from class Object

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

Methods inherited from interface ApplicationThreadDeframerListener.TransportExecutor

runOnTransportThread

Methods inherited from interface MessageDeframer.Listener

bytesRead, deframeFailed

Field Details

HTTP_STATUS_MARSHALLER

private static final InternalMetadata.TrustedAsciiMarshaller<Integer> HTTP_STATUS_MARSHALLER

Metadata marshaller for HTTP status lines.

HTTP2_STATUS

private static final Metadata.Key<Integer> HTTP2_STATUS

transportError

private Status transportError

When non-null, transportErrorMetadata must also be non-null.

transportErrorMetadata

private Metadata transportErrorMetadata

errorCharset

private Charset errorCharset

headersReceived

private boolean headersReceived

Constructor Details

Http2ClientStreamTransportState

protected Http2ClientStreamTransportState(int maxMessageSize,
 StatsTraceContext statsTraceCtx,
 TransportTracer transportTracer,
 CallOptions options)

Method Details

http2ProcessingFailed

protected abstract void http2ProcessingFailed(Status status,
 boolean stopDelivery,
 Metadata trailers)

Called to process a failure in HTTP/2 processing. It should notify the transport to cancel the stream and call transportReportStatus().

transportHeadersReceived

protected void transportHeadersReceived(Metadata headers)

Called by subclasses whenever Headers are received from the transport.

Parameters:

headers - the received headers

transportDataReceived

protected void transportDataReceived(ReadableBuffer frame,
 boolean endOfStream)

Called by subclasses whenever a data frame is received from the transport.

Parameters:

frame - the received data frame

endOfStream - true if there will be no more data received for this stream

transportTrailersReceived

protected void transportTrailersReceived(Metadata trailers)

Called by subclasses for the terminal trailer metadata on a stream.

Parameters:

trailers - the received terminal trailer metadata

statusFromTrailers

private Status statusFromTrailers(Metadata trailers)

Extract the response status from trailers.

validateInitialMetadata

@Nullable
private Status validateInitialMetadata(Metadata headers)

Inspect initial headers to make sure they conform to HTTP and gRPC, returning a Status on failure.

Returns:

status with description of failure, or null when valid

extractCharset

private static Charset extractCharset(Metadata headers)

Inspect the raw metadata and figure out what charset is being used.

stripTransportDetails

private static void stripTransportDetails(Metadata metadata)

Strip HTTP transport implementation details so they don't leak via metadata into the application layer.