Home
last modified time | relevance | path

Searched refs:SocketStats (Results 1 – 25 of 25) sorted by relevance

/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzTestHelper.java28 import io.grpc.InternalChannelz.SocketStats;
43 static final class TestSocket implements InternalInstrumented<SocketStats> {
65 public ListenableFuture<SocketStats> getStats() { in getStats()
66 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
68 new SocketStats( in getStats()
90 static final class TestListenSocket implements InternalInstrumented<SocketStats> {
95 public ListenableFuture<SocketStats> getStats() { in getStats()
96 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
98 new SocketStats( in getStats()
127 Collections.<InternalInstrumented<SocketStats>>emptyList());
DChannelzProtoUtilTest.java44 import io.grpc.InternalChannelz.SocketStats;
541 .setListenSockets(ImmutableList.<InternalInstrumented<SocketStats>>of(listenSocket)) in toServer()
555 ImmutableList.<InternalInstrumented<SocketStats>>of(listenSocket, otherListenSocket)) in toServer()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DInternalChannelz.java59 private final ConcurrentMap<Long, InternalInstrumented<SocketStats>> otherSockets
60 = new ConcurrentHashMap<Long, InternalInstrumented<SocketStats>>();
66 extends ConcurrentSkipListMap<Long, InternalInstrumented<SocketStats>> {
96 public void addClientSocket(InternalInstrumented<SocketStats> socket) { in addClientSocket()
100 public void addListenSocket(InternalInstrumented<SocketStats> socket) { in addListenSocket()
106 InternalInstrumented<ServerStats> server, InternalInstrumented<SocketStats> socket) { in addServerSocket()
128 public void removeClientSocket(InternalInstrumented<SocketStats> socket) { in removeClientSocket()
132 public void removeListenSocket(InternalInstrumented<SocketStats> socket) { in removeListenSocket()
138 InternalInstrumented<ServerStats> server, InternalInstrumented<SocketStats> socket) { in removeServerSocket()
190 Iterator<InternalInstrumented<SocketStats>> iterator in getServerSockets()
[all …]
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServer.java30 import io.grpc.InternalChannelz.SocketStats;
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> {
354 public ListenableFuture<SocketStats> getStats() { in getStats()
355 final SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
359 ret.set(new SocketStats( in getStats()
372 ret.set(new SocketStats( in getStats()
DNettyServerTransport.java25 import io.grpc.InternalChannelz.SocketStats;
203 public ListenableFuture<SocketStats> getStats() { in getStats()
204 final SettableFuture<SocketStats> result = SettableFuture.create(); in getStats()
230 private SocketStats getStatsHelper(Channel ch) { in getStatsHelper()
232 return new SocketStats( in getStatsHelper()
DNettyClientTransport.java29 import io.grpc.InternalChannelz.SocketStats;
334 public ListenableFuture<SocketStats> getStats() {
335 final SettableFuture<SocketStats> result = SettableFuture.create();
361 private SocketStats getStatsHelper(Channel ch) {
363 return new SocketStats(
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DFailingClientTransport.java24 import io.grpc.InternalChannelz.SocketStats;
62 public ListenableFuture<SocketStats> getStats() { in getStats()
63 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
DServerTransport.java19 import io.grpc.InternalChannelz.SocketStats;
25 public interface ServerTransport extends InternalInstrumented<SocketStats> {
DInternalServer.java19 import io.grpc.InternalChannelz.SocketStats;
57 List<InternalInstrumented<SocketStats>> getListenSockets(); in getListenSockets()
DClientTransport.java20 import io.grpc.InternalChannelz.SocketStats;
34 public interface ClientTransport extends InternalInstrumented<SocketStats> {
DForwardingConnectionClientTransport.java23 import io.grpc.InternalChannelz.SocketStats;
73 public ListenableFuture<SocketStats> getStats() { in getStats()
DDelayedClientTransport.java24 import io.grpc.InternalChannelz.SocketStats;
194 public ListenableFuture<SocketStats> getStats() { in getStats()
195 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
DGrpcUtil.java32 import io.grpc.InternalChannelz.SocketStats;
697 public ListenableFuture<SocketStats> getStats() { in getTransportFromPickResult()
/external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/
DChannelzBenchmark.java22 import io.grpc.InternalChannelz.SocketStats;
51 public InternalInstrumented<SocketStats> serverSocketToAdd;
52 public InternalInstrumented<SocketStats> serverSocketToRemove;
83 InternalInstrumented<SocketStats> sock = create(); in populate()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DInternalChannelzTest.java36 import io.grpc.InternalChannelz.SocketStats;
221 InternalInstrumented<SocketStats> socket = create(); in getSocket()
241 InternalInstrumented<SocketStats> socket = create(); in serverSocket()
260 InternalInstrumented<SocketStats> socket1 = create(); in serverSocket_eachServerSeparate()
261 InternalInstrumented<SocketStats> socket2 = create(); in serverSocket_eachServerSeparate()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessServer.java22 import io.grpc.InternalChannelz.SocketStats;
83 public List<InternalInstrumented<SocketStats>> getListenSockets() { in getListenSockets()
DInProcessTransport.java33 import io.grpc.InternalChannelz.SocketStats;
242 public ListenableFuture<SocketStats> getStats() {
243 SettableFuture<SocketStats> ret = SettableFuture.create();
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerTest.java28 import io.grpc.InternalChannelz.SocketStats;
215 InternalInstrumented<SocketStats> listenSocket = getOnlyElement(ns.getListenSockets()); in channelzListenSocket()
219 SocketStats socketStats = listenSocket.getStats().get(); in channelzListenSocket()
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientTransport.java24 import io.grpc.InternalChannelz.SocketStats;
103 public ListenableFuture<SocketStats> getStats() { in getStats()
104 SettableFuture<SocketStats> f = SettableFuture.create(); in getStats()
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DChannelzService.java25 import io.grpc.InternalChannelz.SocketStats;
125 InternalInstrumented<SocketStats> s = channelz.getSocket(request.getSocketId()); in getSocket()
DChannelzProtoUtil.java34 import io.grpc.InternalChannelz.SocketStats;
129 for (InternalInstrumented<SocketStats> listenSocket : stats.listenSockets) { in toServer()
175 static Socket toSocket(InternalInstrumented<SocketStats> obj) { in toSocket()
176 SocketStats socketStats = getFuture(obj.getStats()); in toSocket()
215 static SocketData extractSocketData(SocketStats socketStats) { in extractSocketData()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java37 import io.grpc.InternalChannelz.SocketStats;
926 public ListenableFuture<SocketStats> getStats() { in getStats()
927 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
930 ret.set(new SocketStats( in getStats()
937 ret.set(new SocketStats( in getStats()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java60 import io.grpc.InternalChannelz.SocketStats;
1367 public List<InternalInstrumented<SocketStats>> getListenSockets() { in getListenSockets()
1406 public ListenableFuture<SocketStats> getStats() { in getStats()
1407 SettableFuture<SocketStats> ret = SettableFuture.create(); in getStats()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java50 import io.grpc.InternalChannelz.SocketStats;
1722 SocketStats clientSocketStats = client.getStats().get(); in socketStats()
1729 SocketStats serverSocketStats = serverTransportListener.transport.getStats().get(); in socketStats()
2066 private static TransportStats getTransportStats(InternalInstrumented<SocketStats> socket) in getTransportStats()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java59 import io.grpc.InternalChannelz.SocketStats;
2076 private static TransportStats getTransportStats(InternalInstrumented<SocketStats> obj) in getTransportStats()