blob: 632fefee1349174dab653edaf0c833f9c7955ace (
plain)
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/*
* udp_pes_scheduler.h: PES scheduler for UDP/RTP streams
*
* See the main source file 'xineliboutput.c' for copyright information and
* how to reach the author.
*
* $Id: udp_pes_scheduler.h,v 1.7 2006-12-30 00:36:05 phintuka Exp $
*
*/
#ifndef __UDP_PES_SCHEDULER_H
#define __UDP_PES_SCHEDULER_H
#include <stdint.h>
#include <vdr/tools.h> // uchar
#include <vdr/thread.h>
//----------------------- cTimePts ------------------------------------------
class cTimePts
{
private:
int64_t begin; /* Start time (PTS) */
struct timeval tbegin; /* Start time (real time) */
bool m_Paused;
int m_Multiplier;
bool m_Monotonic;
public:
cTimePts(void);
int64_t Now(void);
void Set(int64_t Pts = 0LL);
void Pause(void);
void Resume(void);
void TrickSpeed(int Multiplier);
};
//----------------------- cUdpPesScheduler ----------------------------------
#define MAX_UDP_HANDLES 16
class cUdpBackLog;
class cUdpScheduler : public cThread
{
public:
cUdpScheduler();
virtual ~cUdpScheduler();
// fd should be binded & connected to IP:PORT (local+remote) pair !
bool AddHandle(int fd); /* UDP unicast */
void RemoveHandle(int fd); /* UDP unicast */
bool AddRtp(void); /* UDP/RTP multicast */
void RemoveRtp(void); /* UDP/RTP multicast */
bool Poll(int TimeoutMs, bool Master);
bool Queue(uint64_t StreamPos, const uchar *Data, int Length);
void ReSend(int fd, uint64_t Pos, int Seq1, int Seq2);
void Clear(void);
bool Flush(int TimeoutMs);
void Pause(bool On);
void TrickSpeed(int Multiplier);
protected:
// Data for payload handling & buffering
// Signalling
cCondVar m_Cond;
cMutex m_Lock;
// Clients
int m_Handles[MAX_UDP_HANDLES];
int m_wmem[MAX_UDP_HANDLES]; /* kernel buffer size */
int m_fd_rtp;
int m_fd_rtcp;
// Queue
int m_QueueNextSeq; /* next outgoing */
int m_QueuePending; /* outgoing queue size */
cUdpBackLog *m_BackLog; /* queue for incoming data (not yet send) and retransmissions */
// Data for scheduling algorithm
cTimePts MasterClock; /* Current MPEG PTS (synchronized to current stream) */
cCondWait CondWait;
int64_t current_audio_vtime;
int64_t current_video_vtime;
// RTP
uint32_t m_ssrc; /* RTP synchronization source id */
cTimePts RtpScr; /* 90 kHz monotonic time source for RTP timestamps */
// RTCP
uint64_t m_LastRtcpTime;
uint32_t m_Frames;
uint32_t m_Octets;
// Scheduling
int64_t last_delay_time;
bool m_TrickSpeed;
bool m_Master; /* if true, we are master metronom for playback */
int calc_elapsed_vtime(int64_t pts, bool Audio);
void Schedule(const uchar *Data, int Length);
bool m_Running;
virtual void Action(void);
void Send_RTCP(void);
int m_fd_sap;
void Send_SAP(bool Announce = true);
};
#endif
|
