[mirror_ifupdown2.git] / addons / address.py

#!/usr/bin/python
#
# Copyright 2014 Cumulus Networks, Inc. All rights reserved.
# Author: Roopa Prabhu, roopa@cumulusnetworks.com
#

try:
    from ipaddr import IPNetwork
    from sets import Set
    from ifupdown.iface import *
    from ifupdownaddons.modulebase import moduleBase
    from ifupdownaddons.iproute2 import iproute2
    from ifupdownaddons.dhclient import dhclient
except ImportError, e:
    raise ImportError (str(e) + "- required module not found")

class address(moduleBase):
    """  ifupdown2 addon module to configure address, mtu, hwaddress, alias
    (description) on an interface """

    _modinfo = {'mhelp' : 'address configuration module for interfaces',
                'attrs': {
                      'address' :
                            {'help' : 'ipv4 or ipv6 addresses',
                             'example' : ['address 10.0.12.3/24',
                             'address 2000:1000:1000:1000:3::5/128']},
                      'netmask' :
                            {'help': 'netmask',
                             'example' : ['netmask 255.255.255.0'],
                             'compat' : True},
                      'broadcast' :
                            {'help': 'broadcast address',
                             'example' : ['broadcast 10.0.1.255']},
                      'scope' :
                            {'help': 'scope',
                             'example' : ['scope host']},
                      'preferred-lifetime' :
                            {'help': 'preferred lifetime',
                             'example' : ['preferred-lifetime forever',
                                          'preferred-lifetime 10']},
                      'gateway' :
                            {'help': 'default gateway',
                             'example' : ['gateway 255.255.255.0']},
                      'mtu' :
                            { 'help': 'interface mtu',
                              'example' : ['mtu 1600'],
                              'default' : '1500'},
                      'hwaddress' :
                            {'help' : 'hw address',
                             'example': ['hwaddress 44:38:39:00:27:b8']},
                      'alias' :
                            { 'help': 'description/alias',
                              'example' : ['alias testnetwork']},
                      'address-purge' :
                            { 'help': 'purge existing addresses. By default ' +
                              'any existing ip addresses on an interface are ' +
                              'purged to match persistant addresses in the ' +
                              'interfaces file. Set this attribute to \'no\'' +
                              'if you want to preserve existing addresses',
                              'default' : 'yes',
                              'example' : ['address-purge yes/no']}}}

    def __init__(self, *args, **kargs):
        moduleBase.__init__(self, *args, **kargs)
        self.ipcmd = None
        self._bridge_fdb_query_cache = {}

    def _address_valid(self, addrs):
        if not addrs:
           return False
        if any(map(lambda a: True if a[:7] != '0.0.0.0'
                else False, addrs)):
           return True
        return False

    def _process_bridge(self, ifaceobj, up):
        hwaddress = ifaceobj.get_attr_value_first('hwaddress')
        addrs = ifaceobj.get_attr_value_first('address')
        is_vlan_dev_on_vlan_aware_bridge = False
        is_bridge = self.ipcmd.is_bridge(ifaceobj.name)
        if not is_bridge:
            if '.' in ifaceobj.name:
                (bridgename, vlan) = ifaceobj.name.split('.')
                is_vlan_dev_on_vlan_aware_bridge = self.ipcmd.bridge_is_vlan_aware(bridgename)
        if is_bridge or is_vlan_dev_on_vlan_aware_bridge:
           if self._address_valid(addrs):
              if up:
                self.write_file('/proc/sys/net/ipv4/conf/%s' %ifaceobj.name +
                                '/arp_accept', '1')
              else:
                self.write_file('/proc/sys/net/ipv4/conf/%s' %ifaceobj.name +
                                '/arp_accept', '0')
        if hwaddress and is_vlan_dev_on_vlan_aware_bridge:
           if up:
              self.ipcmd.bridge_fdb_add(bridgename, hwaddress, vlan)
           else:
              self.ipcmd.bridge_fdb_del(bridgename, hwaddress, vlan)

    def _inet_address_config(self, ifaceobj):
        purge_addresses = ifaceobj.get_attr_value_first('address-purge')
        if not purge_addresses:
           purge_addresses = 'yes'
        newaddrs = []
        addrs = ifaceobj.get_attr_value('address')
        if addrs:
            # If user address is not in CIDR notation, convert them to CIDR
            for addr_index in range(0, len(addrs)):
                addr = addrs[addr_index]
                if '/' in addr:
                    newaddrs.append(addr)
                    continue
                netmask = ifaceobj.get_attr_value_n('netmask', addr_index)
                if netmask:
                    prefixlen = IPNetwork('%s' %addr +
                                '/%s' %netmask).prefixlen
                    newaddrs.append(addr + '/%s' %prefixlen)
                else:
                    newaddrs.append(addr)

        if (not self.PERFMODE and
                not (ifaceobj.flags & iface.HAS_SIBLINGS) and
                purge_addresses == 'yes'):
            # if perfmode is not set and also if iface has no sibling
            # objects, purge addresses that are not present in the new
            # config
            runningaddrs = self.ipcmd.addr_get(ifaceobj.name, details=False)
            if newaddrs == runningaddrs:
                return
            try:
                # if primary address is not same, there is no need to keep any.
                # reset all addresses
                if (newaddrs and runningaddrs and
                        (newaddrs[0] != runningaddrs[0])):
                    self.ipcmd.del_addr_all(ifaceobj.name)
                else:
                    self.ipcmd.del_addr_all(ifaceobj.name, newaddrs)
            except Exception, e:
                self.log_warn(str(e))
        if not newaddrs:
            return
        for addr_index in range(0, len(newaddrs)):
            try:
                self.ipcmd.addr_add(ifaceobj.name, newaddrs[addr_index],
                    ifaceobj.get_attr_value_n('broadcast', addr_index),
                    ifaceobj.get_attr_value_n('pointopoint',addr_index),
                    ifaceobj.get_attr_value_n('scope', addr_index),
                    ifaceobj.get_attr_value_n('preferred-lifetime', addr_index))
            except Exception, e:
                self.log_error(str(e))

    def _up(self, ifaceobj):
        if not self.ipcmd.link_exists(ifaceobj.name):
            return
        addr_method = ifaceobj.addr_method
        try:
            # release any stale dhcp addresses if present
            if (addr_method != "dhcp" and not self.PERFMODE and
                    not (ifaceobj.flags & iface.HAS_SIBLINGS)):
                # if not running in perf mode and ifaceobj does not have
                # any sibling iface objects, kill any stale dhclient
                # processes
                dhclientcmd = dhclient()
                if dhclient.is_running(ifaceobj.name):
                    # release any dhcp leases
                    dhclientcmd.release(ifaceobj.name)
                elif dhclient.is_running6(ifaceobj.name):
                    dhclientcmd.release6(ifaceobj.name)
        except:
            pass

        self.ipcmd.batch_start()
        if addr_method != "dhcp":
            self._inet_address_config(ifaceobj)
        mtu = ifaceobj.get_attr_value_first('mtu')
        if mtu:
           self.ipcmd.link_set(ifaceobj.name, 'mtu', mtu)
        alias = ifaceobj.get_attr_value_first('alias')
        if alias:
           self.ipcmd.link_set_alias(ifaceobj.name, alias)
        hwaddress = ifaceobj.get_attr_value_first('hwaddress')
        if hwaddress:
            self.ipcmd.link_set(ifaceobj.name, 'address', hwaddress)
        self.ipcmd.batch_commit()

        try:
            # Handle special things on a bridge
            self._process_bridge(ifaceobj, True)
        except Exception, e:
            self.log_warn('%s: %s' %(ifaceobj.name, str(e)))
            pass

        if addr_method != "dhcp":
            self.ipcmd.route_add_gateway(ifaceobj.name,
                    ifaceobj.get_attr_value_first('gateway'))

    def _down(self, ifaceobj):
        try:
            if not self.ipcmd.link_exists(ifaceobj.name):
                return
            addr_method = ifaceobj.addr_method
            if addr_method != "dhcp":
                self.ipcmd.route_del_gateway(ifaceobj.name,
                    ifaceobj.get_attr_value_first('gateway'),
                    ifaceobj.get_attr_value_first('metric'))
                self.ipcmd.del_addr_all(ifaceobj.name)
            mtu = ifaceobj.get_attr_value_first('mtu')
            if mtu:
                self.ipcmd.link_set(ifaceobj.name, 'mtu',
                        self.get_mod_subattr('mtu', 'default'))
            alias = ifaceobj.get_attr_value_first('alias')
            if alias:
                self.ipcmd.link_set(ifaceobj.name, 'alias', "\'\'")
            # XXX hwaddress reset cannot happen because we dont know last
            # address.

            # Handle special things on a bridge
            self._process_bridge(ifaceobj, False)
        except Exception, e:
            self.logger.debug('%s : %s' %(ifaceobj.name, str(e)))
            pass

    def _get_iface_addresses(self, ifaceobj):
        addrlist = ifaceobj.get_attr_value('address')
        outaddrlist = []

        if not addrlist: return None
        for addrindex in range(0, len(addrlist)):
            addr = addrlist[addrindex]
            netmask = ifaceobj.get_attr_value_n('netmask', addrindex)
            if netmask:
                prefixlen = IPNetwork('%s' %addr +
                                '/%s' %netmask).prefixlen
                addr = addr + '/%s' %prefixlen
            outaddrlist.append(addr)
        return outaddrlist

    def _get_bridge_fdbs(self, bridgename, vlan):
        fdbs = self._bridge_fdb_query_cache.get(bridgename)
        if not fdbs:
           fdbs = self.ipcmd.bridge_fdb_show_dev(bridgename)
           if not fdbs:
              return
           self._bridge_fdb_query_cache[bridgename] = fdbs
        return fdbs.get(vlan)

    def _check_addresses_in_bridge(self, ifaceobj, hwaddress):
        """ If the device is a bridge, make sure the addresses
        are in the bridge """
        if '.' in ifaceobj.name:
            (bridgename, vlan) = ifaceobj.name.split('.')
            if self.ipcmd.bridge_is_vlan_aware(bridgename):
                fdb_addrs = self._get_bridge_fdbs(bridgename, vlan)
                if not fdb_addrs or hwaddress not in fdb_addrs:
                   return False
        return True

    def _query_check(self, ifaceobj, ifaceobjcurr):
        runningaddrsdict = None
        if not self.ipcmd.link_exists(ifaceobj.name):
            self.logger.debug('iface %s not found' %ifaceobj.name)
            return
        self.query_n_update_ifaceobjcurr_attr(ifaceobj, ifaceobjcurr,
                'mtu', self.ipcmd.link_get_mtu)
        hwaddress = ifaceobj.get_attr_value_first('hwaddress')
        if hwaddress:
            rhwaddress = self.ipcmd.link_get_hwaddress(ifaceobj.name)
            if not rhwaddress  or rhwaddress != hwaddress:
               ifaceobjcurr.update_config_with_status('hwaddress', rhwaddress,
                       1)
            elif not self._check_addresses_in_bridge(ifaceobj, hwaddress):
               # XXX: hw address is not in bridge
               ifaceobjcurr.update_config_with_status('hwaddress', rhwaddress,
                       1)
               ifaceobjcurr.status_str = 'bridge fdb error'
            else:
               ifaceobjcurr.update_config_with_status('hwaddress', rhwaddress,
                       0)
        self.query_n_update_ifaceobjcurr_attr(ifaceobj, ifaceobjcurr,
                    'alias', self.ipcmd.link_get_alias)
        # compare addresses
        addrs = self._get_iface_addresses(ifaceobj)
        runningaddrsdict = self.ipcmd.addr_get(ifaceobj.name)

        # Set ifaceobjcurr method and family
        ifaceobjcurr.addr_method = ifaceobj.addr_method
        ifaceobjcurr.addr_family = ifaceobj.addr_family
        if not runningaddrsdict and not addrs:
            return
        runningaddrs = runningaddrsdict.keys() if runningaddrsdict else []
        if runningaddrs != addrs:
            runningaddrsset = set(runningaddrs) if runningaddrs else set([])
            addrsset = set(addrs) if addrs else set([])
            if (ifaceobj.flags & iface.HAS_SIBLINGS):
                if not addrsset:
                    return
                # only check for addresses present in running config
                addrsdiff = addrsset.difference(runningaddrsset)
                for addr in addrs:
                    if addr in addrsdiff:
                        ifaceobjcurr.update_config_with_status('address',
                                    addr, 1)
                    else:
                        ifaceobjcurr.update_config_with_status('address',
                                    addr, 0)
            else:
                addrsdiff = addrsset.symmetric_difference(runningaddrsset)
                for addr in addrsset.union(runningaddrsset):
                    if addr in addrsdiff:
                        ifaceobjcurr.update_config_with_status('address',
                                                               addr, 1)
                    else:
                        ifaceobjcurr.update_config_with_status('address',
                                                               addr, 0)
        elif addrs:
            [ifaceobjcurr.update_config_with_status('address',
                       addr, 0) for addr in addrs]
        #XXXX Check broadcast address, scope, etc
        return

    def _query_running(self, ifaceobjrunning):
        if not self.ipcmd.link_exists(ifaceobjrunning.name):
            self.logger.debug('iface %s not found' %ifaceobjrunning.name)
            ifaceobjrunning.status = ifaceStatus.NOTFOUND
            return
        dhclientcmd = dhclient()
        if (dhclientcmd.is_running(ifaceobjrunning.name) or
                dhclientcmd.is_running6(ifaceobjrunning.name)):
            # If dhcp is configured on the interface, we skip it
            return 
        isloopback = self.ipcmd.link_isloopback(ifaceobjrunning.name)
        if isloopback:
            default_addrs = ['127.0.0.1/8', '::1/128']
            ifaceobjrunning.addr_family = 'inet'
            ifaceobjrunning.addr_method = 'loopback'
        else:
            default_addrs = []
        runningaddrsdict = self.ipcmd.addr_get(ifaceobjrunning.name)
        if runningaddrsdict:
            [ifaceobjrunning.update_config('address', addr)
                for addr, addrattrs in runningaddrsdict.items()
                if addr not in default_addrs]
        mtu = self.ipcmd.link_get_mtu(ifaceobjrunning.name)
        if (mtu and
                (ifaceobjrunning.name == 'lo' and mtu != '16436') or
                (ifaceobjrunning.name != 'lo' and
                    mtu != self.get_mod_subattr('mtu', 'default'))):
                ifaceobjrunning.update_config('mtu', mtu)
        alias = self.ipcmd.link_get_alias(ifaceobjrunning.name)
        if alias: 
            ifaceobjrunning.update_config('alias', alias)

    _run_ops = {'up' : _up,
               'down' : _down,
               'query-checkcurr' : _query_check,
               'query-running' : _query_running }

    def get_ops(self):
        """ returns list of ops supported by this module """
        return self._run_ops.keys()

    def _init_command_handlers(self):
        if not self.ipcmd:
            self.ipcmd = iproute2(**self.get_flags())

    def run(self, ifaceobj, operation, query_ifaceobj=None, **extra_args):
        """ run address configuration on the interface object passed as argument

        Args:
            **ifaceobj** (object): iface object

            **operation** (str): any of 'up', 'down', 'query-checkcurr',
                                 'query-running'
        Kwargs:
            query_ifaceobj (object): query check ifaceobject. This is only
                valid when op is 'query-checkcurr'. It is an object same as
                ifaceobj, but contains running attribute values and its config
                status. The modules can use it to return queried running state
                of interfaces. status is success if the running state is same
                as user required state in ifaceobj. error otherwise.
        """
        if ifaceobj.type == ifaceType.BRIDGE_VLAN:
           return
        op_handler = self._run_ops.get(operation)
        if not op_handler:
            return
        self._init_command_handlers()
        if operation == 'query-checkcurr':
            op_handler(self, ifaceobj, query_ifaceobj)
        else:
            op_handler(self, ifaceobj)
