Skip to content

Commit 7cc52a4

Browse files
undo changes
1 parent 151424a commit 7cc52a4

File tree

2 files changed

+10
-51
lines changed

2 files changed

+10
-51
lines changed

pkg/controller/common/layered_node_state.go

Lines changed: 10 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -30,13 +30,10 @@ func NewLayeredNodeState(n *corev1.Node) *LayeredNodeState {
3030
// determined by the pool. If in layered mode, the image annotations are also checked
3131
// checked against the OCL objects.
3232
func (l *LayeredNodeState) IsDone(mcp *mcfgv1.MachineConfigPool, layered bool, mosc *mcfgv1.MachineOSConfig, mosb *mcfgv1.MachineOSBuild) bool {
33-
// if layered {
34-
// klog.Errorf("in IsDone and layered")
35-
// return l.IsNodeDone() && l.IsDesiredMachineConfigEqualToPool(mcp) && l.IsDesiredEqualToBuild(mosc, mosb)
36-
// }
37-
// klog.Errorf("in IsDone and NOT layered")
38-
// return l.IsNodeDone() && l.IsDesiredMachineConfigEqualToPool(mcp)
39-
return l.IsNodeDone() && l.IsDesiredMachineConfigEqualToPool(mcp) && l.IsDesiredEqualToBuild(mosc, mosb)
33+
if layered {
34+
return l.IsNodeDone() && l.IsDesiredMachineConfigEqualToPool(mcp) && l.IsDesiredEqualToBuild(mosc, mosb)
35+
}
36+
return l.IsNodeDone() && l.IsDesiredMachineConfigEqualToPool(mcp)
4037
}
4138

4239
// The original behavior of getUnavailableMachines is: getUnavailableMachines
@@ -70,28 +67,19 @@ func (l *LayeredNodeState) IsUnavailableForUpdate() bool {
7067
// node's desired image annotation and compares the MachineConfig specified by the
7168
// MachineOSBuild to the one specified by the node's desired MachineConfig annotation.
7269
func (l *LayeredNodeState) IsDesiredEqualToBuild(mosc *mcfgv1.MachineOSConfig, mosb *mcfgv1.MachineOSBuild) bool {
73-
klog.Errorf("in IsDesiredEqualToBuild")
74-
return l.isDesiredImageEqualToMachineOSConfig(mosc) && l.isDesiredMachineConfigEqualToBuild(mosb)
70+
return (mosc != nil && l.isDesiredImageEqualToMachineOSConfig(mosc)) && (mosb != nil && l.isDesiredMachineConfigEqualToBuild(mosb))
7571
}
7672

7773
// Compares the desired image annotation on the node against the CurrentImagePullSpec
7874
// specified by the MachineOSConfig object.
7975
func (l *LayeredNodeState) isDesiredImageEqualToMachineOSConfig(mosc *mcfgv1.MachineOSConfig) bool {
80-
klog.Errorf("in isDesiredImageEqualToMachineOSConfig")
8176
return l.isImageAnnotationEqualToMachineOSConfig(daemonconsts.DesiredImageAnnotationKey, mosc)
8277
}
8378

8479
// Compares the MachineConfig specified by the MachineConfigPool to the MachineConfig
8580
// specified by the node's desired MachineConfig annotation.
8681
func (l *LayeredNodeState) isDesiredMachineConfigEqualToBuild(mosb *mcfgv1.MachineOSBuild) bool {
87-
mosbName := ""
88-
// Handle case when MOSB is nil (image mode is being disabled)
89-
if mosb != nil {
90-
// TODO: check if this comes back as nil or empty string
91-
mosbName = mosb.Spec.MachineConfig.Name
92-
}
93-
94-
return l.node.Annotations[daemonconsts.DesiredMachineConfigAnnotationKey] == mosbName
82+
return l.node.Annotations[daemonconsts.DesiredMachineConfigAnnotationKey] == mosb.Spec.MachineConfig.Name
9583

9684
}
9785

@@ -104,9 +92,7 @@ func (l *LayeredNodeState) IsCurrentMachineConfigEqualToPool(mcp *mcfgv1.Machine
10492
// Compares the MachineConfig specified by the MachineConfigPool to the one
10593
// specified by the node's desired MachineConfig annotation.
10694
func (l *LayeredNodeState) IsDesiredMachineConfigEqualToPool(mcp *mcfgv1.MachineConfigPool) bool {
107-
ret := l.node.Annotations[daemonconsts.DesiredMachineConfigAnnotationKey] == mcp.Spec.Configuration.Name
108-
klog.Errorf("in IsDesiredMachineConfigEqualToPool, returning %v", ret)
109-
return ret
95+
return l.node.Annotations[daemonconsts.DesiredMachineConfigAnnotationKey] == mcp.Spec.Configuration.Name
11096
}
11197

11298
// Checks if both the current and desired image annotation are present on the node.
@@ -127,42 +113,23 @@ func (l *LayeredNodeState) IsCurrentImageAnnotationPresentOnNode() bool {
127113
// Compares the CurrentImagePullSpec specified by the MachineOSConfig object against the
128114
// image specified by the annotation passed in.
129115
func (l *LayeredNodeState) isImageAnnotationEqualToMachineOSConfig(anno string, mosc *mcfgv1.MachineOSConfig) bool {
130-
moscImage := ""
131-
132-
// // Handle case when MOSC is nil (image mode is being disabled)
133-
// if mosc != nil {
134-
// // TOOD: check if this comes back as nil or empty string
135-
// return moscName =
136-
// }
116+
moscs := NewMachineOSConfigState(mosc)
137117

138-
// Get the image annotation from the node
139118
val, ok := l.node.Annotations[anno]
140-
klog.Errorf("in isImageAnnotationEqualToMachineOSConfig, val: %v, ok: %v", val, ok)
141-
142-
// // Handle case when MOSC is nil (image mode is being disabled)
143-
// if mosc == nil {
144-
// // TOOD: check if this comes back as nil or empty string
145-
// return val == ""
146-
// }
147119

148120
// If a layered node does not have an image annotation and has a valid MOSC, then the image is being built
149121
if val == "" || !ok {
150-
klog.Errorf("in isImageAnnotationEqualToMachineOSConfig returning false cause val == '' or !ok")
151122
return false
152123
}
153124

154-
// Get the MachineOSConfigState
155-
moscs := NewMachineOSConfigState(mosc)
156-
klog.Errorf("in isImageAnnotationEqualToMachineOSConfig with moscs")
157-
158125
if moscs.HasOSImage() {
159126
// If the MOSC image has an image, the image annotation on the node can be directly compared.
160-
moscImage = moscs.GetOSImage()
127+
return moscs.GetOSImage() == val
161128
}
162129

163130
// If the MOSC does not have an image, but the node has an older image annotation, the image is still likely
164131
// being built.
165-
return moscImage == val
132+
return false
166133
}
167134

168135
// Sets the desired MachineConfig annotations from the MachineConfigPool.
@@ -208,26 +175,21 @@ func (l *LayeredNodeState) Node() *corev1.Node {
208175
// isNodeDone returns true if the current == desired and the MCD has marked done.
209176
func (l *LayeredNodeState) IsNodeDone() bool {
210177
if l.node.Annotations == nil {
211-
klog.Error("in IsNodeDone, returning false, 1")
212178
return false
213179
}
214180

215181
if !l.isNodeConfigDone() {
216-
klog.Error("in IsNodeDone, returning false, 2")
217182
return false
218183
}
219184

220185
if !l.isNodeImageDone() {
221-
klog.Error("in IsNodeDone, returning false, 3")
222186
return false
223187
}
224188

225189
if !l.isNodeMCDState(daemonconsts.MachineConfigDaemonStateDone) {
226-
klog.Error("in IsNodeDone, returning false, 4")
227190
return false
228191
}
229192

230-
klog.Error("in IsNodeDone, returning true")
231193
return true
232194
}
233195

pkg/controller/node/status.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,6 @@ func (ctrl *Controller) calculateStatus(mcs []*mcfgv1.MachineConfigNode, cconfig
206206

207207
// this is # 1 priority, get the upgrade states actually reporting
208208
if degradedMachineCount+readyMachineCount+unavailableMachineCount+updatingMachineCount != int32(len(nodes)) {
209-
klog.Errorf("In degraded + ready + unavailable + updating != nodes...")
210209

211210
updatedMachines = getUpdatedMachines(pool, nodes, mosc, mosb, isLayeredPool)
212211
updatedMachineCount = int32(len(updatedMachines))
@@ -219,8 +218,6 @@ func (ctrl *Controller) calculateStatus(mcs []*mcfgv1.MachineConfigNode, cconfig
219218

220219
degradedMachines = getDegradedMachines(nodes)
221220
degradedMachineCount = int32(len(degradedMachines))
222-
} else {
223-
klog.Errorf("In degraded + ready + unavailable + updating == nodes... Not where we want to be.")
224221
}
225222

226223
for _, n := range degradedMachines {

0 commit comments

Comments
 (0)