helpers.py

__author__ = 'brianhoffman'

import threading
import math


def split_array_like(data, length, message_id=None, data_size=None):
    length = length or 1
    retval = []

    blocks = int(math.ceil(len(data) / length))
    blocks += 1

    for i in range(0, blocks):
        if message_id and data_size:
            retval.append('%s|%s|%s' % (message_id, data_size, data[i*length:i*length + length]))
        else:
            retval.append(data[i*length:i*length + length])

    return retval


def set_interval(func, sec=0, times=3):
    def func_wrapper():
        set_interval(func, sec, times-1)
        func()
    func()
    timer = threading.Timer(sec, func_wrapper)
    timer.start()
    return timer


def sort_by_sequence(packet_a, packet_b):
    return packet_a.get_sequence_number() - packet_b.get_sequence_number()