File: JitterBuffer.h

package info (click to toggle)
libtgvoip 2.4.2-1
  • links: PTS, VCS
  • area: main
  • in suites: buster, sid
  • size: 9,004 kB
  • sloc: cpp: 61,331; ansic: 24,725; sh: 4,150; makefile: 749; asm: 242
file content (97 lines) | stat: -rw-r--r-- 2,659 bytes parent folder | download
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
//
// libtgvoip is free and unencumbered public domain software.
// For more information, see http://unlicense.org or the UNLICENSE file
// you should have received with this source code distribution.
//

#ifndef LIBTGVOIP_JITTERBUFFER_H
#define LIBTGVOIP_JITTERBUFFER_H

#include <stdlib.h>
#include <vector>
#include <stdio.h>
#include "MediaStreamItf.h"
#include "BlockingQueue.h"
#include "Buffers.h"
#include "threading.h"

#define JITTER_SLOT_COUNT 64
#define JITTER_SLOT_SIZE 1024
#define JR_OK 1
#define JR_MISSING 2
#define JR_BUFFERING 3


namespace tgvoip{
class JitterBuffer{
public:
	JitterBuffer(MediaStreamItf* out, uint32_t step);
	~JitterBuffer();
	void SetMinPacketCount(uint32_t count);
	int GetMinPacketCount();
	unsigned int GetCurrentDelay();
	double GetAverageDelay();
	void Reset();
	void HandleInput(unsigned char* data, size_t len, uint32_t timestamp, bool isEC);
	size_t HandleOutput(unsigned char* buffer, size_t len, int offsetInSteps, bool advance, int& playbackScaledDuration, bool& isEC);
	void Tick();
	void GetAverageLateCount(double* out);
	int GetAndResetLostPacketCount();
	double GetLastMeasuredJitter();
	double GetLastMeasuredDelay();

private:
	struct jitter_packet_t{
		unsigned char* buffer=NULL;
		size_t size;
		uint32_t timestamp;
		bool isEC;
		double recvTimeDiff;
	};
	static size_t CallbackIn(unsigned char* data, size_t len, void* param);
	static size_t CallbackOut(unsigned char* data, size_t len, void* param);
	void PutInternal(jitter_packet_t* pkt, bool overwriteExisting);
	int GetInternal(jitter_packet_t* pkt, int offset, bool advance);
	void Advance();

	BufferPool bufferPool;
	Mutex mutex;
	jitter_packet_t slots[JITTER_SLOT_COUNT];
	int64_t nextTimestamp=0;
	uint32_t step;
	double minDelay=6;
	uint32_t minMinDelay;
	uint32_t maxMinDelay;
	uint32_t maxUsedSlots;
	uint32_t lastPutTimestamp;
	uint32_t lossesToReset;
	double resyncThreshold;
	unsigned int lostCount=0;
	unsigned int lostSinceReset=0;
	unsigned int gotSinceReset=0;
	bool wasReset=true;
	bool needBuffering=true;
	HistoricBuffer<int, 64, double> delayHistory;
	HistoricBuffer<int, 64, double> lateHistory;
	bool adjustingDelay=false;
	unsigned int tickCount=0;
	unsigned int latePacketCount=0;
	unsigned int dontIncMinDelay=0;
	unsigned int dontDecMinDelay=0;
	int lostPackets=0;
	double prevRecvTime=0;
	double expectNextAtTime=0;
	HistoricBuffer<double, 64> deviationHistory;
	double lastMeasuredJitter=0;
	double lastMeasuredDelay=0;
	int outstandingDelayChange=0;
	unsigned int dontChangeDelay=0;
	double avgDelay=0;
	bool first=true;
#ifdef TGVOIP_DUMP_JITTER_STATS
	FILE* dump;
#endif
};
}

#endif //LIBTGVOIP_JITTERBUFFER_H