scream/code/NetQueue.h at 246b900979f1816c6f4551c81a9f87750b468919 · qvest-digital/scream · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
#ifndef NET_QUEUE
#define NET_QUEUE

class NetQueueItem {
public:
    NetQueueItem();
    void* packet;
    unsigned int ssrc;
    int size;
    unsigned short seqNr;
    float tRelease;
    float tQueue;
    bool isCe;
    bool used;
};
const int NetQueueSize = 10000;
class NetQueue {
public:

    NetQueue(float delay, float rate=0.0f, float jitter=0.0f, bool isL4s = false);

    void insert(float time,
        void *rtpPacket,
        unsigned int ssrc,
        int size,
        unsigned short seqNr,
        bool isCe = false);
    bool extract(float time,
        void *rtpPacket,
        unsigned int &ssrc,
        int& size,
        unsigned short &seqNr,
        bool &isCe);
    int sizeOfQueue();

    void updateRate(float time);

    NetQueueItem *items[NetQueueSize];
    int head; // Pointer to last inserted item
    int tail; // Pointer to the oldest item
    int nItems;
    float delay;
    float rate;
    float jitter;
    float nextTx;
    float lastQueueLow;
    bool isL4s;
    int bytesTx;
    float lastRateUpdateT;
    float pDrop;
    float prevRateFrac;
    float l4sTh;
	float tQueueAvg;
};

#endif