Home
last modified time | relevance | path

Searched refs:streamTracerFactories (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessServer.java47 private final List<ServerStreamTracer.Factory> streamTracerFactories; field in InProcessServer
60 List<ServerStreamTracer.Factory> streamTracerFactories) { in InProcessServer() argument
63 this.streamTracerFactories = in InProcessServer()
64 Collections.unmodifiableList(checkNotNull(streamTracerFactories, "streamTracerFactories")); in InProcessServer()
116 return streamTracerFactories; in getStreamTracerFactories()
DInProcessServerBuilder.java128 List<ServerStreamTracer.Factory> streamTracerFactories) { in buildTransportServer() argument
129 return new InProcessServer(name, schedulerPool, streamTracerFactories); in buildTransportServer()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DCallOptions.java64 private List<ClientStreamTracer.Factory> streamTracerFactories = Collections.emptyList(); field in CallOptions
216 new ArrayList<ClientStreamTracer.Factory>(streamTracerFactories.size() + 1); in withStreamTracerFactory()
217 newList.addAll(streamTracerFactories); in withStreamTracerFactory()
219 newOptions.streamTracerFactories = Collections.unmodifiableList(newList); in withStreamTracerFactory()
228 return streamTracerFactories; in getStreamTracerFactories()
422 streamTracerFactories = other.streamTracerFactories; in CallOptions()
437 .add("streamTracerFactories", streamTracerFactories) in toString()
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
DInProcessTransportTest.java39 protected InternalServer newServer(List<ServerStreamTracer.Factory> streamTracerFactories) { in newServer() argument
42 SharedResourcePool.forResource(GrpcUtil.TIMER_SERVICE), streamTracerFactories); in newServer()
47 InternalServer server, List<ServerStreamTracer.Factory> streamTracerFactories) { in newServer() argument
48 return newServer(streamTracerFactories); in newServer()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyTransportTest.java58 protected InternalServer newServer(List<ServerStreamTracer.Factory> streamTracerFactories) { in newServer() argument
63 .buildTransportServer(streamTracerFactories); in newServer()
68 InternalServer server, List<ServerStreamTracer.Factory> streamTracerFactories) { in newServer() argument
74 .buildTransportServer(streamTracerFactories); in newServer()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpTransportTest.java52 protected InternalServer newServer(List<ServerStreamTracer.Factory> streamTracerFactories) { in newServer() argument
57 streamTracerFactories, in newServer()
63 InternalServer server, List<ServerStreamTracer.Factory> streamTracerFactories) { in newServer() argument
69 streamTracerFactories, in newServer()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerTransport.java77 private final List<ServerStreamTracer.Factory> streamTracerFactories; field in NettyServerTransport
84 List<ServerStreamTracer.Factory> streamTracerFactories, in NettyServerTransport() argument
100 this.streamTracerFactories = in NettyServerTransport()
101 Preconditions.checkNotNull(streamTracerFactories, "streamTracerFactories"); in NettyServerTransport()
257 streamTracerFactories, in createHandler()
DNettyServer.java93 private final List<ServerStreamTracer.Factory> streamTracerFactories; field in NettyServer
105 ProtocolNegotiator protocolNegotiator, List<ServerStreamTracer.Factory> streamTracerFactories, in NettyServer() argument
120 this.streamTracerFactories = checkNotNull(streamTracerFactories, "streamTracerFactories"); in NettyServer()
196 streamTracerFactories, in start()
DNettyServerHandler.java111 private final List<ServerStreamTracer.Factory> streamTracerFactories; field in NettyServerHandler
135 List<ServerStreamTracer.Factory> streamTracerFactories, in newHandler() argument
160 streamTracerFactories, in newHandler()
181 List<ServerStreamTracer.Factory> streamTracerFactories, in newHandler() argument
225 streamTracerFactories, in newHandler()
239 List<ServerStreamTracer.Factory> streamTracerFactories, in NettyServerHandler() argument
302 this.streamTracerFactories = checkNotNull(streamTracerFactories, "streamTracerFactories"); in NettyServerHandler()
420 StatsTraceContext.newServerContext(streamTracerFactories, method, metadata); in onHeadersRead()
DNettyServerBuilder.java425 List<ServerStreamTracer.Factory> streamTracerFactories) { in buildTransportServer() argument
434 negotiator, streamTracerFactories, transportTracerFactory, in buildTransportServer()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/internal/
DAccessProtectedHack.java26 List<ServerStreamTracer.Factory> streamTracerFactories, in serverBuilderBuildTransportServer() argument
29 return builder.buildTransportServer(streamTracerFactories); in serverBuilderBuildTransportServer()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerImplBuilder.java92 private final List<ServerStreamTracer.Factory> streamTracerFactories = field in AbstractServerImplBuilder
163 streamTracerFactories.add(checkNotNull(factory, "factory")); in addStreamTracerFactory()
279 tracerFactories.addAll(streamTracerFactories); in getTracerFactories()
292 List<ServerStreamTracer.Factory> streamTracerFactories); in buildTransportServer() argument
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java152 private List<ServerStreamTracer.Factory> streamTracerFactories; field in ServerImplTest
200 streamTracerFactories = Arrays.asList(streamTracerFactory); in startUp()
415 streamTracerFactories, "Waiter/nonexist", requestHeaders); in methodNotFound()
443 streamTracerFactories, "Waiter/nonexist", requestHeaders); in decompressorNotFound()
496 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in basicExchangeHelper()
702 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in interceptors()
747 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in exceptionInStartCallPropagatesToStream()
909 StatsTraceContext.newServerContext(streamTracerFactories, "Waitier/serve", requestHeaders); in testCallContextIsBoundInListenerCallbacks()
974 StatsTraceContext.newServerContext(streamTracerFactories, "Waitier/serve", requestHeaders); in testClientClose_setup()
1080 StatsTraceContext.newServerContext(streamTracerFactories, "Waiter/serve", requestHeaders); in handlerRegistryPriorities()
[all …]
DAbstractServerImplBuilderTest.java99 List<ServerStreamTracer.Factory> streamTracerFactories) { in buildTransportServer() argument
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java117 List<ServerStreamTracer.Factory> streamTracerFactories); in newServer() argument
123 InternalServer server, List<ServerStreamTracer.Factory> streamTracerFactories); in newServer() argument