_seap-packetq.h

#ifndef _SEAP_PACKETQ_H
#define _SEAP_PACKETQ_H

#include <stdint.h>
#include <pthread.h>
#include "_seap-packet.h"

struct SEAP_packetq_item {
        struct SEAP_packetq_item *next;
        struct SEAP_packetq_item *prev;
        SEAP_packet_t            *packet;
};

#define SEAP_PACKETQ_DONTFREE 0x00000001

typedef struct {
        pthread_mutex_t lock;
        uint32_t        flags;
        int             count;

        struct SEAP_packetq_item *first;
        struct SEAP_packetq_item *last;
} SEAP_packetq_t;

int  SEAP_packetq_init(SEAP_packetq_t *queue);
void SEAP_packetq_free(SEAP_packetq_t *queue);

struct SEAP_packetq_item *SEAP_packetq_item_new(void);
void SEAP_packetq_item_free(struct SEAP_packetq_item *i, bool freepacket);

int  SEAP_packetq_get(SEAP_packetq_t *queue, SEAP_packet_t **packet_dst);
int  SEAP_packetq_put(SEAP_packetq_t *queue, SEAP_packet_t *packet);

int SEAP_packetq_count(SEAP_packetq_t *queue);

#endif /* _SEAP_PACKETQ_H */