@@ -183,7 +183,6 @@ func (m *defaultResourceManager) reconcileWithIPTargetType(ctx context.Context,
183183if err != nil {
184184return "" , "" , false , ctrlerrors .NewErrorWithMetrics (controllerName , "list_targets_error" , err , m .metricsCollector )
185185}
186- totalTargets := len (targets )
187186
188187notDrainingTargets , _ := partitionTargetsByDrainingStatus (targets )
189188matchedEndpointAndTargets , unmatchedEndpoints , unmatchedTargets := matchPodEndpointWithTargets (endpoints , notDrainingTargets )
@@ -244,7 +243,7 @@ func (m *defaultResourceManager) reconcileWithIPTargetType(ctx context.Context,
244243return "" , "" , false , ctrlerrors .NewErrorWithMetrics (controllerName , "update_tracked_ip_targets_error" , err , m .metricsCollector )
245244}
246245
247- eligibleTargetsCount := m .getMaxNewTargets (len (unmatchedEndpoints ), totalTargets , tgbScopedLogger )
246+ eligibleTargetsCount := m .getMaxNewTargets (len (unmatchedEndpoints ), len ( targets ) , tgbScopedLogger )
248247unmatchedEndpoints = unmatchedEndpoints [:eligibleTargetsCount ]
249248
250249if err := m .registerPodEndpoints (ctx , tgb , unmatchedEndpoints ); err != nil {
@@ -314,7 +313,6 @@ func (m *defaultResourceManager) reconcileWithInstanceTargetType(ctx context.Con
314313if err != nil {
315314return "" , "" , false , ctrlerrors .NewErrorWithMetrics (controllerName , "list_targets_error" , err , m .metricsCollector )
316315}
317- totalTargets := len (targets )
318316
319317notDrainingTargets , _ := partitionTargetsByDrainingStatus (targets )
320318
@@ -349,7 +347,7 @@ func (m *defaultResourceManager) reconcileWithInstanceTargetType(ctx context.Con
349347return "" , "" , false , ctrlerrors .NewErrorWithMetrics (controllerName , "update_tracked_instance_targets_error" , err , m .metricsCollector )
350348}
351349
352- eligibleTargetsCount := m .getMaxNewTargets (len (unmatchedEndpoints ), totalTargets , tgbScopedLogger )
350+ eligibleTargetsCount := m .getMaxNewTargets (len (unmatchedEndpoints ), len ( targets ) , tgbScopedLogger )
353351unmatchedEndpoints = unmatchedEndpoints [:eligibleTargetsCount ]
354352
355353if err := m .registerNodePortEndpoints (ctx , tgb , unmatchedEndpoints ); err != nil {
0 commit comments