runTaskProcessor.cxx File Reference

#include <PndMvdMQTaskProcessor.h>
#include <csignal>
#include "FairMQLogger.h"
#include "GenericProcessor.h"
#include "runSimpleMQStateMachine.h"
#include "BoostSerializer.h"
#include "RootSerializer.h"
#include "PndMvdPixelClusterTask.h"
#include "PndMvdStripClusterTask.h"

Go to the source code of this file.

Typedefs
using	PixelHitFinder = PndMvdMQTaskProcessor< PndMvdPixelClusterTask >
	std More...
using	StripHitFinder = PndMvdMQTaskProcessor< PndMvdStripClusterTask >

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

Typedef Documentation

using PixelHitFinder = PndMvdMQTaskProcessor<PndMvdPixelClusterTask>

std

FairRoot - FairMQ - base/MQ

Definition at line 17 of file runTaskProcessor.cxx.

using StripHitFinder = PndMvdMQTaskProcessor<PndMvdStripClusterTask>

Definition at line 18 of file runTaskProcessor.cxx.

Function Documentation

int main	(	int	argc,
		char **	argv
	)

Definition at line 24 of file runTaskProcessor.cxx.

References PndMvdMQTaskProcessor< T >::SetDataToKeep().

                                {
        try {
                std::string taskname;
                std::string keepdata;

                namespace po = boost::program_options;
                po::options_description processor_options("Processor options");
                processor_options.add_options()("task-name",
                                po::value<std::string>(&taskname)->required(),
                                "Name of task to run")("keep-data",
                                po::value<std::string>(&keepdata),
                                "Name of data to keep in stream");

                FairMQProgOptions config;
                config.AddToCmdLineOptions(processor_options);

                config.ParseAll(argc, argv);

                if (strcmp(taskname.c_str(), "PndMvdPixelClusterTask") == 0) {
                        PixelHitFinder processor;
                        processor.SetDataToKeep(keepdata);
                        runStateMachine(processor, config);
                } else if (strcmp(taskname.c_str(), "PndMvdStripClusterTask") == 0) {
                        StripHitFinder processor;
                        processor.SetDataToKeep(keepdata);
                        runStateMachine(processor, config);
                } else {
                        LOG(INFO) << "TASK \"" << taskname << "\" UNKNOWN!!! " << strcmp(taskname.c_str(), "PndMvdStripClusterTask");
                }


        } catch (std::exception& e) {
                LOG(ERROR) << "Unhandled Exception reached the top of main: "
                                                                << e.what() << ", application will now exit";
                return 1;
        }

        return 0;
}