Commit	Line	Data
15ef32ea RP	1	#!/usr/bin/python
	2	#
	3	# Copyright 2014 Cumulus Networks, Inc. All rights reserved.
	4	# Author: Roopa Prabhu, roopa@cumulusnetworks.com
	5	#
	6
	7	try:
	8	from ipaddr import IPNetwork
	9	from sets import Set
	10	from ifupdown.iface import *
	11	from ifupdownaddons.modulebase import moduleBase
	12	from ifupdownaddons.iproute2 import iproute2
	13	from ifupdownaddons.dhclient import dhclient
	14	except ImportError, e:
	15	raise ImportError (str(e) + "- required module not found")
	16
	17	class address(moduleBase):
	18	""" ifupdown2 addon module to configure address, mtu, hwaddress, alias
	19	(description) on an interface """
	20
	21	_modinfo = {'mhelp' : 'address configuration module for interfaces',
	22	'attrs': {
	23	'address' :
	24	{'help' : 'ipv4 or ipv6 addresses',
	25	'example' : ['address 10.0.12.3/24',
	26	'address 2000:1000:1000:1000:3::5/128']},
	27	'netmask' :
	28	{'help': 'netmask',
	29	'example' : ['netmask 255.255.255.0'],
	30	'compat' : True},
	31	'broadcast' :
	32	{'help': 'broadcast address',
	33	'example' : ['broadcast 10.0.1.255']},
	34	'scope' :
	35	{'help': 'scope',
	36	'example' : ['scope host']},
	37	'preferred-lifetime' :
	38	{'help': 'preferred lifetime',
	39	'example' : ['preferred-lifetime forever',
	40	'preferred-lifetime 10']},
	41	'gateway' :
	42	{'help': 'default gateway',
	43	'example' : ['gateway 255.255.255.0']},
	44	'mtu' :
	45	{ 'help': 'interface mtu',
	46	'example' : ['mtu 1600'],
	47	'default' : '1500'},
	48	'hwaddress' :
	49	{'help' : 'hw address',
	50	'example': ['hwaddress 44:38:39:00:27:b8']},
	51	'alias' :
	52	{ 'help': 'description/alias',
394e68b5 RP	53	'example' : ['alias testnetwork']},
	54	'address-purge' :
	55	{ 'help': 'purge existing addresses. By default ' +
	56	'any existing ip addresses on an interface are ' +
	57	'purged to match persistant addresses in the ' +
	58	'interfaces file. Set this attribute to \'no\'' +
	59	'if you want to preserve existing addresses',
	60	'default' : 'yes',
	61	'example' : ['address-purge yes/no']}}}
