Raw data remapper

EventFilter/RawDataCollector/python/rawDataMapperByLabel_cfi.py

@@ -0,0 +1,9 @@
+import FWCore.ParameterSet.Config as cms
+
+rawDataCollector = cms.EDProducer("RawDataMapperByLabel",
+    rawCollectionList = cms.VInputTag( cms.InputTag('rawDataCollector'),
+                                       cms.InputTag('rawDataRepacker'),
+                                       cms.InputTag('rawDataReducedFormat')),
+    mainCollection= cms.InputTag('rawDataCollector')                          
+)
+

EventFilter/RawDataCollector/src/RawDataCollectorByLabel.cc

@@ -71,10 +71,10 @@ void RawDataCollectorByLabel::produce(Event & e, const EventSetup& c){
        if(verbose_ > 1) std::cout << "Copying data from FED #" << j << std::endl;
        FEDRawData & fedDataProd = producedData->FEDData(j);
        if ( fedDataProd.size() != 0 ) {
-	 if(verbose_ > 1) {
-	   std::cout << " More than one FEDRawDataCollection with data in FED ";
-	   std::cout << j << " Skipping the 2nd\n";
-	 }
+        if(verbose_ > 1) {
+	   	    std::cout << " More than one FEDRawDataCollection with data in FED ";
+	   	    std::cout << j << " Skipping the 2nd\n";
+        }
 	 continue;
        } 
        fedDataProd.resize(size);

EventFilter/RawDataCollector/src/RawDataMapperByLabel.cc

@@ -0,0 +1,113 @@
+/** \file
+ * Implementation of class RawDataMapperByLabel
+ *
+ */
+
+#include "DataFormats/Provenance/interface/ProcessHistory.h" 
+#include "DataFormats/Common/interface/Handle.h"
+#include "DataFormats/FEDRawData/interface/FEDRawDataCollection.h" 
+#include "DataFormats/Common/interface/Handle.h"
+
+#include "FWCore/Framework/interface/Event.h"
+#include "FWCore/Framework/interface/ESHandle.h"
+#include "FWCore/Framework/interface/EventSetup.h"
+#include "FWCore/MessageLogger/interface/MessageLogger.h"
+#include "FWCore/ParameterSet/interface/ConfigurationDescriptions.h"
+#include "FWCore/ParameterSet/interface/ParameterSetDescription.h"
+#include "FWCore/Framework/interface/MakerMacros.h"
+#include "FWCore/Framework/interface/stream/EDProducer.h"
+#include "FWCore/Utilities/interface/InputTag.h"
+
+#include <iostream>
+
+using namespace edm;
+
+class RawDataMapperByLabel: public edm::stream::EDProducer<> {
+public:
+
+    ///Constructor
+    RawDataMapperByLabel(const edm::ParameterSet& pset);
+
+    ///Destructor
+    ~RawDataMapperByLabel() override;
+
+    void produce(edm::Event & e, const edm::EventSetup& c) override; 
+
+    static void fillDescriptions(edm::ConfigurationDescriptions &);     
+private:
+
+    typedef std::vector<edm::InputTag>::const_iterator tag_iterator_t;
+    typedef std::vector<edm::EDGetTokenT<FEDRawDataCollection> >::const_iterator tok_iterator_t;
+
+    std::vector<edm::InputTag> inputTags_ ;
+    std::vector<edm::EDGetTokenT<FEDRawDataCollection> > inputTokens_;
+
+    bool firstEvent_;
+    edm::InputTag filledCollectionName_;
+    edm::InputTag mainCollectionTag_ ;
+
+
+
+};
+
+
+RawDataMapperByLabel::RawDataMapperByLabel(const edm::ParameterSet& pset) {
+
+  inputTags_ = pset.getParameter<std::vector<InputTag> >("rawCollectionList");
+  mainCollectionTag_ = pset.getParameter<InputTag>("rainCollection");
+  firstEvent_= true;
+  filledCollectionName_= InputTag("");
+
+  inputTokens_.reserve(inputTags_.size());
+  for(auto const& inputTag: inputTags_) {
+    inputTokens_.push_back(consumes<FEDRawDataCollection>(inputTag));
+  }
+  produces<FEDRawDataCollection>();
+
+}
+
+RawDataMapperByLabel::~RawDataMapperByLabel(){
+
+}
+
+
+void RawDataMapperByLabel::produce(Event & e, const EventSetup& c){
+
+ bool alreadyACollectionFilled= false;
+ tag_iterator_t inputTag = inputTags_.begin();
+ for(tok_iterator_t inputTok = inputTokens_.begin(); inputTok != inputTokens_.end(); ++inputTok, ++inputTag  ) {
+   Handle<FEDRawDataCollection> input;
+   if (e.getByToken(*inputTok,input)){
+    	if(input.isValid()){
+    	    if(firstEvent_){  
+    	    	filledCollectionName_ = *inputTag; 
+    	    	alreadyACollectionFilled = true;
+                firstEvent_= false;  
+            }
+
+    		if(alreadyACollectionFilled) throw cms::Exception("Unknown input type") << "Two input collections are present. Please make sure that the input dataset has only one FEDRawDataCollector collection filled";
+            if(!(filledCollectionName_==*inputTag)) throw cms::Exception("Unknown input type") << "The filled collection has changed!";
+
+            if(!(mainCollectionTag_==filledCollectionName_)) e.put(std::make_unique<FEDRawDataCollection>(*input.product()));
+
+        }
+    }
+  }
+}
+
+void RawDataMapperByLabel::fillDescriptions(edm::ConfigurationDescriptions & descriptions) {
+    edm::ParameterSetDescription desc;
+
+    std::vector<edm::InputTag> tmp_itvect;
+    tmp_itvect.push_back( edm::InputTag("rawDataCollector"));
+    tmp_itvect.push_back( edm::InputTag("rawDataRepacker"));
+    tmp_itvect.push_back( edm::InputTag("rawDataReducedFormat"));
+
+    desc.add<std::vector<edm::InputTag>>("rawCollectionList",  tmp_itvect);
+    desc.add<edm::InputTag>("mainCollection", edm::InputTag("rawDataCollector"));
+
+    descriptions.add("rawDataCollector", desc);
+}
+
+DEFINE_FWK_MODULE(RawDataMapperByLabel);
+

EventFilter/RawDataCollector/src/SealModule.cc

@@ -3,6 +3,7 @@
 #include "FWCore/ServiceRegistry/interface/ServiceMaker.h"
 #include "EventFilter/RawDataCollector/src/RawDataCollectorByLabel.h"
 
+
 using namespace edm::serviceregistry;
 
 DEFINE_FWK_MODULE(RawDataCollectorByLabel);