Searched refs:GrpclbClientLoadRecorder (Results 1 – 3 of 3) sorted by relevance
42 final class GrpclbClientLoadRecorder extends ClientStreamTracer.Factory { class44 private static final AtomicLongFieldUpdater<GrpclbClientLoadRecorder> callsStartedUpdater =45 AtomicLongFieldUpdater.newUpdater(GrpclbClientLoadRecorder.class, "callsStarted");46 private static final AtomicLongFieldUpdater<GrpclbClientLoadRecorder> callsFinishedUpdater =47 AtomicLongFieldUpdater.newUpdater(GrpclbClientLoadRecorder.class, "callsFinished");48 private static final AtomicLongFieldUpdater<GrpclbClientLoadRecorder> callsFailedToSendUpdater =49 AtomicLongFieldUpdater.newUpdater(GrpclbClientLoadRecorder.class, "callsFailedToSend");50 private static final AtomicLongFieldUpdater<GrpclbClientLoadRecorder>53 GrpclbClientLoadRecorder.class, "callsFinishedKnownReceived");73 GrpclbClientLoadRecorder(TimeProvider time) { in GrpclbClientLoadRecorder() method in GrpclbClientLoadRecorder[all …]
334 GrpclbClientLoadRecorder getLoadRecorder() { in getLoadRecorder()346 @Nullable GrpclbClientLoadRecorder loadRecorder) { in useRoundRobinLists()468 final GrpclbClientLoadRecorder loadRecorder;482 loadRecorder = new GrpclbClientLoadRecorder(time); in LbStream()770 private final GrpclbClientLoadRecorder loadRecorder;773 DropEntry(GrpclbClientLoadRecorder loadRecorder, String token) { in DropEntry()815 private final GrpclbClientLoadRecorder loadRecorder;822 BackendEntry(Subchannel subchannel, GrpclbClientLoadRecorder loadRecorder, String token) { in BackendEntry()
300 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerNoDrop()338 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerWithDrop()1519 private GrpclbClientLoadRecorder getLoadRecorder() { in getLoadRecorder()