15ef32ea RP	62
	63	def __init__(self, args, *kargs):
	64	moduleBase.__init__(self, args, *kargs)
	65	self.ipcmd = None
8e113d63	66	self._bridge_fdb_query_cache = {}
15ef32ea	67
75afe2a7 RP	68	def _address_valid(self, addrs):
	69	if not addrs:
	70	return False
	71	if any(map(lambda a: True if a[:7] != '0.0.0.0'
	72	else False, addrs)):
	73	return True
	74	return False
	75
	76	def _process_bridge(self, ifaceobj, up):
	77	hwaddress = ifaceobj.get_attr_value_first('hwaddress')
	78	addrs = ifaceobj.get_attr_value_first('address')
	79	is_vlan_dev_on_vlan_aware_bridge = False
	80	is_bridge = self.ipcmd.is_bridge(ifaceobj.name)
	81	if not is_bridge:
	82	if '.' in ifaceobj.name:
	83	(bridgename, vlan) = ifaceobj.name.split('.')
	84	is_vlan_dev_on_vlan_aware_bridge = self.ipcmd.bridge_is_vlan_aware(bridgename)
	85	if is_bridge or is_vlan_dev_on_vlan_aware_bridge:
	86	if self._address_valid(addrs):
	87	if up:
	88	self.write_file('/proc/sys/net/ipv4/conf/%s' %ifaceobj.name +
	89	'/arp_accept', '1')
	90	else:
	91	self.write_file('/proc/sys/net/ipv4/conf/%s' %ifaceobj.name +
	92	'/arp_accept', '0')
	93	if hwaddress and is_vlan_dev_on_vlan_aware_bridge:
	94	if up:
	95	self.ipcmd.bridge_fdb_add(bridgename, hwaddress, vlan)
	96	else:
	97	self.ipcmd.bridge_fdb_del(bridgename, hwaddress, vlan)
