| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | CensusTracingModule.java | 214 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in recordMessageEvent() argument
219 if (optionalWireSize != -1) { in recordMessageEvent()
220 eventBuilder.setCompressedMessageSize(optionalWireSize); in recordMessageEvent()
283 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
285 span, Type.SENT, seqNo, optionalWireSize, optionalUncompressedSize); in outboundMessageSent()
290 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
292 span, Type.RECEIVED, seqNo, optionalWireSize, optionalUncompressedSize); in inboundMessageRead()
349 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
351 span, Type.SENT, seqNo, optionalWireSize, optionalUncompressedSize); in outboundMessageSent()
356 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
[all …]
|
| D | StatsTraceContext.java | 179 public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
181 tracer.outboundMessageSent(seqNo, optionalWireSize, optionalUncompressedSize); in outboundMessageSent()
190 public void inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
192 tracer.inboundMessageRead(seqNo, optionalWireSize, optionalUncompressedSize); in inboundMessageRead()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | TestServerStreamTracer.java | 125 public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
126 delegate.outboundMessageSent(seqNo, optionalWireSize, optionalUncompressedSize); in outboundMessageSent()
130 public void inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
131 delegate.inboundMessageRead(seqNo, optionalWireSize, optionalUncompressedSize); in inboundMessageRead()
|
| D | TestClientStreamTracer.java | 146 public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
147 delegate.outboundMessageSent(seqNo, optionalWireSize, optionalUncompressedSize); in outboundMessageSent()
151 public void inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
152 delegate.inboundMessageRead(seqNo, optionalWireSize, optionalUncompressedSize); in inboundMessageRead()
|
| D | TestStreamTracer.java | 178 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
182 seqNo, optionalWireSize, optionalUncompressedSize)); in outboundMessageSent()
187 int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
190 "inboundMessageRead(%d, %d, %d)", seqNo, optionalWireSize, optionalUncompressedSize)); in inboundMessageRead()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | StreamTracer.java | 65 public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in outboundMessageSent() argument
76 public void inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize) { in inboundMessageRead() argument
|