denBasicService.cpp

Go to the documentation of this file.

#include "denBasicService.h"

denBasicService::denBasicService(FakeGPSProvider *gps, FakeApplicationProvider *appli, ParameterDENM *denm, GeoNet *gn,
                                 ParameterConfiguration *conf, FakeCANProvider *can, ParameterNetwork *network)
{

    m_denm2app = new QUdpSocket(this);
    m_denm2app->bind();
    network->addPort("DENM", m_denm2app->localPort());
    QObject::connect(m_denm2app, SIGNAL(readyRead()), this, SLOT(getAppRequest()));
    m_appliPort = network->internalPort("Application");

    m_paramAppli = appli;
    m_paramDENM = denm;

    m_denmReception = new denReceptionManagement(gps, appli, denm, gn, conf, can, network);
    m_denmReceptionThread = new QThread;
    m_denmTriggering = new denTriggeringManagement(gps, appli, denm, gn, conf, can, network);
    m_denmTriggeringThread = new QThread;
    if(m_paramDENM->kaf())
    {
        m_denKAF = new denKAFManagement(gps, appli, gn);
        m_denKAFThread = new QThread;
        m_denKAF->moveToThread(m_denKAFThread);
        QObject::connect(m_denmReception, SIGNAL(kaf(DENM_t*)), m_denKAF, SLOT(kaf(DENM_t*)));
        QObject::connect(this, SIGNAL(utInitializeSignal()), m_denKAF, SLOT(utInitialize()));
        m_denKAFThread->start();
    }
    else
    {
        m_denKAF = 0;
        m_denKAFThread = 0;
    }

    m_denmReception->moveToThread(m_denmReceptionThread);
    m_denmTriggering->moveToThread(m_denmTriggeringThread);

    QObject::connect(m_denmReceptionThread, SIGNAL(started()), m_denmReception, SLOT(execute()));
    QObject::connect(m_denmTriggering, SIGNAL(setSequenceNumberSignal(quint16)),
                     m_denmReception, SLOT(setSequenceNumberSlot(quint16)));
    QObject::connect(m_denmReception, SIGNAL(setSequenceNumberSignal(quint16)),
                     m_denmTriggering, SLOT(setSequenceNumberSlot(quint16)));
    QObject::connect(this, SIGNAL(utInitializeSignal()), m_denmReception, SLOT(utInitialize()));
    QObject::connect(this, SIGNAL(utInitializeSignal()), m_denmTriggering, SLOT(utInitialize()));
    QObject::connect(m_denmReception, SIGNAL(appendTriggeredDenm(denMessageTableSource*)),
                     m_denmTriggering, SLOT(appendTriggeredDenm(denMessageTableSource*)));
    QObject::connect(m_denmReception, SIGNAL(appDenmResult(QByteArray)), this, SLOT(appDenmResult(QByteArray)));
    QObject::connect(m_denmTriggering, SIGNAL(appDenmResult(QByteArray)), this, SLOT(appDenmResult(QByteArray)));

    m_denmReceptionThread->start();
    m_denmTriggeringThread->start();
}

void denBasicService::appDenmResult(QByteArray msg)
{
    qDebug() << msg.toHex() << "sent to" << m_appliAddr << m_appliPort;
    m_denm2app->writeDatagram(msg, QHostAddress::LocalHost, m_appliPort);
}

void denBasicService::utInitialize()
{
    sleep(1);
    m_denmTriggering->utInitialize();
    m_denmReception->utInitialize();
    if(m_denKAF)
        m_denKAF->utInitialize();
    QThread::sleep(1);
    qDebug() << "denUtInitialize ended";
}

void denBasicService::getAppRequest()
{

    while(m_denm2app->hasPendingDatagrams())
    {
        QNetworkDatagram datagram = m_denm2app->receiveDatagram();

        qInfo() << "DEN Basic service (" << m_denm2app->localPort() << ") received" << datagram.data().toHex() << "from" << datagram.senderPort();

        m_appliPort = datagram.senderPort();
        m_appliAddr = datagram.senderAddress();

        if(datagram.data().at(0) == m_paramDENM->mtAppDENMTrigger())
            m_denmTriggering->AppDENM_trigger(datagram.data());
        else if(datagram.data().at(0) == m_paramDENM->mtAppDENMUpdate())
            m_denmTriggering->AppDENM_update(datagram.data());
        else if(datagram.data().at(0) == m_paramDENM->mtAppDENMTermination())
            AppDENM_terminate(datagram.data());
        qInfo() << "DEN Basic service finished";
    }
}



void denBasicService::AppDENM_terminate(QByteArray datagram)
{
    AppDenmTerminationData termination(datagram);
    ActionID_t actionID;

    actionID.originatingStationID = termination.actionID().originatingStationID();
    actionID.sequenceNumber = termination.actionID().sequenceNumber();

    if(actionID.originatingStationID == m_paramAppli->data().stationID())
        m_denmTriggering->AppDENM_cancellation(termination, actionID);
    else
        m_denmReception->AppDENM_negation(termination, actionID);
}