Home
last modified time | relevance | path

Searched refs:outboundWireSize (Results 1 – 11 of 11) sorted by relevance

/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DTestStreamTracer.java90 protected final AtomicLong outboundWireSize = new AtomicLong(); field in TestStreamTracer.TestBaseStreamTracer
127 return outboundWireSize.get(); in getOutboundWireSize()
136 public void outboundWireSize(long bytes) { in outboundWireSize() method in TestStreamTracer.TestBaseStreamTracer
137 outboundWireSize.addAndGet(bytes); in outboundWireSize()
DTestServerStreamTracer.java90 public void outboundWireSize(long bytes) { in outboundWireSize() method in TestServerStreamTracer
91 delegate.outboundWireSize(bytes); in outboundWireSize()
DTestClientStreamTracer.java111 public void outboundWireSize(long bytes) { in outboundWireSize() method in TestClientStreamTracer
112 delegate.outboundWireSize(bytes); in outboundWireSize()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCensusStatsModule.java213 volatile long outboundWireSize; field in CensusStatsModule.ClientTracer
220 public void outboundWireSize(long bytes) { in outboundWireSize() method in CensusStatsModule.ClientTracer
224 outboundWireSize += bytes; in outboundWireSize()
395 .put(RpcMeasureConstants.RPC_CLIENT_REQUEST_BYTES, tracer.outboundWireSize) in callEnded()
483 private volatile long outboundWireSize; field in CensusStatsModule.ServerTracer
508 public void outboundWireSize(long bytes) { in outboundWireSize() method in CensusStatsModule.ServerTracer
512 outboundWireSize += bytes; in outboundWireSize()
595 .put(RpcMeasureConstants.RPC_SERVER_RESPONSE_BYTES, outboundWireSize) in streamClosed()
DStatsTraceContext.java212 public void outboundWireSize(long bytes) { in outboundWireSize() method in StatsTraceContext
214 tracer.outboundWireSize(bytes); in outboundWireSize()
DMessageFramer.java160 statsTraceCtx.outboundWireSize(currentMessageWireSize); in writePayload()
DAbstractClientStream.java491 statsTraceCtx.outboundWireSize(payload.length); in writePayload()
DRetriableStream.java858 public void outboundWireSize(long bytes) { in outboundWireSize() method in RetriableStream.BufferSizeTracer
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DStreamTracer.java83 public void outboundWireSize(long bytes) { in outboundWireSize() method in StreamTracer
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java879 bufferSizeTracer.outboundWireSize(PER_RPC_BUFFER_LIMIT); in perRpcBufferLimitExceeded()
884 bufferSizeTracer.outboundWireSize(2); in perRpcBufferLimitExceeded()
902 bufferSizeTracer.outboundWireSize(PER_RPC_BUFFER_LIMIT - 1); in perRpcBufferLimitExceededDuringBackoff()
911 bufferSizeTracer.outboundWireSize(2); in perRpcBufferLimitExceededDuringBackoff()
918 bufferSizeTracer.outboundWireSize(PER_RPC_BUFFER_LIMIT - 1); in perRpcBufferLimitExceededDuringBackoff()
920 bufferSizeTracer.outboundWireSize(2); in perRpcBufferLimitExceededDuringBackoff()
934 bufferSizeTracer.outboundWireSize(100); in channelBufferLimitExceeded()
940 bufferSizeTracer.outboundWireSize(100 + 1); in channelBufferLimitExceeded()
DCensusModulesTest.java380 tracer.outboundWireSize(1028); in subtestClientBasicStatsDefaultContext()
388 tracer.outboundWireSize(99); in subtestClientBasicStatsDefaultContext()
841 tracer.outboundWireSize(1028); in subtestServerBasicStatsNoHeaders()
849 tracer.outboundWireSize(99); in subtestServerBasicStatsNoHeaders()