Facilities.cpp

Go to the documentation of this file.

#include "Facilities.h"

Facilities::Facilities(Manager *man, GeoNet *geonet, bool cam, bool denm, bool bluetooth, bool ut, QMutex* mutex)
{
    m_mutex = mutex;
    if(m_mutex != 0)
        m_mutex->lock();

    m_geonet = geonet;
    m_paramGPS = (FakeGPSProvider*)man->hashMap["GPS"];
    m_paramConf = (ParameterConfiguration*)man->hashMap["Configuration"];
    m_paramAppli = (FakeApplicationProvider*)man->hashMap["Application"];
    m_paramCAN = (FakeCANProvider*)man->hashMap["CAN"];
    m_paramDENM = (ParameterDENM*)man->hashMap["DENM"];
    m_paramUt = (ParameterUpperTester*)man->hashMap["UpperTester"];
    m_paramNetwork = (ParameterNetwork*)man->hashMap["Network"];
    m_cam = cam;
    m_denm = denm;
    m_bluetooth = bluetooth;
    m_ut = ut;

    if(!m_cam && !m_denm)
    {
        m_cam=true;
        m_denm=true;
    }

    if(m_mutex != 0)
        m_mutex->unlock();
}

void Facilities::execute()
{
    if(m_mutex != 0)
        m_mutex->lock();

    if(m_cam)
    {
        threadCA = new QThread;
        m_caBasicService = new caBasicService(m_geonet, m_paramGPS, m_paramConf, m_paramAppli, m_paramCAN);
        m_caBasicService->moveToThread(threadCA);
        QObject::connect(threadCA, SIGNAL(started()), m_caBasicService, SLOT(execute()));
        threadCA->start();

        QThread* threadCARM = new QThread;
        caReceptionManagement* ca = new caReceptionManagement(m_paramNetwork);
        ca->moveToThread(threadCARM);
        QObject::connect(threadCARM, SIGNAL(started()), ca, SLOT(execute()));
        threadCARM->start();
    }

    if(m_denm)
    {
        printf("DUT=%d\n", m_ut);
        threadDEN = new QThread;
        m_denBasicService = new denBasicService(m_paramGPS, m_paramAppli, m_paramDENM, m_geonet, m_paramConf, m_paramCAN,
                                                m_paramNetwork);
        m_denBasicService->moveToThread(threadDEN);
        //QObject::connect(threadDEN, SIGNAL(started()), m_denBasicService, SLOT(getAppRequest()));
        threadDEN->start();
    }

    if(m_mutex != 0)
        m_mutex->unlock();
}

void Facilities::getNetworkAndTransportLayerIndication()
{
    while(udpSocket_ind->hasPendingDatagrams())
    {
        quint16 destination;
        QByteArray datagram;
        datagram.resize(udpSocket_ind->pendingDatagramSize());

        udpSocket_ind->readDatagram(datagram.data(), datagram.size());
        destination = split((const unsigned char*)datagram.data(), 0, 2);
/*
        switch (destination)
        {
        case btpPort_CAM:
            udpSocket_ind->writeDatagram(datagram, QHostAddress::LocalHost, btpPort_CAM);
            break;
        case btpPort_DENM:
            udpSocket_ind->writeDatagram(datagram, QHostAddress::LocalHost, btpPort_DENM);
            break;
        default:
            break;
        }
*/
        udpSocket_ind->writeDatagram(datagram, QHostAddress::LocalHost, destination);
    }
}

void Facilities::utInitialize()
{
    if(m_cam)
        m_caBasicService->utInitialize();
    if(m_denm)
        m_denBasicService->utInitialize();
}