---

yaml --- r: 72175 b: "refs/heads/CMSSW_7_1_X" c: f399d7f h: "refs/heads/CMSSW_7_1_X" i: 72173: 8514e5e 72171: ca617d5 72167: 306af32 72159: 40b2df3 v: v3
cms-sw · Aug 22, 2009 · 865b965 · 865b965
1 parent fd48a09
commit 865b965
Show file tree

Hide file tree

Showing 5 changed files with 34 additions and 10 deletions.
diff --git a/[refs] b/[refs]
@@ -1,3 +1,3 @@
 ---
 refs/heads/gh-pages: 09c786f70121f131b3715aaf3464996502bbeb7e
-"refs/heads/CMSSW_7_1_X": 4cf1e716939500c0e3372b7663ad98e38f266581
+"refs/heads/CMSSW_7_1_X": f399d7f23147be120efa03dc8ef2bd3ab059e796
diff --git a/trunk/FWCore/Framework/interface/InputSource.h b/trunk/FWCore/Framework/interface/InputSource.h
@@ -178,8 +178,16 @@ namespace edm {
     /// Called by framework at end of job
     void doEndJob();
 
-    /// Called by framework when events are exhausted.
+    /// Called by framework at beginning of lumi block
+    void doBeginLumi(LuminosityBlockPrincipal& lbp);
+
+    /// Called by framework at end of lumi block
     void doEndLumi(LuminosityBlockPrincipal& lbp);
+
+    /// Called by framework at beginning of run
+    void doBeginRun(RunPrincipal& rp);
+
+    /// Called by framework at end of run
     void doEndRun(RunPrincipal& rp);
 
     /// Called by the framework before forking the process
@@ -284,7 +292,9 @@ namespace edm {
     virtual void wakeUp_();
     void preRead();
     void postRead(Event& event);
+    virtual void beginLuminosityBlock(LuminosityBlock&);
     virtual void endLuminosityBlock(LuminosityBlock&);
+    virtual void beginRun(Run&);
     virtual void endRun(Run&);
     virtual void beginJob(EventSetup const&);
     virtual void endJob();

diff --git a/trunk/FWCore/Framework/src/ConfigurableInputSource.cc b/trunk/FWCore/Framework/src/ConfigurableInputSource.cc
@@ -59,11 +59,6 @@ namespace edm {
     RunAuxiliary runAux(eventID_.run(), ts, Timestamp::invalidTimestamp());
     boost::shared_ptr<RunPrincipal> runPrincipal(
         new RunPrincipal(runAux, productRegistry(), processConfiguration()));
-    RunPrincipal& rp =
-       const_cast<RunPrincipal&>(*runPrincipal);
-    Run run(rp, moduleDescription());
-    beginRun(run);
-    run.commit_();
     newRun_ = false;
     return runPrincipal;
   }
@@ -76,9 +71,6 @@ namespace edm {
     boost::shared_ptr<LuminosityBlockPrincipal> lumiPrincipal(
         new LuminosityBlockPrincipal(
 	    lumiAux, productRegistry(), processConfiguration()));
-    LuminosityBlock lb(*lumiPrincipal, moduleDescription());
-    beginLuminosityBlock(lb);
-    lb.commit_();
     newLumi_ = false;
     return lumiPrincipal;
   }

diff --git a/trunk/FWCore/Framework/src/EventProcessor.cc b/trunk/FWCore/Framework/src/EventProcessor.cc
@@ -1683,6 +1683,7 @@ namespace edm {
 
   void EventProcessor::beginRun(int run) {
     RunPrincipal& runPrincipal = principalCache_.runPrincipal(run);
+    input_->doBeginRun(runPrincipal);
     IOVSyncValue ts(EventID(runPrincipal.run(), 0),
                     0,
                     runPrincipal.beginTime());
@@ -1710,6 +1711,7 @@ namespace edm {
 
   void EventProcessor::beginLumi(int run, int lumi) {
     LuminosityBlockPrincipal& lumiPrincipal = principalCache_.lumiPrincipal(run, lumi);
+    input_->doBeginLumi(lumiPrincipal);
     // NOTE: Using 0 as the event number for the begin of a lumi block is a bad idea
     // lumi blocks know their start and end times why not also start and end events?
     IOVSyncValue ts(EventID(lumiPrincipal.run(), 0), lumiPrincipal.luminosityBlock(), lumiPrincipal.beginTime());

diff --git a/trunk/FWCore/Framework/src/InputSource.cc b/trunk/FWCore/Framework/src/InputSource.cc
@@ -368,6 +368,13 @@ namespace edm {
     }
   }
 
+  void
+  InputSource::doBeginRun(RunPrincipal& rp) {
+    Run run(rp, moduleDescription());
+    beginRun(run);
+    run.commit_();
+  }
+
   void
   InputSource::doEndRun(RunPrincipal& rp) {
     rp.setEndTime(time_);
@@ -376,6 +383,13 @@ namespace edm {
     run.commit_();
   }
 
+  void
+  InputSource::doBeginLumi(LuminosityBlockPrincipal& lbp) {
+    LuminosityBlock lb(lbp, moduleDescription());
+    beginLuminosityBlock(lb);
+    lb.commit_();
+  }
+
   void
   InputSource::doEndLumi(LuminosityBlockPrincipal& lbp) {
     lbp.setEndTime(time_);
@@ -415,9 +429,15 @@ namespace edm {
   void 
   InputSource::wakeUp_() {}
 
+  void
+  InputSource::beginLuminosityBlock(LuminosityBlock&) {}
+
   void
   InputSource::endLuminosityBlock(LuminosityBlock&) {}
 
+  void
+  InputSource::beginRun(Run&) {}
+
   void
   InputSource::endRun(Run&) {}