main.cpp File Reference

#include <iostream>
#include "phoenix_assert.h"
#include "BaseDaemon.h"
#include "Representation.h"

Include dependency graph for main.cpp:

Go to the source code of this file.

Classes
class	TestBaseDaemon
	Test Daemon. More...

Functions
StatAccumulator	createTestStatAccumulator ()
	Create stat accumulator.
int	main (int argc, char **argv)
void	testBaseDaemonGetMessageToConfirm ()
	Get a BaseDaemon with a message to confirm.
void	testBaseDaemonLoadConfigJson (const PPath &fileName)
	Test the load configuration of a BaseDaemon.
void	testBaseDaemonLoadConfigJsonString (const PPath &fileName)
	Test the load configuration of a BaseDaemon from a JSON string.
void	testBaseDaemonLoadConfigToml (const PPath &fileName)
	Test the load configuration of a BaseDaemon.
void	testBaseDaemonLoadConfigTomlString (const PPath &fileName)
	Test the load configuration of a BaseDaemon from a string TOML.
void	testBaseDaemonLoadConfigYml (const PPath &fileName)
	Test the load configuration of a BaseDaemon.
void	testBaseDaemonLoadConfigYmlString (const PPath &fileName)
	Test the load configuration of a BaseDaemon from a string YAML.
void	testBaseDaemonMissingDaemonSectionJsonFile ()
	Test BaseDaemon with missing daemon section in JSON file.
void	testBaseDaemonMissingDaemonSectionJsonString ()
	Test BaseDaemon with missing daemon section in JSON string config.
void	testBaseDaemonMissingDaemonSectionTomlFile ()
	Test BaseDaemon with missing daemon section in TOML file.
void	testBaseDaemonMissingDaemonSectionTomlString ()
	Test BaseDaemon with missing daemon section in TOML string config.
void	testBaseDaemonMissingDaemonSectionYmlFile ()
	Test BaseDaemon with missing daemon section in YML file.
void	testBaseDaemonMissingDaemonSectionYmlString ()
	Test BaseDaemon with missing daemon section in YAML string config.
void	testBaseDaemonParseArgument (const char *configFile, const char *daemonName)
	Test the parse argument of a BaseDaemon.
void	testBaseDaemonProcessConfirmedMessage (const PPath &fileName)
	Test BaseDaemon with a message to process.
void	testClearStatAccumulator ()
	Test the clear of StatAccumulator in BaseDaemon.
void	testFillDaemonStat ()
	Test the fill of Daemon stats.
void	testFillVecStat ()
	Test the fill vector of stats.
void	testUpdateStatAccumulator ()
	Test the update of a StatAccumulator.

Function Documentation

createTestStatAccumulator()

StatAccumulator createTestStatAccumulator

(

)

Create stat accumulator.

Returns

StatAccumulator

Definition at line 304 of file main.cpp.

                                            {
        StatAccumulator stat;
        stat.setNbEvent(4lu);
        stat.setMin(2.0f);
        stat.setMax(8.0f);
        stat.setSum(20.0f);
        stat.setNbEventBelowLowerBound(1lu);
        stat.setNbEventAboveUpperBound(1lu);
        stat.setHistLowerBound(0.0f);
        stat.setHistUpperBound(10.0f);
        stat.setVecHistogram(std::vector<size_t>(5, 0lu));
        stat.getVecHistogram()[1] = 1lu; //bin for 2.0
        stat.getVecHistogram()[4] = 1lu; //bin for 8.0
        return stat;
}

References Swarm::StatAccumulator::getVecHistogram(), Swarm::StatAccumulator::setHistLowerBound(), Swarm::StatAccumulator::setHistUpperBound(), Swarm::StatAccumulator::setMax(), Swarm::StatAccumulator::setMin(), Swarm::StatAccumulator::setNbEvent(), Swarm::StatAccumulator::setNbEventAboveUpperBound(), Swarm::StatAccumulator::setNbEventBelowLowerBound(), Swarm::StatAccumulator::setSum(), and Swarm::StatAccumulator::setVecHistogram().

Referenced by testFillDaemonStat(), and testFillVecStat().

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char **	argv )

