Home
last modified time | relevance | path

Searched refs:channelBufferUsed (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DRetriableStream.java74 private final ChannelBufferMeter channelBufferUsed; field in RetriableStream
99 ChannelBufferMeter channelBufferUsed, long perRpcBufferLimit, long channelBufferLimit, in RetriableStream() argument
104 this.channelBufferUsed = channelBufferUsed; in RetriableStream()
127 channelBufferUsed.addAndGet(-perRpcBufferUsed); in commit()
880 channelBufferUsed.addAndGet(bufferNeeded - perRpcBufferUsed); in outboundWireSize()
DManagedChannelImpl.java220 private final ChannelBufferMeter channelBufferUsed = new ChannelBufferMeter(); field in ManagedChannelImpl
472 channelBufferUsed, in newRetriableStream()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java125 private final ChannelBufferMeter channelBufferUsed = new ChannelBufferMeter(); field in RetriableStreamTest
130 ChannelBufferMeter channelBufferUsed, long perRpcBufferLimit, long channelBufferLimit, in RecordedRetriableStream() argument
137 method, headers, channelBufferUsed, perRpcBufferLimit, channelBufferLimit, callExecutor, in RecordedRetriableStream()
181 method, new Metadata(), channelBufferUsed, PER_RPC_BUFFER_LIMIT, CHANNEL_BUFFER_LIMIT, in newThrottledRetriableStream()
881 assertEquals(PER_RPC_BUFFER_LIMIT, channelBufferUsed.addAndGet(0)); in perRpcBufferLimitExceeded()
888 assertEquals(0, channelBufferUsed.addAndGet(0)); in perRpcBufferLimitExceeded()
936 assertEquals(100, channelBufferUsed.addAndGet(0)); in channelBufferLimitExceeded()
938 channelBufferUsed.addAndGet(CHANNEL_BUFFER_LIMIT - 200); in channelBufferLimitExceeded()
944 assertEquals(CHANNEL_BUFFER_LIMIT - 200, channelBufferUsed.addAndGet(0)); in channelBufferLimitExceeded()