+
−/*
+
− * Hedgewars, a free turn based strategy game
+
− * Copyright (c) 2006-2007 Igor Ulyanov <iulyanov@gmail.com>
+
− * Copyright (c) 2004-2013 Andrey Korotaev <unC0Rr@gmail.com>
+
− *
+
− * This program is free software; you can redistribute it and/or modify
+
− * it under the terms of the GNU General Public License as published by
+
− * the Free Software Foundation; version 2 of the License
+
− *
+
− * This program is distributed in the hope that it will be useful,
+
− * but WITHOUT ANY WARRANTY; without even the implied warranty of
+
− * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+
− * GNU General Public License for more details.
+
− *
+
− * You should have received a copy of the GNU General Public License
+
− * along with this program; if not, write to the Free Software
+
− * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
+
− */
+
−
+
−#include "tcpBase.h"
+
−
+
−#include <QList>
+
−#include <QImage>
+
−#include <QThread>
+
−
+
−#include "hwconsts.h"
+
−#include "MessageDialog.h"
+
−
+
−#ifdef HWLIBRARY
+
−extern "C" void Game(char**arguments);
+
−extern "C" void GenLandPreview(int port);
+
−
+
−
+
−EngineInstance::EngineInstance(QObject *parent)
+
−    : QObject(parent)
+
−{
+
−    port = 0;
+
−}
+
−
+
−EngineInstance::~EngineInstance()
+
−{
+
−}
+
−
+
−void EngineInstance::start()
+
−{
+
−#if 0
+
−    char *args[11];
+
−    args[0] = "65000";  //ipcPort
+
−    args[1] = "1024";   //cScreenWidth
+
−    args[2] = "768";    //cScreenHeight
+
−    args[3] = "0";      //cReducedQuality
+
−    args[4] = "en.txt"; //cLocaleFName
+
−    args[5] = "koda";   //UserNick
+
−    args[6] = "1";      //SetSound
+
−    args[7] = "1";      //SetMusic
+
−    args[8] = "0";      //cAltDamage
+
−    args[9]= datadir->absolutePath().toAscii().data(); //cPathPrefix
+
−    args[10]= NULL;     //recordFileName
+
−    Game(args);
+
−#endif
+
−    GenLandPreview(port);
+
−}
+
−
+
−#endif
+
−
+
−QList<TCPBase*> srvsList;
+
−QPointer<QTcpServer> TCPBase::IPCServer(0);
+
−
+
−TCPBase::~TCPBase()
+
−{
+
−    // make sure this object is not in the server list anymore
+
−    srvsList.removeOne(this);
+
−
+
−    if (IPCSocket)
+
−        IPCSocket->deleteLater();
+
−
+
−}
+
−
+
−TCPBase::TCPBase(bool demoMode, QObject *parent) :
+
−    QObject(parent),
+
−    m_hasStarted(false),
+
−    m_isDemoMode(demoMode),
+
−    m_connected(false),
+
−    IPCSocket(0)
+
−{
+
−    if(!IPCServer)
+
−    {
+
−        IPCServer = new QTcpServer(0);
+
−        IPCServer->setMaxPendingConnections(1);
+
−        if (!IPCServer->listen(QHostAddress::LocalHost))
+
−        {
+
−            MessageDialog::ShowFatalMessage(tr("Unable to start server at %1.").arg(IPCServer->errorString()));
+
−            exit(0); // FIXME - should be graceful exit here (lower Critical -> Warning above when implemented)
+
−        }
+
−    }
+
−
+
−    ipc_port=IPCServer->serverPort();
+
−}
+
−
+
−void TCPBase::NewConnection()
+
−{
+
−    if(IPCSocket)
+
−    {
+
−        // connection should be already finished
+
−        return;
+
−    }
+
−
+
−    disconnect(IPCServer, SIGNAL(newConnection()), this, SLOT(NewConnection()));
+
−    IPCSocket = IPCServer->nextPendingConnection();
+
−
+
−    if(!IPCSocket) return;
+
−
+
−    m_connected = true;
+
−
+
−    connect(IPCSocket, SIGNAL(disconnected()), this, SLOT(ClientDisconnect()));
+
−    connect(IPCSocket, SIGNAL(readyRead()), this, SLOT(ClientRead()));
+
−    SendToClientFirst();
+
−
+
−    if(simultaneousRun())
+
−    {
+
−        srvsList.removeOne(this);
+
−        emit isReadyNow();
+
−    }
+
−}
+
−
+
−void TCPBase::RealStart()
+
−{
+
−    connect(IPCServer, SIGNAL(newConnection()), this, SLOT(NewConnection()));
+
−    IPCSocket = 0;
+
−
+
−#ifdef HWLIBRARY
+
−    QThread *thread = new QThread;
+
−    EngineInstance *instance = new EngineInstance;
+
−    instance->port = IPCServer->serverPort();
+
−
+
−    instance->moveToThread(thread);
+
−
+
−    connect(thread, SIGNAL(started()), instance, SLOT(start(void)));
+
−    connect(instance, SIGNAL(finished()), thread, SLOT(quit()));
+
−    connect(instance, SIGNAL(finished()), instance, SLOT(deleteLater()));
+
−    connect(instance, SIGNAL(finished()), thread, SLOT(deleteLater()));
+
−    thread->start();
+
−#else
+
−    QProcess * process;
+
−    process = new QProcess();
+
−    connect(process, SIGNAL(error(QProcess::ProcessError)), this, SLOT(StartProcessError(QProcess::ProcessError)));
+
−    QStringList arguments=getArguments();
+
−
+
−#ifdef QT_DEBUG
+
−    // redirect everything written on stdout/stderr
+
−    process->setProcessChannelMode(QProcess::ForwardedChannels);
+
−#endif
+
−
+
−    process->start(bindir->absolutePath() + "/hwengine", arguments);
+
−#endif
+
−    m_hasStarted = true;
+
−}
+
−
+
−void TCPBase::ClientDisconnect()
+
−{
+
−    disconnect(IPCSocket, SIGNAL(readyRead()), this, SLOT(ClientRead()));
+
−    onClientDisconnect();
+
−
+
−    if(!simultaneousRun())
+
−        emit isReadyNow();
+
−    IPCSocket->deleteLater();
+
−
+
−    deleteLater();
+
−}
+
−
+
−void TCPBase::ClientRead()
+
−{
+
−    QByteArray readed=IPCSocket->readAll();
+
−    if(readed.isEmpty()) return;
+
−    readbuffer.append(readed);
+
−    onClientRead();
+
−}
+
−
+
−void TCPBase::StartProcessError(QProcess::ProcessError error)
+
−{
+
−    MessageDialog::ShowFatalMessage(tr("Unable to run engine at %1\nError code: %2").arg(bindir->absolutePath() + "/hwengine").arg(error));
+
−    ClientDisconnect();
+
−}
+
−
+
−void TCPBase::tcpServerReady()
+
−{
+
−    disconnect(srvsList.first(), SIGNAL(isReadyNow()), this, SLOT(tcpServerReady()));
+
−
+
−    RealStart();
+
−}
+
−
+
−void TCPBase::Start(bool couldCancelPreviousRequest)
+
−{
+
−    if(srvsList.isEmpty())
+
−    {
+
−        srvsList.push_back(this);
+
−        RealStart();
+
−    }
+
−    else
+
−    {
+
−        TCPBase * last = srvsList.last();
+
−        if(couldCancelPreviousRequest
+
−            && last->couldBeRemoved()
+
−            && (last->isConnected() || !last->hasStarted())
+
−            && (last->parent() == parent()))
+
−        {
+
−            srvsList.removeLast();
+
−            last->deleteLater();
+
−            Start(couldCancelPreviousRequest);
+
−        } else
+
−        {
+
−            connect(last, SIGNAL(isReadyNow()), this, SLOT(tcpServerReady()));
+
−            srvsList.push_back(this);
+
−        }
+
−    }
+
−}
+
−
+
−void TCPBase::onClientRead()
+
−{
+
−}
+
−
+
−void TCPBase::onClientDisconnect()
+
−{
+
−}
+
−
+
−void TCPBase::SendToClientFirst()
+
−{
+
−}
+
−
+
−void TCPBase::SendIPC(const QByteArray & buf)
+
−{
+
−    if (buf.size() > MAXMSGCHARS) return;
+
−    quint8 len = buf.size();
+
−    RawSendIPC(QByteArray::fromRawData((char *)&len, 1) + buf);
+
−}
+
−
+
−void TCPBase::RawSendIPC(const QByteArray & buf)
+
−{
+
−    if (!IPCSocket)
+
−    {
+
−        toSendBuf += buf;
+
−    }
+
−    else
+
−    {
+
−        if (toSendBuf.size() > 0)
+
−        {
+
−            IPCSocket->write(toSendBuf);
+
−            if(m_isDemoMode) demo.append(toSendBuf);
+
−            toSendBuf.clear();
+
−        }
+
−        if(!buf.isEmpty())
+
−        {
+
−            IPCSocket->write(buf);
+
−            if(m_isDemoMode) demo.append(buf);
+
−        }
+
−    }
+
−}
+
−
+
−bool TCPBase::couldBeRemoved()
+
−{
+
−    return false;
+
−}
+
−
+
−bool TCPBase::isConnected()
+
−{
+
−    return m_connected;
+
−}
+
−
+
−bool TCPBase::simultaneousRun()
+
−{
+
−    return false;
+
−}
+
−
+
−bool TCPBase::hasStarted()
+
−{
+
−    return m_hasStarted;
+
−}