@@ -292,82 +292,3 @@ func WaitForOneMasterNodeToBeReady(oc *exutil.CLI) error {
292292 }, 5 * time .Minute , 10 * time .Second ).Should (o .BeTrue ())
293293 return nil
294294}
295-
296- // WaitForConfigAndPoolComplete is a helper function that gets a renderedConfig and waits for its pool to complete.
297- // The return value is the final rendered config.
298- func WaitForConfigAndPoolComplete (oc * exutil.CLI , pool , mcName string ) string {
299- config , err := WaitForRenderedConfig (oc , pool , mcName )
300- o .Expect (err ).NotTo (o .HaveOccurred (), fmt .Sprintf ("%v: failed to render machine config %s from pool %s" , err , mcName , pool ))
301-
302- err = WaitForPoolComplete (oc , pool , config )
303- o .Expect (err ).NotTo (o .HaveOccurred (), fmt .Sprintf ("%v: pool %s did not update to config %s" , err , pool , config ))
304- return config
305- }
306-
307- // WaitForRenderedConfig polls a MachineConfigPool until it has
308- // included the given mcName in its config, and returns the new
309- // rendered config name.
310- func WaitForRenderedConfig (oc * exutil.CLI , pool , mcName string ) (string , error ) {
311- return WaitForRenderedConfigs (oc , pool , mcName )
312- }
313-
314- // WaitForRenderedConfigs polls a MachineConfigPool until it has
315- // included the given mcNames in its config, and returns the new
316- // rendered config name.
317- func WaitForRenderedConfigs (oc * exutil.CLI , pool string , mcNames ... string ) (string , error ) {
318- var renderedConfig string
319- machineConfigClient , err := machineconfigclient .NewForConfig (oc .KubeFramework ().ClientConfig ())
320- o .Expect (err ).NotTo (o .HaveOccurred ())
321- found := make (map [string ]bool )
322- o .Eventually (func () bool {
323- // Set up the list
324- for _ , name := range mcNames {
325- found [name ] = false
326- }
327-
328- // Update found based on the MCP
329- mcp , err := machineConfigClient .MachineconfigurationV1 ().MachineConfigPools ().Get (context .TODO (), pool , metav1.GetOptions {})
330- if err != nil {
331- return false
332- }
333- for _ , mc := range mcp .Spec .Configuration .Source {
334- if _ , ok := found [mc .Name ]; ok {
335- found [mc .Name ] = true
336- }
337- }
338-
339- // If any are still false, then they weren't included in the MCP
340- for _ , nameFound := range found {
341- if ! nameFound {
342- return false
343- }
344- }
345-
346- // All the required names were found
347- renderedConfig = mcp .Spec .Configuration .Name
348- return true
349- }, 5 * time .Minute , 10 * time .Second ).Should (o .BeTrue ())
350- return renderedConfig , nil
351- }
352-
353- // WaitForPoolComplete polls a pool until it has completed an update to target
354- func WaitForPoolComplete (oc * exutil.CLI , pool , target string ) error {
355- machineConfigClient , err := machineconfigclient .NewForConfig (oc .KubeFramework ().ClientConfig ())
356- o .Expect (err ).NotTo (o .HaveOccurred ())
357- framework .Logf ("Waiting for pool %s to complete %s" , pool , target )
358- o .Eventually (func () bool {
359- mcp , err := machineConfigClient .MachineconfigurationV1 ().MachineConfigPools ().Get (context .TODO (), pool , metav1.GetOptions {})
360- if err != nil {
361- framework .Logf ("Failed to grab machineconfigpools, error :%v" , err )
362- return false
363- }
364- if mcp .Status .Configuration .Name != target {
365- return false
366- }
367- if IsMachineConfigPoolConditionTrue (mcp .Status .Conditions , mcfgv1 .MachineConfigPoolUpdated ) {
368- return true
369- }
370- return false
371- }, 20 * time .Minute , 10 * time .Second ).Should (o .BeTrue ())
372- return nil
373- }
0 commit comments