93e0265e4e
Once in a while, we receive complaints from other fellow KDE developers about the file organization of kwin. This change addresses some of those complaints by moving all of source code in a separate directory, src/, thus making the project structure more traditional. Things such as tests are kept in their own toplevel directories. This change may wreak havoc on merge requests that add new files to kwin, but if a patch modifies an already existing file, git should be smart enough to figure out that the file has been relocated. We may potentially split the src/ directory further to make navigating the source code easier, but hopefully this is good enough already.
112 lines
2.9 KiB
C++
112 lines
2.9 KiB
C++
/*
|
|
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 <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)
|
|
{
|
|
Q_UNUSED(seq)
|
|
|
|
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;
|
|
}
|
|
|
|
QSharedPointer< PipeWireCore > PipeWireCore::self()
|
|
{
|
|
static QWeakPointer<PipeWireCore> global;
|
|
QSharedPointer<PipeWireCore> ret;
|
|
if (global) {
|
|
ret = global.toStrongRef();
|
|
} else {
|
|
ret.reset(new PipeWireCore);
|
|
ret->init();
|
|
global = ret;
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
} // namespace KWin
|