Definition at line 373 of file main.cpp.

                               {
        
        testBaseDaemonMissingDaemonSectionTomlString();
        testBaseDaemonMissingDaemonSectionYmlString();
        testBaseDaemonMissingDaemonSectionJsonString();
        
        testBaseDaemonMissingDaemonSectionTomlFile();
        testBaseDaemonMissingDaemonSectionYmlFile();
        testBaseDaemonMissingDaemonSectionJsonFile();
        
        testBaseDaemonLoadConfigToml(PPath(DAEMON_CONFIG_OK_TOML));
        testBaseDaemonLoadConfigTomlString(PPath(DAEMON_CONFIG_OK_TOML));
        testBaseDaemonLoadConfigYml(PPath(DAEMON_CONFIG_OK_YAML));
        testBaseDaemonLoadConfigYmlString(PPath(DAEMON_CONFIG_OK_YAML));
        testBaseDaemonLoadConfigJson(PPath(DAEMON_CONFIG_OK_JSON));
        testBaseDaemonLoadConfigJsonString(PPath(DAEMON_CONFIG_OK_JSON));
        testBaseDaemonParseArgument(DAEMON_CONFIG_OK_TOML, "main");
        testBaseDaemonProcessConfirmedMessage(PPath(DAEMON_CONFIG_OK_TOML));
        testBaseDaemonGetMessageToConfirm();
        testUpdateStatAccumulator();
        testClearStatAccumulator();
        testFillVecStat();
        testFillDaemonStat();
        return 0;
}

References testBaseDaemonGetMessageToConfirm(), testBaseDaemonLoadConfigJson(), testBaseDaemonLoadConfigJsonString(), testBaseDaemonLoadConfigToml(), testBaseDaemonLoadConfigTomlString(), testBaseDaemonLoadConfigYml(), testBaseDaemonLoadConfigYmlString(), testBaseDaemonMissingDaemonSectionJsonFile(), testBaseDaemonMissingDaemonSectionJsonString(), testBaseDaemonMissingDaemonSectionTomlFile(), testBaseDaemonMissingDaemonSectionTomlString(), testBaseDaemonMissingDaemonSectionYmlFile(), testBaseDaemonMissingDaemonSectionYmlString(), testBaseDaemonParseArgument(), testBaseDaemonProcessConfirmedMessage(), testClearStatAccumulator(), testFillDaemonStat(), testFillVecStat(), and testUpdateStatAccumulator().

Here is the call graph for this function:

testBaseDaemonGetMessageToConfirm()

void testBaseDaemonGetMessageToConfirm

(

)

Get a BaseDaemon with a message to confirm.

Definition at line 15 of file main.cpp.

                                         {
        BaseDaemon daemon;
        Message msg;
        msg.setId(123);
        msg.setSendTime(time(nullptr));
        msg.getVecRecver().push_back("receiver1");
        daemon.addMessageToConfirm(msg);
 
        Message retrieved;
        phoenix_assert(daemon.getMessageToConfirm(retrieved, 123));
        phoenix_assert(retrieved.getId() == 123);
 
        Message notFound;
        phoenix_assert(!daemon.getMessageToConfirm(notFound, 999));
}

References Swarm::BaseDaemon::addMessageToConfirm(), Swarm::Message::getId(), Swarm::BaseDaemon::getMessageToConfirm(), Swarm::Message::getVecRecver(), Swarm::Message::setId(), and Swarm::Message::setSendTime().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonLoadConfigJson()

void testBaseDaemonLoadConfigJson

(

const PPath &

fileName

)

Test the load configuration of a BaseDaemon.

Parameters

fileName

: name of the configuration json file

Definition at line 191 of file main.cpp.

                                                         {
        BaseDaemon daemon;
        phoenix_assert(daemon.load(fileName, "main"));
        phoenix_assert(daemon.isDaemonExist("other"));
        BaseDaemon daemon2;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon2.load(fileName, "not_in_in_the_list"));
        BaseDaemon daemon3;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ParserException, daemon3.load(PPath("unexisting_config.json"), "main"));
        BaseDaemon daemon4;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ParserException, daemon4.load(PPath("file.nonextension"), "main"));
}

References Swarm::BaseDaemon::isDaemonExist(), and Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonLoadConfigJsonString()

void testBaseDaemonLoadConfigJsonString

(

const PPath &

fileName

)

Test the load configuration of a BaseDaemon from a JSON string.

Parameters

fileName

: nom du fichier de configuration JSON

Definition at line 206 of file main.cpp.

                                                               {
        // Read json file in a string
        PString jsonString = fileName.loadFileContent();
        BaseDaemon daemon;
        daemon.load(jsonString, "main", ConfigFormat::JSON);
        phoenix_assert(daemon.isDaemonExist("other"));
        BaseDaemon daemon2;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon2.load(jsonString, "not_in_in_the_list", ConfigFormat::JSON));
}

