--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/3rdparty/phonon/gstreamer/audiooutput.cpp Mon Jan 11 14:00:40 2010 +0000
@@ -0,0 +1,257 @@
+/* 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()) {
+ g_set_application_name(qApp->applicationName().toUtf8());
+ 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;
+ const QList<AudioDevice> deviceList = m_backend->deviceManager()->audioOutputDevices();
+ if (m_audioSink && newDevice >= 0 && newDevice < deviceList.size()) {
+ // Save previous state
+ GstState oldState = GST_STATE(m_audioSink);
+ const QByteArray oldDeviceValue = GstHelper::property(m_audioSink, "device");
+ const QByteArray deviceId = deviceList.at(newDevice).gstId;
+ 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 neccessary, 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"