File live_view_proxy_adapter.py has 264 lines of code (exceeds 250 allowed). Consider refactoring.

Open

"""ODIN data live view proxy adapter.

This module implements an odin-control adapter capable of subscribing to
multiple Odin Data Live View plugins and combining all streams of frames
into a single ZMQ stream.

Function git_get_keywords has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

def git_get_keywords(versionfile_abs):
    """Extract version information from the given file."""
    # the code embedded in _version.py can just fetch the value of these
    # keywords. When used from setup.py, we don't want to import _version.py,
    # so we do it with a regexp instead. This function is not used from

• Read up
  Read up

Function git_pieces_from_vcs has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

def git_pieces_from_vcs(tag_prefix, root, verbose, run_command=run_command):
    """Get version from 'git describe' in the root of the source tree.

    This only gets called if the git-archive 'subst' keywords were *not*
    expanded, and _version.py hasn't already been rewritten with a short

• Read up
  Read up

Function git_versions_from_keywords has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

def git_versions_from_keywords(keywords, tag_prefix, verbose):
    """Get version information from git keywords."""
    if not keywords:
        raise NotThisMethod("no keywords at all, weird")
    date = keywords.get("date")

• Read up
  Read up

Function update_loop has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

    def update_loop(self):
        """Handle background update loop tasks.
        This method handles background update tasks executed periodically in the tornado
        IOLoop instance. This includes requesting the status from the underlying application
        and preparing the JSON encoded reply in a format that can be easily parsed.

• Read up
  Read up

Function configure has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

    def configure(self, request):
        """Handle a configuration message

        Args:
            request(IpcMessage): The request message

• Read up
  Read up

Method refreshImage has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

    private void refreshImage(ByteBuffer data, String dtype, int[] shape)
    {
        int bitdepth = dtype_map.get(dtype);
        ImageProcessor ip = img.getProcessor();
        Object img_pixels = null;

• Read up
  Read up

Function process_reconnection has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

    def process_reconnection(self, client):
        # We have been notified that a client has reconnected.
        # Loop over all stored configuration, sending any that needs to be processed
        logging.debug("Processing reconnection for client: %d", client)
        # First load the configuration file

• Read up
  Read up

Function handle_data_message has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def handle_data_message(self, socket, endpoint):
        """Handle a data message on the given socket

        Args:
            socket(zmq.Socket): The socket to receive a message on

• Read up
  Read up

Function _send_message has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def _send_message(self, msg, timeout):
        msg.set_msg_id(self.message_id)
        self.message_id = (self.message_id + 1) % self.MESSAGE_ID_MAX
        self.logger.debug("Sending control message:\n%s", msg.encode())
        with self._lock:

• Read up
  Read up

Function __del__ has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def __del__(self):

        for mapped_ctype_name in ('manager_id', 'num_buffers', 'buffer_size'):
            mapped_ctype = getattr(self, mapped_ctype_name, None)
            if mapped_ctype is not None:

• Read up
  Read up

Function __init__ has 11 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(

Function process_configuration_file has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    def process_configuration_file(self, config_file_path, client_index):
        status_code = 200
        response = {}
        if config_file_path != '':
            logging.debug("Loading configuration file {}".format(config_file_path))

• Read up
  Read up

Function __init__ has 9 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(

Function __init__ has 9 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(

Function process_configuration has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def process_configuration(self, request_command, parameters):
        status_code = 200
        response = {}
        logging.debug("Process configuration with URI: %s", request_command)
        client_index = -1

• Read up
  Read up

Function render_pep440 has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

def render_pep440(pieces):
    """Build up version string, with post-release "local version identifier".

    Our goal: TAG[+DISTANCE.gHEX[.dirty]] . Note that if you
    get a tagged build and then dirty it, you'll get TAG+0.gHEX.dirty

• Read up
  Read up

Method update has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void update(Observable o, Object arg)
    {
        switch(arg.toString().toLowerCase())
        {

Function __init__ has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(

Function render_pep440_post has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def render_pep440_post(pieces):
    """TAG[.postDISTANCE[.dev0]+gHEX] .

    The ".dev0" means dirty. Note that .dev0 sorts backwards
    (a dirty tree will appear "older" than the corresponding clean one),

• Read up
  Read up