References Swarm::BaseDaemon::isDaemonExist(), ConfigFormat::JSON, and Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonLoadConfigToml()

void testBaseDaemonLoadConfigToml

(

const PPath &

fileName

)

Test the load configuration of a BaseDaemon.

Parameters

fileName

: name of the configuration toml file

Definition at line 137 of file main.cpp.

                                                         {
        BaseDaemon daemon;
        daemon.load(fileName, "main");
        phoenix_assert(daemon.isDaemonExist("other"));
        BaseDaemon daemon2;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon2.load(fileName, "not_in_in_the_list"));
        BaseDaemon daemon3;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ParserException, daemon3.load(PPath("unexisting_config.toml"), "main"));
}

References Swarm::BaseDaemon::isDaemonExist(), and Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonLoadConfigTomlString()

void testBaseDaemonLoadConfigTomlString

(

const PPath &

fileName

)

Test the load configuration of a BaseDaemon from a string TOML.

Parameters

fileName

: name of the configuration TOML file

Definition at line 150 of file main.cpp.

                                                               {
        // Read toml file in a string
        PString tomlString = fileName.loadFileContent();
        BaseDaemon daemon;
        daemon.load(tomlString, "main", ConfigFormat::TOML);
        phoenix_assert(daemon.isDaemonExist("other"));
        BaseDaemon daemon2;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon2.load(tomlString, "not_in_in_the_list", ConfigFormat::TOML));
}

References Swarm::BaseDaemon::isDaemonExist(), Swarm::BaseDaemon::load(), and ConfigFormat::TOML.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonLoadConfigYml()

void testBaseDaemonLoadConfigYml

(

const PPath &

fileName

)

Test the load configuration of a BaseDaemon.

Parameters

fileName

: name of the configuration yml file

Definition at line 163 of file main.cpp.

                                                        {
        BaseDaemon daemon;
        daemon.load(fileName, "main");
        phoenix_assert(daemon.isDaemonExist("other"));
        BaseDaemon daemon2;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon2.load(fileName, "not_in_in_the_list"));
        BaseDaemon daemon3;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ParserException, daemon3.load(PPath("unexisting_config.yml"), "main"));
        BaseDaemon daemon4;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ParserException, daemon4.load(PPath("file.nonextension"), "main"));
}

References Swarm::BaseDaemon::isDaemonExist(), and Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonLoadConfigYmlString()

void testBaseDaemonLoadConfigYmlString

(

const PPath &

fileName

)

Test the load configuration of a BaseDaemon from a string YAML.

Parameters

fileName

: name of the configuration YAML file

Definition at line 178 of file main.cpp.

                                                              {
        // Read yaml file in a string
        PString ymlString = fileName.loadFileContent();
        BaseDaemon daemon;
        daemon.load(ymlString, "main", ConfigFormat::YAML);
        phoenix_assert(daemon.isDaemonExist("other"));
        BaseDaemon daemon2;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon2.load(ymlString, "not_in_in_the_list", ConfigFormat::YAML));
}

References Swarm::BaseDaemon::isDaemonExist(), Swarm::BaseDaemon::load(), and ConfigFormat::YAML.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonMissingDaemonSectionJsonFile()

void testBaseDaemonMissingDaemonSectionJsonFile

(

)

Test BaseDaemon with missing daemon section in JSON file.

Definition at line 121 of file main.cpp.

                                                 {
        PPath tempFile = PPath("test_no_daemon_section.json");
        PString invalidJsonConfig = R"({
"other_section": {
        "name": "test",
        "value": 42
}
})";
        tempFile.saveFileContent(invalidJsonConfig);
        BaseDaemon daemon;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon.load(tempFile, "main"));
}

References Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonMissingDaemonSectionJsonString()

void testBaseDaemonMissingDaemonSectionJsonString

(

)

Test BaseDaemon with missing daemon section in JSON string config.

Definition at line 80 of file main.cpp.

                                                   {
        PString invalidJsonConfig = R"({
"other_section": {
        "name": "test",
        "value": 42
},
"another_section": {
        "host": "localhost"
}
})";
        BaseDaemon daemon;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon.load(invalidJsonConfig, "main", ConfigFormat::JSON));
}

References ConfigFormat::JSON, and Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonMissingDaemonSectionTomlFile()

