1 files changed, 256 insertions, 0 deletions
diff --git a/src/3rdparty/phonon/gstreamer/audiooutput.cpp b/src/3rdparty/phonon/gstreamer/audiooutput.cpp
new file mode 100644
index 0000000..f3137b2
--- /dev/null
+++ b/src/3rdparty/phonon/gstreamer/audiooutput.cpp
@@ -0,0 +1,256 @@
+/*  This file is part of the KDE project.
+
+    Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies).
+    Copyright (C) 2008 Matthias Kretz <kretz@kde.org>
+
+    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 or 3 of the License.
+
+    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, see <http://www.gnu.org/licenses/>.
+*/
+
+#include "common.h"
+#include "audiooutput.h"
+#include "backend.h"
+#include "mediaobject.h"
+#include "gsthelper.h"
+#include <phonon/audiooutput.h>
+
+QT_BEGIN_NAMESPACE
+
+namespace Phonon
+{
+namespace Gstreamer
+{
+AudioOutput::AudioOutput(Backend *backend, QObject *parent)
+        : QObject(parent)
+        , MediaNode(backend, AudioSink)
+        , m_volumeLevel(1.0)
+        , m_device(0) // ### get from backend
+        , m_volumeElement(0)
+        , m_audioBin(0)
+        , m_audioSink(0)
+        , m_conv(0)
+{
+    static int count = 0;
+    m_name = "AudioOutput" + QString::number(count++);
+    if (m_backend->isValid()) {
+        m_audioBin = gst_bin_new (NULL);
+        gst_object_ref (GST_OBJECT (m_audioBin));
+        gst_object_sink (GST_OBJECT (m_audioBin));     
+
+        m_conv = gst_element_factory_make ("audioconvert", NULL);
+
+        // Get category from parent
+        Phonon::Category category = Phonon::NoCategory;
+        if (Phonon::AudioOutput *audioOutput = qobject_cast<Phonon::AudioOutput *>(parent))
+            category = audioOutput->category();
+    
+        m_audioSink = m_backend->deviceManager()->createAudioSink(category);
+        m_volumeElement = gst_element_factory_make ("volume", NULL);
+        GstElement *queue = gst_element_factory_make ("queue", NULL);
+        GstElement *audioresample = gst_element_factory_make ("audioresample", NULL);
+    
+        if (queue && m_audioBin && m_conv && audioresample && m_audioSink && m_volumeElement) {
+            gst_bin_add_many (GST_BIN (m_audioBin), queue, m_conv, audioresample, m_volumeElement, m_audioSink, (const char*)NULL);
+    
+            if (gst_element_link_many (queue, m_conv, audioresample, m_volumeElement, m_audioSink, (const char*)NULL)) {
+                // Add ghost sink for audiobin
+                GstPad *audiopad = gst_element_get_pad (queue, "sink");
+                gst_element_add_pad (m_audioBin, gst_ghost_pad_new ("sink", audiopad));
+                gst_object_unref (audiopad);
+                m_isValid = true; // Initialization ok, accept input
+            }
+        }
+    }
+}
+
+void AudioOutput::mediaNodeEvent(const MediaNodeEvent *event)
+{
+    if (!m_audioBin)
+        return;
+
+    switch (event->type()) {
+
+    default:
+        break;
+    }
+}
+
+
+AudioOutput::~AudioOutput()
+{
+    if (m_audioBin) {
+        gst_element_set_state (m_audioBin, GST_STATE_NULL);
+        gst_object_unref (m_audioBin);
+    }
+}
+
+qreal AudioOutput::volume() const
+{
+    return m_volumeLevel;
+}
+
+int AudioOutput::outputDevice() const
+{
+    return m_device;
+}
+
+void AudioOutput::setVolume(qreal newVolume)
+{
+    if (newVolume > 2.0 )
+        newVolume = 2.0;
+    else if (newVolume < 0.0)
+        newVolume = 0.0;
+
+    if (newVolume == m_volumeLevel)
+        return;
+
+    m_volumeLevel = newVolume;
+
+    if (m_volumeElement) {
+        g_object_set(G_OBJECT(m_volumeElement), "volume", newVolume, (const char*)NULL);
+    }
+
+    emit volumeChanged(newVolume);
+}
+
+bool AudioOutput::setOutputDevice(int newDevice)
+{
+    m_backend->logMessage(Q_FUNC_INFO + QString::number(newDevice), Backend::Info, this);
+
+    if (newDevice == m_device)
+        return true;
+
+    if (root()) {
+        root()->saveState();
+        if (gst_element_set_state(root()->pipeline(), GST_STATE_READY) == GST_STATE_CHANGE_FAILURE)
+            return false;
+    }
+
+    bool success = false;
+    if (m_audioSink &&  newDevice >= 0) {
+        // Save previous state
+        GstState oldState = GST_STATE(m_audioSink);
+        const QByteArray oldDeviceValue = GstHelper::property(m_audioSink, "device");
+        const QByteArray deviceId = m_backend->deviceManager()->gstId(newDevice);
+        m_device = newDevice;
+
+        // We test if the device can be opened by checking if it can go from NULL to READY state
+        gst_element_set_state(m_audioSink, GST_STATE_NULL);
+        success = GstHelper::setProperty(m_audioSink, "device", deviceId);
+        if (success) {
+            success = (gst_element_set_state(m_audioSink, oldState) == GST_STATE_CHANGE_SUCCESS);
+        }
+        if (!success) { // Revert state
+            m_backend->logMessage(Q_FUNC_INFO +
+                                  QLatin1String(" Failed to change device ") +
+                                  deviceId, Backend::Info, this);
+
+            GstHelper::setProperty(m_audioSink, "device", oldDeviceValue);
+            gst_element_set_state(m_audioSink, oldState);
+        } else {
+            m_backend->logMessage(Q_FUNC_INFO +
+                                  QLatin1String(" Successfully changed device ") +
+                                  deviceId, Backend::Info, this);
+        }
+
+        // Note the stopped state should not really be necessary, but seems to be required to
+        // properly reset after changing the audio state
+        if (root()) {
+            QMetaObject::invokeMethod(root(), "setState", Qt::QueuedConnection, Q_ARG(State, StoppedState));
+            root()->resumeState();
+        }
+    }
+    return success;
+}
+
+#if (PHONON_VERSION >= PHONON_VERSION_CHECK(4, 2, 0))
+bool AudioOutput::setOutputDevice(const AudioOutputDevice &newDevice)
+{
+    m_backend->logMessage(Q_FUNC_INFO, Backend::Info, this);
+    if (!m_audioSink || !newDevice.isValid()) {
+        return false;
+    }
+    const QVariant driver = newDevice.property("driver");
+    if (!driver.isValid()) {
+        return setOutputDevice(newDevice.index());
+    }
+    if (newDevice.index() == m_device) {
+        return true;
+    }
+
+    if (root()) {
+        root()->saveState();
+        if (gst_element_set_state(root()->pipeline(), GST_STATE_READY) == GST_STATE_CHANGE_FAILURE)
+            return false;
+    }
+
+    // Save previous state
+    const GstState oldState = GST_STATE(m_audioSink);
+    const QByteArray oldDeviceValue = GstHelper::property(m_audioSink, "device");
+
+    const QByteArray sinkName = GstHelper::property(m_audioSink, "name");
+    if (sinkName == "alsasink" || sinkName == "alsasink2") {
+        if (driver.toByteArray() != "alsa") {
+            return false;
+        }
+    }
+
+    const QVariant deviceIdsProperty = newDevice.property("deviceIds");
+    QStringList deviceIds;
+    if (deviceIdsProperty.type() == QVariant::StringList) {
+        deviceIds = deviceIdsProperty.toStringList();
+    } else if (deviceIdsProperty.type() == QVariant::String) {
+        deviceIds += deviceIdsProperty.toString();
+    }
+
+    // We test if the device can be opened by checking if it can go from NULL to READY state
+    foreach (const QString &deviceId, deviceIds) {
+        gst_element_set_state(m_audioSink, GST_STATE_NULL);
+        if (GstHelper::setProperty(m_audioSink, "device", deviceId.toUtf8())) {
+            m_backend->logMessage(Q_FUNC_INFO + QLatin1String("setProperty(device,") +
+                                  deviceId + QLatin1String(") succeeded"), Backend::Info, this);
+            if (gst_element_set_state(m_audioSink, oldState) == GST_STATE_CHANGE_SUCCESS) {
+                m_backend->logMessage(Q_FUNC_INFO + QLatin1String("go to old state on device") +
+                                      deviceId + QLatin1String(" succeeded"), Backend::Info, this);
+                m_device = newDevice.index();
+                if (root()) {
+                    QMetaObject::invokeMethod(root(), "setState", Qt::QueuedConnection, Q_ARG(State, StoppedState));
+                    root()->resumeState();
+                }
+                return true;
+            } else {
+                m_backend->logMessage(Q_FUNC_INFO + QLatin1String("go to old state on device") +
+                                      deviceId + QLatin1String(" failed"), Backend::Info, this);
+            }
+        } else {
+            m_backend->logMessage(Q_FUNC_INFO + QLatin1String("setProperty(device,") +
+                                  deviceId + QLatin1String(") failed"), Backend::Info, this);
+        }
+    }
+    // Revert state
+    GstHelper::setProperty(m_audioSink, "device", oldDeviceValue);
+    gst_element_set_state(m_audioSink, oldState);
+
+    if (root()) {
+        QMetaObject::invokeMethod(root(), "setState", Qt::QueuedConnection, Q_ARG(State, StoppedState));
+        root()->resumeState();
+    }
+
+    return false;
+}
+#endif
+
+}
+} //namespace Phonon::Gstreamer
+
+QT_END_NAMESPACE
+#include "moc_audiooutput.cpp"