Searched refs:tracerFactory (Results 1 – 7 of 7) sorted by relevance
/external/grpc-grpc-java/core/src/test/java/io/grpc/ |
D | LoadBalancerTest.java | 38 private final ClientStreamTracer.Factory tracerFactory = mock(ClientStreamTracer.Factory.class); field in LoadBalancerTest 58 PickResult result = PickResult.withSubchannel(subchannel, tracerFactory); in pickResult_withSubchannelAndTracer() 61 assertThat(result.getStreamTracerFactory()).isSameAs(tracerFactory); in pickResult_withSubchannelAndTracer() 96 PickResult sc3 = PickResult.withSubchannel(subchannel, tracerFactory); in pickResult_equals()
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
D | CensusTracingModule.java | 384 final ClientCallTracer tracerFactory = newClientCallTracer(CONTEXT_SPAN_KEY.get(), method); in interceptCall() local 388 callOptions.withStreamTracerFactory(tracerFactory)); in interceptCall() 396 tracerFactory.callEnded(status); in interceptCall()
|
D | CensusStatsModule.java | 665 final ClientCallTracer tracerFactory = in interceptCall() local 669 next.newCall(method, callOptions.withStreamTracerFactory(tracerFactory)); in interceptCall() 677 tracerFactory.callEnded(status); in interceptCall()
|
D | RetriableStream.java | 166 ClientStreamTracer.Factory tracerFactory = new ClientStreamTracer.Factory() { in createSubstream() local 175 sub.stream = newSubstream(tracerFactory, newHeaders); in createSubstream() 184 ClientStreamTracer.Factory tracerFactory, Metadata headers); in newSubstream() argument
|
D | ManagedChannelImpl.java | 493 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata newHeaders) { in newRetriableStream() argument 494 CallOptions newOptions = callOptions.withStreamTracerFactory(tracerFactory); in newRetriableStream()
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | CensusModulesTest.java | 807 ServerStreamTracer.Factory tracerFactory = in subtestServerBasicStatsNoHeaders() local 810 tracerFactory.newServerStreamTracer(method.getFullMethodName(), new Metadata()); in subtestServerBasicStatsNoHeaders() 886 ServerStreamTracer.Factory tracerFactory = censusTracing.getServerTracerFactory(); in serverBasicTracingNoHeaders() local 888 tracerFactory.newServerStreamTracer(method.getFullMethodName(), new Metadata()); in serverBasicTracingNoHeaders() 934 ServerStreamTracer.Factory tracerFactory = censusTracing.getServerTracerFactory(); in serverTracingSampledToLocalSpanStore() local 936 tracerFactory.newServerStreamTracer(sampledMethod.getFullMethodName(), new Metadata()); in serverTracingSampledToLocalSpanStore() 954 ServerStreamTracer.Factory tracerFactory = censusTracing.getServerTracerFactory(); in serverTracingNotSampledToLocalSpanStore_whenServerCallNotCreated() local 956 tracerFactory.newServerStreamTracer(sampledMethod.getFullMethodName(), new Metadata()); in serverTracingNotSampledToLocalSpanStore_whenServerCallNotCreated()
|
D | RetriableStreamTest.java | 160 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata metadata) { in newSubstream() argument 162 tracerFactory.newClientStreamTracer(CallOptions.DEFAULT, new Metadata()); in newSubstream()
|