Home
last modified time | relevance | path

Searched refs:inboundUncompressedSize (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DTestStreamTracer.java93 protected final AtomicLong inboundUncompressedSize = new AtomicLong(); field in TestStreamTracer.TestBaseStreamTracer
122 return inboundUncompressedSize.get(); in getInboundUncompressedSize()
151 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in TestStreamTracer.TestBaseStreamTracer
152 inboundUncompressedSize.addAndGet(bytes); in inboundUncompressedSize()
DTestServerStreamTracer.java105 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in TestServerStreamTracer
106 delegate.inboundUncompressedSize(bytes); in inboundUncompressedSize()
DTestClientStreamTracer.java126 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in TestClientStreamTracer
127 delegate.inboundUncompressedSize(bytes); in inboundUncompressedSize()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCensusStatsModule.java216 volatile long inboundUncompressedSize; field in CensusStatsModule.ClientTracer
250 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in CensusStatsModule.ClientTracer
254 inboundUncompressedSize += bytes; in inboundUncompressedSize()
402 tracer.inboundUncompressedSize); in callEnded()
486 private volatile long inboundUncompressedSize; field in CensusStatsModule.ServerTracer
538 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in CensusStatsModule.ServerTracer
542 inboundUncompressedSize += bytes; in inboundUncompressedSize()
598 .put(RpcMeasureConstants.RPC_SERVER_UNCOMPRESSED_REQUEST_BYTES, inboundUncompressedSize); in streamClosed()
DStatsTraceContext.java223 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in StatsTraceContext
225 tracer.inboundUncompressedSize(bytes); in inboundUncompressedSize()
DMessageDeframer.java416 statsTraceCtx.inboundUncompressedSize(nextFrame.readableBytes()); in getUncompressedBody()
508 statsTraceCtx.inboundUncompressedSize(count - maxCount); in reportCount()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DStreamTracer.java107 public void inboundUncompressedSize(long bytes) { in inboundUncompressedSize() method in StreamTracer
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DCensusModulesTest.java386 tracer.inboundUncompressedSize(67); in subtestClientBasicStatsDefaultContext()
394 tracer.inboundUncompressedSize(552); in subtestClientBasicStatsDefaultContext()
837 tracer.inboundUncompressedSize(67); in subtestServerBasicStatsNoHeaders()
847 tracer.inboundUncompressedSize(552); in subtestServerBasicStatsNoHeaders()