Function _openbsd_remotes_on has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

def _openbsd_remotes_on(port, which_end):
    '''
    OpenBSD specific helper function.
    Returns set of ipv4 host addresses of remote established connections
    on local or remote tcp port.

• Read up
  Read up

Function _aix_remotes_on has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

def _aix_remotes_on(port, which_end):
    '''
    AIX specific helper function.
    Returns set of ipv4 host addresses of remote established connections
    on local or remote tcp port.

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if line.strip().startswith('sl'):
                        continue
                    iret = _parse_tcp_line(line)

Avoid deeply nested control flow statements.

Open

                    if line.strip().startswith('sl'):
                        continue
                    iret = _parse_tcp_line(line)

Avoid deeply nested control flow statements.

Open

                    if '.' in ip:
                        if 'inet' not in ifaces[iface.Description]:
                            ifaces[iface.Description]['inet'] = []
                        item = {'address': ip,
                                'label': iface.Description}

Function construct_scalar has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def construct_scalar(self, node):
        '''
        Verify integers and pass them in correctly is they are declared
        as octal
        '''

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if mmask.group(1):
                        mmask = _number_of_set_bits_to_ipv4_netmask(
                            int(mmask.group(1), 16))
                    else:
                        mmask = mmask.group(2)

Avoid deeply nested control flow statements.

Open

                        if not isinstance(subnode, MappingNode):
                            raise ConstructorError("while constructing a mapping",
                                                   node.start_mark,
                                                   "expected a mapping for merging, but found {0}".format(subnode.id),
                                                   subnode.start_mark)

Function _windows_remotes_on has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

def _windows_remotes_on(port, which_end):
    r'''
    Windows specific helper function.
    Returns set of ipv4 host addresses of remote established connections
    on local or remote tcp port.

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if ':' in ip:
                        if 'inet6' not in ifaces[iface.Description]:
                            ifaces[iface.Description]['inet6'] = []
                        item = {'address': ip}
                        if iface.DefaultIPGateway:

Function _filter has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def _filter(self, event):
        '''
        Take an event and run it through configured filters.

        Returns True if event should be stored, else False

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if mod_dir.endswith(util_dir) and mod_dir not in sys.path:
                            sys.path.append(mod_dir)

Avoid deeply nested control flow statements.

Open

                        if load['retcode'].get(fun, 0) and fun in SUB_EVENT:
                            # Minion fired a bad retcode, fire an event
                            self._fire_ret_load_specific_fun(load, fun_index)
            else:

Avoid deeply nested control flow statements.

Open

                        if src_digest != dst_digest:
                            # The downloaded file differs, replace!
                            shutil.copyfile(fn_, dest)
                            ret.append('{0}.{1}'.format(form, relname))
                    else:

Avoid deeply nested control flow statements.

Open

                        if not os.path.isdir(dest_dir):
                            os.makedirs(dest_dir)
                        shutil.copyfile(fn_, dest)

Function cache_id has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

def cache_id(service, name, sub_resource=None, resource_id=None,
             invalidate=False, region=None, key=None, keyid=None,
             profile=None):
    '''
    Cache, invalidate, or retrieve an AWS resource id keyed by name.

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if iret[sl][which_end] == port and iret[sl]['state'] == 1:  # 1 is ESTABLISHED
                        ret.add(iret[sl]['remote_addr'])

Avoid deeply nested control flow statements.

Open

                        if self.opts['master_stats']:
                            _data = data['data']
                            start = time.time()
                        try:

Avoid deeply nested control flow statements.

Open

                    for chunk in data['hwaddr'].split(':'):
                        expand_mac.append('0{0}'.format(chunk) if len(chunk) < 2 else '{0}'.format(chunk))
                    data['hwaddr'] = ':'.join(expand_mac)

Avoid deeply nested control flow statements.

Open

                    if not salt.utils.platform.is_sunos():
                        ipv6scope = mmask6.group(3) or mmask6.group(4)
                        addr_obj['scope'] = ipv6scope.lower() if ipv6scope is not None else ipv6scope
                # SunOS sometimes has ::/0 as inet6 addr when using addrconf
                if not salt.utils.platform.is_sunos() \