void testBaseDaemonMissingDaemonSectionTomlFile

(

)

Test BaseDaemon with missing daemon section in TOML file.

Definition at line 95 of file main.cpp.

                                                 {
        PPath tempFile = PPath("test_no_daemon_section.toml");
        PString invalidTomlConfig = R"(
[other_section]
name = "test"
value = 42
)";
        tempFile.saveFileContent(invalidTomlConfig);
        BaseDaemon daemon;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon.load(tempFile, "main"));
}

References Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonMissingDaemonSectionTomlString()

void testBaseDaemonMissingDaemonSectionTomlString

(

)

Test BaseDaemon with missing daemon section in TOML string config.

Definition at line 52 of file main.cpp.

                                                   {
        PString invalidTomlConfig = R"(
[other_section]
name = "test"
value = 42
 
[another_section]
host = "localhost"
)";
        BaseDaemon daemon;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon.load(invalidTomlConfig, "main", ConfigFormat::TOML));
}

References Swarm::BaseDaemon::load(), and ConfigFormat::TOML.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonMissingDaemonSectionYmlFile()

void testBaseDaemonMissingDaemonSectionYmlFile

(

)

Test BaseDaemon with missing daemon section in YML file.

Definition at line 108 of file main.cpp.

                                                {
        PPath tempFile = PPath("test_no_daemon_section.yml");
        PString invalidYmlConfig = R"(
other_section:
  name: "test"
  value: 42
)";
        tempFile.saveFileContent(invalidYmlConfig);
        BaseDaemon daemon;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon.load(tempFile, "main"));
}

References Swarm::BaseDaemon::load().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonMissingDaemonSectionYmlString()

void testBaseDaemonMissingDaemonSectionYmlString

(

)

Test BaseDaemon with missing daemon section in YAML string config.

Definition at line 66 of file main.cpp.

                                                  {
        PString invalidYmlConfig = R"(
other_section:
  name: "test"
  value: 42
 
another_section:
  host: "localhost"
)";
        BaseDaemon daemon;
        PHOENIX_EXCEPTION_TYPE_ASSERT(Phoenix::ConfigException, daemon.load(invalidYmlConfig, "main", ConfigFormat::YAML));
}

References Swarm::BaseDaemon::load(), and ConfigFormat::YAML.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonParseArgument()

void testBaseDaemonParseArgument	(	const char *	configFile,
		const char *	daemonName )

Test the parse argument of a BaseDaemon.

Parameters

configFile	: name of the configuration file
daemonName	: name of the daemon to load

Definition at line 220 of file main.cpp.

                                                                                 {
        const char* argv[] = {
                "phoenix_daemon",
                "--daemonconfig", configFile,
                "--daemonname", daemonName
        };
        int argc = sizeof(argv) / sizeof(argv[0]);
        BaseDaemon daemon;
        phoenix_assert(daemon.parseArgument(argc, const_cast<char**>(argv)));
        daemon.stop();
        phoenix_assert(daemon.isDaemonExist("other"));
}

References Swarm::BaseDaemon::isDaemonExist(), Swarm::BaseDaemon::parseArgument(), and Swarm::BaseDaemon::stop().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testBaseDaemonProcessConfirmedMessage()

void testBaseDaemonProcessConfirmedMessage

(

const PPath &

fileName

)

Test BaseDaemon with a message to process.

Parameters

fileName

: configuration of the Daemon

Definition at line 34 of file main.cpp.

                                                                   {
        BaseDaemon daemon;
        daemon.load(fileName, "main");
 
        Message msg;
        msg.setId(456);
        msg.setSendTime(3lu);
        msg.setData(Data());
        msg.getVecRecver().push_back("receiver2");
        daemon.addMessageToConfirm(msg);
 
        // Confirm the message
        daemon.processConfirmedMessage(456, 5lu);
        Message shouldNotExist;
        phoenix_assert(!daemon.getMessageToConfirm(shouldNotExist, 456));
}

References Swarm::BaseDaemon::addMessageToConfirm(), Swarm::BaseDaemon::getMessageToConfirm(), Swarm::Message::getVecRecver(), Swarm::BaseDaemon::load(), Swarm::BaseDaemon::processConfirmedMessage(), Swarm::Message::setData(), Swarm::Message::setId(), and Swarm::Message::setSendTime().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testClearStatAccumulator()

void testClearStatAccumulator

(

)

Test the clear of StatAccumulator in BaseDaemon.

