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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/*
* dxr3syncbuffer.h
*
* Copyright (C) 2002-2004 Kai Möller
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*
*/
#ifndef _DXR3SYNCBUFFER_H_
#define _DXR3SYNCBUFFER_H_
#include <vdr/ringbuffer.h>
#include "dxr3interface.h"
#include "dxr3generaldefines.h"
#include "uncopyable.h"
#include "accessors.h"
// ==================================
const uint32_t UNKNOWN_CHANNEL_COUNT = 0xFFFFFFFF;
const uint32_t UNKNOWN_DATA_RATE = 0xFFFFFFFF;
const uint32_t UNKNOWN_ASPECT_RATIO = 0xFFFFFFFF;
// ==================================
class cFixedLengthFrame : private Uncopyable {
public:
cFixedLengthFrame() : samplerate(UNKNOWN_DATA_RATE), channels(UNKNOWN_CHANNEL_COUNT), aspectratio(UNKNOWN_ASPECT_RATIO),
m_count(0), m_length(0), m_pts(0), m_type(ftUnknown)
{}
~cFixedLengthFrame();
void Init(uint32_t lenght);
void CopyFrame(const uint8_t* pStart, int length, uint32_t pts,
eFrameType type);
uint8_t* GetData(void);
int GetCount(void);
uint32_t GetPts(void);
void SetPts(uint32_t pts);
eFrameType GetFrameType() { return m_type; }
Accessors<uint32_t> samplerate;
Accessors<uint32_t> channels;
Accessors<uint32_t> aspectratio;
private:
uint8_t* m_pData;
int m_count;
int m_length;
uint32_t m_pts;
eFrameType m_type;
};
// ==================================
class cDxr3SyncBuffer : public cRingBuffer, private Uncopyable {
public:
enum eSyncBufferException
{
SYNC_BUFFER_OVERRUN
};
public:
cDxr3SyncBuffer(int frameCount, int frameLength);
~cDxr3SyncBuffer();
virtual int Available(void);
cFixedLengthFrame* Push(const uint8_t* pStart, int length, uint32_t pts,
eFrameType type = ftUnknown)
throw (eSyncBufferException);
void Pop(void);
cFixedLengthFrame* Get(void);
void Clear(void);
void Stop(void)
{
m_bStopped = true;
};
void Start(void);
void WakeUp(void);
void WaitForReceiverStopped(void);
void SetDemuxMode(eDxr3DemuxMode demuxMode)
{
m_demuxMode = demuxMode;
};
bool Poll(int TimeoutMs);
bool IsPolled(void)
{
return m_bPollSync;
};
uint32_t GetFillLevel(void)
{
return Available() * 100 / Size();
};
private:
void ReceiverStopped(void);
cFixedLengthFrame* m_pBuffer;
int m_count;
int m_nextFree;
int m_next;
bool m_bPutBlock;
bool m_bGetBlock;
bool m_bStartReceiver;
bool m_bStopped;
eDxr3DemuxMode m_demuxMode;
cCondVar receiverStopped;
cMutex receiverStoppedMutex;
cDxr3Interface *m_dxr3Device;
bool m_bPollSync;
cDxr3SyncBuffer(); // you are not allowed to use this constructor
};
#endif /*_DXR3SYNCBUFFER_H_*/
// Local variables:
// mode: c++
// c-file-style: "stroustrup"
// c-file-offsets: ((inline-open . 0))
// tab-width: 4;
// indent-tabs-mode: nil
// End:
|
