File indexing completed on 2024-11-10 04:57:06

 /*
     SPDX-FileCopyrightText: 2018-2020 Red Hat Inc
     SPDX-FileCopyrightText: 2020 Aleix Pol Gonzalez <aleixpol@kde.org>
     SPDX-FileContributor: Jan Grulich <jgrulich@redhat.com>
 
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "pipewirecore.h"
 #include "kwinscreencast_logging.h"
 #include <cerrno>
 
 #include <KLocalizedString>
 
 #include <QSocketNotifier>
 
 namespace KWin
 {
 
 PipeWireCore::PipeWireCore()
 {
     pw_init(nullptr, nullptr);
     pwCoreEvents.version = PW_VERSION_CORE_EVENTS;
     pwCoreEvents.error = &PipeWireCore::onCoreError;
 }
 
 PipeWireCore::~PipeWireCore()
 {
     if (pwMainLoop) {
         pw_loop_leave(pwMainLoop);
     }
 
     if (pwCore) {
         pw_core_disconnect(pwCore);
     }
 
     if (pwContext) {
         pw_context_destroy(pwContext);
     }
 
     if (pwMainLoop) {
         pw_loop_destroy(pwMainLoop);
     }
 }
 
 void PipeWireCore::onCoreError(void *data, uint32_t id, int seq, int res, const char *message)
 {
     qCWarning(KWIN_SCREENCAST) << "PipeWire remote error: " << message;
     if (id == PW_ID_CORE && res == -EPIPE) {
         PipeWireCore *pw = static_cast<PipeWireCore *>(data);
         Q_EMIT pw->pipewireFailed(QString::fromUtf8(message));
     }
 }
 
 bool PipeWireCore::init()
 {
     pwMainLoop = pw_loop_new(nullptr);
     if (!pwMainLoop) {
         qCWarning(KWIN_SCREENCAST, "Failed to create PipeWire loop: %s", strerror(errno));
         m_error = i18n("Failed to start main PipeWire loop");
         return false;
     }
     pw_loop_enter(pwMainLoop);
 
     QSocketNotifier *notifier = new QSocketNotifier(pw_loop_get_fd(pwMainLoop), QSocketNotifier::Read, this);
     connect(notifier, &QSocketNotifier::activated, this, [this] {
         int result = pw_loop_iterate(pwMainLoop, 0);
         if (result < 0) {
             qCWarning(KWIN_SCREENCAST) << "pipewire_loop_iterate failed: " << result;
         }
     });
 
     pwContext = pw_context_new(pwMainLoop, nullptr, 0);
     if (!pwContext) {
         qCWarning(KWIN_SCREENCAST) << "Failed to create PipeWire context";
         m_error = i18n("Failed to create PipeWire context");
         return false;
     }
 
     pwCore = pw_context_connect(pwContext, nullptr, 0);
     if (!pwCore) {
         qCWarning(KWIN_SCREENCAST) << "Failed to connect PipeWire context";
         m_error = i18n("Failed to connect PipeWire context");
         return false;
     }
 
     if (pw_loop_iterate(pwMainLoop, 0) < 0) {
         qCWarning(KWIN_SCREENCAST) << "Failed to start main PipeWire loop";
         m_error = i18n("Failed to start main PipeWire loop");
         return false;
     }
 
     pw_core_add_listener(pwCore, &coreListener, &pwCoreEvents, this);
     return true;
 }
 
 } // namespace KWin
 
 #include "moc_pipewirecore.cpp"