async def setup(middleware):
try:
interface_renamer = InterfaceRenamer(middleware)
if await middleware.call("failover.node") == "B":
link_address_key = "link_address_b"
else:
link_address_key = "link_address"
real_interfaces = RealInterfaceCollection(await middleware.call("interface.query", INTERFACE_FILTERS))
# Migrate BSD network interfaces to Linux
for db_interface in await middleware.call("datastore.query", "network.interfaces", [], {"prefix": "int_"}):
if m := RE_FREEBSD_BRIDGE.match(db_interface["interface"]):
interface_renamer.rename(db_interface["interface"], f"br{m.group(1)}")
if m := RE_FREEBSD_LAGG.match(db_interface["interface"]):
interface_renamer.rename(db_interface["interface"], f"bond{m.group(1)}")
db_interfaces = DatabaseInterfaceCollection(
await middleware.call("datastore.query", "network.interface_link_address"),
)
for db_interface in db_interfaces:
if db_interface[link_address_key] is not None:
real_interface_by_link_address = real_interfaces.by_link_address.get(db_interface[link_address_key])
if real_interface_by_link_address is None:
middleware.logger.warning(
"Interface with link address %r does not exist anymore (its name was %r)",
db_interface[link_address_key], db_interface["interface"],
)
continue
if real_interface_by_link_address["name"] == db_interface["interface"]:
continue
middleware.logger.info(
"Interface %r is now %r (matched by link address %r)",
db_interface["interface"], real_interface_by_link_address["name"], db_interface[link_address_key],
)
interface_renamer.rename(db_interface["interface"], real_interface_by_link_address["name"])
await interface_renamer.commit()
except Exception:
middleware.logger.error("Unhandled exception while migrating network interfaces", exc_info=True)
await middleware.call("interface.persist_link_addresses")
