@@ -30,13 +30,10 @@ func NewLayeredNodeState(n *corev1.Node) *LayeredNodeState {
30
30
// determined by the pool. If in layered mode, the image annotations are also checked
31
31
// checked against the OCL objects.
32
32
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 )
40
37
}
41
38
42
39
// The original behavior of getUnavailableMachines is: getUnavailableMachines
@@ -70,8 +67,7 @@ func (l *LayeredNodeState) IsUnavailableForUpdate() bool {
70
67
// node's desired image annotation and compares the MachineConfig specified by the
71
68
// MachineOSBuild to the one specified by the node's desired MachineConfig annotation.
72
69
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 ))
75
71
}
76
72
77
73
// Compares the desired image annotation on the node against the CurrentImagePullSpec
@@ -84,14 +80,7 @@ func (l *LayeredNodeState) isDesiredImageEqualToMachineOSConfig(mosc *mcfgv1.Mac
84
80
// Compares the MachineConfig specified by the MachineConfigPool to the MachineConfig
85
81
// specified by the node's desired MachineConfig annotation.
86
82
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
83
+ return l .node .Annotations [daemonconsts .DesiredMachineConfigAnnotationKey ] == mosb .Spec .MachineConfig .Name
95
84
96
85
}
97
86
@@ -104,9 +93,7 @@ func (l *LayeredNodeState) IsCurrentMachineConfigEqualToPool(mcp *mcfgv1.Machine
104
93
// Compares the MachineConfig specified by the MachineConfigPool to the one
105
94
// specified by the node's desired MachineConfig annotation.
106
95
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
96
+ return l .node .Annotations [daemonconsts .DesiredMachineConfigAnnotationKey ] == mcp .Spec .Configuration .Name
110
97
}
111
98
112
99
// Checks if both the current and desired image annotation are present on the node.
@@ -127,42 +114,23 @@ func (l *LayeredNodeState) IsCurrentImageAnnotationPresentOnNode() bool {
127
114
// Compares the CurrentImagePullSpec specified by the MachineOSConfig object against the
128
115
// image specified by the annotation passed in.
129
116
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
- // }
117
+ moscs := NewMachineOSConfigState (mosc )
137
118
138
- // Get the image annotation from the node
139
119
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
- // }
147
120
148
121
// If a layered node does not have an image annotation and has a valid MOSC, then the image is being built
149
122
if val == "" || ! ok {
150
- klog .Errorf ("in isImageAnnotationEqualToMachineOSConfig returning false cause val == '' or !ok" )
151
123
return false
152
124
}
153
125
154
- // Get the MachineOSConfigState
155
- moscs := NewMachineOSConfigState (mosc )
156
- klog .Errorf ("in isImageAnnotationEqualToMachineOSConfig with moscs" )
157
-
158
126
if moscs .HasOSImage () {
159
127
// If the MOSC image has an image, the image annotation on the node can be directly compared.
160
- moscImage = moscs .GetOSImage ()
128
+ return moscs .GetOSImage () == val
161
129
}
162
130
163
131
// If the MOSC does not have an image, but the node has an older image annotation, the image is still likely
164
132
// being built.
165
- return moscImage == val
133
+ return false
166
134
}
167
135
168
136
// Sets the desired MachineConfig annotations from the MachineConfigPool.
@@ -208,26 +176,21 @@ func (l *LayeredNodeState) Node() *corev1.Node {
208
176
// isNodeDone returns true if the current == desired and the MCD has marked done.
209
177
func (l * LayeredNodeState ) IsNodeDone () bool {
210
178
if l .node .Annotations == nil {
211
- klog .Error ("in IsNodeDone, returning false, 1" )
212
179
return false
213
180
}
214
181
215
182
if ! l .isNodeConfigDone () {
216
- klog .Error ("in IsNodeDone, returning false, 2" )
217
183
return false
218
184
}
219
185
220
186
if ! l .isNodeImageDone () {
221
- klog .Error ("in IsNodeDone, returning false, 3" )
222
187
return false
223
188
}
224
189
225
190
if ! l .isNodeMCDState (daemonconsts .MachineConfigDaemonStateDone ) {
226
- klog .Error ("in IsNodeDone, returning false, 4" )
227
191
return false
228
192
}
229
193
230
- klog .Error ("in IsNodeDone, returning true" )
231
194
return true
232
195
}
233
196
0 commit comments