archive
/
ansible
mirror of https://github.com/ansible/ansible.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixed module structure

Browse Source
reviewable/pr18780/r1
GGabriele 8 years ago
parent 2579ca43bf
commit e725a077c5
1 changed files with 93 additions and 609 deletions
Show Stats Download Patch File Download Diff File

702
network/nxos/nxos_bgp.py
Unescape Escape View File

@ -29,10 +29,10 @@ author:
extends_documentation_fragment: nxos extends_documentation_fragment: nxos
notes: notes:
- I(state)=absent removes the whole BGP ASN configuration when VRF is - I(state)=absent removes the whole BGP ASN configuration when VRF is
C(default) or the whole VRF instance within the BGP process when using I(default) or the whole VRF instance within the BGP process when using
a different VRF. a different VRF.
- C(default) when supported restores params default value. - I(default) when supported restores params default value.
- Configuring global parmas is only permitted if VRF is C(default). - Configuring global parmas is only permitted if VRF is I(default).
options: options:
asn: asn:
description: description:
@ -41,12 +41,14 @@ options:
required: true required: true
vrf: vrf:
description: description:
- Name of the VRF. The name 'default' is a valid VRF representing the global BGP. - Name of the VRF. The name 'default' is a valid VRF representing
the global BGP.
required: false required: false
default: null default: null
bestpath_always_compare_med: bestpath_always_compare_med:
description: description:
- Enable/Disable MED comparison on paths from different autonomous systems. - Enable/Disable MED comparison on paths from different
autonomous systems.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
@ -79,15 +81,16 @@ options:
default: null default: null
bestpath_med_missing_as_worst: bestpath_med_missing_as_worst:
description: description:
- Enable/Disable assigns the value of infinity to received routes that - Enable/Disable assigns the value of infinity to received
do not carry the MED attribute, making these routes the least desirable. routes that do not carry the MED attribute, making these routes
the least desirable.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
bestpath_med_non_deterministic: bestpath_med_non_deterministic:
description: description:
- Enable/Disable deterministic selection of the best MED path from among - Enable/Disable deterministic selection of the best MED pat
the paths from the same autonomous system. from among the paths from the same autonomous system.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
@ -108,25 +111,28 @@ options:
default: null default: null
disable_policy_batching: disable_policy_batching:
description: description:
- Enable/Disable the batching evaluation of prefix advertisements to all peers. - Enable/Disable the batching evaluation of prefix advertisement
to all peers.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
disable_policy_batching_ipv4_prefix_list: disable_policy_batching_ipv4_prefix_list:
description: description:
- Enable/Disable the batching evaluation of prefix advertisements to all - Enable/Disable the batching evaluation of prefix advertisements
peers with prefix list. to all peers with prefix list.
required: false required: false
default: null default: null
disable_policy_batching_ipv6_prefix_list: disable_policy_batching_ipv6_prefix_list:
description: description:
- Enable/Disable the batching evaluation of prefix advertisements to all peers with prefix list. - Enable/Disable the batching evaluation of prefix advertisements
to all peers with prefix list.
required: false required: false
enforce_first_as: enforce_first_as:
description: description:
- Enable/Disable enforces the neighbor autonomous system to be the first AS number - Enable/Disable enforces the neighbor autonomous system to be
listed in the AS path attribute for eBGP. On NX-OS, this property is only supported the first AS number listed in the AS path attribute for eBGP.
in the global BGP context. On NX-OS, this property is only supported in the
global BGP context.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
@ -156,14 +162,16 @@ options:
fast_external_fallover: fast_external_fallover:
description: description:
- Enable/Disable immediately reset the session if the link to a - Enable/Disable immediately reset the session if the link to a
directly connected BGP peer goes down. Only supported in the global BGP context. directly connected BGP peer goes down. Only supported in the
global BGP context.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
flush_routes: flush_routes:
description: description:
- Enable/Disable flush routes in RIB upon controlled restart. - Enable/Disable flush routes in RIB upon controlled restart.
On NX-OS, this property is only supported in the global BGP context. On NX-OS, this property is only supported in the global
BGP context.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
@ -187,7 +195,8 @@ options:
default: null default: null
graceful_restart_timers_stalepath_time: graceful_restart_timers_stalepath_time:
description: description:
- Set maximum time that BGP keeps the stale routes from the restarting BGP peer. - Set maximum time that BGP keeps the stale routes from the
restarting BGP peer.
choices: ['true','false'] choices: ['true','false']
default: null default: null
isolate: isolate:
@ -209,13 +218,14 @@ options:
default: null default: null
maxas_limit: maxas_limit:
description: description:
- Specify Maximum number of AS numbers allowed in the AS-path attribute - Specify Maximum number of AS numbers allowed in the AS-path
Valid values are between 1 and 512. attribute. Valid values are between 1 and 512.
required: false required: false
default: null default: null
neighbor_down_fib_accelerate: neighbor_down_fib_accelerate:
description: description:
- Enable/Disable handle BGP neighbor down event, due to various reasons. - Enable/Disable handle BGP neighbor down event, due to
various reasons.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
@ -237,13 +247,15 @@ options:
default: null default: null
suppress_fib_pending: suppress_fib_pending:
description: description:
- Enable/Disable advertise only routes programmed in hardware to peers. - Enable/Disable advertise only routes programmed in hardware
to peers.
required: false required: false
choices: ['true','false'] choices: ['true','false']
default: null default: null
timer_bestpath_limit: timer_bestpath_limit:
description: description:
- Specify timeout for the first best path after a restart, in seconds. - Specify timeout for the first best path after a restart,
in seconds.
required: false required: false
default: null default: null
timer_bestpath_limit_always: timer_bestpath_limit_always:
@ -264,16 +276,11 @@ options:
default: null default: null
state: state:
description: description:
- Determines whether the config should be present or not on the device. - Determines whether the config should be present or not
on the device.
required: false required: false
default: present default: present
choices: ['present','absent'] choices: ['present','absent']
m_facts:
description:
- Used to print module facts
required: false
default: false
choices: ['true','false']
''' '''
@ -292,11 +299,12 @@ EXAMPLES = '''
RETURN = ''' RETURN = '''
proposed: proposed:
description: k/v pairs of parameters passed into module description: k/v pairs of parameters passed into module
returned: always returned: verbose mode
type: dict type: dict
sample: {"asn": "65535", "router_id": "1.1.1.1", "vrf": "test"} sample: {"asn": "65535", "router_id": "1.1.1.1", "vrf": "test"}
existing: existing:
description: k/v pairs of existing BGP configuration description: k/v pairs of existing BGP configuration
returned: verbose mode
type: dict type: dict
sample: {"asn": "65535", "bestpath_always_compare_med": false, sample: {"asn": "65535", "bestpath_always_compare_med": false,
"bestpath_aspath_multipath_relax": false, "bestpath_aspath_multipath_relax": false,
@ -317,7 +325,7 @@ existing:
"timer_bgp_keepalive": "60", "vrf": "test"} "timer_bgp_keepalive": "60", "vrf": "test"}
end_state: end_state:
description: k/v pairs of BGP configuration after module execution description: k/v pairs of BGP configuration after module execution
returned: always returned: verbose mode
type: dict type: dict
sample: {"asn": "65535", "bestpath_always_compare_med": false, sample: {"asn": "65535", "bestpath_always_compare_med": false,
"bestpath_aspath_multipath_relax": false, "bestpath_aspath_multipath_relax": false,
@ -349,203 +357,51 @@ changed:
''' '''
# COMMON CODE FOR MIGRATION # COMMON CODE FOR MIGRATION
import re import re
import time
import collections
import itertools
import shlex
from ansible.module_utils.basic import AnsibleModule, env_fallback, get_exception
from ansible.module_utils.basic import BOOLEANS_TRUE, BOOLEANS_FALSE
from ansible.module_utils.shell import Shell, ShellError, HAS_PARAMIKO
from ansible.module_utils.netcfg import parse
from ansible.module_utils.urls import fetch_url
DEFAULT_COMMENT_TOKENS = ['#', '!']
class ConfigLine(object):
def __init__(self, text):
self.text = text
self.children = list()
self.parents = list()
self.raw = None
@property from ansible.module_utils.basic import get_exception
def line(self): from ansible.module_utils.netcfg import NetworkConfig, ConfigLine
line = ['set']
line.extend([p.text for p in self.parents])
line.append(self.text)
return ' '.join(line)
def __str__(self): try:
return self.raw from ansible.module_utils.nxos import get_module
except ImportError:
from ansible.module_utils.nxos import NetworkModule
def __eq__(self, other):
if self.text == other.text:
return self.parents == other.parents
def __ne__(self, other): def to_list(val):
return not self.__eq__(other) if isinstance(val, (list, tuple)):
return list(val)
def ignore_line(text, tokens=None): elif val is not None:
for item in (tokens or DEFAULT_COMMENT_TOKENS): return [val]
if text.startswith(item): else:
return True return list()
def get_next(iterable):
item, next_item = itertools.tee(iterable, 2)
next_item = itertools.islice(next_item, 1, None)
return itertools.izip_longest(item, next_item)
def parse(lines, indent, comment_tokens=None):
toplevel = re.compile(r'\S')
childline = re.compile(r'^\s*(.+)$')
ancestors = list()
config = list()
for line in str(lines).split('\n'):
text = str(re.sub(r'([{};])', '', line)).strip()
cfg = ConfigLine(text)
cfg.raw = line
if not text or ignore_line(text, comment_tokens):
continue
# handle top level commands
if toplevel.match(line):
ancestors = [cfg]
# handle sub level commands
else:
match = childline.match(line)
line_indent = match.start(1)
level = int(line_indent / indent)
parent_level = level - 1
cfg.parents = ancestors[:level] class CustomNetworkConfig(NetworkConfig):
if level > len(ancestors): def expand_section(self, configobj, S=None):
config.append(cfg) if S is None:
S = list()
S.append(configobj)
for child in configobj.children:
if child in S:
continue continue
self.expand_section(child, S)
return S
for i in range(level, len(ancestors)): def get_object(self, path):
ancestors.pop()
ancestors.append(cfg)
ancestors[parent_level].children.append(cfg)
config.append(cfg)
return config
class CustomNetworkConfig(object):
def __init__(self, indent=None, contents=None, device_os=None):
self.indent = indent or 1
self._config = list()
self._device_os = device_os
if contents:
self.load(contents)
@property
def items(self):
return self._config
@property
def lines(self):
lines = list()
for item, next_item in get_next(self.items):
if next_item is None:
lines.append(item.line)
elif not next_item.line.startswith(item.line):
lines.append(item.line)
return lines
def __str__(self):
text = ''
for item in self.items: for item in self.items:
if not item.parents:
expand = self.get_section(item.text)
text += '%s\n' % self.get_section(item.text)
return str(text).strip()
def load(self, contents):
self._config = parse(contents, indent=self.indent)
def load_from_file(self, filename):
self.load(open(filename).read())
def get(self, path):
if isinstance(path, basestring):
path = [path]
for item in self._config:
if item.text == path[-1]: if item.text == path[-1]:
parents = [p.text for p in item.parents] parents = [p.text for p in item.parents]
if parents == path[:-1]: if parents == path[:-1]:
return item return item
def search(self, regexp, path=None):
regex = re.compile(r'^%s' % regexp, re.M)
if path:
parent = self.get(path)
if not parent or not parent.children:
return
children = [c.text for c in parent.children]
data = '\n'.join(children)
else:
data = str(self)
match = regex.search(data)
if match:
if match.groups():
values = match.groupdict().values()
groups = list(set(match.groups()).difference(values))
return (groups, match.groupdict())
else:
return match.group()
def findall(self, regexp):
regexp = r'%s' % regexp
return re.findall(regexp, str(self))
def expand(self, obj, items):
block = [item.raw for item in obj.parents]
block.append(obj.raw)
current_level = items
for b in block:
if b not in current_level:
current_level[b] = collections.OrderedDict()
current_level = current_level[b]
for c in obj.children:
if c.raw not in current_level:
current_level[c.raw] = collections.OrderedDict()
def to_lines(self, section):
lines = list()
for entry in section[1:]:
line = ['set']
line.extend([p.text for p in entry.parents])
line.append(entry.text)
lines.append(' '.join(line))
return lines
def to_block(self, section): def to_block(self, section):
return '\n'.join([item.raw for item in section]) return '\n'.join([item.raw for item in section])
def get_section(self, path): def get_section(self, path):
try: try:
section = self.get_section_objects(path) section = self.get_section_objects(path)
if self._device_os == 'junos':
return self.to_lines(section)
return self.to_block(section) return self.to_block(section)
except ValueError: except ValueError:
return list() return list()
@ -558,119 +414,6 @@ class CustomNetworkConfig(object):
raise ValueError('path does not exist in config') raise ValueError('path does not exist in config')
return self.expand_section(obj) return self.expand_section(obj)
def expand_section(self, configobj, S=None):
if S is None:
S = list()
S.append(configobj)
for child in configobj.children:
if child in S:
continue
self.expand_section(child, S)
return S
def flatten(self, data, obj=None):
if obj is None:
obj = list()
for k, v in data.items():
obj.append(k)
self.flatten(v, obj)
return obj
def get_object(self, path):
for item in self.items:
if item.text == path[-1]:
parents = [p.text for p in item.parents]
if parents == path[:-1]:
return item
def get_children(self, path):
obj = self.get_object(path)
if obj:
return obj.children
def difference(self, other, path=None, match='line', replace='line'):
updates = list()
config = self.items
if path:
config = self.get_children(path) or list()
if match == 'line':
for item in config:
if item not in other.items:
updates.append(item)
elif match == 'strict':
if path:
current = other.get_children(path) or list()
else:
current = other.items
for index, item in enumerate(config):
try:
if item != current[index]:
updates.append(item)
except IndexError:
updates.append(item)
elif match == 'exact':
if path:
current = other.get_children(path) or list()
else:
current = other.items
if len(current) != len(config):
updates.extend(config)
else:
for ours, theirs in itertools.izip(config, current):
if ours != theirs:
updates.extend(config)
break
if self._device_os == 'junos':
return updates
diffs = collections.OrderedDict()
for update in updates:
if replace == 'block' and update.parents:
update = update.parents[-1]
self.expand(update, diffs)
return self.flatten(diffs)
def replace(self, replace, text=None, regex=None, parents=None,
add_if_missing=False, ignore_whitespace=False):
match = None
parents = parents or list()
if text is None and regex is None:
raise ValueError('missing required arguments')
if not regex:
regex = ['^%s$' % text]
patterns = [re.compile(r, re.I) for r in to_list(regex)]
for item in self.items:
for regexp in patterns:
if ignore_whitespace is True:
string = item.text
else:
string = item.raw
if regexp.search(item.text):
if item.text != replace:
if parents == [p.text for p in item.parents]:
match = item
break
if match:
match.text = replace
indent = len(match.raw) - len(match.raw.lstrip())
match.raw = replace.rjust(len(replace) + indent)
elif add_if_missing:
self.add(replace, parents=parents)
def add(self, lines, parents=None): def add(self, lines, parents=None):
"""Adds one or lines of configuration """Adds one or lines of configuration
@ -721,303 +464,44 @@ class CustomNetworkConfig(object):
self.items.append(item) self.items.append(item)
def argument_spec(): def get_network_module(**kwargs):
return dict( try:
# config options return get_module(**kwargs)
running_config=dict(aliases=['config']), except NameError:
save_config=dict(type='bool', default=False, aliases=['save']) return NetworkModule(**kwargs)
)
nxos_argument_spec = argument_spec()
NET_PASSWD_RE = re.compile(r"[\r\n]?password: $", re.I)
NET_COMMON_ARGS = dict(
host=dict(required=True),
port=dict(type='int'),
username=dict(fallback=(env_fallback, ['ANSIBLE_NET_USERNAME'])),
password=dict(no_log=True, fallback=(env_fallback, ['ANSIBLE_NET_PASSWORD'])),
ssh_keyfile=dict(fallback=(env_fallback, ['ANSIBLE_NET_SSH_KEYFILE']), type='path'),
transport=dict(default='cli', choices=['cli', 'nxapi']),
use_ssl=dict(default=False, type='bool'),
validate_certs=dict(default=True, type='bool'),
provider=dict(type='dict'),
timeout=dict(default=10, type='int')
)
NXAPI_COMMAND_TYPES = ['cli_show', 'cli_show_ascii', 'cli_conf', 'bash']
NXAPI_ENCODINGS = ['json', 'xml']
CLI_PROMPTS_RE = [
re.compile(r'[\r\n]?[a-zA-Z]{1}[a-zA-Z0-9-]*[>|#|%](?:\s*)$'),
re.compile(r'[\r\n]?[a-zA-Z]{1}[a-zA-Z0-9-]*\(.+\)#(?:\s*)$')
]
CLI_ERRORS_RE = [
re.compile(r"% ?Error"),
re.compile(r"^% \w+", re.M),
re.compile(r"% ?Bad secret"),
re.compile(r"invalid input", re.I),
re.compile(r"(?:incomplete|ambiguous) command", re.I),
re.compile(r"connection timed out", re.I),
re.compile(r"[^\r\n]+ not found", re.I),
re.compile(r"'[^']' +returned error code: ?\d+"),
re.compile(r"syntax error"),
re.compile(r"unknown command")
]
def to_list(val):
if isinstance(val, (list, tuple)):
return list(val)
elif val is not None:
return [val]
else:
return list()
class Nxapi(object):
def __init__(self, module):
self.module = module
# sets the module_utils/urls.py req parameters
self.module.params['url_username'] = module.params['username']
self.module.params['url_password'] = module.params['password']
self.url = None
self._nxapi_auth = None
def _get_body(self, commands, command_type, encoding, version='1.0', chunk='0', sid=None):
"""Encodes a NXAPI JSON request message
"""
if isinstance(commands, (list, set, tuple)):
commands = ' ;'.join(commands)
if encoding not in NXAPI_ENCODINGS:
msg = 'invalid encoding, received %s, exceped one of %s' % \
(encoding, ','.join(NXAPI_ENCODINGS))
self.module_fail_json(msg=msg)
msg = {
'version': version,
'type': command_type,
'chunk': chunk,
'sid': sid,
'input': commands,
'output_format': encoding
}
return dict(ins_api=msg)
def connect(self):
host = self.module.params['host']
port = self.module.params['port']
if self.module.params['use_ssl']:
proto = 'https'
if not port:
port = 443
else:
proto = 'http'
if not port:
port = 80
self.url = '%s://%s:%s/ins' % (proto, host, port)
def send(self, commands, command_type='cli_show_ascii', encoding='json'):
"""Send commands to the device.
"""
clist = to_list(commands)
if command_type not in NXAPI_COMMAND_TYPES:
msg = 'invalid command_type, received %s, exceped one of %s' % \
(command_type, ','.join(NXAPI_COMMAND_TYPES))
self.module_fail_json(msg=msg)
data = self._get_body(clist, command_type, encoding)
data = self.module.jsonify(data)
headers = {'Content-Type': 'application/json'}
if self._nxapi_auth:
headers['Cookie'] = self._nxapi_auth
response, headers = fetch_url(self.module, self.url, data=data,
headers=headers, method='POST')
self._nxapi_auth = headers.get('set-cookie')
if headers['status'] != 200:
self.module.fail_json(**headers)
response = self.module.from_json(response.read())
result = list()
output = response['ins_api']['outputs']['output']
for item in to_list(output):
if item['code'] != '200':
self.module.fail_json(**item)
else:
result.append(item['body'])
return result
class Cli(object):
def __init__(self, module):
self.module = module
self.shell = None
def connect(self, **kwargs):
host = self.module.params['host']
port = self.module.params['port'] or 22
username = self.module.params['username']
password = self.module.params['password']
timeout = self.module.params['timeout']
key_filename = self.module.params['ssh_keyfile']
allow_agent = (key_filename is not None) or (key_filename is None and password is None)
try:
self.shell = Shell(kickstart=False, prompts_re=CLI_PROMPTS_RE,
errors_re=CLI_ERRORS_RE)
self.shell.open(host, port=port, username=username,
password=password, key_filename=key_filename,
allow_agent=allow_agent, timeout=timeout)
except ShellError:
e = get_exception()
msg = 'failed to connect to %s:%s - %s' % (host, port, str(e))
self.module.fail_json(msg=msg)
def send(self, commands, encoding='text'):
try:
return self.shell.send(commands)
except ShellError:
e = get_exception()
self.module.fail_json(msg=e.message, commands=commands)
class NetworkModule(AnsibleModule):
def __init__(self, *args, **kwargs):
super(NetworkModule, self).__init__(*args, **kwargs)
self.connection = None
self._config = None
self._connected = False
@property
def connected(self):
return self._connected
@property
def config(self):
if not self._config:
self._config = self.get_config()
return self._config
def _load_params(self):
super(NetworkModule, self)._load_params()
provider = self.params.get('provider') or dict()
for key, value in provider.items():
if key in NET_COMMON_ARGS:
if self.params.get(key) is None and value is not None:
self.params[key] = value
def connect(self):
cls = globals().get(str(self.params['transport']).capitalize())
try:
self.connection = cls(self)
except TypeError:
e = get_exception()
self.fail_json(msg=e.message)
self.connection.connect()
if self.params['transport'] == 'cli':
self.connection.send('terminal length 0')
self._connected = True
def configure(self, commands):
commands = to_list(commands)
if self.params['transport'] == 'cli':
return self.configure_cli(commands)
else:
return self.execute(commands, command_type='cli_conf')
def configure_cli(self, commands):
commands = to_list(commands)
commands.insert(0, 'configure')
responses = self.execute(commands)
responses.pop(0)
return responses
def execute(self, commands, **kwargs):
if not self.connected:
self.connect()
return self.connection.send(commands, **kwargs)
def disconnect(self):
self.connection.close()
self._connected = False
def parse_config(self, cfg):
return parse(cfg, indent=2)
def get_config(self):
cmd = 'show running-config'
if self.params.get('include_defaults'):
cmd += ' all'
response = self.execute(cmd)
return response[0]
def get_module(**kwargs):
"""Return instance of NetworkModule
"""
argument_spec = NET_COMMON_ARGS.copy()
if kwargs.get('argument_spec'):
argument_spec.update(kwargs['argument_spec'])
kwargs['argument_spec'] = argument_spec
module = NetworkModule(**kwargs)
if module.params['transport'] == 'cli' and not HAS_PARAMIKO:
module.fail_json(msg='paramiko is required but does not appear to be installed')
return module
def custom_get_config(module, include_defaults=False): def get_config(module, include_defaults=False):
config = module.params['running_config'] config = module.params['config']
if not config: if not config:
cmd = 'show running-config' try:
if module.params['include_defaults']: config = module.get_config()
cmd += ' all' except AttributeError:
if module.params['transport'] == 'nxapi': defaults = module.params['include_defaults']
config = module.execute([cmd], command_type='cli_show_ascii')[0] config = module.config.get_config(include_defaults=defaults)
else:
config = module.execute([cmd])[0]
return CustomNetworkConfig(indent=2, contents=config) return CustomNetworkConfig(indent=2, contents=config)
def load_config(module, candidate): def load_config(module, candidate):
config = custom_get_config(module) config = get_config(module)
commands = candidate.difference(config) commands = candidate.difference(config)
commands = [str(c).strip() for c in commands] commands = [str(c).strip() for c in commands]
save_config = module.params['save_config'] save_config = module.params['save']
result = dict(changed=False) result = dict(changed=False)
if commands: if commands:
if not module.check_mode: if not module.check_mode:
module.configure(commands) try:
module.configure(commands)
except AttributeError:
module.config(commands)
if save_config: if save_config:
module.config.save_config() try:
module.config.save_config()
except AttributeError:
module.execute(['copy running-config startup-config'])
result['changed'] = True result['changed'] = True
result['updates'] = commands result['updates'] = commands
@ -1206,7 +690,7 @@ def get_value(arg, config):
def get_existing(module, args): def get_existing(module, args):
existing = {} existing = {}
netcfg = custom_get_config(module) netcfg = get_config(module)
try: try:
asn_regex = '.*router\sbgp\s(?P<existing_asn>\d+).*' asn_regex = '.*router\sbgp\s(?P<existing_asn>\d+).*'
@ -1221,7 +705,7 @@ def get_existing(module, args):
if module.params['vrf'] != 'default': if module.params['vrf'] != 'default':
parents = [bgp_parent, 'vrf {0}'.format(module.params['vrf'])] parents = [bgp_parent, 'vrf {0}'.format(module.params['vrf'])]
else: else:
parents = bgp_parent parents = [bgp_parent]
config = netcfg.get_section(parents) config = netcfg.get_section(parents)
if config: if config:
@ -1409,12 +893,12 @@ def main():
timer_bestpath_limit=dict(required=False, type='str'), timer_bestpath_limit=dict(required=False, type='str'),
timer_bgp_hold=dict(required=False, type='str'), timer_bgp_hold=dict(required=False, type='str'),
timer_bgp_keepalive=dict(required=False, type='str'), timer_bgp_keepalive=dict(required=False, type='str'),
m_facts=dict(required=False, default=False, type='bool'),
state=dict(choices=['present', 'absent'], default='present', state=dict(choices=['present', 'absent'], default='present',
required=False), required=False),
include_defaults=dict(default=True) include_defaults=dict(default=True),
config=dict(),
save=dict(type='bool', default=False)
) )
argument_spec.update(nxos_argument_spec)
module = get_module(argument_spec=argument_spec, module = get_module(argument_spec=argument_spec,
required_together=[['timer_bgp_hold', required_together=[['timer_bgp_hold',
'timer_bgp_keepalive']], 'timer_bgp_keepalive']],
@ -1509,7 +993,7 @@ def main():
result['updates'] = [] result['updates'] = []
result['connected'] = module.connected result['connected'] = module.connected
if module.params['m_facts']: if module._verbosity > 0:
end_state = invoke('get_existing', module, args) end_state = invoke('get_existing', module, args)
result['end_state'] = end_state result['end_state'] = end_state
result['existing'] = existing result['existing'] = existing

Write Preview
Loading…
Cancel
Save