| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzTestHelper.java | 78 public InternalLogId getLogId() { in getLogId() method in ChannelzTestHelper.TestSocket
85 .add("logId", getLogId()) in toString()
108 public InternalLogId getLogId() { in getLogId() method in ChannelzTestHelper.TestListenSocket
115 .add("logId", getLogId()) in toString()
137 public InternalLogId getLogId() { in getLogId() method in ChannelzTestHelper.TestServer
144 .add("logId", getLogId()) in toString()
171 public InternalLogId getLogId() { in getLogId() method in ChannelzTestHelper.TestChannel
178 .add("logId", getLogId()) in toString()
|
| D | ChannelzServiceTest.java | 78 assertChannelNotFound(root.getLogId().getId()); in getChannel()
86 getChannelHelper(root.getLogId().getId())); in getChannel()
89 assertChannelNotFound(root.getLogId().getId()); in getChannel()
95 assertSubchannelNotFound(subchannel.getLogId().getId()); in getSubchannel()
103 getSubchannelHelper(subchannel.getLogId().getId())); in getSubchannel()
106 assertSubchannelNotFound(subchannel.getLogId().getId()); in getSubchannel()
133 assertSocketNotFound(socket.getLogId().getId()); in getSocket()
141 getSocketHelper(socket.getLogId().getId())); in getSocket()
144 assertSocketNotFound(socket.getLogId().getId()); in getSocket()
|
| D | ChannelzProtoUtilTest.java | 100 .setChannelId(channel.getLogId().getId())
121 .setSubchannelId(subchannel.getLogId().getId())
142 .setServerId(server.getLogId().getId())
282 .setSocketId(socket.getLogId().getId())
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelImpl.java | 322 public InternalLogId getLogId() { in getLogId() method in ManagedChannelImpl
376 logger.log(Level.FINE, "[{0}] Exiting idle mode", getLogId()); in exitIdleMode()
391 logger.log(Level.FINE, "[{0}] Entering idle mode", getLogId()); in enterIdleMode()
627 logger.log(Level.FINE, "[{0}] Created with target {1}", new Object[] {getLogId(), target}); in ManagedChannelImpl()
681 logger.log(Level.FINE, "[{0}] shutdown() called", getLogId()); in shutdown()
711 logger.log(Level.FINE, "[{0}] Shutting down", getLogId()); in shutdown()
722 logger.log(Level.FINE, "[{0}] shutdownNow() called", getLogId()); in shutdownNow()
845 logger.log(Level.FINE, "[{0}] Terminated", getLogId()); in maybeTerminateChannel()
1089 new Object[] {getLogId(), internalSubchannel.getLogId(), addressGroups}); in createSubchannel()
1261 new Object[]{getLogId(), servers, config}); in onAddresses()
[all …]
|
| D | ForwardingConnectionClientTransport.java | 58 public InternalLogId getLogId() { in getLogId() method in ForwardingConnectionClientTransport
59 return delegate().getLogId(); in getLogId()
|
| D | InternalSubchannel.java | 245 new Object[] {logId, transport.getLogId(), address}); in startNewTransport()
491 public InternalLogId getLogId() { in getLogId() method in InternalSubchannel
549 new Object[] {logId, transport.getLogId(), address}); in transportReady()
583 new Object[] {logId, transport.getLogId(), address, s}); in transportShutdown()
619 new Object[] {logId, transport.getLogId(), address}); in transportTerminated()
|
| D | FailingClientTransport.java | 69 public InternalLogId getLogId() { in getLogId() method in FailingClientTransport
|
| D | GrpcUtil.java | 692 public InternalLogId getLogId() { in getTransportFromPickResult() method
693 return transport.getLogId(); in getTransportFromPickResult()
|
| D | DelayedClientTransport.java | 342 public InternalLogId getLogId() { in getLogId() method in DelayedClientTransport
|
| D | OobChannel.java | 308 public InternalLogId getLogId() { in getLogId() method in OobChannel
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | InternalWithLogId.java | 33 InternalLogId getLogId(); in getLogId() method
|
| D | InternalChannelz.java | 238 T prev = map.put(object.getLogId().getId(), object); in add()
1096 return withLogId.getLogId().getId(); in id()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 332 assertNotNull(channelz.getRootChannel(channel.getLogId().getId())); in channelzMembership()
333 assertFalse(channelz.containsSubchannel(channel.getLogId())); in channelzMembership()
336 assertNull(channelz.getRootChannel(channel.getLogId().getId())); in channelzMembership()
337 assertFalse(channelz.containsSubchannel(channel.getLogId())); in channelzMembership()
343 assertNotNull(channelz.getRootChannel(channel.getLogId().getId())); in channelzMembership_subchannel()
348 assertNull(channelz.getRootChannel(subchannel.getInternalSubchannel().getLogId().getId())); in channelzMembership_subchannel()
349 assertTrue(channelz.containsSubchannel(subchannel.getInternalSubchannel().getLogId())); in channelzMembership_subchannel()
356 assertTrue(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_subchannel()
360 assertFalse(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_subchannel()
363 assertTrue(channelz.containsSubchannel(subchannel.getInternalSubchannel().getLogId())); in channelzMembership_subchannel()
[all …]
|
| D | TestUtils.java | 78 when(mockTransport.getLogId()).thenReturn(InternalLogId.allocate("mocktransport")); in captureTransports()
|
| D | InternalSubchannelTest.java | 818 assertNotNull(internalSubchannel.getLogId()); in logId()
982 assertTrue(channelz.containsClientSocket(t0.transport.getLogId())); in channelzMembership()
984 assertFalse(channelz.containsClientSocket(t0.transport.getLogId())); in channelzMembership()
997 assertEquals(actualTransport.transport.getLogId(), registeredTransport.getLogId()); in channelzStatContainsTransport()
|
| D | ServerImplTest.java | 1282 assertTrue(builder.channelz.containsServer(server.getLogId())); in channelz_membership()
1284 assertFalse(builder.channelz.containsServer(server.getLogId())); in channelz_membership()
1396 public InternalLogId getLogId() { in getLogId() method in ServerImplTest.SimpleServerTransport
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzProtoUtil.java | 94 .setChannelId(obj.getLogId().getId()) in toChannelRef()
102 .setSubchannelId(obj.getLogId().getId()) in toSubchannelRef()
110 .setServerId(obj.getLogId().getId()) in toServerRef()
118 .setSocketId(obj.getLogId().getId()) in toSocketRef()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServer.java | 305 public InternalLogId getLogId() { in getLogId() method in NettyServer
393 public InternalLogId getLogId() { in getLogId() method in NettyServer.ListenSocket
|
| D | NettyServerTransport.java | 165 public InternalLogId getLogId() { in getLogId() method in NettyServerTransport
|
| D | NettyClientTransport.java | 314 public InternalLogId getLogId() {
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancer.java | 75 public InternalLogId getLogId() { in getLogId() method in GrpclbLoadBalancer
|
| /external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/ |
| D | ChannelzBenchmark.java | 143 public InternalLogId getLogId() { in create() method
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 234 public InternalLogId getLogId() {
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | InternalChannelzTest.java | 313 public InternalLogId getLogId() { in create() method
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 226 public InternalLogId getLogId() {
|