File worker.py has 369 lines of code (exceeds 250 allowed). Consider refactoring.

Open

__author__ = 'tanel'

import logging
import logging.config
import time

Function received_message has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

    def received_message(self, m):
        logger.debug("%s: Got message from server of type %s" % (self.request_id, str(type(m))))
        if self.state == self.__class__.STATE_CONNECTED:
            props = json.loads(str(m))
            content_type = props['content_type']

• Read up
  Read up

File master_server.py has 290 lines of code (exceeds 250 allowed). Consider refactoring.

Open

#!/usr/bin/env python
#
# Copyright 2013 Tanel Alumae

"""

Function received_message has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    def received_message(self, m):
        response = json.loads(str(m))
        #print >> sys.stderr, "RESPONSE:", response
        #print >> sys.stderr, "JSON was:", m
        if response['status'] == 0:

• Read up
  Read up

Function __testDecoder has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def __testDecoder(self):
        finished = [False]

Function create_pipeline has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def create_pipeline(self, conf):

        self.appsrc = Gst.ElementFactory.make("appsrc", "appsrc")

        self.decodebin = Gst.ElementFactory.make("decodebin", "decodebin")

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

Open

    def post_process_full(self, full_result):
        if self.full_post_processor:
            self.full_post_processor.stdin.write("%s\n\n" % json.dumps(full_result))
            self.full_post_processor.stdin.flush()
            lines = []

• Read up
  Read up

Function create_pipeline has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def create_pipeline(self, conf):

        self.appsrc = Gst.ElementFactory.make("appsrc", "appsrc")
        self.decodebin = Gst.ElementFactory.make("decodebin", "decodebin")
        self.audioconvert = Gst.ElementFactory.make("audioconvert", "audioconvert")

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

Open

    def send_event(self, event):
        event_str = str(event)
        if len(event_str) > 100:
            event_str = event_str[:97] + "..."
        logging.info("%s: Receiving event %s from worker" % (self.id, event_str))

• Read up
  Read up

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

Open

    def create_pipeline(self, conf):

        self.appsrc = Gst.ElementFactory.make("appsrc", "appsrc")
        self.decodebin = Gst.ElementFactory.make("decodebin", "decodebin")
        self.audioconvert = Gst.ElementFactory.make("audioconvert", "audioconvert")

• Read up
  Read up

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

Open

    def create_pipeline(self, conf):

        self.appsrc = Gst.ElementFactory.make("appsrc", "appsrc")

        self.decodebin = Gst.ElementFactory.make("decodebin", "decodebin")

• Read up
  Read up

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

Open

    def __init__(self, audiofile, url, protocols=None, extensions=None, heartbeat_freq=None, byterate=32000,

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

Open

    def post_process(self, texts, blocking=False):
        if self.post_processor:
            logging.debug("%s: Waiting for postprocessor lock" % self.request_id)
            if blocking:
                timeout=None

• Read up
  Read up

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

Open

    def finish_request(self):
        if self.state == self.STATE_CONNECTED:
            # connection closed when we are not doing anything
            self.decoder_pipeline.finish_request()
            self.state = self.STATE_FINISHED

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if as_props.get('type', "") == "string+gzip+base64":
                            adaptation_state = zlib.decompress(base64.b64decode(as_props.get('value', '')))
                            logger.info("%s: Setting adaptation state to user-provided value" % (self.request_id))
                            self.decoder_pipeline.set_adaptation_state(adaptation_state)
                        else:

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

Open

    def _on_full_result(self, full_result_json):
        try:
            self._increment_num_processing(1)
            
            self.last_decoder_message = time.time()

• Read up
  Read up

Function main has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

def main():
    logging.basicConfig(level=logging.DEBUG, format="%(levelname)8s %(asctime)s %(message)s ")
    logging.debug('Starting up worker')
    parser = argparse.ArgumentParser(description='Worker for kaldigstserver')
    parser.add_argument('-u', '--uri', default="ws://localhost:8888/worker/ws/speech", dest="uri", help="Server<-->worker websocket URI")

• Read up
  Read up

Function opened has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def opened(self):
        #print "Socket opened!"
        def send_data_to_ws():
            if self.send_adaptation_state_filename is not None:
                print >> sys.stderr, "Sending adaptation state from %s" % self.send_adaptation_state_filename

• Read up
  Read up

Function __testDecoder has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def __testDecoder(self):
        finished = [False]

• Read up
  Read up

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

Open

    def guard_timeout(self):
        global SILENCE_TIMEOUT
        while self.state in [self.STATE_EOS_RECEIVED, self.STATE_CONNECTED, self.STATE_INITIALIZED, self.STATE_PROCESSING]:
            if time.time() - self.last_decoder_message > SILENCE_TIMEOUT:
                logger.warning("%s: More than %d seconds from last decoder hypothesis update, cancelling" % (self.request_id, SILENCE_TIMEOUT))

• Read up
  Read up