Home
last modified time | relevance | path

Searched refs:InternalInstrumented (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DInternalChannelzTest.java58 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_onePage()
67 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_onePage_multi()
68 InternalInstrumented<ChannelStats> root2 = create(); in getRootChannels_onePage_multi()
78 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_paginate()
79 InternalInstrumented<ChannelStats> root2 = create(); in getRootChannels_paginate()
93 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_remove()
103 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_addAfterLastPage()
111 InternalInstrumented<ChannelStats> root2 = create(); in getRootChannels_addAfterLastPage()
130 InternalInstrumented<ServerStats> server1 = create(); in getServers_onePage()
139 InternalInstrumented<ServerStats> server1 = create(); in getServers_onePage_multi()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DInternalChannelz.java52 private final ConcurrentNavigableMap<Long, InternalInstrumented<ServerStats>> servers
53 = new ConcurrentSkipListMap<Long, InternalInstrumented<ServerStats>>();
54 private final ConcurrentNavigableMap<Long, InternalInstrumented<ChannelStats>> rootChannels
55 = new ConcurrentSkipListMap<Long, InternalInstrumented<ChannelStats>>();
56 private final ConcurrentMap<Long, InternalInstrumented<ChannelStats>> subchannels
57 = new ConcurrentHashMap<Long, InternalInstrumented<ChannelStats>>();
59 private final ConcurrentMap<Long, InternalInstrumented<SocketStats>> otherSockets
60 = new ConcurrentHashMap<Long, InternalInstrumented<SocketStats>>();
66 extends ConcurrentSkipListMap<Long, InternalInstrumented<SocketStats>> {
79 public void addServer(InternalInstrumented<ServerStats> server) { in addServer()
[all …]
DInternalInstrumented.java28 public interface InternalInstrumented<T> extends InternalWithLogId { interface
/external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/
DChannelzBenchmark.java23 import io.grpc.InternalInstrumented;
46 public InternalInstrumented<ServerStats> serverToRemove;
48 public InternalInstrumented<ServerStats> serverToAdd;
50 public InternalInstrumented<ServerStats> serverForServerSocket;
51 public InternalInstrumented<SocketStats> serverSocketToAdd;
52 public InternalInstrumented<SocketStats> serverSocketToRemove;
79 InternalInstrumented<ServerStats> srv = create(); in populate()
83 InternalInstrumented<SocketStats> sock = create(); in populate()
133 private static <T> InternalInstrumented<T> create() { in create()
134 return new InternalInstrumented<T>() { in create()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzTestHelper.java30 import io.grpc.InternalInstrumented;
43 static final class TestSocket implements InternalInstrumented<SocketStats> {
90 static final class TestListenSocket implements InternalInstrumented<SocketStats> {
120 static final class TestServer implements InternalInstrumented<ServerStats> {
127 Collections.<InternalInstrumented<SocketStats>>emptyList());
149 static final class TestChannel implements InternalInstrumented<ChannelStats> {
DChannelzProtoUtilTest.java45 import io.grpc.InternalInstrumented;
541 .setListenSockets(ImmutableList.<InternalInstrumented<SocketStats>>of(listenSocket)) in toServer()
555 ImmutableList.<InternalInstrumented<SocketStats>>of(listenSocket, otherListenSocket)) in toServer()
668 Collections.<InternalInstrumented<ChannelStats>>emptyList(), true))); in toGetTopChannelsResponse()
678 ImmutableList.<InternalInstrumented<ChannelStats>>of(channel), false))); in toGetTopChannelsResponse()
689 ImmutableList.<InternalInstrumented<ChannelStats>>of(channel), true))); in toGetTopChannelsResponse()
702 ImmutableList.<InternalInstrumented<ChannelStats>>of(channel, channel2), true))); in toGetTopChannelsResponse()
711 new ServerList(Collections.<InternalInstrumented<ServerStats>>emptyList(), false))); in toGetServersResponse()
720 new ServerList(ImmutableList.<InternalInstrumented<ServerStats>>of(server), false))); in toGetServersResponse()
730 new ServerList(ImmutableList.<InternalInstrumented<ServerStats>>of(server), true))); in toGetServersResponse()
[all …]
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DChannelzService.java26 import io.grpc.InternalInstrumented;
79 InternalInstrumented<ChannelStats> s = channelz.getRootChannel(request.getChannelId()); in getChannel()
107 InternalInstrumented<ChannelStats> s = channelz.getSubchannel(request.getSubchannelId()); in getSubchannel()
125 InternalInstrumented<SocketStats> s = channelz.getSocket(request.getSocketId()); in getSocket()
DChannelzProtoUtil.java36 import io.grpc.InternalInstrumented;
123 static Server toServer(InternalInstrumented<ServerStats> obj) { in toServer()
129 for (InternalInstrumented<SocketStats> listenSocket : stats.listenSockets) { in toServer()
175 static Socket toSocket(InternalInstrumented<SocketStats> obj) { in toSocket()
342 static Channel toChannel(InternalInstrumented<ChannelStats> channel) { in toChannel()
410 static Subchannel toSubchannel(InternalInstrumented<ChannelStats> subchannel) { in toSubchannel()
430 for (InternalInstrumented<ChannelStats> c : rootChannels.channels) { in toGetTopChannelResponse()
440 for (InternalInstrumented<ServerStats> s : servers.servers) { in toGetServersResponse()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerTransport.java20 import io.grpc.InternalInstrumented;
25 public interface ServerTransport extends InternalInstrumented<SocketStats> {
DAbstractSubchannel.java21 import io.grpc.InternalInstrumented;
42 abstract InternalInstrumented<ChannelStats> getInternalSubchannel(); in getInternalSubchannel()
DInternalServer.java20 import io.grpc.InternalInstrumented;
57 List<InternalInstrumented<SocketStats>> getListenSockets(); in getListenSockets()
DClientTransport.java21 import io.grpc.InternalInstrumented;
34 public interface ClientTransport extends InternalInstrumented<SocketStats> {
DOobChannel.java36 import io.grpc.InternalInstrumented;
66 final class OobChannel extends ManagedChannel implements InternalInstrumented<ChannelStats> {
157 InternalInstrumented<ChannelStats> getInternalSubchannel() { in setSubchannel()
DInternalSubchannel.java41 import io.grpc.InternalInstrumented;
66 final class InternalSubchannel implements InternalInstrumented<ChannelStats> {
DServerImpl.java41 import io.grpc.InternalInstrumented;
81 public final class ServerImpl extends io.grpc.Server implements InternalInstrumented<ServerStats> {
DManagedChannelImpl.java50 import io.grpc.InternalInstrumented;
90 InternalInstrumented<ChannelStats> {
1393 InternalInstrumented<ChannelStats> getInternalSubchannel() { in getInternalSubchannel()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServer.java31 import io.grpc.InternalInstrumented;
98 private volatile ImmutableList<InternalInstrumented<SocketStats>> listenSockets
151 public List<InternalInstrumented<SocketStats>> getListenSockets() { in getListenSockets()
259 InternalInstrumented<SocketStats> listenSocket = new ListenSocket(channel); in start()
283 for (InternalInstrumented<SocketStats> listenSocket : listenSockets) { in shutdown()
345 private static final class ListenSocket implements InternalInstrumented<SocketStats> {
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessServer.java23 import io.grpc.InternalInstrumented;
83 public List<InternalInstrumented<SocketStats>> getListenSockets() { in getListenSockets()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerTest.java29 import io.grpc.InternalInstrumented;
215 InternalInstrumented<SocketStats> listenSocket = getOnlyElement(ns.getListenSockets()); in channelzListenSocket()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java61 import io.grpc.InternalInstrumented;
1367 public List<InternalInstrumented<SocketStats>> getListenSockets() { in getListenSockets()
DManagedChannelImplTest.java75 import io.grpc.InternalInstrumented;
2953 InternalInstrumented<ChannelStats> instrumented) throws Exception { in getStats()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java61 import io.grpc.InternalInstrumented;
2076 private static TransportStats getTransportStats(InternalInstrumented<SocketStats> obj) in getTransportStats()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java53 import io.grpc.InternalInstrumented;
2065 private static TransportStats getTransportStats(InternalInstrumented<SocketStats> socket) in getTransportStats()