diff options
author | Lev Zelenskiy <lev.zelenskiy@nokia.com> | 2012-02-15 14:45:18 +1000 |
---|---|---|
committer | Qt by Nokia <qt-info@nokia.com> | 2012-02-16 07:18:27 +0100 |
commit | 16aef591875becad3e6f388af0a2f029cb68b775 (patch) | |
tree | 45af5b903258966e89aa44449c33705fffbd3c3c /src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp | |
parent | 0374f0de5ec881569e463505b232b3870c0fd9d2 (diff) | |
download | qtmultimedia-16aef591875becad3e6f388af0a2f029cb68b775.tar.gz |
QMediaRecorder: GStreamer backend changes for media probing API.
QGstreamerCaptureSession: Using GStreamer buffer probe
to access media data.
Change-Id: I2ee38e864fbd69fcba9efe90d4dcf138528e00c0
Reviewed-by: Michael Goddard <michael.goddard@nokia.com>
Diffstat (limited to 'src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp')
-rw-r--r-- | src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp | 81 |
1 files changed, 81 insertions, 0 deletions
diff --git a/src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp b/src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp index 68f4444cf..60cda07bc 100644 --- a/src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp +++ b/src/plugins/gstreamer/mediacapture/qgstreamercapturesession.cpp @@ -46,6 +46,7 @@ #include "qgstreameraudioencode.h" #include "qgstreamervideoencode.h" #include "qgstreamerimageencode.h" +#include "qgstreameraudioprobecontrol.h" #include <qmediarecorder.h> #include <private/qgstreamerbushelper_p.h> @@ -73,6 +74,7 @@ QGstreamerCaptureSession::QGstreamerCaptureSession(QGstreamerCaptureSession::Cap m_waitingForEos(false), m_pipelineMode(EmptyPipeline), m_captureMode(captureMode), + m_audioBufferProbeId(-1), m_audioInputFactory(0), m_audioPreviewFactory(0), m_videoInputFactory(0), @@ -530,6 +532,7 @@ void QGstreamerCaptureSession::captureImage(int requestId, const QString &fileNa bool QGstreamerCaptureSession::rebuildGraph(QGstreamerCaptureSession::PipelineMode newMode) { + removeAudioBufferProbe(); REMOVE_ELEMENT(m_audioSrc); REMOVE_ELEMENT(m_audioPreview); REMOVE_ELEMENT(m_audioPreviewQueue); @@ -669,6 +672,7 @@ bool QGstreamerCaptureSession::rebuildGraph(QGstreamerCaptureSession::PipelineMo } if (ok) { + addAudioBufferProbe(); m_pipelineMode = newMode; } else { m_pipelineMode = EmptyPipeline; @@ -1024,4 +1028,81 @@ void QGstreamerCaptureSession::setMuted(bool muted) } } +void QGstreamerCaptureSession::addProbe(QGstreamerAudioProbeControl* probe) +{ + QMutexLocker locker(&m_audioProbeMutex); + + if (m_audioProbes.contains(probe)) + return; + + m_audioProbes.append(probe); +} + +void QGstreamerCaptureSession::removeProbe(QGstreamerAudioProbeControl* probe) +{ + QMutexLocker locker(&m_audioProbeMutex); + m_audioProbes.removeOne(probe); +} + +gboolean QGstreamerCaptureSession::padAudioBufferProbe(GstPad *pad, GstBuffer *buffer, gpointer user_data) +{ + Q_UNUSED(pad); + + QGstreamerCaptureSession *session = reinterpret_cast<QGstreamerCaptureSession*>(user_data); + QMutexLocker locker(&session->m_audioProbeMutex); + + if (session->m_audioProbes.isEmpty()) + return TRUE; + + foreach (QGstreamerAudioProbeControl* probe, session->m_audioProbes) + probe->bufferProbed(buffer); + + return TRUE; +} + +GstPad *QGstreamerCaptureSession::getAudioProbePad() +{ + // first see if preview element is available + if (m_audioPreview) { + GstPad *pad = gst_element_get_static_pad(m_audioPreview, "sink"); + if (pad) + return pad; + } + + // preview element is not available, + // try to use sink pin of audio encoder. + if (m_encodeBin) { + GstElement *audioEncoder = gst_bin_get_by_name(GST_BIN(m_encodeBin), "audio-encoder-bin"); + if (audioEncoder) { + GstPad *pad = gst_element_get_static_pad(audioEncoder, "sink"); + gst_object_unref(audioEncoder); + if (pad) + return pad; + } + } + + return 0; +} + +void QGstreamerCaptureSession::removeAudioBufferProbe() +{ + if (m_audioBufferProbeId == -1) + return; + + GstPad *pad = getAudioProbePad(); + if (pad) + gst_pad_remove_buffer_probe(pad, m_audioBufferProbeId); + + m_audioBufferProbeId = -1; +} + +void QGstreamerCaptureSession::addAudioBufferProbe() +{ + Q_ASSERT(m_audioBufferProbeId == -1); + + GstPad *pad = getAudioProbePad(); + if (pad) + m_audioBufferProbeId = gst_pad_add_buffer_probe(pad, G_CALLBACK(padAudioBufferProbe), this); +} + QT_END_NAMESPACE |