17 gst_bus_get_pollfd(get(), &pollFd);
21 m_socketNotifier.setSocket(pollFd.fd);
23 QObject::connect(&m_socketNotifier, &QSocketNotifier::activated, &m_socketNotifier,
24 [
this](QSocketDescriptor, QSocketNotifier::Type) {
25 this->processAllPendingMessages();
28 m_socketNotifier.setEnabled(
true);
30 m_socketNotifier.setHandle(
reinterpret_cast<Qt::HANDLE>(pollFd.fd));
32 QObject::connect(&m_socketNotifier, &QWinEventNotifier::activated, &m_socketNotifier,
33 [
this](QWinEventNotifier::HANDLE) {
34 this->processAllPendingMessages();
36 m_socketNotifier.setEnabled(
true);
39 gst_bus_set_sync_handler(get(), (GstBusSyncHandler)syncGstBusFilter,
this,
nullptr);
95 std::optional<std::chrono::nanoseconds> timeout)
100 GstClockTime gstTimeout = [&]() -> GstClockTime {
102 return GST_CLOCK_TIME_NONE;
103 return timeout->count();
107 gst_bus_timed_pop_filtered(get(), gstTimeout, type),
108 QGstreamerMessage::HasRef,
113 for (QGstreamerBusMessageFilter *filter : std::as_const(busFilters)) {
114 if (filter->processBusMessage(message))