func validateFirewallOpenPorts()

in cmd/nodeadm/init/init.go [112:137]


func validateFirewallOpenPorts() error {
	firewallManager := system.NewFirewallManager()
	enabled, err := firewallManager.IsEnabled()
	if err != nil {
		return err
	}
	if !enabled {
		return nil
	}
	if err := firewallManager.FlushRules(); err != nil {
		return err
	}
	ciliumVxlanPortOpen, err := firewallManager.IsPortOpen(ciliumVxLanPort, vxLanProtocol)
	if err != nil {
		return err
	}
	calicoVxlanPortOpen, err := firewallManager.IsPortOpen(calicoVxLanPort, vxLanProtocol)
	if err != nil {
		return err
	}

	if !ciliumVxlanPortOpen && !calicoVxlanPortOpen {
		return fmt.Errorf("both cilium and calico vxlan ports are closed")
	}
	return nil
}