#include "datacenter.h"
//#include "../../WebInterface/WebDataCore/WebDataShm.h"
#include "ytservicecore.h"

DataCenter::DataCenter(QObject *parent) :
    QTcpServer(parent)
{

}

void DataCenter::start()
{
    if(!this->listen(QHostAddress::Any,55332)){
        exit(-1);
    }
    printf("Listening at 55332\n");
}

void DataCenter::incomingConnection(qintptr socketDescriptor)
{
    WebDataThread *thread = new WebDataThread(socketDescriptor,this);
    connect(thread,&WebDataThread::needSync,this,&DataCenter::eneedSync);
    connect(thread,&WebDataThread::finished,thread,&WebDataThread::quit);
    thread->start();
}

void DataCenter::eneedSync(QString deviceCode)
{
    emit needSync(deviceCode);
}