github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 12:15:52 +00:00
Code Issues Projects Releases Wiki Activity

CollisionCount should have type int32 across controllers that use it for collision avoidance

Browse Source
This commit is contained in:
Di Xu 2017-08-13 20:10:25 +08:00
parent 12ce4151ce
commit 85602fd542
16 changed files with 48 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/apis/apps/fuzzer/fuzzer.go
View File

@ -44,7 +44,7 @@ var Funcs = func(codecs runtimeserializer.CodecFactory) []interface{} {
s.Status.ObservedGeneration = new(int64) s.Status.ObservedGeneration = new(int64)
} }
if s.Status.CollisionCount == nil { if s.Status.CollisionCount == nil {
s.Status.CollisionCount = new(int64) s.Status.CollisionCount = new(int32)
} }
}, },
} }

2
pkg/apis/apps/types.go
View File

@ -192,7 +192,7 @@ type StatefulSetStatus struct {
// uses this field as a collision avoidance mechanism when it needs to create the name for the // uses this field as a collision avoidance mechanism when it needs to create the name for the
// newest ControllerRevision. // newest ControllerRevision.
// +optional // +optional
CollisionCount *int64 CollisionCount *int32
} }
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

4
pkg/apis/apps/v1beta2/conversion.go
View File

@ -244,7 +244,7 @@ func Convert_v1beta2_StatefulSetStatus_To_apps_StatefulSetStatus(in *appsv1beta2
out.CurrentRevision = in.CurrentRevision out.CurrentRevision = in.CurrentRevision
out.UpdateRevision = in.UpdateRevision out.UpdateRevision = in.UpdateRevision
if in.CollisionCount != nil { if in.CollisionCount != nil {
out.CollisionCount = new(int64) out.CollisionCount = new(int32)
*out.CollisionCount = *in.CollisionCount *out.CollisionCount = *in.CollisionCount
} }
return nil return nil
@ -261,7 +261,7 @@ func Convert_apps_StatefulSetStatus_To_v1beta2_StatefulSetStatus(in *apps.Statef
out.CurrentRevision = in.CurrentRevision out.CurrentRevision = in.CurrentRevision
out.UpdateRevision = in.UpdateRevision out.UpdateRevision = in.UpdateRevision
if in.CollisionCount != nil { if in.CollisionCount != nil {
out.CollisionCount = new(int64) out.CollisionCount = new(int32)
*out.CollisionCount = *in.CollisionCount *out.CollisionCount = *in.CollisionCount
} }
return nil return nil

9
pkg/apis/apps/validation/validation_test.go
View File

@ -302,7 +302,8 @@ func TestValidateStatefulSet(t *testing.T) {
} }
func TestValidateStatefulSetStatus(t *testing.T) { func TestValidateStatefulSetStatus(t *testing.T) {
minusOne := int64(-1) observedGenerationMinusOne := int64(-1)
collisionCountMinusOne := int32(-1)
tests := []struct { tests := []struct {
name string name string
replicas int32 replicas int32
@ -310,7 +311,7 @@ func TestValidateStatefulSetStatus(t *testing.T) {
currentReplicas int32 currentReplicas int32
updatedReplicas int32 updatedReplicas int32
observedGeneration *int64 observedGeneration *int64
collisionCount *int64 collisionCount *int32
expectedErr bool expectedErr bool
}{ }{
{ {
@ -359,7 +360,7 @@ func TestValidateStatefulSetStatus(t *testing.T) {
readyReplicas: 3, readyReplicas: 3,
currentReplicas: 2, currentReplicas: 2,
updatedReplicas: 1, updatedReplicas: 1,
observedGeneration: &minusOne, observedGeneration: &observedGenerationMinusOne,
expectedErr: true, expectedErr: true,
}, },
{ {
@ -368,7 +369,7 @@ func TestValidateStatefulSetStatus(t *testing.T) {
readyReplicas: 3, readyReplicas: 3,
currentReplicas: 2, currentReplicas: 2,
updatedReplicas: 1, updatedReplicas: 1,
collisionCount: &minusOne, collisionCount: &collisionCountMinusOne,
expectedErr: true, expectedErr: true,
}, },
{ {

4
pkg/apis/extensions/types.go
View File

@ -345,7 +345,7 @@ type DeploymentStatus struct {
// field as a collision avoidance mechanism when it needs to create the name for the // field as a collision avoidance mechanism when it needs to create the name for the
// newest ReplicaSet. // newest ReplicaSet.
// +optional // +optional
CollisionCount *int64 CollisionCount *int32
} }
type DeploymentConditionType string type DeploymentConditionType string
@ -519,7 +519,7 @@ type DaemonSetStatus struct {
// uses this field as a collision avoidance mechanism when it needs to // uses this field as a collision avoidance mechanism when it needs to
// create the name for the newest ControllerRevision. // create the name for the newest ControllerRevision.
// +optional // +optional
CollisionCount *int64 CollisionCount *int32
} }
// +genclient // +genclient

8
pkg/apis/extensions/validation/validation.go
View File

@ -95,7 +95,7 @@ func ValidateDaemonSetStatusUpdate(ds, oldDS *extensions.DaemonSet) field.ErrorL
allErrs := apivalidation.ValidateObjectMetaUpdate(&ds.ObjectMeta, &oldDS.ObjectMeta, field.NewPath("metadata")) allErrs := apivalidation.ValidateObjectMetaUpdate(&ds.ObjectMeta, &oldDS.ObjectMeta, field.NewPath("metadata"))
allErrs = append(allErrs, validateDaemonSetStatus(&ds.Status, field.NewPath("status"))...) allErrs = append(allErrs, validateDaemonSetStatus(&ds.Status, field.NewPath("status"))...)
if isDecremented(ds.Status.CollisionCount, oldDS.Status.CollisionCount) { if isDecremented(ds.Status.CollisionCount, oldDS.Status.CollisionCount) {
value := int64(0) value := int32(0)
if ds.Status.CollisionCount != nil { if ds.Status.CollisionCount != nil {
value = *ds.Status.CollisionCount value = *ds.Status.CollisionCount
} }
@ -311,7 +311,7 @@ func ValidateDeploymentStatus(status *extensions.DeploymentStatus, fldPath *fiel
allErrs = append(allErrs, apivalidation.ValidateNonnegativeField(int64(status.AvailableReplicas), fldPath.Child("availableReplicas"))...) allErrs = append(allErrs, apivalidation.ValidateNonnegativeField(int64(status.AvailableReplicas), fldPath.Child("availableReplicas"))...)
allErrs = append(allErrs, apivalidation.ValidateNonnegativeField(int64(status.UnavailableReplicas), fldPath.Child("unavailableReplicas"))...) allErrs = append(allErrs, apivalidation.ValidateNonnegativeField(int64(status.UnavailableReplicas), fldPath.Child("unavailableReplicas"))...)
if status.CollisionCount != nil { if status.CollisionCount != nil {
allErrs = append(allErrs, apivalidation.ValidateNonnegativeField(*status.CollisionCount, fldPath.Child("collisionCount"))...) allErrs = append(allErrs, apivalidation.ValidateNonnegativeField(int64(*status.CollisionCount), fldPath.Child("collisionCount"))...)
} }
msg := "cannot be greater than status.replicas" msg := "cannot be greater than status.replicas"
if status.UpdatedReplicas > status.Replicas { if status.UpdatedReplicas > status.Replicas {
@ -342,7 +342,7 @@ func ValidateDeploymentStatusUpdate(update, old *extensions.Deployment) field.Er
fldPath := field.NewPath("status") fldPath := field.NewPath("status")
allErrs = append(allErrs, ValidateDeploymentStatus(&update.Status, fldPath)...) allErrs = append(allErrs, ValidateDeploymentStatus(&update.Status, fldPath)...)
if isDecremented(update.Status.CollisionCount, old.Status.CollisionCount) { if isDecremented(update.Status.CollisionCount, old.Status.CollisionCount) {
value := int64(0) value := int32(0)
if update.Status.CollisionCount != nil { if update.Status.CollisionCount != nil {
value = *update.Status.CollisionCount value = *update.Status.CollisionCount
} }
@ -352,7 +352,7 @@ func ValidateDeploymentStatusUpdate(update, old *extensions.Deployment) field.Er
} }
// TODO: Move in "k8s.io/kubernetes/pkg/api/validation" // TODO: Move in "k8s.io/kubernetes/pkg/api/validation"
func isDecremented(update, old *int64) bool { func isDecremented(update, old *int32) bool {
if update == nil && old != nil { if update == nil && old != nil {
return true return true
} }

19
pkg/apis/extensions/validation/validation_test.go
View File

@ -1238,6 +1238,7 @@ func int64p(i int) *int64 {
} }
func TestValidateDeploymentStatus(t *testing.T) { func TestValidateDeploymentStatus(t *testing.T) {
collisionCount := int32(-3)
tests := []struct { tests := []struct {
name string name string
@ -1246,7 +1247,7 @@ func TestValidateDeploymentStatus(t *testing.T) {
readyReplicas int32 readyReplicas int32
availableReplicas int32 availableReplicas int32
observedGeneration int64 observedGeneration int64
collisionCount *int64 collisionCount *int32
expectedErr bool expectedErr bool
}{ }{
@ -1347,7 +1348,7 @@ func TestValidateDeploymentStatus(t *testing.T) {
name: "invalid collisionCount", name: "invalid collisionCount",
replicas: 3, replicas: 3,
observedGeneration: 1, observedGeneration: 1,
collisionCount: int64p(-3), collisionCount: &collisionCount,
expectedErr: true, expectedErr: true,
}, },
} }
@ -1371,6 +1372,8 @@ func TestValidateDeploymentStatus(t *testing.T) {
} }
func TestValidateDeploymentStatusUpdate(t *testing.T) { func TestValidateDeploymentStatusUpdate(t *testing.T) {
collisionCount := int32(1)
otherCollisionCount := int32(2)
tests := []struct { tests := []struct {
name string name string
@ -1384,24 +1387,24 @@ func TestValidateDeploymentStatusUpdate(t *testing.T) {
CollisionCount: nil, CollisionCount: nil,
}, },
to: extensions.DeploymentStatus{ to: extensions.DeploymentStatus{
CollisionCount: int64p(1), CollisionCount: &collisionCount,
}, },
expectedErr: false, expectedErr: false,
}, },
{ {
name: "stable: valid update", name: "stable: valid update",
from: extensions.DeploymentStatus{ from: extensions.DeploymentStatus{
CollisionCount: int64p(1), CollisionCount: &collisionCount,
}, },
to: extensions.DeploymentStatus{ to: extensions.DeploymentStatus{
CollisionCount: int64p(1), CollisionCount: &collisionCount,
}, },
expectedErr: false, expectedErr: false,
}, },
{ {
name: "unset: invalid update", name: "unset: invalid update",
from: extensions.DeploymentStatus{ from: extensions.DeploymentStatus{
CollisionCount: int64p(1), CollisionCount: &collisionCount,
}, },
to: extensions.DeploymentStatus{ to: extensions.DeploymentStatus{
CollisionCount: nil, CollisionCount: nil,
@ -1411,10 +1414,10 @@ func TestValidateDeploymentStatusUpdate(t *testing.T) {
{ {
name: "decrease: invalid update", name: "decrease: invalid update",
from: extensions.DeploymentStatus{ from: extensions.DeploymentStatus{
CollisionCount: int64p(2), CollisionCount: &otherCollisionCount,
}, },
to: extensions.DeploymentStatus{ to: extensions.DeploymentStatus{
CollisionCount: int64p(1), CollisionCount: &collisionCount,
}, },
expectedErr: true, expectedErr: true,
}, },

4
pkg/controller/controller_utils.go
View File

@ -1030,14 +1030,14 @@ func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, cacheSyncs
} }
// ComputeHash returns a hash value calculated from pod template and a collisionCount to avoid hash collision // ComputeHash returns a hash value calculated from pod template and a collisionCount to avoid hash collision
func ComputeHash(template *v1.PodTemplateSpec, collisionCount *int64) uint32 { func ComputeHash(template *v1.PodTemplateSpec, collisionCount *int32) uint32 {
podTemplateSpecHasher := fnv.New32a() podTemplateSpecHasher := fnv.New32a()
hashutil.DeepHashObject(podTemplateSpecHasher, *template) hashutil.DeepHashObject(podTemplateSpecHasher, *template)
// Add collisionCount in the hash if it exists. // Add collisionCount in the hash if it exists.
if collisionCount != nil { if collisionCount != nil {
collisionCountBytes := make([]byte, 8) collisionCountBytes := make([]byte, 8)
binary.LittleEndian.PutUint64(collisionCountBytes, uint64(*collisionCount)) binary.LittleEndian.PutUint32(collisionCountBytes, uint32(*collisionCount))
podTemplateSpecHasher.Write(collisionCountBytes) podTemplateSpecHasher.Write(collisionCountBytes)
} }

13
pkg/controller/controller_utils_test.go
View File

@ -453,23 +453,26 @@ func int64P(num int64) *int64 {
} }
func TestComputeHash(t *testing.T) { func TestComputeHash(t *testing.T) {
collisionCount := int32(1)
otherCollisionCount := int32(2)
maxCollisionCount := int32(math.MaxInt32)
tests := []struct { tests := []struct {
name string name string
template *v1.PodTemplateSpec template *v1.PodTemplateSpec
collisionCount *int64 collisionCount *int32
otherCollisionCount *int64 otherCollisionCount *int32
}{ }{
{ {
name: "simple", name: "simple",
template: &v1.PodTemplateSpec{}, template: &v1.PodTemplateSpec{},
collisionCount: int64P(1), collisionCount: &collisionCount,
otherCollisionCount: int64P(2), otherCollisionCount: &otherCollisionCount,
}, },
{ {
name: "using math.MaxInt64", name: "using math.MaxInt64",
template: &v1.PodTemplateSpec{}, template: &v1.PodTemplateSpec{},
collisionCount: nil, collisionCount: nil,
otherCollisionCount: int64P(int64(math.MaxInt64)), otherCollisionCount: &maxCollisionCount,
}, },
} }

2
pkg/controller/daemon/update.go
View File

@ -368,7 +368,7 @@ func (dsc *DaemonSetsController) snapshot(ds *extensions.DaemonSet, revision int
return nil, getErr return nil, getErr
} }
if currDS.Status.CollisionCount == nil { if currDS.Status.CollisionCount == nil {
currDS.Status.CollisionCount = new(int64) currDS.Status.CollisionCount = new(int32)
} }
*currDS.Status.CollisionCount++ *currDS.Status.CollisionCount++
_, updateErr := dsc.kubeClient.ExtensionsV1beta1().DaemonSets(ds.Namespace).UpdateStatus(currDS) _, updateErr := dsc.kubeClient.ExtensionsV1beta1().DaemonSets(ds.Namespace).UpdateStatus(currDS)

4
pkg/controller/deployment/sync.go
View File

@ -160,7 +160,7 @@ func (dc *DeploymentController) rsAndPodsWithHashKeySynced(d *extensions.Deploym
// 1. Add hash label to the rs's pod template, and make sure the controller sees this update so that no orphaned pods will be created // 1. Add hash label to the rs's pod template, and make sure the controller sees this update so that no orphaned pods will be created
// 2. Add hash label to all pods this rs owns, wait until replicaset controller reports rs.Status.FullyLabeledReplicas equal to the desired number of replicas // 2. Add hash label to all pods this rs owns, wait until replicaset controller reports rs.Status.FullyLabeledReplicas equal to the desired number of replicas
// 3. Add hash label to the rs's label and selector // 3. Add hash label to the rs's label and selector
func (dc *DeploymentController) addHashKeyToRSAndPods(rs *extensions.ReplicaSet, podList *v1.PodList, collisionCount *int64) (*extensions.ReplicaSet, error) { func (dc *DeploymentController) addHashKeyToRSAndPods(rs *extensions.ReplicaSet, podList *v1.PodList, collisionCount *int32) (*extensions.ReplicaSet, error) {
// If the rs already has the new hash label in its selector, it's done syncing // If the rs already has the new hash label in its selector, it's done syncing
if labelsutil.SelectorHasLabel(rs.Spec.Selector, extensions.DefaultDeploymentUniqueLabelKey) { if labelsutil.SelectorHasLabel(rs.Spec.Selector, extensions.DefaultDeploymentUniqueLabelKey) {
return rs, nil return rs, nil
@ -349,7 +349,7 @@ func (dc *DeploymentController) getNewReplicaSet(d *extensions.Deployment, rsLis
// and requeue the Deployment. // and requeue the Deployment.
if !isEqual { if !isEqual {
if d.Status.CollisionCount == nil { if d.Status.CollisionCount == nil {
d.Status.CollisionCount = new(int64) d.Status.CollisionCount = new(int32)
} }
preCollisionCount := *d.Status.CollisionCount preCollisionCount := *d.Status.CollisionCount
*d.Status.CollisionCount++ *d.Status.CollisionCount++

2
pkg/controller/deployment/util/replicaset_util.go
View File

@ -70,7 +70,7 @@ func UpdateRSWithRetries(rsClient unversionedextensions.ReplicaSetInterface, rsL
} }
// GetReplicaSetHash returns the pod template hash of a ReplicaSet's pod template space // GetReplicaSetHash returns the pod template hash of a ReplicaSet's pod template space
func GetReplicaSetHash(rs *extensions.ReplicaSet, uniquifier *int64) (string, error) { func GetReplicaSetHash(rs *extensions.ReplicaSet, uniquifier *int32) (string, error) {
template, err := scheme.Scheme.DeepCopy(rs.Spec.Template) template, err := scheme.Scheme.DeepCopy(rs.Spec.Template)
if err != nil { if err != nil {
return "", err return "", err

4
staging/src/k8s.io/api/apps/v1beta1/types.go
View File

@ -244,7 +244,7 @@ type StatefulSetStatus struct {
// uses this field as a collision avoidance mechanism when it needs to create the name for the // uses this field as a collision avoidance mechanism when it needs to create the name for the
// newest ControllerRevision. // newest ControllerRevision.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"`
} }
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
@ -445,7 +445,7 @@ type DeploymentStatus struct {
// field as a collision avoidance mechanism when it needs to create the name for the // field as a collision avoidance mechanism when it needs to create the name for the
// newest ReplicaSet. // newest ReplicaSet.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"`
} }
type DeploymentConditionType string type DeploymentConditionType string

6
staging/src/k8s.io/api/apps/v1beta2/types.go
View File

@ -251,7 +251,7 @@ type StatefulSetStatus struct {
// uses this field as a collision avoidance mechanism when it needs to create the name for the // uses this field as a collision avoidance mechanism when it needs to create the name for the
// newest ControllerRevision. // newest ControllerRevision.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"`
} }
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
@ -425,7 +425,7 @@ type DeploymentStatus struct {
// field as a collision avoidance mechanism when it needs to create the name for the // field as a collision avoidance mechanism when it needs to create the name for the
// newest ReplicaSet. // newest ReplicaSet.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"`
} }
type DeploymentConditionType string type DeploymentConditionType string
@ -598,7 +598,7 @@ type DaemonSetStatus struct {
// uses this field as a collision avoidance mechanism when it needs to // uses this field as a collision avoidance mechanism when it needs to
// create the name for the newest ControllerRevision. // create the name for the newest ControllerRevision.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"`
} }
// +genclient // +genclient

4
staging/src/k8s.io/api/extensions/v1beta1/types.go
View File

@ -345,7 +345,7 @@ type DeploymentStatus struct {
// field as a collision avoidance mechanism when it needs to create the name for the // field as a collision avoidance mechanism when it needs to create the name for the
// newest ReplicaSet. // newest ReplicaSet.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"`
} }
type DeploymentConditionType string type DeploymentConditionType string
@ -524,7 +524,7 @@ type DaemonSetStatus struct {
// uses this field as a collision avoidance mechanism when it needs to // uses this field as a collision avoidance mechanism when it needs to
// create the name for the newest ControllerRevision. // create the name for the newest ControllerRevision.
// +optional // +optional
CollisionCount *int64 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"` CollisionCount *int32 `json:"collisionCount,omitempty" protobuf:"varint,9,opt,name=collisionCount"`
} }
// +genclient // +genclient

2
test/e2e/apps/deployment.go
View File

@ -1449,7 +1449,7 @@ func testDeploymentHashCollisionAvoidance(f *framework.Framework) {
return false, nil return false, nil
} }
framework.Logf(spew.Sprintf("deployment status: %#v", d.Status)) framework.Logf(spew.Sprintf("deployment status: %#v", d.Status))
return d.Status.CollisionCount != nil && *d.Status.CollisionCount == int64(1), nil return d.Status.CollisionCount != nil && *d.Status.CollisionCount == int32(1), nil
}); err != nil { }); err != nil {
framework.Failf("Failed to increment collision counter for deployment %q: %v", deploymentName, err) framework.Failf("Failed to increment collision counter for deployment %q: %v", deploymentName, err)
} }