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

 /*
     KWin - the KDE window manager
     This file is part of the KDE project.
 
     SPDX-FileCopyrightText: 2013 Martin Gräßlin <mgraesslin@kde.org>
 
     SPDX-License-Identifier: GPL-2.0-or-later
 */
 // own
 #include "client_machine.h"
 #include "effect/xcb.h"
 #include "main.h"
 #include "utils/common.h"
 // KF5
 #include <NETWM>
 // Qt
 #include <QFutureWatcher>
 #include <QtConcurrentRun>
 // system
 #include <netdb.h>
 #include <sys/socket.h>
 #include <sys/types.h>
 #include <unistd.h>
 
 namespace KWin
 {
 
 static QString getHostName()
 {
 #ifdef HOST_NAME_MAX
     char hostnamebuf[HOST_NAME_MAX];
 #else
     char hostnamebuf[256];
 #endif
     if (gethostname(hostnamebuf, sizeof hostnamebuf) >= 0) {
         hostnamebuf[sizeof(hostnamebuf) - 1] = 0;
         return QString::fromLocal8Bit(hostnamebuf);
     }
     return QString();
 }
 
 GetAddrInfo::GetAddrInfo(const QString &hostName, QObject *parent)
     : QObject(parent)
     , m_resolving(false)
     , m_resolved(false)
     , m_ownResolved(false)
     , m_hostName(hostName)
     , m_addressHints(std::make_unique<addrinfo>())
     , m_address(nullptr)
     , m_ownAddress(nullptr)
     , m_watcher(std::make_unique<QFutureWatcher<int>>())
     , m_ownAddressWatcher(std::make_unique<QFutureWatcher<int>>())
 {
     // watcher will be deleted together with the GetAddrInfo once the future
     // got canceled or finished
     connect(m_watcher.get(), &QFutureWatcher<int>::canceled, this, &GetAddrInfo::deleteLater);
     connect(m_watcher.get(), &QFutureWatcher<int>::finished, this, &GetAddrInfo::slotResolved);
     connect(m_ownAddressWatcher.get(), &QFutureWatcher<int>::canceled, this, &GetAddrInfo::deleteLater);
     connect(m_ownAddressWatcher.get(), &QFutureWatcher<int>::finished, this, &GetAddrInfo::slotOwnAddressResolved);
 }
 
 GetAddrInfo::~GetAddrInfo()
 {
     if (m_watcher && m_watcher->isRunning()) {
         m_watcher->cancel();
         m_watcher->waitForFinished();
     }
     if (m_ownAddressWatcher && m_ownAddressWatcher->isRunning()) {
         m_ownAddressWatcher->cancel();
         m_ownAddressWatcher->waitForFinished();
     }
     if (m_address) {
         freeaddrinfo(m_address);
     }
     if (m_ownAddress) {
         freeaddrinfo(m_ownAddress);
     }
 }
 
 void GetAddrInfo::resolve()
 {
     if (m_resolving) {
         return;
     }
     m_resolving = true;
     *m_addressHints = {};
     m_addressHints->ai_family = PF_UNSPEC;
     m_addressHints->ai_socktype = SOCK_STREAM;
     m_addressHints->ai_flags |= AI_CANONNAME;
 
     m_watcher->setFuture(QtConcurrent::run([this]() {
         return getaddrinfo(m_hostName.toLocal8Bit().constData(), nullptr, m_addressHints.get(), &m_address);
     }));
     m_ownAddressWatcher->setFuture(QtConcurrent::run([this] {
         // needs to be performed in a lambda as getHostName() returns a temporary value which would
         // get destroyed in the main thread before the getaddrinfo thread is able to read it
         return getaddrinfo(getHostName().toLocal8Bit().constData(), nullptr, m_addressHints.get(), &m_ownAddress);
     }));
 }
 
 void GetAddrInfo::slotResolved()
 {
     if (resolved(m_watcher.get())) {
         m_resolved = true;
         compare();
     }
 }
 
 void GetAddrInfo::slotOwnAddressResolved()
 {
     if (resolved(m_ownAddressWatcher.get())) {
         m_ownResolved = true;
         compare();
     }
 }
 
 bool GetAddrInfo::resolved(QFutureWatcher<int> *watcher)
 {
     if (!watcher->isFinished()) {
         return false;
     }
     if (watcher->result() != 0) {
         qCDebug(KWIN_CORE) << "getaddrinfo failed with error:" << gai_strerror(watcher->result());
         // call failed;
         deleteLater();
         return false;
     }
     return true;
 }
 
 void GetAddrInfo::compare()
 {
     if (!m_resolved || !m_ownResolved) {
         return;
     }
     addrinfo *address = m_address;
     while (address) {
         if (address->ai_canonname && m_hostName == QByteArray(address->ai_canonname).toLower()) {
             addrinfo *ownAddress = m_ownAddress;
             bool localFound = false;
             while (ownAddress) {
                 if (ownAddress->ai_canonname && QByteArray(ownAddress->ai_canonname).toLower() == m_hostName) {
                     localFound = true;
                     break;
                 }
                 ownAddress = ownAddress->ai_next;
             }
             if (localFound) {
                 Q_EMIT local();
                 break;
             }
         }
         address = address->ai_next;
     }
     deleteLater();
 }
 
 ClientMachine::ClientMachine(QObject *parent)
     : QObject(parent)
     , m_localhost(false)
     , m_resolved(false)
     , m_resolving(false)
 {
 }
 
 ClientMachine::~ClientMachine()
 {
 }
 
 void ClientMachine::resolve(xcb_window_t window, xcb_window_t clientLeader)
 {
     if (m_resolved) {
         return;
     }
     QString name = NETWinInfo(connection(), window, rootWindow(), NET::Properties(), NET::WM2ClientMachine).clientMachine();
     if (name.isEmpty() && clientLeader && clientLeader != window) {
         name = NETWinInfo(connection(), clientLeader, rootWindow(), NET::Properties(), NET::WM2ClientMachine).clientMachine();
     }
     if (name.isEmpty()) {
         name = localhost();
     }
     if (name == localhost()) {
         setLocal();
     }
     m_hostName = name;
     checkForLocalhost();
     m_resolved = true;
 }
 
 void ClientMachine::checkForLocalhost()
 {
     if (isLocal()) {
         // nothing to do
         return;
     }
     QString host = getHostName();
 
     if (!host.isEmpty()) {
         host = host.toLower();
         const QString lowerHostName(m_hostName.toLower());
         if (host == lowerHostName) {
             setLocal();
             return;
         }
         if (int index = host.indexOf('.'); index != -1) {
             if (QStringView(host).left(index) == lowerHostName) {
                 setLocal();
                 return;
             }
         } else {
             m_resolving = true;
             // check using information from get addr info
             // GetAddrInfo gets automatically destroyed once it finished or not
             GetAddrInfo *info = new GetAddrInfo(lowerHostName, this);
             connect(info, &GetAddrInfo::local, this, &ClientMachine::setLocal);
             connect(info, &GetAddrInfo::destroyed, this, &ClientMachine::resolveFinished);
             info->resolve();
         }
     }
 }
 
 void ClientMachine::setLocal()
 {
     m_localhost = true;
     Q_EMIT localhostChanged();
 }
 
 void ClientMachine::resolveFinished()
 {
     m_resolving = false;
 }
 
 } // namespace
 
 #include "moc_client_machine.cpp"