Package io.grpc.internal
Class RetriableStream.BufferSizeTracer
java.lang.Object
io.grpc.StreamTracer
io.grpc.ClientStreamTracer
io.grpc.internal.RetriableStream.BufferSizeTracer
- Enclosing class:
RetriableStream<ReqT>
Traces the buffer used by a substream.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.ClientStreamTracer
ClientStreamTracer.Factory, ClientStreamTracer.StreamInfo
-
Field Summary
FieldsFields inherited from class io.grpc.ClientStreamTracer
NAME_RESOLUTION_DELAYED
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
outboundWireSize
(long bytes) A message is sent to the wire, so its reference would be released if no retry or hedging were involved.Methods inherited from class io.grpc.ClientStreamTracer
addOptionalLabel, createPendingStream, inboundHeaders, inboundHeaders, inboundTrailers, outboundHeaders, streamCreated
Methods inherited from class io.grpc.StreamTracer
inboundMessage, inboundMessageRead, inboundUncompressedSize, inboundWireSize, outboundMessage, outboundMessageSent, outboundUncompressedSize, streamClosed
-
Field Details
-
substream
-
bufferNeeded
long bufferNeeded
-
-
Constructor Details
-
BufferSizeTracer
BufferSizeTracer(RetriableStream.Substream substream)
-
-
Method Details
-
outboundWireSize
public void outboundWireSize(long bytes) A message is sent to the wire, so its reference would be released if no retry or hedging were involved. So at this point we have to hold the reference of the message longer for retry, and we need to incrementsubstream.bufferNeeded
.- Overrides:
outboundWireSize
in classStreamTracer
-