main.cpp

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#include <iostream>
#include "swarm_mock_daemon.h"
 
/*---------------------------------------------------------------------------------------
Configuration:
- localhost:3390 is the Recv mock file to stop the Daemon
- localhost:3391 is the Send mock file to test the Daemon
 
Workflow :
1. We mock the fact that the 'test' daemon sends two data (a Shadok and a Gibis) to the 'main' Daemon using the mock file 'main_localhost_3390'.
2. The main daemon is configured to have callable functions to process Shadok and Gibis data. 
So as we read a data from the mock file, it deserializes it and process it using the appropriate type.
3. The main daemon has also an extraLoopProcessing function that checks if the data received have the expected type (here one Shadok and one Gibis).
4. THen in the mock file 'main_localhost_3391', we mock the fact that the 'main' Daemon has sent a confirmation message for each data received.
5. Finally, the 'main' Daemon is stopped by a STOP message from another daemon
 
+----------------+                      +-----------------------------------+   +---------------------------------------+
|   main daemon  |                      |  Mock file (main_localhost_3390)  |   |  Mock file (main_localhost_3391)      |
+----------------+                      +-----------------------------------+   +---------------------------------------+
                |                                                                                |                                                                               |
                | <--- RESULT_DATA (Shadok)--------------|                                                                               |
                |                                                                                |                                                                               |
                |  --- MESSAGE_CONFIRMATION (Shadok) ----------------------------------------->  |
                |                                                                                |                                                                               |
                | <--- RESULT_DATA (Gibis) --------------|                                                                               |
                |                                                                                |                                                                               |
                |  --- MESSAGE_CONFIRMATION (Gibis) ------------------------------------------>  |
                |                                                                                |                                                                               |
                |  <--- STOP message ---------------     |                                                                               |
                |                                                                                |                                                                               |
-----------------------------------------------------------------------------------------*/


void createMockFileMainSend(const PString & hostName, size_t port, const PString & prefix){
        PMockSocketGenerator::Socket mock;
        phoenix_assert(phoenix_initializeMockSocket(mock, PSocketParam{hostName, port}, prefix));
        PVecMockMessage vecOutput;
        //At time 0, whe receive a confiramtion for the Shadok message sent
        Message confirmationShadok;
        confirmationShadok.setSendTime(0lu);
        confirmationShadok.setId(1lu);
        confirmationShadok.setSender("main");
        confirmationShadok.setType(MessageType::MESSAGE_CONFIRMATION);
        confirmationShadok.getVecRecver().push_back("test");
        mock.sendData(confirmationShadok);
 
        //At time 1, we receive a confirmation for the Gibis message sent
        Message confirmationGibis;
        confirmationGibis.setSendTime(1lu);
        confirmationGibis.setId(2lu);
        confirmationGibis.setSender("main");
        confirmationGibis.setType(MessageType::MESSAGE_CONFIRMATION);
        confirmationGibis.getVecRecver().push_back("test");
        mock.sendData(confirmationGibis);
}


void createMockFileMainRecv(const PString & hostName, size_t port, const PString & prefix){
        PMockSocketGenerator::Socket mock;
        phoenix_assert(phoenix_initializeMockSocket(mock, PSocketParam{hostName, port}, prefix));
 
        //We receive a Shadok message
        Message shadokMsg;
        shadokMsg.setId(1lu);
        shadokMsg.setSendTime(0lu);
        shadokMsg.setIsConfirmationNeeded(true);
        shadokMsg.setType(MessageType::RESULT_DATA);
        shadokMsg.setSender("test");
        Shadok shadok("Bob", 42);
        shadokMsg.setData(phoenix_createData(shadok));
        shadokMsg.getVecRecver().push_back("main");
        mock.sendData(shadokMsg);
 
        //We receive a Gibis message
        Message gibisMsg;
        gibisMsg.setId(2lu);
        gibisMsg.setSendTime(1lu);
        gibisMsg.setIsConfirmationNeeded(true);
        gibisMsg.setType(MessageType::RESULT_DATA);
        gibisMsg.setSender("test");
        Gibis gibis("Red", 100);
        gibisMsg.setData(phoenix_createData(gibis));
        gibisMsg.getVecRecver().push_back("main");
        mock.sendData(gibisMsg);
 
        //Finally we stop the Daemon
        Message messageStop;
        messageStop.setId(3lu);
        messageStop.setType(MessageType::STOP);
        mock.sendData(messageStop);
}


void createDaemon(const PPath & fileName, const PString & daemonName){
        RecvDataDaemon daemon;
        daemon.setSocketMode(PSocketMode::MOCK);
        daemon.setClockMode(PClockMode::MOCK);
        phoenix_assert(daemon.load(fileName, daemonName));
        phoenix_assert(daemon.run());
}


void testMonitoring(const PPath & fileName){
        phoenix_createClockMock("main_", 4lu);
        createMockFileMainSend("localhost", 3391lu, "main_");
        createMockFileMainRecv("localhost", 3390, "main_");
        createDaemon(fileName, "main");
}
 
int main(int argc, char** argv){
        testMonitoring(PPath(DAEMON_CONFIG_OK));
        return 0;
}