Searched refs:streamTracerFactory (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 244 @Nullable private final ClientStreamTracer.Factory streamTracerFactory; field in LoadBalancer.PickResult
253 @Nullable Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory, in PickResult() argument
256 this.streamTracerFactory = streamTracerFactory; in PickResult()
329 Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory) { in withSubchannel() argument
331 Preconditions.checkNotNull(subchannel, "subchannel"), streamTracerFactory, Status.OK, in withSubchannel()
396 return streamTracerFactory; in getStreamTracerFactory()
422 .add("streamTracerFactory", streamTracerFactory) in toString()
430 return Objects.hashCode(subchannel, status, streamTracerFactory, drop); in hashCode()
444 && Objects.equal(streamTracerFactory, that.streamTracerFactory) in equals()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | GrpcUtil.java | 674 final ClientStreamTracer.Factory streamTracerFactory = result.getStreamTracerFactory(); in getTransportFromPickResult() local
675 if (streamTracerFactory == null) { in getTransportFromPickResult()
683 method, headers, callOptions.withStreamTracerFactory(streamTracerFactory)); in getTransportFromPickResult()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerImplTest.java | 151 private ServerStreamTracer.Factory streamTracerFactory; field in ServerImplTest
200 streamTracerFactories = Arrays.asList(streamTracerFactory); in startUp()
202 when(streamTracerFactory.newServerStreamTracer(anyString(), any(Metadata.class))) in startUp()
427 verify(streamTracerFactory).newServerStreamTracer(eq("Waiter/nonexist"), same(requestHeaders)); in methodNotFound()
561 verify(streamTracerFactory).newServerStreamTracer(eq("Waiter/serve"), same(requestHeaders)); in basicExchangeHelper()
|
| D | ClientCallImplTest.java | 106 private ClientStreamTracer.Factory streamTracerFactory; field in ClientCallImplTest
135 baseCallOptions = CallOptions.DEFAULT.withStreamTracerFactory(streamTracerFactory); in setUp()
140 verifyZeroInteractions(streamTracerFactory); in tearDown()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 122 private ServerStreamTracer.Factory streamTracerFactory; field in NettyServerHandlerTest
164 when(streamTracerFactory.newServerStreamTracer(anyString(), any(Metadata.class))) in setUp()
234 verify(streamTracerFactory).newServerStreamTracer(eq("foo/bar"), any(Metadata.class)); in streamTracerCreated()
1066 Arrays.asList(streamTracerFactory), in newHandler()
|