ros-hitstats-to-json Namespace Reference

Classes
class	LastUpdatedOrderedDict
class	LookUpDict

Functions
def	get_lines (pattern, filename)
def	split_lines (pattern, lines)
def	main ()

Function Documentation

get_lines()

def ros-hitstats-to-json.get_lines	(		pattern,
			filename
	)

Definition at line 42 of file ros-hitstats-to-json.py.

def get_lines(pattern, filename):
    if not os.path.isfile(filename):
        logging.warning("Cannot open file {}".format(filename))
        return None
    with open(filename) as logfile:
        lines = re.findall("{}.*$".format(pattern),
                           logfile.read(), re.MULTILINE)
        if len(lines) == 0:
            logging.warning("Could not find pattern \"{}\" in file {}".format(pattern, filename))
            return None
        return lines
 
 

main()

def ros-hitstats-to-json.main

(

)

Definition at line 67 of file ros-hitstats-to-json.py.

def main():
    logging.basicConfig(stream=sys.stdout,
                        format='%(levelname)-8s %(message)s',
                        level=logging.INFO)
 
    ros_stats = LastUpdatedOrderedDict()
 
    lines = get_lines(r'^\s*ROS-', 'ros_hitstats_reject.txt')
    table = split_lines(r'\||,', lines)
 
    for row in table:
        name = row[LookUpDict.ROS_NAME]
        hit_rate = row[LookUpDict.TOTAL_ROB_FRAC_PER_EVT]
        data_rate = row[LookUpDict.TOTAL_BYTES_PER_EVT]
        ros_stats[name] = LastUpdatedOrderedDict({
            'hits-per-evt': hit_rate,
            'kbytes-per-evt': float(data_rate)/1000
        })
 
    data = LastUpdatedOrderedDict()
    output_file = 'extra-results.json'
    if os.path.isfile(output_file):
        with open(output_file) as f:
            data.update(json.load(f, object_pairs_hook=LastUpdatedOrderedDict))
 
    data.update({'ros-stats': ros_stats})
 
    with open(output_file, 'w') as f:
        json.dump(data, f, indent=4)
 
 

split_lines()

def ros-hitstats-to-json.split_lines	(		pattern,
			lines
	)

Definition at line 55 of file ros-hitstats-to-json.py.

def split_lines(pattern, lines):
    result = []
    for line in lines:
        split_result = []
        for token in re.split(pattern, line):
            token = token.replace(' ', '')
            if not token == '':
                split_result.append(token)
        result.append(split_result)
    return result