cb46a208	98
15ef32ea	99	def _inet_address_config(self, ifaceobj):
394e68b5 RP	100	purge_addresses = ifaceobj.get_attr_value_first('address-purge')
	101	if not purge_addresses:
	102	purge_addresses = 'yes'
15ef32ea RP	103	newaddrs = []
	104	addrs = ifaceobj.get_attr_value('address')
	105	if addrs:
	106	# If user address is not in CIDR notation, convert them to CIDR
	107	for addr_index in range(0, len(addrs)):
	108	addr = addrs[addr_index]
	109	if '/' in addr:
	110	newaddrs.append(addr)
	111	continue
	112	netmask = ifaceobj.get_attr_value_n('netmask', addr_index)
	113	if netmask:
	114	prefixlen = IPNetwork('%s' %addr +
	115	'/%s' %netmask).prefixlen
	116	newaddrs.append(addr + '/%s' %prefixlen)
	117	else:
	118	newaddrs.append(addr)
	119
394e68b5 RP	120	if (not self.PERFMODE and
	121	not (ifaceobj.flags & iface.HAS_SIBLINGS) and
	122	purge_addresses == 'yes'):
15ef32ea RP	123	# if perfmode is not set and also if iface has no sibling
	124	# objects, purge addresses that are not present in the new
	125	# config
	126	runningaddrs = self.ipcmd.addr_get(ifaceobj.name, details=False)
	127	if newaddrs == runningaddrs:
	128	return
	129	try:
	130	# if primary address is not same, there is no need to keep any.
	131	# reset all addresses
	132	if (newaddrs and runningaddrs and
	133	(newaddrs[0] != runningaddrs[0])):
	134	self.ipcmd.del_addr_all(ifaceobj.name)
	135	else:
	136	self.ipcmd.del_addr_all(ifaceobj.name, newaddrs)
	137	except Exception, e:
	138	self.log_warn(str(e))
	139	if not newaddrs:
	140	return
	141	for addr_index in range(0, len(newaddrs)):
	142	try:
	143	self.ipcmd.addr_add(ifaceobj.name, newaddrs[addr_index],
	144	ifaceobj.get_attr_value_n('broadcast', addr_index),
	145	ifaceobj.get_attr_value_n('pointopoint',addr_index),
	146	ifaceobj.get_attr_value_n('scope', addr_index),
	147	ifaceobj.get_attr_value_n('preferred-lifetime', addr_index))
	148	except Exception, e:
	149	self.log_error(str(e))
	150
	151	def _up(self, ifaceobj):
	152	if not self.ipcmd.link_exists(ifaceobj.name):
	153	return
