aboutsummaryrefslogtreecommitdiff
path: root/src/plugins/Input/mplayer/decoder_mplayer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/plugins/Input/mplayer/decoder_mplayer.cpp')
-rw-r--r--src/plugins/Input/mplayer/decoder_mplayer.cpp207
1 files changed, 207 insertions, 0 deletions
diff --git a/src/plugins/Input/mplayer/decoder_mplayer.cpp b/src/plugins/Input/mplayer/decoder_mplayer.cpp
new file mode 100644
index 000000000..924b3c7ea
--- /dev/null
+++ b/src/plugins/Input/mplayer/decoder_mplayer.cpp
@@ -0,0 +1,207 @@
+/***************************************************************************
+ * Copyright (C) 2008 by Ilya Kotov *
+ * forkotov02@hotmail.ru *
+ * *
+ * This program is free software; you can redistribute it and/or modify *
+ * it under the terms of the GNU General Public License as published by *
+ * the Free Software Foundation; either version 2 of the License, or *
+ * (at your option) any later version. *
+ * *
+ * This program 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 General Public License for more details. *
+ * *
+ * You should have received a copy of the GNU General Public License *
+ * along with this program; if not, write to the *
+ * Free Software Foundation, Inc., *
+ * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
+ ***************************************************************************/
+
+#include <qmmp/constants.h>
+#include <qmmp/buffer.h>
+#include <qmmp/output.h>
+#include <qmmp/recycler.h>
+#include <qmmp/fileinfo.h>
+#include <qmmp/decoderfactory.h>
+
+#include <QObject>
+#include <QProcess>
+#include <QFile>
+#include <QApplication>
+#include <QAction>
+#include <QMetaObject>
+#include <QKeyEvent>
+#include <QMenu>
+#include <QRegExp>
+
+#include "decoder_mplayer.h"
+
+#define MPLAYER_DEBUG
+
+static QRegExp rx_av("^[AV]: *([0-9,:.-]+)");
+static QRegExp rx_pause("^(.*)=(.*)PAUSE(.*)");
+static QRegExp rx_end("^(.*)End of file(.*)");
+static QRegExp rx_quit("^(.*)Quit(.*)");
+static QRegExp rx_audio("^AUDIO: *([0-9,.]+) *Hz.*([0-9,.]+) *ch.*([0-9]+).* ([0-9,.]+) *kbit.*");
+
+
+FileInfo *MplayerInfo::createFileInfo(const QString &path)
+{
+ QRegExp rx_id_length("^ID_LENGTH=([0-9,.]+)*");
+ QStringList args;
+ args << "-slave";
+ args << "-identify";
+ args << "-frames";
+ args << "0";
+ args << "-vo";
+ args << "null";
+ args << "-ao";
+ args << "null";
+ args << path;
+ QProcess mplayer_process;
+ mplayer_process.start("mplayer", args);
+ mplayer_process.waitForFinished();
+ QString str = QString::fromLocal8Bit(mplayer_process.readAll()).trimmed();
+ FileInfo *info = new FileInfo(path);
+ QStringList lines = str.split("\n");
+ foreach(QString line, lines)
+ {
+ if (rx_id_length.indexIn(line) > -1)
+ info->setLength((qint64) rx_id_length.cap(1).toDouble());
+ }
+#ifdef MPLAYER_DEBUG
+ qDebug(qPrintable(str));
+#endif
+ return info;
+}
+
+QStringList MplayerInfo::filters()
+{
+ QStringList filters;
+ filters << "*.avi" << "*.mpg" << "*.mpeg" << "*.divx" << "*.qt" << "*.mov" << "*.wmv" << "*.asf";
+ return filters;
+}
+
+DecoderMplayer::DecoderMplayer(QObject *parent, DecoderFactory *d, const QString &url)
+ : Decoder(parent, d)
+{
+ m_url = url;
+ m_bitrate = 0;
+ m_samplerate = 0;
+ m_channels = 0;
+ m_bitsPerSample = 0;
+ m_length = 0;
+ m_currentTime = 0;
+ m_process = new QProcess(this);
+}
+
+DecoderMplayer::~DecoderMplayer()
+{
+ qDebug(__FUNCTION__);
+ m_process->close();
+}
+
+bool DecoderMplayer::initialize()
+{
+ FileInfo *info = MplayerInfo::createFileInfo(m_url);
+ m_length = info->length();
+ delete info;
+ m_args.clear();
+ m_args << "-slave";
+ m_args << m_url;
+ connect(m_process, SIGNAL(readyReadStandardOutput()), SLOT(readStdOut()));
+ return TRUE;
+}
+
+qint64 DecoderMplayer::lengthInSeconds()
+{
+ return m_length;
+}
+
+void DecoderMplayer::seek(qint64 pos)
+{
+ if (m_process->state() == QProcess::Running)
+ m_process->write(QString("seek %1 \n").arg(pos - m_currentTime).toLocal8Bit ());
+}
+
+void DecoderMplayer::stop()
+{
+ if (m_process->state() == QProcess::Running)
+ {
+ m_process->write("quit\n");
+ m_process->waitForFinished(200);
+ }
+ StateHandler::instance()->dispatch(Qmmp::Stopped);
+}
+
+void DecoderMplayer::pause()
+{
+ m_process->write("pause\n");
+}
+
+void DecoderMplayer::setEQ(double bands[10], double preamp)
+{
+}
+
+void DecoderMplayer::setEQEnabled(bool on)
+{
+}
+
+void DecoderMplayer::run()
+{
+ QMetaObject::invokeMethod(this, "startMplayerProcess");
+ StateHandler::instance()->dispatch(Qmmp::Playing);
+}
+
+void DecoderMplayer::readStdOut()
+{
+ QString line = QString::fromLocal8Bit(m_process->readAll ()).trimmed();
+ QStringList lines = line.split("\n");
+ foreach(line, lines)
+ {
+ if (rx_av.indexIn(line) > -1)
+ {
+ StateHandler::instance()->dispatch(Qmmp::Playing);
+ m_currentTime = (qint64) rx_av.cap(1).toDouble();
+ StateHandler::instance()->dispatch(m_currentTime,
+ m_length,
+ m_bitrate,
+ m_samplerate,
+ m_bitsPerSample,
+ m_channels);
+ }
+ else if (rx_pause.indexIn(line) > -1)
+ {
+ StateHandler::instance()->dispatch(Qmmp::Paused);
+ }
+ else if (rx_end.indexIn(line) > -1)
+ {
+ if (m_process->state() == QProcess::Running)
+ m_process->waitForFinished(500);
+ finish();
+ }
+ else if (rx_quit.indexIn(line) > -1)
+ {
+ if (m_process->state() == QProcess::Running)
+ m_process->waitForFinished(500);
+ StateHandler::instance()->dispatch(Qmmp::Stopped);
+ }
+ else if (rx_audio.indexIn(line) > -1)
+ {
+ m_samplerate = rx_audio.cap(1).toInt();
+ m_channels = rx_audio.cap(2).toInt();
+ m_bitsPerSample = rx_audio.cap(3).toDouble();
+ m_bitrate = rx_audio.cap(4).toDouble();
+ }
+#ifdef MPLAYER_DEBUG
+ else
+ qDebug(qPrintable(line));
+#endif
+ }
+}
+
+void DecoderMplayer::startMplayerProcess()
+{
+ m_process->start ("mplayer", m_args);
+}