From 2c797a80af26ce7f0880a6126deae877c8278b6e Mon Sep 17 00:00:00 2001
From: Michail Kargakis <mkargaki@redhat.com>
Date: Mon, 10 Oct 2016 19:02:31 +0200
Subject: [PATCH] Revert "Error out when any RS has more available pods then
 its spec replicas"

This reverts commit 32ababbe1b0bf9ee6786aa555cc3cd7f54f2014a.
---
 pkg/controller/deployment/rolling_test.go       |  8 +-------
 .../deployment/util/deployment_util.go          | 17 +++++------------
 2 files changed, 6 insertions(+), 19 deletions(-)

diff --git a/pkg/controller/deployment/rolling_test.go b/pkg/controller/deployment/rolling_test.go
index 3dd5db6b82f..1c9afcd41be 100644
--- a/pkg/controller/deployment/rolling_test.go
+++ b/pkg/controller/deployment/rolling_test.go
@@ -395,7 +395,6 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 		oldReplicas         int
 		scaleExpected       bool
 		expectedOldReplicas int
-		errorExpected       bool
 	}{
 		{
 			deploymentReplicas:  10,
@@ -404,7 +403,6 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 			oldReplicas:         10,
 			scaleExpected:       true,
 			expectedOldReplicas: 9,
-			errorExpected:       false,
 		},
 		{
 			deploymentReplicas:  10,
@@ -413,7 +411,6 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 			oldReplicas:         10,
 			scaleExpected:       true,
 			expectedOldReplicas: 8,
-			errorExpected:       false,
 		},
 		{
 			deploymentReplicas: 10,
@@ -421,7 +418,6 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 			readyPods:          8,
 			oldReplicas:        10,
 			scaleExpected:      false,
-			errorExpected:      false,
 		},
 		{
 			deploymentReplicas: 10,
@@ -429,7 +425,6 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 			readyPods:          10,
 			oldReplicas:        0,
 			scaleExpected:      false,
-			errorExpected:      true,
 		},
 		{
 			deploymentReplicas: 10,
@@ -437,7 +432,6 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 			readyPods:          1,
 			oldReplicas:        10,
 			scaleExpected:      false,
-			errorExpected:      false,
 		},
 	}
 
@@ -479,7 +473,7 @@ func TestDeploymentController_scaleDownOldReplicaSetsForRollingUpdate(t *testing
 			eventRecorder: &record.FakeRecorder{},
 		}
 		scaled, err := controller.scaleDownOldReplicaSetsForRollingUpdate(allRSs, oldRSs, deployment)
-		if !test.errorExpected && err != nil {
+		if err != nil {
 			t.Errorf("unexpected error: %v", err)
 			continue
 		}
diff --git a/pkg/controller/deployment/util/deployment_util.go b/pkg/controller/deployment/util/deployment_util.go
index 7362489e592..684ba083ba4 100644
--- a/pkg/controller/deployment/util/deployment_util.go
+++ b/pkg/controller/deployment/util/deployment_util.go
@@ -662,7 +662,7 @@ func GetAvailablePodsForReplicaSets(c clientset.Interface, deployment *extension
 // CountAvailablePodsForReplicaSets returns the number of available pods corresponding to the given pod list and replica sets.
 // Note that the input pod list should be the pods targeted by the deployment of input replica sets.
 func CountAvailablePodsForReplicaSets(podList *api.PodList, rss []*extensions.ReplicaSet, minReadySeconds int32) (int32, error) {
-	rsPods, err := filterPodsMatchingReplicaSets(rss, podList, minReadySeconds)
+	rsPods, err := filterPodsMatchingReplicaSets(rss, podList)
 	if err != nil {
 		return 0, err
 	}
@@ -717,8 +717,8 @@ func IsPodAvailable(pod *api.Pod, minReadySeconds int32, now time.Time) bool {
 }
 
 // filterPodsMatchingReplicaSets filters the given pod list and only return the ones targeted by the input replicasets
-func filterPodsMatchingReplicaSets(replicaSets []*extensions.ReplicaSet, podList *api.PodList, minReadySeconds int32) ([]api.Pod, error) {
-	allRSPods := []api.Pod{}
+func filterPodsMatchingReplicaSets(replicaSets []*extensions.ReplicaSet, podList *api.PodList) ([]api.Pod, error) {
+	rsPods := []api.Pod{}
 	for _, rs := range replicaSets {
 		matchingFunc, err := rsutil.MatchingPodsFunc(rs)
 		if err != nil {
@@ -727,16 +727,9 @@ func filterPodsMatchingReplicaSets(replicaSets []*extensions.ReplicaSet, podList
 		if matchingFunc == nil {
 			continue
 		}
-		rsPods := podutil.Filter(podList, matchingFunc)
-		avaPodsCount := countAvailablePods(rsPods, minReadySeconds)
-		if avaPodsCount > rs.Spec.Replicas {
-			msg := fmt.Sprintf("Found %s/%s with %d available pods, more than its spec replicas %d", rs.Namespace, rs.Name, avaPodsCount, rs.Spec.Replicas)
-			glog.Errorf("ERROR: %s", msg)
-			return nil, fmt.Errorf(msg)
-		}
-		allRSPods = append(allRSPods, podutil.Filter(podList, matchingFunc)...)
+		rsPods = append(rsPods, podutil.Filter(podList, matchingFunc)...)
 	}
-	return allRSPods, nil
+	return rsPods, nil
 }
 
 // IsRollingUpdate returns true if the strategy type is a rolling update.