68d9fee0	154	addr_method = ifaceobj.addr_method
15ef32ea RP	155	try:
15ef32ea RP	156	# release any stale dhcp addresses if present
68d9fee0	157	if (addr_method != "dhcp" and not self.PERFMODE and
15ef32ea RP	158	not (ifaceobj.flags & iface.HAS_SIBLINGS)):
	159	# if not running in perf mode and ifaceobj does not have
	160	# any sibling iface objects, kill any stale dhclient
	161	# processes
75afe2a7	162	dhclientcmd = dhclient()
15ef32ea RP	163	if dhclient.is_running(ifaceobj.name):
	164	# release any dhcp leases
	165	dhclientcmd.release(ifaceobj.name)
	166	elif dhclient.is_running6(ifaceobj.name):
	167	dhclientcmd.release6(ifaceobj.name)
	168	except:
	169	pass
8e113d63	170
15ef32ea	171	self.ipcmd.batch_start()
68d9fee0 RP	172	if addr_method != "dhcp":
68d9fee0 RP	173	self._inet_address_config(ifaceobj)
15ef32ea RP	174	mtu = ifaceobj.get_attr_value_first('mtu')
15ef32ea RP	175	if mtu:
8e113d63	176	self.ipcmd.link_set(ifaceobj.name, 'mtu', mtu)
15ef32ea RP	177	alias = ifaceobj.get_attr_value_first('alias')
15ef32ea RP	178	if alias:
8e113d63	179	self.ipcmd.link_set_alias(ifaceobj.name, alias)
cb46a208 RP	180	hwaddress = ifaceobj.get_attr_value_first('hwaddress')
	181	if hwaddress:
	182	self.ipcmd.link_set(ifaceobj.name, 'address', hwaddress)
