You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdegames/libtdegames/kgame/kgameprocess.cpp

159 lines
4.5 KiB

/*
This file is part of the TDE games library
Copyright (C) 2001 Martin Heni (martin@heni-online.de)
Copyright (C) 2001 Andreas Beckermann (b_mann@gmx.de)
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License version 2 as published by the Free Software Foundation.
This library 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
Library General Public License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
Boston, MA 02110-1301, USA.
*/
/*
$Id$
*/
#include "kgameprocess.h"
#include "kplayer.h"
#include "kgame.h"
#include "kgamemessage.h"
#include "kmessageio.h"
#include <krandomsequence.h>
#include <tqbuffer.h>
#include <tqdatastream.h>
#include <tqcstring.h>
#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#define READ_BUFFER_SIZE 1024
// ----------------------- Process Child ---------------------------
KGameProcess::KGameProcess() : TQObject(0,0)
{
mTerminate=false;
// Check whether a player is set. If not create one!
rFile.open(IO_ReadOnly|IO_Raw,stdin);
wFile.open(IO_WriteOnly|IO_Raw,stdout);
mMessageIO=new KMessageFilePipe(this,&rFile,&wFile);
// mMessageClient=new KMessageClient(this);
// mMessageClient->setServer(mMessageIO);
// connect (mMessageClient, TQ_SIGNAL(broadcastReceived(const TQByteArray&, TQ_UINT32)),
// this, TQ_SLOT(receivedMessage(const TQByteArray&, TQ_UINT32)));
connect (mMessageIO, TQ_SIGNAL(received(const TQByteArray&)),
this, TQ_SLOT(receivedMessage(const TQByteArray&)));
fprintf(stderr,"KGameProcess::constructor %p %p\n",&rFile,&wFile);
mRandom = new KRandomSequence;
mRandom->setSeed(0);
}
KGameProcess::~KGameProcess()
{
delete mRandom;
//delete mMessageClient;
//delete mMessageServer;
delete mMessageIO;
rFile.close();
wFile.close();
fprintf(stderr,"KGameProcess::destructor\n");
}
bool KGameProcess::exec(int argc, char *argv[])
{
// Get id and cookie, ... from command line
processArgs(argc,argv);
do
{
mMessageIO->exec();
} while(!mTerminate);
return true;
}
// You have to do this to create a message
// TQByteArray buffer;
// TQDataStream wstream(buffer,IO_WriteOnly);
// then stream data into the stream and call this function
void KGameProcess::sendSystemMessage(TQDataStream &stream,int msgid,TQ_UINT32 receiver)
{
fprintf(stderr,"KGameProcess::sendMessage id=%d recv=%d",msgid,receiver);
TQByteArray a;
TQDataStream outstream(a,IO_WriteOnly);
TQBuffer *device=(TQBuffer *)stream.device();
TQByteArray data=device->buffer();;
KGameMessage::createHeader(outstream,0,receiver,msgid);
outstream.writeRawBytes(data.data(),data.size());
//if (mMessageClient) mMessageClient->sendBroadcast(a);
// TODO: The fixed received 2 will cause problems. But how to address the
// proper one?
// if (mMessageClient) mMessageClient->sendForward(a,2);
if (mMessageIO) mMessageIO->send(a);
}
void KGameProcess::sendMessage(TQDataStream &stream,int msgid,TQ_UINT32 receiver)
{
sendSystemMessage(stream,msgid+KGameMessage::IdUser,receiver);
}
void KGameProcess::processArgs(int argc, char *argv[])
{
int v=0;
if (argc>2)
{
v=atoi(argv[2]);
//kdDebug(11001) << "cookie (unused) " << v << endl;
}
if (argc>1)
{
v=atoi(argv[1]);
//kdDebug(11001) << "id (unused) " << v << endl;
}
fprintf(stderr,"processArgs \n");
fflush(stderr);
}
void KGameProcess::receivedMessage(const TQByteArray& receiveBuffer)
{
TQDataStream stream(receiveBuffer, IO_ReadOnly);
int msgid;
TQ_UINT32 sender;
TQ_UINT32 receiver;
KGameMessage::extractHeader(stream, sender, receiver, msgid);
fprintf(stderr,"------ receiveNetworkTransmission(): id=%d sender=%d,recv=%d\n",msgid,sender,receiver);
switch(msgid)
{
case KGameMessage::IdTurn:
TQ_INT8 b;
stream >> b;
emit signalTurn(stream,(bool)b);
break;
case KGameMessage::IdIOAdded:
TQ_INT16 id;
stream >> id;
emit signalInit(stream,(int)id);
break;
default:
emit signalCommand(stream,msgid-KGameMessage::IdUser,receiver,sender);
break;
}
}
#include "kgameprocess.moc"