Home
last modified time | relevance | path

Searched refs:timeProvider (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DTransportTracer.java32 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 …]
DCallTracer.java28 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()
DManagedChannelImpl.java125 private final TimeProvider timeProvider; field in ManagedChannelImpl
404 .setTimestampNanos(timeProvider.currentTimeNanos()) in enterIdleMode()
550 final TimeProvider timeProvider) { in ManagedChannelImpl() argument
609 this.timeProvider = checkNotNull(timeProvider, "timeProvider"); in ManagedChannelImpl()
613 return new CallTracer(timeProvider); in ManagedChannelImpl()
622 long currentTimeNanos = timeProvider.currentTimeNanos(); in ManagedChannelImpl()
697 .setTimestampNanos(timeProvider.currentTimeNanos()) in shutdown()
763 .setTimestampNanos(timeProvider.currentTimeNanos()) in panic()
1033 long subchannelCreationTime = timeProvider.currentTimeNanos(); in createSubchannel()
1077 timeProvider); in createSubchannel()
[all …]
DOobChannel.java85 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()
DInternalSubchannel.java80 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/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java156 private final TimeProvider timeProvider = new TimeProvider() { field in GrpclbLoadBalancerTest
259 timeProvider, in setUp()
300 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerNoDrop()
338 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerWithDrop()