Searched refs:perRpcBufferUsed (Results 1 – 1 of 1) sorted by relevance
91 private long perRpcBufferUsed; field in RetriableStream127 channelBufferUsed.addAndGet(-perRpcBufferUsed); in commit()871 if (bufferNeeded <= perRpcBufferUsed) { in outboundWireSize()880 channelBufferUsed.addAndGet(bufferNeeded - perRpcBufferUsed); in outboundWireSize()881 perRpcBufferUsed = bufferNeeded; in outboundWireSize()