runHitSampler.cxx File Reference

#include <iostream>
#include "boost/program_options.hpp"
#include "FairMQLogger.h"
#include "FairMQSampler.h"
#include "FairMQParser.h"
#include "FairMQTransportFactoryZMQ.h"
#include "PndMQSdsHitLoader.h"
#include "PndSdsHit.h"
#include "FairMQProgOptions.h"
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/binary_oarchive.hpp>

Go to the source code of this file.

Functions
int	main (int argc, char **argv)

Function Documentation

int main	(	int	argc,
		char **	argv
	)

Definition at line 46 of file runHitSampler.cxx.

References filename.

{

        FairMQProgOptions config;

        FairMQSampler<PndMQSdsHitLoader> sampler;
        sampler.CatchSignals();

        try
        {
                std::string InputFile, ParFile, Branch;

                options_description samplerOptions("Sampler options");
                samplerOptions.add_options()
                                ("InputFile", value<std::string>(&InputFile)->default_value(""))
                                ("ParameterFile", value<std::string>(&ParFile)->default_value(""))
                                ("Branch", value<std::string>(&Branch)->default_value(""));

                config.AddToCmdLineOptions(samplerOptions);

                config.ParseAll(argc, argv);

                std::string filename = config.GetValue<std::string>("config-json-file");
                std::string id = config.GetValue<std::string>("id");



                config.UserParser<FairMQParser::JSON>(filename, id);
                sampler.fChannels = config.GetFairMQMap();

                LOG(INFO) << "PID: " << getpid();

                #ifdef NANOMSG
                        FairMQTransportFactory* transportFactory = new FairMQTransportFactoryNN();
                #else
                        FairMQTransportFactory* transportFactory = new FairMQTransportFactoryZMQ();
                #endif

                sampler.SetTransport(transportFactory);

                sampler.SetProperty(FairMQDevice::Id, id);
                sampler.SetProperty(FairMQSampler<PndMQSdsHitLoader>::InputFile, config.GetValue<string>("InputFile"));
                sampler.SetProperty(FairMQSampler<PndMQSdsHitLoader>::ParFile, config.GetValue<string>("ParameterFile"));
                sampler.SetProperty(FairMQSampler<PndMQSdsHitLoader>::Branch, config.GetValue<string>("Branch"));
          //sampler.SetProperty(FairMQSampler::EventRate, options.eventRate);

                sampler.ChangeState("INIT_DEVICE");
                sampler.WaitForEndOfState("INIT_DEVICE");

                sampler.ChangeState("INIT_TASK");
                sampler.WaitForEndOfState("INIT_TASK");

                sampler.ChangeState("RUN");
                sampler.InteractiveStateLoop();
        }
        catch (std::exception& e)
        {
                LOG(ERROR) << e.what();
                LOG(INFO) << "Command line options are the following: ";
                config.PrintHelp();
                return 1;
        }

    return 0;
}