| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | StatsTraceContext.java | 40 public final class StatsTraceContext { class
41 public static final StatsTraceContext NOOP = new StatsTraceContext(new StreamTracer[0]);
49 public static StatsTraceContext newClientContext(CallOptions callOptions, Metadata headers) { in newClientContext()
60 return new StatsTraceContext(tracers); in newClientContext()
66 public static StatsTraceContext newServerContext( in newServerContext()
75 return new StatsTraceContext(tracers); in newServerContext()
79 StatsTraceContext(StreamTracer[] tracers) { in StatsTraceContext() method in StatsTraceContext
|
| D | AbstractServerStream.java | 80 private final StatsTraceContext statsTraceCtx;
85 WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx) { in AbstractServerStream()
180 public StatsTraceContext statsTraceContext() { in statsTraceContext()
192 private final StatsTraceContext statsTraceCtx;
204 StatsTraceContext statsTraceCtx, in TransportState()
|
| D | AbstractStream.java | 113 private final StatsTraceContext statsTraceCtx;
137 StatsTraceContext statsTraceCtx, in TransportState()
211 public final StatsTraceContext getStatsTraceContext() { in getStatsTraceContext()
|
| D | AbstractClientStream.java | 109 StatsTraceContext statsTraceCtx, in AbstractClientStream()
214 private final StatsTraceContext statsTraceCtx;
236 StatsTraceContext statsTraceCtx, in TransportState()
463 private final StatsTraceContext statsTraceCtx;
466 public GetFramer(Metadata headers, StatsTraceContext statsTraceCtx) { in GetFramer()
|
| D | MessageDeframer.java | 90 private final StatsTraceContext statsTraceCtx;
121 StatsTraceContext statsTraceCtx, in MessageDeframer()
444 private final StatsTraceContext statsTraceCtx;
449 SizeEnforcingInputStream(InputStream in, int maxMessageSize, StatsTraceContext statsTraceCtx) { in SizeEnforcingInputStream()
|
| D | ServerStream.java | 93 StatsTraceContext statsTraceContext(); in statsTraceContext()
|
| D | MessageFramer.java | 80 private final StatsTraceContext statsTraceCtx;
96 Sink sink, WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx) { in MessageFramer()
|
| D | ServerImpl.java | 433 final StatsTraceContext statsTraceCtx = Preconditions.checkNotNull( in streamCreated()
499 final ServerStream stream, Metadata headers, StatsTraceContext statsTraceCtx) { in createContext()
530 Context.CancellableContext context, StatsTraceContext statsTraceCtx) { in startCall()
|
| /external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/ |
| D | StatsTraceContextBenchmark.java | 51 public StatsTraceContext newClientContext() { in newClientContext()
52 return StatsTraceContext.newClientContext(CallOptions.DEFAULT, emptyMetadata); in newClientContext()
61 public StatsTraceContext newServerContext_empty() { in newServerContext_empty()
62 return StatsTraceContext.newServerContext( in newServerContext_empty()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractClientStreamTest.java | 73 private final StatsTraceContext statsTraceCtx = StatsTraceContext.NOOP;
379 StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); in getRequest()
412 StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[] {tracer}); in writeMessage_closesStream()
456 StatsTraceContext statsTraceCtx, in BaseAbstractClientStream()
470 StatsTraceContext statsTraceCtx, in BaseAbstractClientStream()
479 StatsTraceContext statsTraceCtx, in BaseAbstractClientStream()
534 public BaseTransportState(StatsTraceContext statsTraceCtx, TransportTracer transportTracer) { in BaseTransportState()
|
| D | ServerImplTest.java | 413 StatsTraceContext statsTraceCtx = in methodNotFound()
414 StatsTraceContext.newServerContext( in methodNotFound()
441 StatsTraceContext statsTraceCtx = in decompressorNotFound()
442 StatsTraceContext.newServerContext( in decompressorNotFound()
495 StatsTraceContext statsTraceCtx = in basicExchangeHelper()
496 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in basicExchangeHelper()
701 StatsTraceContext statsTraceCtx = in interceptors()
702 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in interceptors()
746 StatsTraceContext statsTraceCtx = in exceptionInStartCallPropagatesToStream()
747 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in exceptionInStartCallPropagatesToStream()
[all …]
|
| D | MessageDeframerTest.java | 93 private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer});
330 private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer});
|
| D | AbstractServerStreamTest.java | 362 super(bufferAllocator, StatsTraceContext.NOOP); in AbstractServerStreamBase()
379 super(maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportState()
|
| D | MessageFramerTest.java | 65 private StatsTraceContext statsTraceCtx;
73 statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); in setUp()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 36 import io.grpc.internal.StatsTraceContext;
92 StatsTraceContext.NOOP, in setUp()
152 StatsTraceContext.NOOP, transportTracer); in start_userAgentRemoved()
167 StatsTraceContext.NOOP, transportTracer); in start_headerFieldOrder()
195 StatsTraceContext.NOOP, transportTracer); in getUnaryRequest()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 52 import io.grpc.internal.StatsTraceContext;
149 final StatsTraceContext statsTraceCtx =
150 StatsTraceContext.newClientContext(callOptions, headers);
301 final StatsTraceContext statsTraceCtx;
320 statsTraceCtx = StatsTraceContext.newServerContext(
494 public StatsTraceContext statsTraceContext() {
500 final StatsTraceContext statsTraceCtx;
517 statsTraceCtx = StatsTraceContext.newClientContext(callOptions, headers);
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 26 import io.grpc.internal.StatsTraceContext;
59 StatsTraceContext statsTraceCtx, in NettyServerStream()
166 StatsTraceContext statsTraceCtx, in TransportState()
|
| D | NettyClientStream.java | 34 import io.grpc.internal.StatsTraceContext;
72 StatsTraceContext statsTraceCtx, in NettyClientStream()
221 StatsTraceContext statsTraceCtx, in TransportState()
|
| D | NettyClientTransport.java | 41 import io.grpc.internal.StatsTraceContext;
161 StatsTraceContext statsTraceCtx = StatsTraceContext.newClientContext(callOptions, headers); in newStream()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 35 import io.grpc.internal.StatsTraceContext;
118 final StatsTraceContext statsTraceCtx = in newStream()
119 StatsTraceContext.newClientContext(callOptions, headers); in newStream()
|
| D | CronetClientStream.java | 39 import io.grpc.internal.StatsTraceContext;
68 private final StatsTraceContext statsTraceCtx;
94 StatsTraceContext statsTraceCtx, in CronetClientStream()
230 int maxMessageSize, StatsTraceContext statsTraceCtx, Object lock, in TransportState()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 30 import io.grpc.internal.StatsTraceContext;
55 private final StatsTraceContext statsTraceCtx;
75 StatsTraceContext statsTraceCtx, in OkHttpClientStream()
208 StatsTraceContext statsTraceCtx, in TransportState()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientStreamTest.java | 52 import io.grpc.internal.StatsTraceContext;
419 StatsTraceContext.NOOP, in setHttp2StreamShouldNotifyReady()
449 StatsTraceContext.NOOP, in removeUserAgentFromApplicationHeaders()
478 StatsTraceContext.NOOP, in getRequestSentThroughHeader()
510 StatsTraceContext.NOOP, in createStream()
549 super(handler, channel.eventLoop(), maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()
|
| D | NettyServerStreamTest.java | 41 import io.grpc.internal.StatsTraceContext;
286 StatsTraceContext statsTraceCtx = StatsTraceContext.NOOP; in createStream()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 40 import io.grpc.internal.StatsTraceContext;
120 StatsTraceContext.NOOP, in setUp()
589 StatsTraceContext.NOOP, in addCronetRequestAnnotation_deprecated()
622 StatsTraceContext.NOOP, in withAnnotation()
660 StatsTraceContext.NOOP, in getUnaryRequest()
715 StatsTraceContext.NOOP, in idempotentMethod_usesHttpPut()
745 StatsTraceContext.NOOP, in alwaysUsePutOption_usesHttpPut()
783 StatsTraceContext.NOOP, in reservedHeadersStripped()
|