#ifndef _rtp_queue_h_
#define _rtp_queue_h_

#include "rtp-packet.h"

#if defined(__cplusplus)
extern "C" {
#endif

typedef struct rtp_queue_t rtp_queue_t;

rtp_queue_t *rtp_queue_create(int threshold, int frequency, void (*freepkt)(void *, struct rtp_packet_t *),
                              void *param);
int rtp_queue_destroy(rtp_queue_t *queue);

/// @return 1-ok, 0-discard, <0-error
int rtp_queue_write(rtp_queue_t *queue, struct rtp_packet_t *pkt);
struct rtp_packet_t *rtp_queue_read(rtp_queue_t *queue);

struct rtp_queue_stats_t {
    int total;

    int duplicate;
    int reorder; // misorder
    int late;    // two late
    int bad;     // bad seq

    int lost; // read discard by threshold
};
void rtp_queue_stats(rtp_queue_t *queue, struct rtp_queue_stats_t *stats);

#if defined(__cplusplus)
}
#endif
#endif /* !_rtp_queue_h_ */