denReceptionManagement.h

Go to the documentation of this file.

#ifndef denReceptionManagement_H
#define denReceptionManagement_H

#include <QObject>
#include <QUdpSocket>
#include <constantes.h>
#include <api.h>
#include <UpperTesterPrimitives.h>
#include <ParameterDENM.h>
#include <QNetworkDatagram>
#include <QMutex>

#include <DENM.h>

#include <AppDenmTriggerData.h>
#include <AppDenmIndication.h>
#include <AppDenmTerminationIndication.h>

#include <denMessageTableSource.h>
#include <denMessageTableReception.h>

#include <apiDenBasicService.h>
#include <Geonet.h>

class denReceptionManagement : public QObject
{
    Q_OBJECT
public:
    denReceptionManagement(FakeGPSProvider *gps, FakeApplicationProvider *appli, ParameterDENM *denm, GeoNet *gn,
                           ParameterConfiguration *conf, FakeCANProvider *can, ParameterNetwork *network);
    ~denReceptionManagement();

    void decodeDenm(QByteArray data);
    void denmReception(DENM_t*);
    void AppDENM_negation(AppDenmTerminationData termination, ActionID_t actionID);
    void sendRequestResponseIndication_Response(SituationContainer_t *s, ActionID_t originatingActionID);
    bool PassDenmToNetworkAndTransportLayerTrigger(AppDenmTriggerData data, char *msg, int denmLength);
    void AppDENM_result(ActionID_t actionID, bool success, AppDenmResultData::e_failureNotification failureNotification, DENM_t *denm);

    void setSequenceNumber(SequenceNumber_t s){m_sequenceNumber = s;}

    void discardDENM(int index);
    void killReceptionThreads();

signals:
    void setSequenceNumberSignal(quint16);
    void appendTriggeredDenm(denMessageTableSource*);
    void appDenmResult(QByteArray);
    void kaf(DENM_t *);

public slots:
    void utInitialize();
    //void execute();
    void setSequenceNumberSlot(quint16);
    void discardDENMFromReceivedTable(ActionID_t);
    void readDatagram();

private:
//    void denmEventIndication(uchar* packet, quint16 packetLen);
    QVector<denMessageTableReception*> m_receivedDENM;
    SequenceNumber_t m_sequenceNumber;
    GeoNet *m_geonet;
    QMutex *m_mutexReception; 
    FakeGPSProvider* m_paramGPS;
    FakeApplicationProvider* m_paramAppli;
    ParameterDENM* m_paramDENM;
    ParameterConfiguration* m_paramConf;
    FakeCANProvider* m_paramCan;
    QUdpSocket* denm2app;
    QUdpSocket* m_internalSocket;
    quint16 appPort;
};

#endif // denReceptionManagement_H