| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | TransportTracer.java | 32 private final TimeProvider timeProvider; field in TransportTracer
48 this.timeProvider = SYSTEM_TIME_PROVIDER; in TransportTracer()
51 private TransportTracer(TimeProvider timeProvider) { in TransportTracer() argument
52 this.timeProvider = timeProvider; in TransportTracer()
83 lastLocalStreamCreatedTimeNanos = timeProvider.currentTimeNanos(); in reportLocalStreamStarted()
91 lastRemoteStreamCreatedTimeNanos = timeProvider.currentTimeNanos(); in reportRemoteStreamStarted()
113 lastMessageSentTimeNanos = timeProvider.currentTimeNanos(); in reportMessageSent()
121 lastMessageReceivedTimeNanos = timeProvider.currentTimeNanos(); in reportMessageReceived()
160 private TimeProvider timeProvider; field in TransportTracer.Factory
163 public Factory(TimeProvider timeProvider) { in Factory() argument
[all …]
|
| D | AutoConfiguredLoadBalancerFactory.java | 53 private final TimeProvider timeProvider; field in AutoConfiguredLoadBalancerFactory
56 @Nullable ChannelTracer channelTracer, @Nullable TimeProvider timeProvider) { in AutoConfiguredLoadBalancerFactory() argument
58 this.timeProvider = timeProvider; in AutoConfiguredLoadBalancerFactory()
63 return new AutoConfiguredLoadBalancer(helper, channelTracer, timeProvider); in newLoadBalancer()
90 private final TimeProvider timeProvider; field in AutoConfiguredLoadBalancerFactory.AutoConfiguredLoadBalancer
93 Helper helper, @Nullable ChannelTracer channelTracer, @Nullable TimeProvider timeProvider) { in AutoConfiguredLoadBalancer() argument
98 this.timeProvider = timeProvider; in AutoConfiguredLoadBalancer()
100 checkNotNull(timeProvider, "timeProvider"); in AutoConfiguredLoadBalancer()
133 .setTimestampNanos(timeProvider.currentTimeNanos()) in handleResolvedAddressGroups()
|
| D | CallTracer.java | 28 private final TimeProvider timeProvider; field in CallTracer
34 CallTracer(TimeProvider timeProvider) { in CallTracer() argument
35 this.timeProvider = timeProvider; in CallTracer()
40 lastCallStartedNanos = timeProvider.currentTimeNanos(); in reportCallStarted()
|
| D | ManagedChannelImpl.java | 125 private final TimeProvider timeProvider; field in ManagedChannelImpl
359 .setTimestampNanos(timeProvider.currentTimeNanos()) in enterIdleMode()
521 final TimeProvider timeProvider) { in ManagedChannelImpl() argument
526 this.timeProvider = checkNotNull(timeProvider, "timeProvider"); in ManagedChannelImpl()
529 long currentTimeNanos = timeProvider.currentTimeNanos(); in ManagedChannelImpl()
535 this.loadBalancerFactory = new AutoConfiguredLoadBalancerFactory(channelTracer, timeProvider); in ManagedChannelImpl()
591 return new CallTracer(timeProvider); in ManagedChannelImpl()
670 .setTimestampNanos(timeProvider.currentTimeNanos()) in shutdown()
744 .setTimestampNanos(timeProvider.currentTimeNanos()) in panic()
1022 long subchannelCreationTime = timeProvider.currentTimeNanos(); in createSubchannel()
[all …]
|
| D | OobChannel.java | 85 private final TimeProvider timeProvider; field in OobChannel
107 TimeProvider timeProvider) { in OobChannel() argument
138 this.timeProvider = timeProvider; in OobChannel()
250 .setTimestampNanos(timeProvider.currentTimeNanos()) in handleSubchannelStateChange()
|
| D | InternalSubchannel.java | 80 private final TimeProvider timeProvider; field in InternalSubchannel
169 TimeProvider timeProvider) { in InternalSubchannel() argument
186 this.timeProvider = timeProvider; in InternalSubchannel()
336 .setTimestampNanos(timeProvider.currentTimeNanos()) in gotoState()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | BinlogHelper.java | 104 private TimeProvider timeProvider; field in BinlogHelper.SinkWriterImpl
112 TimeProvider timeProvider, in SinkWriterImpl() argument
116 this.timeProvider = timeProvider; in SinkWriterImpl()
122 long epochNanos = timeProvider.currentTimeNanos(); in newTimestampedBuilder()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 268 TimeProvider timeProvider = new TimeProvider() { in channelTracing_lbPolicyChanged() local
305 new AutoConfiguredLoadBalancerFactory(channelTracer, timeProvider).newLoadBalancer(helper); in channelTracing_lbPolicyChanged()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinlogHelperTest.java | 139 private final BinlogHelper.TimeProvider timeProvider = new TimeProvider() { field in BinlogHelperTest
148 timeProvider,
799 sink, timeProvider, zeroHeaderBytes, MESSAGE_LIMIT); in logTrailer()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 155 private final TimeProvider timeProvider = new TimeProvider() { field in GrpclbLoadBalancerTest
258 timeProvider, in setUp()
299 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerNoDrop()
337 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerWithDrop()
|