From 3cbd6283880b7a0897f3d376e17a4f3229414992 Mon Sep 17 00:00:00 2001 From: Bohan Yang Date: Thu, 16 May 2024 15:12:00 -0700 Subject: [PATCH] revert un-needed change in test helper --- .../relative/TrackerClientMockHelper.java | 24 ++++--------------- 1 file changed, 5 insertions(+), 19 deletions(-) diff --git a/d2/src/test/java/com/linkedin/d2/balancer/strategies/relative/TrackerClientMockHelper.java b/d2/src/test/java/com/linkedin/d2/balancer/strategies/relative/TrackerClientMockHelper.java index 7d4827a726..881425ba48 100644 --- a/d2/src/test/java/com/linkedin/d2/balancer/strategies/relative/TrackerClientMockHelper.java +++ b/d2/src/test/java/com/linkedin/d2/balancer/strategies/relative/TrackerClientMockHelper.java @@ -27,7 +27,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.stream.Collectors; import org.mockito.Mockito; import static org.mockito.Matchers.anyInt; @@ -78,19 +77,6 @@ public static List mockTrackerClients(int numTrackerClients, return mockTrackerClients(numTrackerClients, callCountList, outstandingCallCountList, latencyList, outstandingLatencyList, errorCountList, false, doNotLoadBalance); } - public static List mockTrackerClients(int numTrackerClients, List callCountList, - List outstandingCallCountList, List latencyList, List outstandingLatencyList, - List errorCountList, boolean doNotSlowStart, List doNotLoadBalance) - { - List> errorTypeCountsList = errorCountList.stream().map(count -> { - Map errorTypeCounts = new HashMap<>(); - errorTypeCounts.put(ErrorType.SERVER_ERROR, count); - return errorTypeCounts; - }).collect(Collectors.toList()); - return mockTrackerClients(numTrackerClients, callCountList, outstandingCallCountList, latencyList, - outstandingLatencyList, errorCountList, doNotSlowStart, doNotLoadBalance, errorTypeCountsList); - } - /** * Mock a list of {@link TrackerClient} for testing * @@ -100,13 +86,11 @@ public static List mockTrackerClients(int numTrackerClients, List * @param latencyList The latency of each host * @param outstandingLatencyList The outstanding latency of each host * @param errorCountList The error count of each host - * @param errorTypeCounts The error count by type of each host * @return A list of mocked {@link TrackerClient} */ public static List mockTrackerClients(int numTrackerClients, List callCountList, List outstandingCallCountList, List latencyList, List outstandingLatencyList, - List errorCountList, boolean doNotSlowStart, List doNotLoadBalance, - List> errorTypeCounts) + List errorCountList, boolean doNotSlowStart, List doNotLoadBalance) { List trackerClients = new ArrayList<>(); for (int index = 0; index < numTrackerClients; index ++) @@ -115,6 +99,8 @@ public static List mockTrackerClients(int numTrackerClients, List TrackerClient trackerClient = Mockito.mock(TrackerClient.class); CallTracker callTracker = Mockito.mock(CallTracker.class); LongStats longStats = new LongStats(callCountList.get(index), latencyList.get(index), 0, 0, 0, 0, 0, 0, 0); + Map errorTypeCounts = new HashMap<>(); + errorTypeCounts.put(ErrorType.SERVER_ERROR, errorCountList.get(index)); CallTrackerImpl.CallTrackerStats callStats = new CallTrackerImpl.CallTrackerStats( RelativeLoadBalancerStrategyFactory.DEFAULT_UPDATE_INTERVAL_MS, @@ -129,8 +115,8 @@ public static List mockTrackerClients(int numTrackerClients, List RelativeLoadBalancerStrategyFactory.DEFAULT_UPDATE_INTERVAL_MS - outstandingLatencyList.get(index), outstandingCallCountList.get(index), longStats, - errorTypeCounts.get(index), - errorTypeCounts.get(index)); + errorTypeCounts, + errorTypeCounts); Mockito.when(trackerClient.getCallTracker()).thenReturn(callTracker); Mockito.when(callTracker.getCallStats()).thenReturn(callStats);