Definition at line 265 of file main.cpp.

                               {
        BaseDaemon daemon;
        StatAccumulator stat;
        stat.setHistLowerBound(0.0f);
        stat.setHistUpperBound(10.0f);
        stat.setVecHistogram(std::vector<size_t>(5, 0lu)); //5 bins
 
        daemon.getConfig().getDaemonStatAccumulator().getMapStatComputing()["stat_name"] = stat;
        daemon.getConfig().getDaemonStatAccumulator().getMapStatCommunication()["daemon_name"]["stat_name"] = stat;
 
        phoenix_assert(!daemon.getConfig().getDaemonStatAccumulator().getMapStatComputing().empty());
        phoenix_assert(!daemon.getConfig().getDaemonStatAccumulator().getMapStatCommunication().empty());
 
        daemon.clearStat();
        for(MapStatAccumulator::const_iterator it = daemon.getConfig().getDaemonStatAccumulator().getMapStatComputing().begin();
                it != daemon.getConfig().getDaemonStatAccumulator().getMapStatComputing().end(); ++it)
        {
                phoenix_assert(it->second.getNbEvent() == 0lu);
                for(std::vector<size_t>::const_iterator vit = it->second.getVecHistogram().begin();
                        vit != it->second.getVecHistogram().end(); ++vit) {
                        phoenix_assert(*vit == 0lu);
                }
        }
        for(MapDaemonStatAccumulator::const_iterator itMap = daemon.getConfig().getDaemonStatAccumulator().getMapStatCommunication().begin();
                itMap != daemon.getConfig().getDaemonStatAccumulator().getMapStatCommunication().end(); ++itMap)
        {
                for(MapStatAccumulator::const_iterator it = itMap->second.begin(); it != itMap->second.end(); ++it) {
                        phoenix_assert(it->second.getNbEvent() == 0lu);
                        for(std::vector<size_t>::const_iterator vit = it->second.getVecHistogram().begin();
                                vit != it->second.getVecHistogram().end(); ++vit) {
                                phoenix_assert(*vit == 0lu);
                        }
                }
        }
}

References Swarm::BaseDaemon::clearStat(), Swarm::BaseDaemon::getConfig(), Swarm::DaemonConfig::getDaemonStatAccumulator(), Swarm::DaemonStatAccumulator::getMapStatCommunication(), Swarm::DaemonStatAccumulator::getMapStatComputing(), Swarm::StatAccumulator::setHistLowerBound(), Swarm::StatAccumulator::setHistUpperBound(), and Swarm::StatAccumulator::setVecHistogram().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testFillDaemonStat()

void testFillDaemonStat

(

)

Test the fill of Daemon stats.

Definition at line 355 of file main.cpp.

                         {
        TestBaseDaemon daemon;
        StatAccumulator stat1 = createTestStatAccumulator();
        daemon.getConfig().getDaemonStatAccumulator().getMapStatComputing()["stat1"] = stat1;
        StatAccumulator stat2 = createTestStatAccumulator();
        daemon.getConfig().getDaemonStatAccumulator().getMapStatCommunication()["other"]["stat2"] = stat2;
 
        Stat daemonStat;
        time_t startTime = 1000lu;
        time_t endTime = 2000lu;
        daemon.fillDaemonStat(daemonStat, startTime, endTime);
 
        phoenix_assert(daemonStat.getMapStatComputing().find("stat1") != daemonStat.getMapStatComputing().end());
        phoenix_assert(daemonStat.getMapStatCommunication().find("other") != daemonStat.getMapStatCommunication().end());
        phoenix_assert(daemonStat.getMapStatCommunication()["other"].find("stat2") != daemonStat.getMapStatCommunication()["other"].end());
        phoenix_assert(daemonStat.getMapStatComputing().find("bad_stat") == daemonStat.getMapStatComputing().end());
}

References createTestStatAccumulator(), TestBaseDaemon::fillDaemonStat(), Swarm::BaseDaemon::getConfig(), Swarm::DaemonConfig::getDaemonStatAccumulator(), Swarm::DaemonStatAccumulator::getMapStatCommunication(), Swarm::Stat::getMapStatCommunication(), Swarm::DaemonStatAccumulator::getMapStatComputing(), and Swarm::Stat::getMapStatComputing().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testFillVecStat()

void testFillVecStat

(

)

Test the fill vector of stats.

