kmessageio.cpp

/*
    This file is part of the KDE games library
    SPDX-FileCopyrightText: 2001 Burkhard Lehner <Burkhard.Lehner@gmx.de>
 
    SPDX-License-Identifier: LGPL-2.0-only
*/
 
/*
     KMessageIO class and subclasses KMessageSocket and KMessageDirect
*/
 
#include "kmessageio.h"
 
// own
#include <kdegamesprivate_kgame_logging.h>
// Qt
#include <KProcess>
#include <QDataStream>
#include <QTcpSocket>
 
// ----------------------- KMessageIO -------------------------
 
KMessageIO::KMessageIO(QObject *parent)
    : QObject(parent)
    , m_id(0)
{
}
 
KMessageIO::~KMessageIO()
{
}
 
void KMessageIO::setId(quint32 id)
{
    m_id = id;
}
 
quint32 KMessageIO::id()
{
    return m_id;
}
 
bool KMessageIO::isNetwork() const
{
    qCCritical(KDEGAMESPRIVATE_KGAME_LOG) << "Calling PURE virtual isNetwork...BAD";
    return false;
}
 
bool KMessageIO::isConnected() const
{
    qCCritical(KDEGAMESPRIVATE_KGAME_LOG) << "Calling PURE virtual isConnected...BAD";
    return false;
}
 
quint16 KMessageIO::peerPort() const
{
    return 0;
}
 
QString KMessageIO::peerName() const
{
    return QStringLiteral("localhost");
}
 
// ----------------------KMessageSocket -----------------------
 
KMessageSocket::KMessageSocket(const QString &host, quint16 port, QObject *parent)
    : KMessageIO(parent)
{
    mSocket = new QTcpSocket();
    mSocket->connectToHost(host, port);
    initSocket();
}
 
KMessageSocket::KMessageSocket(const QHostAddress &host, quint16 port, QObject *parent)
    : KMessageIO(parent)
{
    mSocket = new QTcpSocket();
    mSocket->connectToHost(host.toString(), port);
    initSocket();
}
 
KMessageSocket::KMessageSocket(QTcpSocket *socket, QObject *parent)
    : KMessageIO(parent)
{
    mSocket = socket;
    initSocket();
}
 
KMessageSocket::KMessageSocket(int socketFD, QObject *parent)
    : KMessageIO(parent)
{
    mSocket = new QTcpSocket();
    mSocket->setSocketDescriptor(socketFD);
    initSocket();
}
 
KMessageSocket::~KMessageSocket()
{
    delete mSocket;
}
 
bool KMessageSocket::isConnected() const
{
    return mSocket->state() == QAbstractSocket::ConnectedState;
}
 
void KMessageSocket::send(const QByteArray &msg)
{
    QDataStream str(mSocket);
    str << quint8('M'); // magic number for begin of message
    str.writeBytes(msg.data(), msg.size()); // writes the length (as quint32) and the data
}
 
void KMessageSocket::processNewData()
{
    if (isRecursive)
        return;
    isRecursive = true;
 
    QDataStream str(mSocket);
    while (mSocket->bytesAvailable() > 0) {
        if (mAwaitingHeader) {
            // Header = magic number + packet length = 5 bytes
            if (mSocket->bytesAvailable() < 5) {
                isRecursive = false;
                return;
            }
 
            // Read the magic number first. If something unexpected is found,
            // start over again, ignoring the data that was read up to then.
 
            quint8 v;
            str >> v;
            if (v != 'M') {
                qCWarning(KDEGAMESPRIVATE_KGAME_LOG) << ": Received unexpected data, magic number wrong!";
                continue;
            }
 
            str >> mNextBlockLength;
            mAwaitingHeader = false;
        } else {
            // Data not completely read => wait for more
            if (mSocket->bytesAvailable() < (qint64)mNextBlockLength) {
                isRecursive = false;
                return;
            }
 
            QByteArray msg(mNextBlockLength, 0);
            str.readRawData(msg.data(), mNextBlockLength);
 
            // send the received message
            Q_EMIT received(msg);
 
            // Waiting for the header of the next message
            mAwaitingHeader = true;
        }
    }
 
    isRecursive = false;
}
 
void KMessageSocket::initSocket()
{
    connect(mSocket, &QTcpSocket::errorOccurred, this, &KMessageSocket::connectionBroken);
    connect(mSocket, &QTcpSocket::disconnected, this, &KMessageSocket::connectionBroken);
    connect(mSocket, &QTcpSocket::readyRead, this, &KMessageSocket::processNewData);
    mAwaitingHeader = true;
    mNextBlockLength = 0;
    isRecursive = false;
}
 
quint16 KMessageSocket::peerPort() const
{
    return mSocket->peerPort();
}
 
QString KMessageSocket::peerName() const
{
    return mSocket->peerName();
}
 
// ----------------------KMessageDirect -----------------------
 
KMessageDirect::KMessageDirect(KMessageDirect *partner, QObject *parent)
    : KMessageIO(parent)
    , mPartner(nullptr)
{
    // 0 as first parameter leaves the object unconnected
    if (!partner)
        return;
 
    // Check if the other object is already connected
    if (partner && partner->mPartner) {
        qCWarning(KDEGAMESPRIVATE_KGAME_LOG) << ": Object is already connected!";
        return;
    }
 
    // Connect from us to that object
    mPartner = partner;
 
    // Connect the other object to us
    partner->mPartner = this;
}
 
KMessageDirect::~KMessageDirect()
{
    if (mPartner) {
        mPartner->mPartner = nullptr;
        Q_EMIT mPartner->connectionBroken();
    }
}
 
bool KMessageDirect::isConnected() const
{
    return mPartner != nullptr;
}
 
