src/gatscon/clientthread.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

#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 );
	}
}