Definition at line 328 of file main.cpp.

                      {
        TestBaseDaemon daemon;
        StatAccumulator stat = createTestStatAccumulator();
        time_t startTime = 1000lu;
        time_t endTime = 2000lu;
        
        VecStat vecStat = daemon.fillVecStat(stat, startTime, endTime);
        phoenix_assert(vecStat.getNbEvent().size() == 1lu);
        phoenix_assert(vecStat.getNbEvent()[0] == 4lu);
        phoenix_assert(vecStat.getMin().size() == 1lu);
        phoenix_assert(vecStat.getMin()[0] == 2.0f);
        phoenix_assert(vecStat.getMax().size() == 1lu);
        phoenix_assert(vecStat.getMax()[0] == 8.0f);
        phoenix_assert(vecStat.getAverage().size() == 1lu);
        phoenix_assert(vecStat.getAverage()[0] == 5.0f); //20.0 / 4
 
        phoenix_assert(vecStat.getStartTimestamp().size() == 1lu);
        phoenix_assert(vecStat.getStartTimestamp()[0] == startTime);
        phoenix_assert(vecStat.getEndTimestamp().size() == 1lu);
        phoenix_assert(vecStat.getEndTimestamp()[0] == endTime);
        phoenix_assert(vecStat.getRate().size() == 1lu);
        phoenix_assert(vecStat.getRateEventBelowLowerBound().size() == 1lu);
        phoenix_assert(vecStat.getRateEventAboveUpperBound().size() == 1lu);
        phoenix_assert(vecStat.getVecRateQuantile().size() == 5lu);
}

References createTestStatAccumulator(), TestBaseDaemon::fillVecStat(), Swarm::VecStat::getAverage(), Swarm::VecStat::getEndTimestamp(), Swarm::VecStat::getMax(), Swarm::VecStat::getMin(), Swarm::VecStat::getNbEvent(), Swarm::VecStat::getRate(), Swarm::VecStat::getRateEventAboveUpperBound(), Swarm::VecStat::getRateEventBelowLowerBound(), Swarm::VecStat::getStartTimestamp(), and Swarm::VecStat::getVecRateQuantile().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

testUpdateStatAccumulator()

void testUpdateStatAccumulator

(

)

Test the update of a StatAccumulator.

Definition at line 234 of file main.cpp.

                                {
        BaseDaemon daemon;
        StatAccumulator stat;
        stat.setHistLowerBound(0.0f);
        stat.setHistUpperBound(10.0f);
        stat.setVecHistogram(std::vector<size_t>(5, 0lu)); //5 bins
        
        daemon.updateStatAccumulator(stat, 2.0f);
        phoenix_assert(stat.getNbEvent() == 1lu);
        phoenix_assert(stat.getMin() == 2.0f);
        phoenix_assert(stat.getMax() == 2.0f);
        phoenix_assert(stat.getSum() == 2.0f);
        phoenix_assert(stat.getVecHistogram()[1] == 1lu); //bin size = 2.0, so 2.0 goes to bin 1
 
        daemon.updateStatAccumulator(stat, 8.0f);
        phoenix_assert(stat.getNbEvent() == 2lu);
        phoenix_assert(stat.getMin() == 2.0f);
        phoenix_assert(stat.getMax() == 8.0f);
        phoenix_assert(stat.getSum() == 10.0f);
        phoenix_assert(stat.getVecHistogram()[4] == 1lu); //8.0 goes to bin 4
 
        daemon.updateStatAccumulator(stat, -1.0f); //below lower bound
        phoenix_assert(stat.getNbEvent() == 3lu);
        phoenix_assert(stat.getNbEventBelowLowerBound() == 1lu);
 
        daemon.updateStatAccumulator(stat, 12.0f); //above upper bound
        phoenix_assert(stat.getNbEvent() == 4lu);
        phoenix_assert(stat.getNbEventAboveUpperBound() == 1lu);
}

References Swarm::StatAccumulator::getMax(), Swarm::StatAccumulator::getMin(), Swarm::StatAccumulator::getNbEvent(), Swarm::StatAccumulator::getNbEventAboveUpperBound(), Swarm::StatAccumulator::getNbEventBelowLowerBound(), Swarm::StatAccumulator::getSum(), Swarm::StatAccumulator::getVecHistogram(), Swarm::StatAccumulator::setHistLowerBound(), Swarm::StatAccumulator::setHistUpperBound(), Swarm::StatAccumulator::setVecHistogram(), and Swarm::BaseDaemon::updateStatAccumulator().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function: