#include "clientthread.h"

#include <bu/tcpsocket.h>

ClientThread::ClientThread( QObject *pParent, const QByteArray &baHost,
		int iPort ) :
	QThread( pParent ),
	baHost( baHost ),
	iPort( iPort ),
	gsCli( ssCli )
{
}

ClientThread::~ClientThread()
{
}

void ClientThread::send( Gats::Object *pObj )
{
	gsCli.writeObject( pObj );
}

void ClientThread::run()
{
	ssCli.setStream(
		new Bu::TcpSocket( baHost.constData(), iPort )
		);

	while( !ssCli.isEos() )
	{
		Gats::Object *pObj = gsCli.readObject();
		if( pObj == NULL )
			continue;

		emit recv( pObj );
	}
}