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
139
140
141
142
143
144
|
/*
* Copyright (C) 2005-2018 Team Kodi
* This file is part of Kodi - https://kodi.tv
*
* SPDX-License-Identifier: GPL-2.0-or-later
* See LICENSES/README.md for more information.
*/
#pragma once
#include "DVDMessageQueue.h"
#include "IVideoPlayer.h"
#include "threads/Thread.h"
#include "utils/Stopwatch.h"
#include <memory>
class CDVDStreamInfo;
namespace PVR
{
class CPVRChannel;
class CPVRRadioRDSInfoTag;
}
/// --- CDVDRadioRDSData ------------------------------------------------------------
#define UECP_DATA_START 0xFE /*!< A data record starts with the start byte */
#define UECP_DATA_STOP 0xFF /*!< A data record stops with the stop byte */
#define UECP_SIZE_MAX 263 /*!< The Max possible size of a UECP packet
max. 255(MSG)+4(ADD/SQC/MFL)+2(CRC)+2(Start/Stop) of RDS-data */
#define RT_MEL 65
#define MAX_RTPC 50
class CDVDRadioRDSData : public CThread, public IDVDStreamPlayer
{
public:
explicit CDVDRadioRDSData(CProcessInfo &processInfo);
~CDVDRadioRDSData() override;
bool CheckStream(const CDVDStreamInfo& hints);
bool OpenStream(CDVDStreamInfo hints) override;
void CloseStream(bool bWaitForBuffers) override;
void Flush();
// waits until all available data has been rendered
void WaitForBuffers() { m_messageQueue.WaitUntilEmpty(); }
bool AcceptsData() const override { return !m_messageQueue.IsFull(); }
void SendMessage(std::shared_ptr<CDVDMsg> pMsg, int priority = 0) override
{
if (m_messageQueue.IsInited())
m_messageQueue.Put(pMsg, priority);
}
void FlushMessages() override { m_messageQueue.Flush(); }
bool IsInited() const override { return true; }
bool IsStalled() const override { return true; }
protected:
void OnExit() override;
void Process() override;
private:
void ResetRDSCache();
void ProcessUECP(const unsigned char *Data, unsigned int Length);
inline unsigned int DecodePI(const uint8_t* msgElement);
inline unsigned int DecodePS(uint8_t *msgElement);
inline unsigned int DecodeDI(const uint8_t* msgElement);
inline unsigned int DecodeTA_TP(const uint8_t* msgElement);
inline unsigned int DecodeMS(const uint8_t* msgElement);
inline unsigned int DecodePTY(const uint8_t* msgElement);
inline unsigned int DecodePTYN(uint8_t *msgElement);
inline unsigned int DecodeRT(uint8_t *msgElement, unsigned int len);
inline unsigned int DecodeRTC(uint8_t *msgElement);
inline unsigned int DecodeODA(uint8_t *msgElement, unsigned int len);
inline unsigned int DecodeRTPlus(uint8_t *msgElement, unsigned int len);
inline unsigned int DecodeTMC(uint8_t *msgElement, unsigned int len);
inline unsigned int DecodeEPPTransmitterInfo(const uint8_t* msgElement);
inline unsigned int DecodeSlowLabelingCodes(const uint8_t* msgElement);
inline unsigned int DecodeDABDynLabelCmd(const uint8_t* msgElement, unsigned int len);
inline unsigned int DecodeDABDynLabelMsg(const uint8_t* msgElement, unsigned int len);
inline unsigned int DecodeAF(uint8_t *msgElement, unsigned int len);
inline unsigned int DecodeEonAF(uint8_t *msgElement, unsigned int len);
inline unsigned int DecodeTDC(uint8_t *msgElement, unsigned int len);
void SendTMCSignal(unsigned int flags, uint8_t *data);
void SetRadioStyle(const std::string& genre);
std::shared_ptr<PVR::CPVRRadioRDSInfoTag> m_currentInfoTag;
std::shared_ptr<PVR::CPVRChannel> m_currentChannel;
bool m_currentFileUpdate;
int m_speed;
CCriticalSection m_critSection;
CDVDMessageQueue m_messageQueue;
uint8_t m_UECPData[UECP_SIZE_MAX+1];
unsigned int m_UECPDataIndex;
bool m_UECPDataStart;
bool m_UECPDatabStuff;
bool m_UECPDataDeadBreak;
bool m_RDS_IsRBDS;
bool m_RDS_SlowLabelingCodesPresent;
uint16_t m_PI_Current;
unsigned int m_PI_CountryCode;
unsigned int m_PI_ProgramType;
unsigned int m_PI_ProgramReferenceNumber;
unsigned int m_EPP_TM_INFO_ExtendedCountryCode;
bool m_DI_IsStereo;
bool m_DI_ArtificialHead;
bool m_DI_Compressed;
bool m_DI_DynamicPTY;
bool m_TA_TP_TrafficAdvisory;
float m_TA_TP_TrafficVolume;
bool m_MS_SpeechActive;
int m_PTY;
char m_PTYN[9];
bool m_PTYN_Present;
bool m_RT_NewItem;
uint8_t m_RTPlus_WorkText[RT_MEL+1];
bool m_RTPlus_TToggle;
int m_RTPlus_iDiffs;
CStopWatch m_RTPlus_iTime;
bool m_RTPlus_GenrePresent;
char m_RTPlus_Temptext[RT_MEL];
bool m_RTPlus_Show;
char m_RTPlus_Title[RT_MEL];
char m_RTPlus_Artist[RT_MEL];
int m_RTPlus_iToggle;
unsigned int m_RTPlus_ItemToggle;
time_t m_RTPlus_Starttime;
CDateTime m_RTC_DateTime; ///< From RDS transmitted date / time data
uint8_t m_TMC_LastData[5];
};
|
