Avoid too many return statements within this function.

Open

    return fnd

Avoid too many return statements within this function.

Open

                    return ''

Avoid too many return statements within this function.

Open

                    return self.extract_aes(payload)

Avoid too many return statements within this function.

Open

    return []

Avoid too many return statements within this function.

Open

                return key_str, token

Avoid too many return statements within this function.

Open

                    return self.extract_aes(payload, master_pub=False)

Avoid too many return statements within this function.

Open

    return False

Avoid too many return statements within this function.

Open

        return fnd

Avoid too many return statements within this function.

Open

        return fnd

Avoid too many return statements within this function.

Open

                return self.extract_aes(payload, master_pub=False)

Avoid too many return statements within this function.

Open

            return _add_file_stat(fnd)

Avoid too many return statements within this function.

Open

    return []

Avoid too many return statements within this function.

Open

    return ret

Function _encrypt_private has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def _encrypt_private(self, ret, dictkey, target):
        '''
        The server equivalent of ReqChannel.crypted_transfer_decode_dictentry
        '''
        # encrypt with a specific AES key

• Read up
  Read up

Function clear_doc has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def clear_doc(self, docname):
        for typ, routes in self.routes.items():
            for path, info in list(routes.items()):
                if info[0] == docname:
                    del routes[path]

• Read up
  Read up

Function start has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def start(self):
        '''
        Perform the work necessary to start up a Tornado IPC server

        Blocks until socket is established

• Read up
  Read up

Function on_recv has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def on_recv(self, callback):
        '''
        Register an on_recv callback
        '''
        if callback is None:

• Read up
  Read up

Function _publish_daemon has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def _publish_daemon(self, **kwargs):
        '''
        Bind to the interface specified in the configuration file
        '''
        salt.utils.process.appendproctitle(self.__class__.__name__)

• Read up
  Read up

Function event_map has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def event_map(self):
        if ZeroMQSocketMonitor.__EVENT_MAP is None:
            event_map = {}
            for name in dir(zmq):
                if name.startswith('EVENT_'):

• Read up
  Read up

Function factory has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def factory(opts, **kwargs):
        # Default to ZeroMQ for now
        ttype = 'zeromq'

        # determine the ttype

• Read up
  Read up