diff options
Diffstat (limited to 'src/gsttools/qgstreamerbushelper.cpp')
-rw-r--r-- | src/gsttools/qgstreamerbushelper.cpp | 25 |
1 files changed, 19 insertions, 6 deletions
diff --git a/src/gsttools/qgstreamerbushelper.cpp b/src/gsttools/qgstreamerbushelper.cpp index 68c8795ce..751e805ba 100644 --- a/src/gsttools/qgstreamerbushelper.cpp +++ b/src/gsttools/qgstreamerbushelper.cpp @@ -98,17 +98,20 @@ private: void processMessage(GstMessage* message) { QGstreamerMessage msg(message); - foreach (QGstreamerBusMessageFilter *filter, busFilters) { - if (filter->processBusMessage(msg)) - break; - } - emit m_helper->message(msg); + doProcessMessage(msg); + } + + void queueMessage(GstMessage* message) + { + QGstreamerMessage msg(message); + QMetaObject::invokeMethod(this, "doProcessMessage", Qt::QueuedConnection, + Q_ARG(QGstreamerMessage, msg)); } static gboolean busCallback(GstBus *bus, GstMessage *message, gpointer data) { Q_UNUSED(bus); - reinterpret_cast<QGstreamerBusHelperPrivate*>(data)->processMessage(message); + reinterpret_cast<QGstreamerBusHelperPrivate*>(data)->queueMessage(message); return TRUE; } @@ -117,6 +120,16 @@ private: QGstreamerBusHelper* m_helper; QTimer* m_intervalTimer; +private slots: + void doProcessMessage(const QGstreamerMessage& msg) + { + foreach (QGstreamerBusMessageFilter *filter, busFilters) { + if (filter->processBusMessage(msg)) + break; + } + emit m_helper->message(msg); + } + public: QMutex filterMutex; QList<QGstreamerSyncMessageFilter*> syncFilters; |