main.cpp File Reference

#include <iostream>
#include "swarm_mock_daemon.h"

Include dependency graph for main.cpp:

Go to the source code of this file.

Functions
void	createDaemon (const PPath &fileName, const PString &daemonName)
	Create a simple Daemon stat manager.
void	createMockFileMainRecv (const PString &hostName, size_t port, const PString &prefix)
	Simulate data to send.
void	createMockFileMainSend (const PString &hostName, size_t port, const PString &prefix)
	Simulate data to send.
int	main (int argc, char **argv)
void	testMonitoring (const PPath &fileName)
	Test a simple Daemon stat manager.

Function Documentation

createDaemon()

void createDaemon	(	const PPath &	fileName,
		const PString &	daemonName )

Create a simple Daemon stat manager.

Parameters

fileName	: Daemon configuration
daemonName	: name of the current Daemon

Definition at line 109 of file main.cpp.

                                                                     {
        RecvDataDaemon daemon;
        daemon.setSocketMode(PSocketMode::MOCK);
        daemon.setClockMode(PClockMode::MOCK);
        phoenix_assert(daemon.load(fileName, daemonName));
        phoenix_assert(daemon.run());
}

Referenced by testBaseDaemonLoadConfig(), and testMonitoring().

Here is the caller graph for this function:

createMockFileMainRecv()

void createMockFileMainRecv	(	const PString &	hostName,
		size_t	port,
		const PString &	prefix )

Simulate data to send.

Parameters

mockName

: name of the associated mock

Definition at line 70 of file main.cpp.

                                                                                          {
        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);
}

References phoenix_createData(), MessageType::RESULT_DATA, and MessageType::STOP.

Referenced by testBaseDaemonLoadConfig(), and testMonitoring().

Here is the call graph for this function:

Here is the caller graph for this function:

createMockFileMainSend()

void createMockFileMainSend	(	const PString &	hostName,
		size_t	port,
		const PString &	prefix )

Simulate data to send.

Parameters

hostName	: name of the host
port	: port to be used
prefix	: prefix of the mock file of the current test

Definition at line 44 of file main.cpp.

                                                                                          {
        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);
}

References MessageType::MESSAGE_CONFIRMATION.

Referenced by testBaseDaemonLoadConfig(), and testMonitoring().

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char **	argv )

Definition at line 127 of file main.cpp.

                               {
        testMonitoring(PPath(DAEMON_CONFIG_OK));
        return 0;
}

References testMonitoring().

Here is the call graph for this function:

testMonitoring()

void testMonitoring

(

const PPath &

fileName

)

Test a simple Daemon stat manager.

Parameters

fileName

: Daemon configuration

Definition at line 120 of file main.cpp.

                                           {
        phoenix_createClockMock("main_", 4lu);
        createMockFileMainSend("localhost", 3391lu, "main_");
        createMockFileMainRecv("localhost", 3390, "main_");
        createDaemon(fileName, "main");
}

References createDaemon(), createMockFileMainRecv(), and createMockFileMainSend().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function: