#include "boost/program_options.hpp"
#include <atomic>
#include <csignal>
#include <iostream>
#include <string>
#include <thread>
#include "FWCore/TestProcessor/interface/TestProcessor.h"
#include "DataFormats/TestObjects/interface/ToyProducts.h"
#include "DataFormats/TestObjects/interface/ThingCollection.h"
#include "FWCore/SharedMemory/interface/WriteBuffer.h"
#include "FWCore/SharedMemory/interface/WorkerChannel.h"
#include "FWCore/SharedMemory/interface/ROOTSerializer.h"
#include "FWCore/SharedMemory/interface/WorkerMonitorThread.h"

Classes
class	Harness

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

Variables
static char const *const	kHelpCommandOpt = "help,h"

static char const *const	kHelpOpt = "help"

static char const *const	kMemoryNameCommandOpt = "memory-name,m"

static char const *const	kMemoryNameOpt = "memory-name"

static char const *const	kUniqueIDCommandOpt = "unique-id,i"

static char const *const	kUniqueIDOpt = "unique-id"

Function Documentation

◆ main()

int main	(	int	argc,
		char *	argv[]
	)

===============================================================================================================================================================================================

variant2: for each run define phi-averaged A for normalization channel (Dref,16) and then, divide Rijk on it, i.e. get RRijk

eta=27

eta=25

eta=23

eta=22

eta=21

eta=26

eta=24

eta=19

eta=17

eta=25

eta=23

eta=22

eta=21

eta=26

eta=24

eta=20

eta=19

eta=18

eta=27 L1=1

eta=25 L1=1

eta=23 L1=1

eta=22 L1=1

eta=21 L1=1

eta=29 L1=1

eta=26 L1=1

eta=24 L1=1

eta=20 L1=1

eta=19 L1=1

eta=18 L1=1

eta=17 L1=1

eta=28 L7=1

eta=27 L7=1

eta=25 L7=1

eta=23 L7=1

eta=22 L7=1

eta=21 L7=1

eta=26 L7=1

eta=24 L7=1

eta=20 L7=1

eta=19 L7=1

eta=18 L7=1

eta=17 L7=1

eta=27

eta=25

eta=23

eta=22

eta=21

eta=26

eta=24

eta=19

eta=17

eta=25

eta=23

eta=22

eta=21

eta=26

eta=24

eta=20

eta=19

eta=18

eta=27 L1=1

eta=25 L1=1

eta=23 L1=1

eta=22 L1=1

eta=21 L1=1

eta=26 L1=1

eta=24 L1=1

eta=20 L1=1

eta=19 L1=1

eta=18 L1=1

eta=17 L1=1

eta=28 L7=1

eta=27 L7=1

eta=25 L7=1

eta=23 L7=1

eta=22 L7=1

eta=21 L7=1

eta=26 L7=1

eta=24 L7=1

eta=20 L7=1

eta=19 L7=1

eta=18 L7=1

eta=17 L7=1

eta=27

eta=28

errA with average Amplitudes

Summed Amplitude Plots:

Summed Amplitude Plots:

Summed Amplitude Plots:

RBX:

errA with average Amplitudes

Summed Amplitude Plots:

Summed Amplitude Plots:

Summed Amplitude Plots:

RBX:

errA with average Amplitudes

Summed Amplitude Plots:

Summed Amplitude Plots:

Summed Amplitude Plots:

RBX:

Prepare maps of good/bad channels:

Definition at line 61 of file interprocess.cc.

