follower option with consistency
This commit is contained in:
parent
69384a5e69
commit
73d45f54cf
|
@ -873,6 +873,20 @@ def test_follower_not_same_not_equal():
|
||||||
cfg.property.read_write()
|
cfg.property.read_write()
|
||||||
|
|
||||||
|
|
||||||
|
def test_follower_consistency():
|
||||||
|
ip_admin_eth1 = IPOption('ip_admin_eth1', "ip réseau autorisé", multi=True, default=['1.1.1.1'])
|
||||||
|
netmask_admin_eth1 = NetmaskOption('netmask_admin_eth1', "masque du sous-réseau", multi=True)
|
||||||
|
netmask_admin_eth1.impl_add_consistency('ip_netmask', ip_admin_eth1)
|
||||||
|
interface1 = Leadership('interface1', '', [ip_admin_eth1, netmask_admin_eth1])
|
||||||
|
od1 = OptionDescription('od', '', [interface1])
|
||||||
|
maconfig = OptionDescription('toto', '', [od1])
|
||||||
|
cfg = Config(maconfig)
|
||||||
|
cfg.property.read_write()
|
||||||
|
cfg.option('od.interface1.ip_admin_eth1').value.set(['192.168.1.1', '192.168.2.1'])
|
||||||
|
cfg.option('od.interface1.netmask_admin_eth1', 1).value.set('255.255.255.0')
|
||||||
|
cfg.option('od.interface1.ip_admin_eth1').value.pop(0)
|
||||||
|
|
||||||
|
|
||||||
def test_follower_force_store_value():
|
def test_follower_force_store_value():
|
||||||
ip_admin_eth0 = IPOption('ip_admin_eth0', "ip réseau autorisé", multi=True, default=['1.1.1.1'])
|
ip_admin_eth0 = IPOption('ip_admin_eth0', "ip réseau autorisé", multi=True, default=['1.1.1.1'])
|
||||||
netmask_admin_eth0 = NetmaskOption('netmask_admin_eth0', "masque du sous-réseau", multi=True, properties=('force_store_value',))
|
netmask_admin_eth0 = NetmaskOption('netmask_admin_eth0', "masque du sous-réseau", multi=True, properties=('force_store_value',))
|
||||||
|
|
|
@ -244,7 +244,6 @@ def test_symlink_with_follower(config_type):
|
||||||
cfg = get_config(cfg, config_type)
|
cfg = get_config(cfg, config_type)
|
||||||
assert cfg.value.dict() == {'ip_admin_eth0.ip_admin_eth0': [], 'ip_admin_eth0.netmask_admin_eth0': [], 'follower': []}
|
assert cfg.value.dict() == {'ip_admin_eth0.ip_admin_eth0': [], 'ip_admin_eth0.netmask_admin_eth0': [], 'follower': []}
|
||||||
cfg.option('ip_admin_eth0.ip_admin_eth0').value.set(['val1', 'val2'])
|
cfg.option('ip_admin_eth0.ip_admin_eth0').value.set(['val1', 'val2'])
|
||||||
print(cfg.value.dict())
|
|
||||||
assert cfg.value.dict() == {'ip_admin_eth0.ip_admin_eth0': ['val1', 'val2'], 'ip_admin_eth0.netmask_admin_eth0': [None, None], 'follower': [None, None]}
|
assert cfg.value.dict() == {'ip_admin_eth0.ip_admin_eth0': ['val1', 'val2'], 'ip_admin_eth0.netmask_admin_eth0': [None, None], 'follower': [None, None]}
|
||||||
#
|
#
|
||||||
assert cfg.option('ip_admin_eth0.netmask_admin_eth0', 0).value.get() == None
|
assert cfg.option('ip_admin_eth0.netmask_admin_eth0', 0).value.get() == None
|
||||||
|
|
|
@ -282,7 +282,8 @@ class SubConfig(object):
|
||||||
def getattr(self,
|
def getattr(self,
|
||||||
name,
|
name,
|
||||||
option_bag,
|
option_bag,
|
||||||
from_follower=False):
|
from_follower=False,
|
||||||
|
follower_check_length=True):
|
||||||
"""
|
"""
|
||||||
attribute notation mechanism for accessing the value of an option
|
attribute notation mechanism for accessing the value of an option
|
||||||
:param name: attribute name
|
:param name: attribute name
|
||||||
|
@ -314,7 +315,7 @@ class SubConfig(object):
|
||||||
if not from_follower or option_bag.option.impl_getrequires():
|
if not from_follower or option_bag.option.impl_getrequires():
|
||||||
self.cfgimpl_get_settings().validate_properties(option_bag)
|
self.cfgimpl_get_settings().validate_properties(option_bag)
|
||||||
|
|
||||||
if option.impl_is_follower() and not from_follower:
|
if follower_check_length and option.impl_is_follower() and not from_follower:
|
||||||
length = self.cfgimpl_get_length_leadership(option_bag)
|
length = self.cfgimpl_get_length_leadership(option_bag)
|
||||||
follower_len = self.cfgimpl_get_values()._p_.get_max_length(option_bag.path)
|
follower_len = self.cfgimpl_get_values()._p_.get_max_length(option_bag.path)
|
||||||
if follower_len > length:
|
if follower_len > length:
|
||||||
|
@ -323,8 +324,12 @@ class SubConfig(object):
|
||||||
follower_len,
|
follower_len,
|
||||||
length,
|
length,
|
||||||
option_bag.index))
|
option_bag.index))
|
||||||
|
else:
|
||||||
|
length = None
|
||||||
if option.impl_is_follower() and option_bag.index is None:
|
if option.impl_is_follower() and option_bag.index is None:
|
||||||
value = []
|
value = []
|
||||||
|
if length is None:
|
||||||
|
length = self.cfgimpl_get_length_leadership(option_bag)
|
||||||
for idx in range(length):
|
for idx in range(length):
|
||||||
soption_bag = OptionBag()
|
soption_bag = OptionBag()
|
||||||
soption_bag.set_option(option,
|
soption_bag.set_option(option,
|
||||||
|
|
|
@ -686,7 +686,8 @@ class Option(BaseOption):
|
||||||
fromconsistency.append(cons_id)
|
fromconsistency.append(cons_id)
|
||||||
coption_bag.fromconsistency = fromconsistency
|
coption_bag.fromconsistency = fromconsistency
|
||||||
current_value = option_bag.config_bag.context.getattr(path,
|
current_value = option_bag.config_bag.context.getattr(path,
|
||||||
coption_bag)
|
coption_bag,
|
||||||
|
follower_check_length=False)
|
||||||
if index_ is None and index is not None:
|
if index_ is None and index is not None:
|
||||||
#if self is a follower and current_option is a leader and func not in ALLOWED_CONST_LIST
|
#if self is a follower and current_option is a leader and func not in ALLOWED_CONST_LIST
|
||||||
#return only the value of the leader for isolate follower
|
#return only the value of the leader for isolate follower
|
||||||
|
|
Loading…
Reference in New Issue