MythTV  master
decoderhandler.cpp
Go to the documentation of this file.
1 // c/c++
2 #include <cassert>
3 #include <cstdio>
4 #include <unistd.h>
5 
6 // qt
7 #include <QApplication>
8 #include <QFileInfo>
9 #include <QUrl>
10 
11 // MythTV
12 #include <libmythbase/mythdirs.h>
15 #include <libmythbase/mythrandom.h>
16 #include <libmythbase/remotefile.h>
18 
19 // mythmusic
20 #include "decoder.h"
21 #include "decoderhandler.h"
22 
23 /**********************************************************************/
24 
25 const QEvent::Type DecoderHandlerEvent::kReady = (QEvent::Type) QEvent::registerEventType();
26 const QEvent::Type DecoderHandlerEvent::kMeta = (QEvent::Type) QEvent::registerEventType();
27 const QEvent::Type DecoderHandlerEvent::kBufferStatus = (QEvent::Type) QEvent::registerEventType();
28 const QEvent::Type DecoderHandlerEvent::kOperationStart = (QEvent::Type) QEvent::registerEventType();
29 const QEvent::Type DecoderHandlerEvent::kOperationStop = (QEvent::Type) QEvent::registerEventType();
30 const QEvent::Type DecoderHandlerEvent::kError = (QEvent::Type) QEvent::registerEventType();
31 
33  : MythEvent(type),
34  m_meta(new MusicMetadata(meta))
35 {
36 }
37 
39 {
40  delete m_msg;
41  delete m_meta;
42 }
43 
45 {
46  auto *result = new DecoderHandlerEvent(*this);
47 
48  if (m_msg)
49  result->m_msg = new QString(*m_msg);
50 
51  if (m_meta)
52  result->m_meta = new MusicMetadata(*m_meta);
53 
54  result->m_available = m_available;
55  result->m_maxSize = m_maxSize;
56 
57  return result;
58 }
59 
60 void DecoderHandlerEvent::getBufferStatus(int *available, int *maxSize) const
61 {
62  *available = m_available;
63  *maxSize = m_maxSize;
64 }
65 
66 /**********************************************************************/
67 
69 {
70  stop();
71 }
72 
74 {
75  m_state = LOADING;
76 
77  m_playlist.clear();
78  m_meta = *mdata;
79  m_playlistPos = -1;
80  m_redirects = 0;
81 
82  if (QFileInfo(mdata->Filename()).isAbsolute())
83  m_url = QUrl::fromLocalFile(mdata->Filename());
84  else
85  m_url.setUrl(mdata->Filename());
86 
88 }
89 
90 void DecoderHandler::doStart(bool result)
91 {
93 
94  if (QFileInfo(m_meta.Filename()).isAbsolute())
95  m_url = QUrl::fromLocalFile(m_meta.Filename());
96  else
97  m_url.setUrl(m_meta.Filename());
98 
99  if (m_state == LOADING && result)
100  {
101  for (int ii = 0; ii < m_playlist.size(); ii++)
102  {
104  LOG(VB_PLAYBACK, LOG_INFO, QString("Track %1 = %2")
105  .arg(ii) .arg(file ? file->File() : "<invalid>"));
106  }
107  next();
108  }
109  else
110  {
111  if (m_state == STOPPED)
112  {
113  doFailed(m_url, "Could not get playlist");
114  }
115  }
116 }
117 
118 void DecoderHandler::error(const QString &e)
119 {
120  auto *str = new QString(e);
122  dispatch(ev);
123 }
124 
126 {
127  if (m_state == STOPPED)
128  return true;
129 
130  if (m_playlistPos + 1 >= m_playlist.size())
131  {
132  m_state = STOPPED;
133  return true;
134  }
135 
136  return false;
137 }
138 
140 {
141  if (done())
142  return false;
143 
144  if (m_meta.Format() == "cast")
145  {
147  }
148  else
149  {
150  m_playlistPos++;
151  }
152 
154  if (nullptr == entry)
155  return false;
156 
157  if (QFileInfo(entry->File()).isAbsolute())
158  m_url = QUrl::fromLocalFile(entry->File());
159  else
160  m_url.setUrl(entry->File());
161 
162  LOG(VB_PLAYBACK, LOG_INFO, QString("Now playing '%1'").arg(m_url.toString()));
163 
164  // we use the avfdecoder for everything except CD tracks
165  if (m_url.toString().endsWith(".cda"))
166  doConnectDecoder(m_url, ".cda");
167  else
168  {
169  // we don't know what format radio stations are so fake a format
170  // and hope avfdecoder can decode it
171  doConnectDecoder(m_url, ".mp3");
172  }
173 
174  m_state = ACTIVE;
175 
176  return true;
177 }
178 
180 {
181  LOG(VB_PLAYBACK, LOG_INFO, QString("DecoderHandler: Stopping decoder"));
182 
183  if (m_decoder && m_decoder->isRunning())
184  {
185  m_decoder->lock();
186  m_decoder->stop();
187  m_decoder->unlock();
188  }
189 
190  if (m_decoder)
191  {
192  m_decoder->lock();
193  m_decoder->cond()->wakeAll();
194  m_decoder->unlock();
195  }
196 
197  if (m_decoder)
198  {
199  m_decoder->wait();
200  delete m_decoder;
201  m_decoder = nullptr;
202  }
203 
204  doOperationStop();
205 
206  m_state = STOPPED;
207 }
208 
209 void DecoderHandler::customEvent(QEvent *event)
210 {
211  if (event == nullptr)
212  return;
213 
214  if (auto *dhe = dynamic_cast<DecoderHandlerEvent*>(event))
215  {
216  // Proxy all DecoderHandlerEvents
217  dispatch(*dhe);
218  return;
219  }
220  if (event->type() == MythEvent::kMythEventMessage)
221  {
222  auto *me = dynamic_cast<MythEvent *>(event);
223  if (me == nullptr)
224  return;
225  QStringList tokens = me->Message().split(" ", Qt::SkipEmptyParts);
226 
227  if (tokens.isEmpty())
228  return;
229 
230  if (tokens[0] == "DOWNLOAD_FILE")
231  {
232  QStringList args = me->ExtraDataList();
233 
234  if (tokens[1] == "UPDATE")
235  {
236  }
237  else if (tokens[1] == "FINISHED")
238  {
239  const QString& downloadUrl = args[0];
240  int fileSize = args[2].toInt();
241  int errorCode = args[4].toInt();
242  const QString& filename = args[1];
243 
244  if ((errorCode != 0) || (fileSize == 0))
245  {
246  LOG(VB_GENERAL, LOG_ERR, QString("DecoderHandler: failed to download playlist from '%1'")
247  .arg(downloadUrl));
248  QUrl url(downloadUrl);
249  m_state = STOPPED;
250  doOperationStop();
251  doFailed(url, "Could not get playlist");
252  }
253  else
254  {
255  QUrl fileUrl = QUrl::fromLocalFile(filename);
256  createPlaylistFromFile(fileUrl);
257  }
258  }
259  }
260  }
261 }
262 
263 void DecoderHandler::createPlaylist(const QUrl &url)
264 {
265  QString extension = QFileInfo(url.path()).suffix();
266  LOG(VB_NETWORK, LOG_INFO,
267  QString("File %1 has extension %2")
268  .arg(QFileInfo(url.path()).fileName(), extension));
269 
270  if (extension == "pls" || extension == "m3u" || extension == "asx")
271  {
272  if (url.scheme() == "file" || QFileInfo(url.toString()).isAbsolute())
274  else
276 
277  return;
278  }
279 
281 }
282 
284 {
285  auto *entry = new PlayListFileEntry;
286 
287  if (url.scheme() == "file" || QFileInfo(url.toString()).isAbsolute())
288  entry->setFile(url.toLocalFile());
289  else
290  entry->setFile(url.toString());
291 
292  m_playlist.add(entry);
293 
294  doStart((m_playlist.size() > 0));
295 }
296 
298 {
299  QString file = url.toLocalFile();
300 
302 
303  doStart((m_playlist.size() > 0));
304 }
305 
307 {
308  LOG(VB_NETWORK, LOG_INFO,
309  QString("Retrieving playlist from '%1'").arg(url.toString()));
310 
311  doOperationStart(tr("Retrieving playlist"));
312 
313  QString extension = QFileInfo(url.path()).suffix().toLower();
314  QString saveFilename = GetConfDir() + "/MythMusic/playlist." + extension;
315  GetMythDownloadManager()->queueDownload(url.toString(), saveFilename, this);
316 
317  //TODO should find a better way to do this
318  QElapsedTimer time;
319  time.start();
320  while (m_state == LOADING)
321  {
322  if (time.hasExpired(30000))
323  {
324  doOperationStop();
325  GetMythDownloadManager()->cancelDownload(url.toString());
326  LOG(VB_GENERAL, LOG_ERR, QString("DecoderHandler:: Timed out trying to download playlist from: %1")
327  .arg(url.toString()));
328  m_state = STOPPED;
329  }
330 
331  QCoreApplication::processEvents();
332  usleep(500);
333  }
334 }
335 
336 void DecoderHandler::doConnectDecoder(const QUrl &url, const QString &format)
337 {
338  if (m_decoder && !m_decoder->factory()->supports(format))
339  {
340  delete m_decoder;
341  m_decoder = nullptr;
342  }
343 
344  if (!m_decoder)
345  {
346  m_decoder = Decoder::create(format, nullptr, true);
347  if (m_decoder == nullptr)
348  {
349  doFailed(url, QString("No decoder for this format '%1'").arg(format));
350  return;
351  }
352  }
353 
354  m_decoder->setURL(url.toString());
355 
357  dispatch(ev);
358 }
359 
360 void DecoderHandler::doFailed(const QUrl &url, const QString &message)
361 {
362  LOG(VB_NETWORK, LOG_ERR,
363  QString("DecoderHandler error: '%1' - %2").arg(message, url.toString()));
364  DecoderHandlerEvent ev(DecoderHandlerEvent::kError, new QString(message));
365  dispatch(ev);
366 }
367 
368 void DecoderHandler::doOperationStart(const QString &name)
369 {
370  m_op = true;
372  dispatch(ev);
373 }
374 
376 {
377  if (!m_op)
378  return;
379 
380  m_op = false;
382  dispatch(ev);
383 }
build_compdb.args
args
Definition: build_compdb.py:11
DecoderFactory::supports
virtual bool supports(const QString &source) const =0
MusicMetadata::Filename
QString Filename(bool find=true)
Definition: musicmetadata.cpp:977
DecoderHandler::m_url
QUrl m_url
Definition: decoderhandler.h:125
MythEvent::kMythEventMessage
static const Type kMythEventMessage
Definition: mythevent.h:79
DecoderHandler::doConnectDecoder
void doConnectDecoder(const QUrl &url, const QString &format)
Definition: decoderhandler.cpp:336
Decoder::factory
DecoderFactory * factory() const
Definition: decoder.h:79
mythrandom.h
DecoderHandlerEvent::m_available
int m_available
Definition: decoderhandler.h:64
decoderhandler.h
MThread::wait
bool wait(std::chrono::milliseconds time=std::chrono::milliseconds::max())
Wait for the MThread to exit, with a maximum timeout.
Definition: mthread.cpp:300
DecoderHandlerEvent::clone
MythEvent * clone(void) const override
Definition: decoderhandler.cpp:44
PlayListFile::get
PlayListFileEntry * get(int i)
Get a file entry.
Definition: pls.h:60
PlayListFileEntry::File
QString File(void)
Definition: pls.h:25
MythEvent
This class is used as a container for messages.
Definition: mythevent.h:16
MythDownloadManager::queueDownload
void queueDownload(const QString &url, const QString &dest, QObject *caller, bool reload=false)
Adds a url to the download queue.
Definition: mythdownloadmanager.cpp:394
LOG
#define LOG(_MASK_, _LEVEL_, _QSTRING_)
Definition: mythlogging.h:39
MusicMetadata
Definition: musicmetadata.h:80
build_compdb.file
file
Definition: build_compdb.py:55
mythdirs.h
MythObservable::dispatch
void dispatch(const MythEvent &event)
Dispatch an event to all listeners.
Definition: mythobservable.cpp:73
DecoderHandlerEvent::~DecoderHandlerEvent
~DecoderHandlerEvent() override
Definition: decoderhandler.cpp:38
DecoderHandler::m_playlistPos
int m_playlistPos
Definition: decoderhandler.h:121
DecoderHandler::next
bool next(void)
Definition: decoderhandler.cpp:139
DecoderHandler::LOADING
@ LOADING
Definition: decoderhandler.h:85
Decoder::cond
QWaitCondition * cond()
Definition: decoder.h:89
DecoderHandlerEvent::m_meta
MusicMetadata * m_meta
Definition: decoderhandler.h:63
MythEvent::Message
const QString & Message() const
Definition: mythevent.h:65
DecoderHandlerEvent::m_msg
QString * m_msg
Definition: decoderhandler.h:62
DecoderHandler::error
void error(const QString &e)
Definition: decoderhandler.cpp:118
PlayListFileEntry
Class for representing entries in a pls file.
Definition: pls.h:19
DecoderHandlerEvent
Events sent by the DecoderHandler and it's helper classes.
Definition: decoderhandler.h:25
mythlogging.h
DecoderHandlerEvent::getBufferStatus
void getBufferStatus(int *available, int *maxSize) const
Definition: decoderhandler.cpp:60
Decoder::create
static Decoder * create(const QString &source, AudioOutput *output, bool deletable=false)
Definition: decoder.cpp:98
GetConfDir
QString GetConfDir(void)
Definition: mythdirs.cpp:263
Decoder::unlock
virtual void unlock(void)
Definition: decoder.h:86
remotefile.h
PlayListFile::parse
static int parse(PlayListFile *pls, const QString &filename)
Parse a pls, m3u or asx playlist file.
Definition: pls.cpp:34
DecoderHandler::ACTIVE
@ ACTIVE
Definition: decoderhandler.h:84
DecoderHandlerEvent::kOperationStart
static const Type kOperationStart
Definition: decoderhandler.h:49
DecoderHandler::m_meta
MusicMetadata m_meta
Definition: decoderhandler.h:124
DecoderHandler::createPlaylistForSingleFile
void createPlaylistForSingleFile(const QUrl &url)
Definition: decoderhandler.cpp:283
Decoder::stop
virtual void stop()=0
PlayListFileEntry::setFile
void setFile(const QString &f)
Definition: pls.h:29
DecoderHandler::createPlaylist
void createPlaylist(const QUrl &url)
Definition: decoderhandler.cpp:263
DecoderHandler::m_decoder
Decoder * m_decoder
Definition: decoderhandler.h:123
MythDownloadManager::cancelDownload
void cancelDownload(const QString &url, bool block=true)
Cancel a queued or current download.
Definition: mythdownloadmanager.cpp:1018
DecoderHandler::customEvent
void customEvent(QEvent *e) override
Definition: decoderhandler.cpp:209
DecoderHandlerEvent::kOperationStop
static const Type kOperationStop
Definition: decoderhandler.h:50
DecoderHandlerEvent::kMeta
static const Type kMeta
Definition: decoderhandler.h:47
PlayListFile::size
int size(void) const
Get the number of entries in the pls file.
Definition: pls.h:54
PlayListFile::clear
void clear(void)
Clear out all the entries.
Definition: pls.h:83
DecoderHandler::m_state
int m_state
Definition: decoderhandler.h:120
Decoder::setURL
void setURL(const QString &url)
Definition: decoder.h:83
DecoderHandlerEvent::DecoderHandlerEvent
DecoderHandlerEvent(Type type)
Definition: decoderhandler.h:28
DecoderHandler::start
void start(MusicMetadata *mdata)
Definition: decoderhandler.cpp:73
DecoderHandler::doOperationStop
void doOperationStop(void)
Definition: decoderhandler.cpp:375
DecoderHandler::done
bool done(void)
Definition: decoderhandler.cpp:125
DecoderHandler::m_op
bool m_op
Definition: decoderhandler.h:126
DecoderHandler::~DecoderHandler
~DecoderHandler(void) override
Definition: decoderhandler.cpp:68
DecoderHandler::STOPPED
@ STOPPED
Definition: decoderhandler.h:86
DecoderHandler::doStart
void doStart(bool result)
Definition: decoderhandler.cpp:90
MusicMetadata::Format
QString Format() const
Definition: musicmetadata.h:235
DecoderHandler::doFailed
void doFailed(const QUrl &url, const QString &message)
Definition: decoderhandler.cpp:360
DecoderHandlerEvent::kError
static const Type kError
Definition: decoderhandler.h:51
DecoderHandler::m_redirects
uint m_redirects
Definition: decoderhandler.h:127
DecoderHandlerEvent::kBufferStatus
static const Type kBufferStatus
Definition: decoderhandler.h:48
DecoderHandlerEvent::kReady
static const Type kReady
Definition: decoderhandler.h:46
DecoderHandler::createPlaylistFromRemoteUrl
void createPlaylistFromRemoteUrl(const QUrl &url)
Definition: decoderhandler.cpp:306
MThread::isRunning
bool isRunning(void) const
Definition: mthread.cpp:263
DecoderHandlerEvent::m_maxSize
int m_maxSize
Definition: decoderhandler.h:65
DecoderHandler::stop
void stop(void)
Definition: decoderhandler.cpp:179
Decoder::lock
virtual void lock(void)
Definition: decoder.h:85
PlayListFile::add
void add(PlayListFileEntry *e)
Add a entry to the playlist.
Definition: pls.h:80
DecoderHandler::m_playlist
PlayListFile m_playlist
Definition: decoderhandler.h:122
mythdownloadmanager.h
build_compdb.filename
filename
Definition: build_compdb.py:21
DecoderHandler::doOperationStart
void doOperationStart(const QString &name)
Definition: decoderhandler.cpp:368
DecoderHandler::createPlaylistFromFile
void createPlaylistFromFile(const QUrl &url)
Definition: decoderhandler.cpp:297
MythRandomStd::MythRandom
uint32_t MythRandom()
generate 32 random bits
Definition: mythrandom.h:20
musicmetadata.h
decoder.h
GetMythDownloadManager
MythDownloadManager * GetMythDownloadManager(void)
Gets the pointer to the MythDownloadManager singleton.
Definition: mythdownloadmanager.cpp:146