cprrt.pxd

include "posix/time.pxd"

from libc.stdint cimport uint32_t, uint16_t, uint8_t, int32_t
from libc.string cimport const_char

cdef extern from "pthread.h" nogil:
    ctypedef struct pthread_t:
        pass

    ctypedef struct pthread_mutex_t:
        pass

    ctypedef struct pthread_cond_t:
        pass

cdef extern from "proto/vdmcode/block_code.h":
    cdef struct prrtCoder:
        pass

    ctypedef prrtCoder PrrtCoder

cdef extern from "proto/channelStateInformation.h":
    cdef struct prrtChannelStateInformation:
        pass

    ctypedef prrtChannelStateInformation PrrtChannelStateInformation

cdef extern from "proto/codingParams.h":
    ctypedef struct prrtCodingParams:
        uint8_t k
        uint8_t r
        uint8_t n
        uint8_t c
        uint8_t *n_cycle

    ctypedef prrtCodingParams PrrtCodingParams
    PrrtCodingParams *PrrtCodingParams_create()
    PrrtCodingParams *PrrtCodingParams_copy(PrrtCodingParams *cpar)
    bint PrrtCodingParams_update(PrrtCodingParams *cpar, uint8_t k, uint8_t n)
    bint PrrtCodingParams_destroy(PrrtCodingParams *cpar)

cdef extern from "util/list.h":
    cdef struct list:
        pass

    ctypedef list List

    cdef struct listNode:
        pass

    ctypedef listNode ListNode

    void List_push(List *list, const void *value)
    void *List_pop(const List *list)

    void List_unshift(List *list, const void *value)
    void *List_shift(const List *list)

    void *List_remove(List *list, const ListNode *node)

cdef extern from "proto/block.h":
    cdef struct prrtBlock:
        uint32_t data_count
        uint32_t redundancy_count
        PrrtCodingParams coding_params
        uint32_t largest_data_length
        uint16_t baseSequenceNumber
        List* data_blocks
        List* redundancy_blocks
        uint8_t is_coded

    ctypedef prrtBlock PrrtBlock

cdef extern from "proto/types/packet.h":
    cdef struct prrtPacket:
        uint8_t type_priority;
        uint8_t index;
        uint16_t sequenceNumber;
        void* payload;
        uint32_t payloadLength;

    ctypedef prrtPacket PrrtPacket

    ctypedef uint32_t prrtTimedelta_t;

cdef extern from "proto/receiver.h":
    ctypedef struct PrrtReceiver:
        const char* host_name
        uint16_t port

    PrrtReceiver* PrrtReceiver_create(const char *host, uint16_t port)
    bint PrrtReceiver_destroy(PrrtReceiver* receiver)


cdef extern from "proto/socket.h":
    cdef struct prrtSocket:
        int dataSocketFd
        int feedbackSocketFd
        pthread_t receiveFeedbackThread

        pthread_t sendDataThread
        pthread_mutex_t outQueueFilledMutex
        pthread_cond_t outQueueFilledCv
        MPSCQueue* sendDataQueue

        pthread_t receiveDataThread
        pthread_mutex_t inQueueFilledMutex
        pthread_cond_t inQueueFilledMutexCv
        PrrtPacketDeliveryStore *packetDeliveryStore

        BPTreeNode* dataStore

        PrrtReceiver* receiver

        uint16_t packetsCount
        uint16_t sequenceNumberSource
        uint16_t sequenceNumberRepetition
        uint16_t sequenceNumberRedundancy
        uint16_t sequenceNumberFeedback

    ctypedef prrtSocket PrrtSocket

    cdef PrrtSocket* PrrtSocket_create(bint isSender, const uint32_t target_delay)
    bint PrrtSocket_bind(PrrtSocket *sock_ptr, const_char *ipAddress, const uint16_t port)
    int PrrtSocket_close(const PrrtSocket *sock_ptr)
    int PrrtSocket_connect(PrrtSocket *sock_ptr, const_char *host, const uint16_t port)
    int PrrtSocket_send(PrrtSocket *sock_ptr, const uint8_t *data, const size_t data_len)

    int32_t PrrtSocket_recv(PrrtSocket *sock_ptr, void *buf_ptr) nogil
    int32_t PrrtSocket_receive_asap(PrrtSocket *s, void *buf_ptr) nogil
    int32_t PrrtSocket_receive_asap_wait(PrrtSocket *s, void *buf_ptr) nogil
    int32_t PrrtSocket_receive_asap_timedwait(PrrtSocket *s, void *buf_ptr, timespec* deadline) nogil

    int32_t PrrtSocket_receive_ordered(PrrtSocket *s, void *buf_ptr, prrtTimedelta_t time_window_us) nogil
    int32_t PrrtSocket_receive_ordered_wait(PrrtSocket *s, void *buf_ptr, prrtTimedelta_t time_window_us) nogil
    int32_t PrrtSocket_receive_ordered_timedwait(PrrtSocket *s, void *buf_ptr, prrtTimedelta_t time_window_us, timespec* deadline) nogil

    bint PrrtSocket_set_sock_opt(PrrtSocket *sock_ptr, const_char *name, const uint32_t value)
    uint32_t PrrtSocket_get_sock_opt(PrrtSocket *sock_ptr, const_char *name)
    bint PrrtSocket_set_coding_parameters(PrrtSocket *s, uint8_t k, uint8_t n)
    PrrtCodingParams *PrrtSocket_get_coding_parameters(PrrtSocket *s)
    bint PrrtSocket_uses_thread_pinning(PrrtSocket *socket)
    uint32_t PrrtSocket_get_rtprop(PrrtSocket *socket)

    bint PrrtSocket_uses_thread_pinning(PrrtSocket *socket)
    uint32_t PrrtSocket_get_rtt(PrrtSocket *socket)
    float PrrtSocket_get_plr(PrrtSocket *socket)
    uint32_t PrrtSocket_get_delivery_rate(PrrtSocket *socket)
    bint PrrtSocket_enable_thread_pinning(PrrtSocket *socket)

cdef extern from "proto/stores/packetDeliveryStore.h":
    ctypedef struct PrrtPacketDeliveryStore:
        pass

cdef extern from "util/bptree.h":
    ctypedef struct BPTreeNode:
        pass

    BPTreeNode *BPTree_insert(BPTreeNode *root, int key, void *value);
    BPTreeNode *BPTree_delete(BPTreeNode *root, int key);
    BPTreeNode *BPTree_destroy(BPTreeNode *root);
    void *BPTree_get(BPTreeNode *root, int key);
    void BPTree_get_range(BPTreeNode *root, List *list, int key_start, int key_end);


cdef extern from "util/pipe.h":
    ctypedef struct Pipe:
        pass

cdef extern from "util/mpsc_queue.h":
    ctypedef struct MPSCQueue:
        pass