Home
last modified time | relevance | path

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

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCensusStatsModule.java75 private final Supplier<Stopwatch> stopwatchSupplier; field in CensusStatsModule
83 CensusStatsModule(Supplier<Stopwatch> stopwatchSupplier, boolean propagateTags) { in CensusStatsModule() argument
88 stopwatchSupplier, in CensusStatsModule() local
98 StatsRecorder statsRecorder, Supplier<Stopwatch> stopwatchSupplier, in CensusStatsModule() argument
103 this.stopwatchSupplier = checkNotNull(stopwatchSupplier, "stopwatchSupplier"); in CensusStatsModule()
331 this.stopwatch = module.stopwatchSupplier.get().start(); in ClientCallTracer()
491 Supplier<Stopwatch> stopwatchSupplier, in ServerTracer() argument
497 this.stopwatch = stopwatchSupplier.get().start(); in ServerTracer()
643 stopwatchSupplier, in newServerStreamTracer()
DManagedChannelImpl.java135 private final Supplier<Stopwatch> stopwatchSupplier; field in ManagedChannelImpl
519 Supplier<Stopwatch> stopwatchSupplier, in ManagedChannelImpl() argument
556 this.stopwatchSupplier = checkNotNull(stopwatchSupplier, "stopwatchSupplier"); in ManagedChannelImpl()
580 stopwatchSupplier.get()); in ManagedChannelImpl()
1063 stopwatchSupplier, in createSubchannel()
1186 transportFactory.getScheduledExecutorService(), stopwatchSupplier, channelExecutor, in createOobChannel()
DInternalSubchannel.java167 Supplier<Stopwatch> stopwatchSupplier, ChannelExecutor channelExecutor, Callback callback, in InternalSubchannel() argument
180 this.connectingTimer = stopwatchSupplier.get(); in InternalSubchannel()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClock.java63 private final Supplier<Stopwatch> stopwatchSupplier = field in FakeClock
201 return stopwatchSupplier; in getStopwatchSupplier()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java708 Supplier<Stopwatch> stopwatchSupplier = new Supplier<Stopwatch>() { in newHandler() local
722 stopwatchSupplier, in newHandler()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java199 Supplier<Stopwatch> stopwatchSupplier = new Supplier<Stopwatch>() { in startTransport() local
212 stopwatchSupplier, in startTransport()