1 #include "boost/program_options.hpp" 10 #include "DataFormats/TestObjects/interface/ToyProducts.h" 11 #include "DataFormats/TestObjects/interface/ThingCollection.h" 33 auto run = tester_.testBeginRun(iRun);
34 return *
run.get<edmtest::ThingCollection>(
"beginRun");
38 auto lumi = tester_.testBeginLuminosityBlock(iLumi);
39 return *
lumi.get<edmtest::ThingCollection>(
"beginLumi");
43 auto event = tester_.test();
44 return *
event.get<edmtest::ThingCollection>();
48 auto lumi = tester_.testEndLuminosityBlock();
49 return *
lumi.get<edmtest::ThingCollection>(
"endLumi");
53 auto run = tester_.testEndRun();
54 return *
run.get<edmtest::ThingCollection>(
"endRun");
65 descString +=
"] memory_name";
66 boost::program_options::options_description
desc(descString);
72 boost::program_options::positional_options_description
p;
76 boost::program_options::options_description all_options(
"All Options");
77 all_options.add(
desc);
79 boost::program_options::variables_map vm;
81 store(boost::program_options::command_line_parser(
argc,
argv).
options(all_options).positional(
p).
run(), vm);
84 std::cout <<
argv[0] <<
": Error while trying to process command line arguments:\n" 85 << iException.what() <<
"\nFor usage and an options list, please do 'cmsRun --help'.";
95 std::cout <<
" no argument given" << std::endl;
100 std::cout <<
" no second argument given" << std::endl;
122 auto lockPtr = communicationChannel.
accessLock();
131 TCSerializer serializer(sm_buffer);
132 TCSerializer br_serializer(sm_buffer);
133 TCSerializer bl_serializer(sm_buffer);
134 TCSerializer el_serializer(sm_buffer);
135 TCSerializer er_serializer(sm_buffer);
137 std::cerr << uniqueID <<
" process: initializing " << std::endl;
142 for (
int i = 0;
i < nlines; ++
i) {
144 std::getline(std::cin,
c);
154 std::cerr << uniqueID <<
" process: done initializing" << std::endl;
160 switch (iTransition) {
162 std::cerr << uniqueID <<
" process: start beginRun " << std::endl;
165 br_serializer.serialize(
value);
166 std::cerr << uniqueID <<
" process: end beginRun " <<
value.size() << std::endl;
171 std::cerr << uniqueID <<
" process: start beginLumi " << std::endl;
174 bl_serializer.serialize(
value);
175 std::cerr << uniqueID <<
" process: end beginLumi " <<
value.size() << std::endl;
185 serializer.serialize(
value);
191 std::cerr << uniqueID <<
" process: start endLumi " << std::endl;
194 el_serializer.serialize(
value);
195 std::cerr << uniqueID <<
" process: end endLumi " <<
value.size() << std::endl;
200 std::cerr << uniqueID <<
" process: start endRun " << std::endl;
203 er_serializer.serialize(
value);
204 std::cerr << uniqueID <<
" process: end endRun " <<
value.size() << std::endl;
212 std::cerr << uniqueID <<
" process: notifying and waiting" <<
counter << std::endl;
216 std::cerr <<
"caught exception \n" << iExcept.what() <<
"\n";
edmtest::ThingCollection getEndLumiValue()
int main(int argc, char *argv[])
edmtest::ThingCollection getEventValue()
boost::interprocess::scoped_lock< boost::interprocess::named_mutex > * accessLock()
the lock is made accessible so that the WorkerMonitorThread can be used to unlock it in the event of ...
edm::test::TestProcessor tester_
edmtest::ThingCollection getBeginLumiValue(unsigned int iLumi)
void handleTransitions(F &&iF)
void setupSignalHandling()
Sets the unix signal handler which communicates with the thread.
void setAction(std::function< void()> iFunc)
static char const *const kUniqueIDCommandOpt
static char const *const kUniqueIDOpt
void workerSetupDone()
Matches the ControllerChannel::setupWorker call.
Harness(std::string const &iConfig)
static char const *const kMemoryNameOpt
BufferInfo * fromWorkerBufferInfo()
This can be used with WriteBuffer to keep Controller and Worker in sync.
edmtest::ThingCollection getEndRunValue()
static std::atomic< unsigned int > counter
static char const *const kMemoryNameCommandOpt
static char const *const kHelpOpt
static char const *const kHelpCommandOpt
edmtest::ThingCollection getBeginRunValue(unsigned int iRun)