References edm::shared_memory::WorkerChannel::accessLock(), dir2webdir::argc, cmsBatch::argv, cms::cuda::assert(), edm::BeginLuminosityBlock, edm::BeginRun, c, EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0::cerr, CMS_SA_ALLOW, ctppsRawToDigi_cff::configuration, counter, gather_cfg::cout, submitPVResolutionJobs::desc, edm::EndLuminosityBlock, edm::EndRun, relativeConstraints::error, edm::Event, cppFunctionSkipper::exception, edm::shared_memory::WorkerChannel::fromWorkerBufferInfo(), Harness::getBeginLumiValue(), Harness::getBeginRunValue(), Harness::getEndLumiValue(), Harness::getEndRunValue(), Harness::getEventValue(), edm::shared_memory::WorkerChannel::handleTransitions(), mps_fire::i, kHelpCommandOpt, kHelpOpt, kMemoryNameCommandOpt, kMemoryNameOpt, kUniqueIDCommandOpt, kUniqueIDOpt, AlcaSiPixelAliHarvester0T_cff::options, AlCaHLTBitMon_ParallelJobs::p, writedatasetfile::run, edm::shared_memory::WorkerMonitorThread::setAction(), edm::shared_memory::WorkerMonitorThread::setupSignalHandling(), edm::shared_memory::WorkerMonitorThread::startThread(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::shared_memory::WorkerChannel::workerSetupDone().

                                  {
   std::string descString(argv[0]);
   descString += " [--";
   descString += kMemoryNameOpt;
   descString += "] memory_name";
   boost::program_options::options_description desc(descString);
 
   desc.add_options()(kHelpCommandOpt, "produce help message")(
       kMemoryNameCommandOpt,
       boost::program_options::value<std::string>(),
       "memory name")(kUniqueIDCommandOpt, boost::program_options::value<std::string>(), "unique id");
 
   boost::program_options::positional_options_description p;
   p.add(kMemoryNameOpt, 1);
   p.add(kUniqueIDOpt, 2);
 
   boost::program_options::options_description all_options("All Options");
   all_options.add(desc);
 
   boost::program_options::variables_map vm;
   try {
     store(boost::program_options::command_line_parser(argc, argv).options(all_options).positional(p).run(), vm);
     notify(vm);
   } catch (boost::program_options::error const& iException) {
     std::cout << argv[0] << ": Error while trying to process command line arguments:\n"
               << iException.what() << "\nFor usage and an options list, please do 'cmsRun --help'.";
     return 1;
   }
 
   if (vm.count(kHelpOpt)) {
     std::cout << desc << std::endl;
     return 0;
   }
 
   if (!vm.count(kMemoryNameOpt)) {
     std::cout << " no argument given" << std::endl;
     return 1;
   }
 
   if (!vm.count(kUniqueIDOpt)) {
     std::cout << " no second argument given" << std::endl;
     return 1;
   }
 
   WorkerMonitorThread monitorThread;
 
   monitorThread.startThread();
 
   CMS_SA_ALLOW try {
     std::string const memoryName(vm[kMemoryNameOpt].as<std::string>());
     std::string const uniqueID(vm[kUniqueIDOpt].as<std::string>());
     {
       //using namespace boost::interprocess;
       //auto controlNameUnique = unique_name(memoryName, uniqueID);
 
       //This class is holding the lock
       WorkerChannel communicationChannel(memoryName, uniqueID);
 
       WriteBuffer sm_buffer{memoryName, communicationChannel.fromWorkerBufferInfo()};
       int counter = 0;
 
       //The lock must be released if there is a catastrophic signal
       auto lockPtr = communicationChannel.accessLock();
       monitorThread.setAction([lockPtr]() {
         if (lockPtr) {
           std::cerr << "SIGNAL CAUGHT: unlock\n";
           lockPtr->unlock();
         }
       });
 
       using TCSerializer = ROOTSerializer<edmtest::ThingCollection, WriteBuffer>;
       TCSerializer serializer(sm_buffer);
       TCSerializer br_serializer(sm_buffer);
       TCSerializer bl_serializer(sm_buffer);
       TCSerializer el_serializer(sm_buffer);
       TCSerializer er_serializer(sm_buffer);
 
       std::cerr << uniqueID << " process: initializing " << std::endl;
       int nlines;
       std::cin >> nlines;
 
       std::string configuration;
       for (int i = 0; i < nlines; ++i) {
         std::string c;
         std::getline(std::cin, c);
         std::cerr << c << "\n";
         configuration += c + "\n";
       }
 
       Harness harness(configuration);
 
       //Either ROOT or the Framework are overriding the signal handlers
       monitorThread.setupSignalHandling();
 
       std::cerr << uniqueID << " process: done initializing" << std::endl;
       communicationChannel.workerSetupDone();
 
       std::cerr << uniqueID << " process: waiting " << counter << std::endl;
       communicationChannel.handleTransitions([&](edm::Transition iTransition, unsigned long long iTransitionID) {
         ++counter;
         switch (iTransition) {
           case edm::Transition::BeginRun: {
             std::cerr << uniqueID << " process: start beginRun " << std::endl;
             auto value = harness.getBeginRunValue(iTransitionID);
 
             br_serializer.serialize(value);
             std::cerr << uniqueID << " process: end beginRun " << value.size() << std::endl;
 
             break;
           }
           case edm::Transition::BeginLuminosityBlock: {
             std::cerr << uniqueID << " process: start beginLumi " << std::endl;
             auto value = harness.getBeginLumiValue(iTransitionID);
 
             bl_serializer.serialize(value);
             std::cerr << uniqueID << " process: end beginLumi " << value.size() << std::endl;
 
             break;
           }
           case edm::Transition::Event: {
             std::cerr << uniqueID << " process: integrating " << counter << std::endl;
             auto value = harness.getEventValue();
 
             std::cerr << uniqueID << " process: integrated " << counter << std::endl;
 
             serializer.serialize(value);
             std::cerr << uniqueID << " process: " << value.size() << " " << counter << std::endl;
             //usleep(10000000);
             break;
           }
           case edm::Transition::EndLuminosityBlock: {
             std::cerr << uniqueID << " process: start endLumi " << std::endl;
             auto value = harness.getEndLumiValue();
 
             el_serializer.serialize(value);
             std::cerr << uniqueID << " process: end endLumi " << value.size() << std::endl;
 
             break;
           }
           case edm::Transition::EndRun: {
             std::cerr << uniqueID << " process: start endRun " << std::endl;
             auto value = harness.getEndRunValue();
 
             er_serializer.serialize(value);
             std::cerr << uniqueID << " process: end endRun " << value.size() << std::endl;
 
             break;
           }
           default: {
             assert(false);
           }
         }
         std::cerr << uniqueID << " process: notifying and waiting" << counter << std::endl;
       });
     }
   } catch (std::exception const& iExcept) {
     std::cerr << "caught exception \n" << iExcept.what() << "\n";
     return 1;
   } catch (...) {
     std::cerr << "caught unknown exception";
     return 1;
   }
   return 0;
 }

Referenced by main().

Classes

Functions

Variables

Function Documentation

◆ main()

Variable Documentation

◆ kHelpCommandOpt

◆ kHelpOpt

◆ kMemoryNameCommandOpt

◆ kMemoryNameOpt

◆ kUniqueIDCommandOpt

◆ kUniqueIDOpt