isoCluster: Ensure IPU netdevs on host are up

Currently, we need to cold boot the IPU host anytime the IMC reboots to
ensure the netdevs are available.

Ensure the netdevs are available when isocluster deployment completes.

Signed-off-by: Salvatore Daniele <[email protected]>

Author: SalDaniele

isoCluster.py

@@ -105,6 +105,34 @@ def enable_acc_connectivity(node: NodeConfig) -> None:
     ipu_acc.run("nmcli con mod enp0s1f0 ipv4.route-metric 0")
     ipu_acc.run("ip route delete default via 192.168.0.1")  # remove imc default route to avoid conflict
     logger.info(f"{node.name} connectivity established")
+    ensure_ipu_netdevs_available(node)
+
+
+#TODO: Remove this workaround once rebooting the IMC no longer causes the netdevs on the IPU host to be removed
+def host_from_imc(imc: str) -> str:
+    ipu_host = imc.split('-intel-ipu-imc')[0]
+    return ipu_host
+
+
+#TODO: Remove this workaround once rebooting the IMC no longer causes the netdevs on the IPU host to be removed
+def ensure_ipu_netdevs_available(node: NodeConfig) -> None:
+    # This is a hack, iso_cluster deployments in general should not need to know about the x86 host they are connected to.
+    # However, since we need to cold boot the corresponding host, for the time being, infer this from the IMC address
+    # rather than requiring the user to provide this information.
+    ipu_host = host.Host(host_from_imc(node.bmc))
+    ipu_host.ssh_connect("core")
+    ret = ipu_host.run(f"test -d /sys/class/net/ens2f0")
+    retries = 3
+    while ret.returncode != 0:
+        logger.error(f"{ipu_host.hostname()} does not have a network device ens2f0 cold booting node to try to recover")
+        ipu_host.cold_boot()
+        logger.info("Cold boot triggered, waiting for host to reboot")
+        time.sleep(60)
+        ipu_host.ssh_connect("core")
+        retries = retries - 1
+        if retries == 0:
+            logger.error_and_exit(f"Failed to bring up IPU net device on {ipu_host.hostname()}")
+        ret = ipu_host.run(f"test -d /sys/class/net/ens2f0")
 
 
 def is_http_url(url: str) -> bool: