proxyobject.cpp

#include "proxyobject.h"
#include <QDebug>
#include <QSettings>
#include <QString>
#include <QTcpSocket>
#include <QTimerEvent>
#include <QHostInfo>
using namespace ZPNetwork;
extern quint64 g_bytesRecieved ;
extern quint64 g_bytesSent ;
extern quint64 g_secRecieved ;
extern quint64 g_secSent ;
ProxyObject::ProxyObject(QObject *parent)
	: QObject(parent)
	, engine(new ZPNetwork::zp_net_Engine(2048,this))
{
	connect (engine, &zp_net_Engine::evt_Message, this, &ProxyObject::slot_Message );
	connect (engine, &zp_net_Engine::evt_SocketError, this, &ProxyObject::slot_SocketError );
	connect (engine, &zp_net_Engine::evt_NewClientConnected, this, &ProxyObject::slot_NewClientConnected );
	connect (engine, &zp_net_Engine::evt_ClientDisconnected, this, &ProxyObject::slot_ClientDisconnected );
	connect (engine, &zp_net_Engine::evt_Data_recieved, this, &ProxyObject::slot_Data_recieved );
	connect (engine, &zp_net_Engine::evt_Data_transferred, this, &ProxyObject::slot_Data_transferred );
	initEngine();
	m_nTimerRefresh = startTimer(1000);
}
void ProxyObject::slot_Message(QObject * pSource,QString message )
{
	QString msg = message + tr(",Source=%1").arg((quint64)pSource);
	qDebug()<<msg;
}
void ProxyObject::initEngine()
{
	engine->AddListeningAddress("SQLServer",QHostAddress("127.0.0.1"),1433,false);
	engine->AddClientTransThreads(2,false);
}

//The socket error message
void ProxyObject::slot_SocketError(QObject * senderSock ,QAbstractSocket::SocketError socketError)
{
	QString msg = tr(",Source=%1, SockError = %2").arg((quint64)senderSock).arg((quint64)socketError);
	qWarning()<<msg;
}

//this event indicates new client connected.
void ProxyObject::slot_NewClientConnected(QObject * clientHandle)
{
	QTcpSocket * sock = qobject_cast<QTcpSocket *> (clientHandle);
	if (sock)
	{
		QString pn = sock->peerName();
		if (pn.length())
		{
			qDebug()<<"Outer side " << pn<<":"<<sock->peerPort()<<" Connected";
			if (m_list_pendingInners.size())
			{
				QObject * innerClient = m_list_pendingInners.first();
				m_list_pendingInners.pop_front();
				m_hash_Inner2Outer[innerClient] = clientHandle;
				m_hash_Outer2Inner[clientHandle] = innerClient;
				if (penging_data.contains(innerClient))
				{
					while (penging_data[innerClient].empty()==false)
					{
						engine->SendDataToClient(clientHandle,penging_data[innerClient].first());
						penging_data[innerClient].pop_front();
					}
					penging_data.remove(innerClient);
				}
				if (penging_data.contains(clientHandle))
				{
					while (penging_data[clientHandle].empty()==false)
					{
						engine->SendDataToClient(innerClient,penging_data[clientHandle].first());
						penging_data[clientHandle].pop_front();
					}
					penging_data.remove(clientHandle);
				}
			}
		}
		else
		{
			qDebug()<<"Inner side "<<sock->peerAddress().toString()<<":"<<sock->peerPort()<<" Connected";
			m_list_pendingInners.push_back(clientHandle);
			QHostInfo info = QHostInfo::fromName("hds150188277.my3w.com");
			QList<QHostAddress> lstaddr = info.addresses();
			qDebug()<<lstaddr.size();
			if (lstaddr.size())
				engine->connectTo(QHostAddress(lstaddr.first().toString()),1433,false);
			else
			{
				qWarning()<<"Address Not found in DNS.";
				engine->KickClients(clientHandle);
			}
		}

	}
}

//this event indicates a client disconnected.
void ProxyObject::slot_ClientDisconnected(QObject * clientHandle)
{
	penging_data.remove(clientHandle);
	m_hash_Inner2Outer.remove(clientHandle);
	m_hash_Outer2Inner.remove(clientHandle);
}

//some data arrival
void ProxyObject::slot_Data_recieved(QObject *  clientHandle,QByteArray  datablock )
{
	if (m_hash_Inner2Outer.contains(clientHandle))
		engine->SendDataToClient(m_hash_Inner2Outer[clientHandle],datablock);
	else if (m_hash_Outer2Inner.contains(clientHandle))
		engine->SendDataToClient(m_hash_Outer2Inner[clientHandle],datablock);
	else
		penging_data[clientHandle].push_back(datablock);
}

//a block of data has been successfuly sent
void ProxyObject::slot_Data_transferred(QObject *   clientHandle,qint64 bytes_sent)
{

}

void ProxyObject::timerEvent(QTimerEvent *event)
{
	if (event->timerId()==m_nTimerRefresh)
	{
		fprintf (stdout,"Send %.2lf MB(%.2lfkbps) Rev %.2lf MB (%.2lfkbps)                \r",
				g_bytesRecieved/1024.0/1024.0,
				g_secRecieved /1024.0*8,
				g_bytesSent/1024.0/1024.0,
				g_secSent/1024.0*8
				);
		g_secRecieved = 0;
		g_secSent = 0;

	}
}