corelink_stream_data.py

Go to the documentation of this file.

"""
    @file corelink_stream_data.py
    Handles the information associated with data streams in the client.
"""
import ctypes
import corelink_const

class StreamData:
    """
        StreamData
    """
    # pylint: disable=too-many-instance-attributes
    # Eight is reasonable in this case.
    def __init__(self,*arg):
        if len(arg)==1:
            rhs = arg[0]
            self.update(rhs.stream_id,
                        rhs.state,
                        rhs.mtu,
                        rhs.user,
                        rhs.workspace,
                        rhs.meta,
                        rhs.stream_ref,
                        rhs.types)
        elif len(arg)==8:
            self.update(arg[0],arg[1],arg[2],arg[3],arg[4],arg[5],arg[6],arg[7])
    def update(self,*arg):
        """
        update the parameters
        """
        self.state =  arg[1]
        self.mtu = arg[2]
        self.stream_ref = arg[6]
        self.stream_id = arg[0]
        self.user = arg[3]
        self.workspace = arg[4]
        self.meta = arg[5]
        self.types = arg[7]
    @staticmethod
    def list_client_streams():
        """
            List client streams
        """
        corelink_const.LIB.getClientStreams.restype = ctypes.POINTER(ctypes.c_char)
        data = corelink_const.LIB.getClientStreams()
        # print(bytes(data[4:10]))
        int_size = ctypes.sizeof(ctypes.c_int)
        length = int.from_bytes(data[0:int_size],"little")
        # print(length)
        stream_ids = []
        for i in range(length):
            data_casted = int.from_bytes(data[(i+1)*int_size:(i+1)*int_size + int_size],"little")
            stream_ids.append(data_casted)
        corelink_const.LIB.freeData(data)
        data_casted = None
        return stream_ids

    @staticmethod
    def is_receiver(stream_id):
        """
            is_receiver
        """
        corelink_const.LIB.isRecvStream.argtypes = [ctypes.c_int]
        corelink_const.LIB.isRecvStream.restype = ctypes.c_bool
        ans = corelink_const.LIB.isRecvStream(stream_id)
        return ans