Searched refs:loadRecorder (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 338 return lbStream.loadRecorder; in getLoadRecorder()
346 @Nullable GrpclbClientLoadRecorder loadRecorder) { in useRoundRobinLists() argument
374 entry = new BackendEntry(subchannel, loadRecorder, backendAddr.getToken()); in useRoundRobinLists()
468 final GrpclbClientLoadRecorder loadRecorder; field in GrpclbState.LbStream
482 loadRecorder = new GrpclbClientLoadRecorder(time); in LbStream()
524 ClientStats stats = loadRecorder.generateLoadReport(); in sendLoadReport()
581 newDropList.add(new DropEntry(loadRecorder, token)); in handleResponse()
605 useRoundRobinLists(newDropList, newBackendAddrList, loadRecorder); in handleResponse()
770 private final GrpclbClientLoadRecorder loadRecorder; field in GrpclbState.DropEntry
773 DropEntry(GrpclbClientLoadRecorder loadRecorder, String token) { in DropEntry() argument
[all …]
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 300 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerNoDrop() local
302 BackendEntry b1 = new BackendEntry(subchannel, loadRecorder, "LBTOKEN0001"); in roundRobinPickerNoDrop()
303 BackendEntry b2 = new BackendEntry(subchannel, loadRecorder, "LBTOKEN0002"); in roundRobinPickerNoDrop()
338 GrpclbClientLoadRecorder loadRecorder = new GrpclbClientLoadRecorder(timeProvider); in roundRobinPickerWithDrop() local
341 DropEntry d = new DropEntry(loadRecorder, "LBTOKEN0003"); in roundRobinPickerWithDrop()
344 BackendEntry b1 = new BackendEntry(subchannel, loadRecorder, "LBTOKEN0001"); in roundRobinPickerWithDrop()
345 BackendEntry b2 = new BackendEntry(subchannel, loadRecorder, "LBTOKEN0002"); in roundRobinPickerWithDrop()
|