#pragma once

#include <pthread.h>
#include <stdint.h>
#include <stdbool.h>

#define QUEUE_SIZE 256
#define PACKET_MAX_SIZE 2048

typedef struct {
    uint8_t data[QUEUE_SIZE][PACKET_MAX_SIZE];
    int size[QUEUE_SIZE];
    int head;
    int tail;
    pthread_mutex_t lock;
} PacketQueue;

void QueueInit(PacketQueue *q);
void QueuePush(PacketQueue *q, void *data, int size);
bool QueuePop(PacketQueue *q, void *data, int *size);