15ef32ea	183	self.ipcmd.batch_commit()
cb46a208	184
68d9fee0 RP	185	try:
	186	# Handle special things on a bridge
	187	self._process_bridge(ifaceobj, True)
	188	except Exception, e:
	189	self.log_warn('%s: %s' %(ifaceobj.name, str(e)))
	190	pass
cb46a208	191
68d9fee0 RP	192	if addr_method != "dhcp":
	193	self.ipcmd.route_add_gateway(ifaceobj.name,
	194	ifaceobj.get_attr_value_first('gateway'))
15ef32ea RP	195
	196	def _down(self, ifaceobj):
	197	try:
	198	if not self.ipcmd.link_exists(ifaceobj.name):
	199	return
68d9fee0 RP	200	addr_method = ifaceobj.addr_method
	201	if addr_method != "dhcp":
	202	self.ipcmd.route_del_gateway(ifaceobj.name,
15ef32ea RP	203	ifaceobj.get_attr_value_first('gateway'),
15ef32ea RP	204	ifaceobj.get_attr_value_first('metric'))
68d9fee0	205	self.ipcmd.del_addr_all(ifaceobj.name)
15ef32ea RP	206	mtu = ifaceobj.get_attr_value_first('mtu')
	207	if mtu:
	208	self.ipcmd.link_set(ifaceobj.name, 'mtu',
	209	self.get_mod_subattr('mtu', 'default'))
	210	alias = ifaceobj.get_attr_value_first('alias')
	211	if alias:
	212	self.ipcmd.link_set(ifaceobj.name, 'alias', "\'\'")
