Skip to content

Commit 41c150c

Browse files
committed
Fix the nil pointer dereference
1 parent a375a60 commit 41c150c

File tree

3 files changed

+11
-4
lines changed

3 files changed

+11
-4
lines changed

pkg/operator/clusteroperator.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111
"k8s.io/client-go/tools/cache"
1212
"k8s.io/client-go/util/workqueue"
1313
"k8s.io/klog/v2"
14+
"k8s.io/utils/clock"
1415

1516
configv1 "github.com/openshift/api/config/v1"
1617
configv1client "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1"
@@ -131,6 +132,7 @@ func (c *ClusterOperatorStatusController) sync() error {
131132
cr,
132133
imagepruner,
133134
c.relatedObjects,
135+
clock.RealClock{},
134136
)
135137

136138
return resource.ApplyMutator(mut)

pkg/resource/clusteroperator.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ import (
1414
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1515
"k8s.io/apimachinery/pkg/runtime"
1616
appslisters "k8s.io/client-go/listers/apps/v1"
17+
"k8s.io/utils/clock"
1718

1819
configv1 "github.com/openshift/api/config/v1"
1920
imageregistryv1 "github.com/openshift/api/imageregistry/v1"
@@ -119,6 +120,7 @@ type generatorClusterOperator struct {
119120
deployLister appslisters.DeploymentNamespaceLister
120121
configLister configlisters.ClusterOperatorLister
121122
configClient configv1client.ClusterOperatorsGetter
123+
clock clock.PassiveClock
122124
}
123125

124126
func NewGeneratorClusterOperator(
@@ -128,6 +130,7 @@ func NewGeneratorClusterOperator(
128130
cr *imageregistryv1.Config,
129131
imagePruner *imageregistryv1.ImagePruner,
130132
relatedObjects []configv1.ObjectReference,
133+
clock clock.PassiveClock,
131134
) *generatorClusterOperator {
132135
return &generatorClusterOperator{
133136
deployLister: deployLister,
@@ -136,6 +139,7 @@ func NewGeneratorClusterOperator(
136139
cr: cr,
137140
imagePruner: imagePruner,
138141
relatedObjects: relatedObjects,
142+
clock: clock,
139143
}
140144
}
141145

@@ -219,9 +223,9 @@ func (gco *generatorClusterOperator) syncConditions(op *configv1.ClusterOperator
219223
}
220224

221225
oldStatus := op.Status.DeepCopy()
222-
configv1helpers.SetStatusCondition(&op.Status.Conditions, unionCondition("Available", operatorv1.ConditionTrue, conditions), nil)
223-
configv1helpers.SetStatusCondition(&op.Status.Conditions, unionCondition("Progressing", operatorv1.ConditionFalse, conditions), nil)
224-
configv1helpers.SetStatusCondition(&op.Status.Conditions, unionCondition("Degraded", operatorv1.ConditionFalse, conditions), nil)
226+
configv1helpers.SetStatusCondition(&op.Status.Conditions, unionCondition("Available", operatorv1.ConditionTrue, conditions), gco.clock)
227+
configv1helpers.SetStatusCondition(&op.Status.Conditions, unionCondition("Progressing", operatorv1.ConditionFalse, conditions), gco.clock)
228+
configv1helpers.SetStatusCondition(&op.Status.Conditions, unionCondition("Degraded", operatorv1.ConditionFalse, conditions), gco.clock)
225229
return !equality.Semantic.DeepEqual(oldStatus, &op.Status)
226230
}
227231

pkg/resource/clusteroperator_test.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
kerror "k8s.io/apimachinery/pkg/api/errors"
1010
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1111
labels "k8s.io/apimachinery/pkg/labels"
12+
"k8s.io/utils/clock"
1213

1314
cfgapi "github.com/openshift/api/config/v1"
1415
imregv1 "github.com/openshift/api/imageregistry/v1"
@@ -263,7 +264,7 @@ func TestSyncVersions(t *testing.T) {
263264

264265
lister.deploys, lister.failOnGet = tt.deploys, tt.failOnGet
265266
gen := NewGeneratorClusterOperator(
266-
lister, nil, nil, tt.config, nil, nil,
267+
lister, nil, nil, tt.config, nil, nil, clock.RealClock{},
267268
)
268269

269270
modified, err := gen.syncVersions(co)

0 commit comments

Comments
 (0)