void KMessageDirect::send(const QByteArray &msg)
{
    if (mPartner)
        Q_EMIT mPartner->received(msg);
    else
        qCCritical(KDEGAMESPRIVATE_KGAME_LOG) << ": Not yet connected!";
}
 
// ----------------------- KMessageProcess ---------------------------
 
KMessageProcess::~KMessageProcess()
{
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessageProcess::Delete process";
    if (mProcess) {
        mProcess->kill();
        mProcess->deleteLater();
        mProcess = nullptr;
        // Maybe todo: delete mSendBuffer
    }
}
KMessageProcess::KMessageProcess(QObject *parent, const QString &file)
    : KMessageIO(parent)
{
    // Start process
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessageProcess::Start process";
    mProcessName = file;
    mProcess = new KProcess;
    // Need both stdout and stderr as separate channels in the communication
    mProcess->setOutputChannelMode(KProcess::SeparateChannels);
    int id = 0;
    *mProcess << mProcessName << QStringLiteral("%1").arg(id);
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessageProcess::Init:Id=" << id;
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessgeProcess::Init:Processname:" << mProcessName;
    connect(mProcess, &KProcess::readyReadStandardOutput, this, &KMessageProcess::slotReceivedStdout);
    connect(mProcess, &KProcess::readyReadStandardError, this, &KMessageProcess::slotReceivedStderr);
    connect(mProcess, static_cast<void (KProcess::*)(int, QProcess::ExitStatus)>(&KProcess::finished), this, &KMessageProcess::slotProcessExited);
    mProcess->start();
    mSendBuffer = nullptr;
    mReceiveCount = 0;
    mReceiveBuffer.resize(1024);
}
bool KMessageProcess::isConnected() const
{
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessageProcess::Is connected";
    if (!mProcess)
        return false;
    return (mProcess->state() == QProcess::Running);
}
 
// Send to process
void KMessageProcess::send(const QByteArray &msg)
{
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessageProcess:: SEND(" << msg.size() << ") to process";
    unsigned int size = msg.size() + 2 * sizeof(long);
 
    if (mProcess == nullptr) {
        qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@KMessageProcess:: cannot write to stdin, no process available";
        return;
    }
 
    char *tmpbuffer = new char[size];
    long *p1 = (long *)tmpbuffer;
    long *p2 = p1 + 1;
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "p1=" << p1 << "p2=" << p2;
    memcpy(tmpbuffer + 2 * sizeof(long), msg.data(), msg.size());
    *p1 = 0x4242aeae;
    *p2 = size;
 
    // no need to add it to a queue -> qiodevice is buffered
    mProcess->write(tmpbuffer, size);
    delete[] tmpbuffer;
}
 
void KMessageProcess::slotReceivedStderr()
{
    QByteArray ba;
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "@@@ KMessageProcess::slotReceivedStderr";
 
    mProcess->setReadChannel(QProcess::StandardError);
    while (mProcess->canReadLine()) {
        ba = mProcess->readLine();
        if (ba.isEmpty())
            return;
        ba.chop(1); // remove QLatin1Char( '\n' )
 
        qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "KProcess (" << ba.size() << "):" << ba.constData();
        Q_EMIT signalReceivedStderr(QLatin1String(ba));
        ba.clear();
    };
}
 
void KMessageProcess::slotReceivedStdout()
{
    mProcess->setReadChannel(QProcess::StandardOutput);
    QByteArray ba = mProcess->readAll();
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "$$$$$$ "
                                       << ": Received" << ba.size() << "bytes over inter process communication";
 
    // Resize receive buffer
    while (mReceiveCount + ba.size() >= mReceiveBuffer.size())
        mReceiveBuffer.resize(mReceiveBuffer.size() + 1024);
    // was 08/2007: mReceiveBuffer += ba;
    std::copy(ba.begin(), ba.begin() + ba.size(), mReceiveBuffer.begin() + mReceiveCount);
    mReceiveCount += ba.size();
 
    // Possible message
    while (mReceiveCount > int(2 * sizeof(long))) {
        long *p1 = (long *)mReceiveBuffer.data();
        long *p2 = p1 + 1;
        int len;
        if (*p1 != 0x4242aeae) {
            qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << ": Cookie error...transmission failure...serious problem...";
        }
        len = (int)(*p2);
        if (len < int(2 * sizeof(long))) {
            qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << ": Message size error";
            break;
        }
        if (len <= mReceiveCount) {
            qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << ": Got message with len" << len;
 
            QByteArray msg;
            msg.resize(len);
            //  msg.setRawData(mReceiveBuffer.data()+2*sizeof(long),len-2*sizeof(long));
 
            std::copy(mReceiveBuffer.begin() + 2 * sizeof(long), mReceiveBuffer.begin() + len, msg.begin());
            //       msg.duplicate(mReceiveBuffer.data()+2*sizeof(long),len-2*sizeof(long));
            Q_EMIT received(msg);
            // msg.resetRawData(mReceiveBuffer.data()+2*sizeof(long),len-2*sizeof(long));
            // Shift buffer
            if (len < mReceiveCount) {
                memmove(mReceiveBuffer.data(), mReceiveBuffer.data() + len, mReceiveCount - len);
            }
            mReceiveCount -= len;
        } else
            break;
    }
}
 
void KMessageProcess::slotProcessExited(int exitCode, QProcess::ExitStatus)
{
    qCDebug(KDEGAMESPRIVATE_KGAME_LOG) << "Process exited (slot) with code" << exitCode;
    Q_EMIT connectionBroken();
    delete mProcess;
    mProcess = nullptr;
}
 
#include "moc_kmessageio.cpp"