75afe2a7 RP	213	# XXX hwaddress reset cannot happen because we dont know last
	214	# address.
	215
	216	# Handle special things on a bridge
	217	self._process_bridge(ifaceobj, False)
15ef32ea	218	except Exception, e:
bcf11b14 RP	219	self.logger.debug('%s : %s' %(ifaceobj.name, str(e)))
bcf11b14 RP	220	pass
15ef32ea RP	221
	222	def _get_iface_addresses(self, ifaceobj):
	223	addrlist = ifaceobj.get_attr_value('address')
	224	outaddrlist = []
	225
	226	if not addrlist: return None
	227	for addrindex in range(0, len(addrlist)):
	228	addr = addrlist[addrindex]
	229	netmask = ifaceobj.get_attr_value_n('netmask', addrindex)
	230	if netmask:
	231	prefixlen = IPNetwork('%s' %addr +
	232	'/%s' %netmask).prefixlen
	233	addr = addr + '/%s' %prefixlen
	234	outaddrlist.append(addr)
	235	return outaddrlist
	236
8e113d63 RP	237	def _get_bridge_fdbs(self, bridgename, vlan):
	238	fdbs = self._bridge_fdb_query_cache.get(bridgename)
	239	if not fdbs:
	240	fdbs = self.ipcmd.bridge_fdb_show_dev(bridgename)
	241	if not fdbs:
	242	return
	243	self._bridge_fdb_query_cache[bridgename] = fdbs
	244	return fdbs.get(vlan)
	245
	246	def _check_addresses_in_bridge(self, ifaceobj, hwaddress):
	247	""" If the device is a bridge, make sure the addresses
	248	are in the bridge """
	249	if '.' in ifaceobj.name:
	250	(bridgename, vlan) = ifaceobj.name.split('.')
	251	if self.ipcmd.bridge_is_vlan_aware(bridgename):
	252	fdb_addrs = self._get_bridge_fdbs(bridgename, vlan)
	253	if not fdb_addrs or hwaddress not in fdb_addrs:
	254	return False
	255	return True
	256
15ef32ea RP	257	def _query_check(self, ifaceobj, ifaceobjcurr):
	258	runningaddrsdict = None
	259	if not self.ipcmd.link_exists(ifaceobj.name):
	260	self.logger.debug('iface %s not found' %ifaceobj.name)
	261	return
	262	self.query_n_update_ifaceobjcurr_attr(ifaceobj, ifaceobjcurr,
	263	'mtu', self.ipcmd.link_get_mtu)
8e113d63 RP	264	hwaddress = ifaceobj.get_attr_value_first('hwaddress')
	265	if hwaddress:
	266	rhwaddress = self.ipcmd.link_get_hwaddress(ifaceobj.name)
	267	if not rhwaddress or rhwaddress != hwaddress:
	268	ifaceobjcurr.update_config_with_status('hwaddress', rhwaddress,
	269	1)
	270	elif not self._check_addresses_in_bridge(ifaceobj, hwaddress):
	271	# XXX: hw address is not in bridge
	272	ifaceobjcurr.update_config_with_status('hwaddress', rhwaddress,
	273	1)
	274	ifaceobjcurr.status_str = 'bridge fdb error'
	275	else:
	276	ifaceobjcurr.update_config_with_status('hwaddress', rhwaddress,
	277	0)
15ef32ea RP	278	self.query_n_update_ifaceobjcurr_attr(ifaceobj, ifaceobjcurr,
	279	'alias', self.ipcmd.link_get_alias)
	280	# compare addresses
	281	addrs = self._get_iface_addresses(ifaceobj)
	282	runningaddrsdict = self.ipcmd.addr_get(ifaceobj.name)
	283
	284	# Set ifaceobjcurr method and family
	285	ifaceobjcurr.addr_method = ifaceobj.addr_method
	286	ifaceobjcurr.addr_family = ifaceobj.addr_family
	287	if not runningaddrsdict and not addrs:
	288	return
	289	runningaddrs = runningaddrsdict.keys() if runningaddrsdict else []
	290	if runningaddrs != addrs:
	291	runningaddrsset = set(runningaddrs) if runningaddrs else set([])
	292	addrsset = set(addrs) if addrs else set([])
	293	if (ifaceobj.flags & iface.HAS_SIBLINGS):
	294	if not addrsset:
	295	return
	296	# only check for addresses present in running config
	297	addrsdiff = addrsset.difference(runningaddrsset)
	298	for addr in addrs:
	299	if addr in addrsdiff:
	300	ifaceobjcurr.update_config_with_status('address',
	301	addr, 1)
	302	else:
	303	ifaceobjcurr.update_config_with_status('address',
	304	addr, 0)
	305	else:
	306	addrsdiff = addrsset.symmetric_difference(runningaddrsset)
	307	for addr in addrsset.union(runningaddrsset):
	308	if addr in addrsdiff:
	309	ifaceobjcurr.update_config_with_status('address',
	310	addr, 1)
	311	else:
	312	ifaceobjcurr.update_config_with_status('address',
	313	addr, 0)
	314	elif addrs:
	315	[ifaceobjcurr.update_config_with_status('address',
	316	addr, 0) for addr in addrs]
	317	#XXXX Check broadcast address, scope, etc
	318	return
	319
	320	def _query_running(self, ifaceobjrunning):
	321	if not self.ipcmd.link_exists(ifaceobjrunning.name):
	322	self.logger.debug('iface %s not found' %ifaceobjrunning.name)
	323	ifaceobjrunning.status = ifaceStatus.NOTFOUND
	324	return
	325	dhclientcmd = dhclient()
	326	if (dhclientcmd.is_running(ifaceobjrunning.name) or
	327	dhclientcmd.is_running6(ifaceobjrunning.name)):
	328	# If dhcp is configured on the interface, we skip it
	329	return
	330	isloopback = self.ipcmd.link_isloopback(ifaceobjrunning.name)
	331	if isloopback:
	332	default_addrs = ['127.0.0.1/8', '::1/128']
	333	ifaceobjrunning.addr_family = 'inet'
	334	ifaceobjrunning.addr_method = 'loopback'
	335	else:
	336	default_addrs = []
	337	runningaddrsdict = self.ipcmd.addr_get(ifaceobjrunning.name)
	338	if runningaddrsdict:
	339	[ifaceobjrunning.update_config('address', addr)
	340	for addr, addrattrs in runningaddrsdict.items()
	341	if addr not in default_addrs]
342	mtu = self.ipcmd.link_get_mtu(ifaceobjrunning.name)
343	if (mtu and
344	(ifaceobjrunning.name == 'lo' and mtu != '16436') or
345	(ifaceobjrunning.name != 'lo' and
346	mtu != self.get_mod_subattr('mtu', 'default'))):
347	ifaceobjrunning.update_config('mtu', mtu)
348	alias = self.ipcmd.link_get_alias(ifaceobjrunning.name)
349	if alias:
350	ifaceobjrunning.update_config('alias', alias)
351
352	_run_ops = {'up' : _up,
353	'down' : _down,
354	'query-checkcurr' : _query_check,
355	'query-running' : _query_running }
356
357	def get_ops(self):
358	""" returns list of ops supported by this module """
359	return self._run_ops.keys()
360
361	def _init_command_handlers(self):
362	if not self.ipcmd:
363	self.ipcmd = iproute2(**self.get_flags())
364
84ca006f	365	def run(self, ifaceobj, operation, query_ifaceobj=None, **extra_args):
15ef32ea RP	366	""" run address configuration on the interface object passed as argument
	367
	368	Args:
	369	ifaceobj (object): iface object
	370
	371	operation (str): any of 'up', 'down', 'query-checkcurr',
	372	'query-running'
	373	Kwargs:
	374	query_ifaceobj (object): query check ifaceobject. This is only
	375	valid when op is 'query-checkcurr'. It is an object same as
	376	ifaceobj, but contains running attribute values and its config
	377	status. The modules can use it to return queried running state
	378	of interfaces. status is success if the running state is same
	379	as user required state in ifaceobj. error otherwise.
	380	"""
8e113d63 RP	381	if ifaceobj.type == ifaceType.BRIDGE_VLAN:
8e113d63 RP	382	return
15ef32ea RP	383	op_handler = self._run_ops.get(operation)
	384	if not op_handler:
	385	return
15ef32ea RP	386	self._init_command_handlers()
	387	if operation == 'query-checkcurr':
	388	op_handler(self, ifaceobj, query_ifaceobj)
	389	else:
	390	op_handler(self, ifaceobj)