DDSPaceModule.cxx

Go to the documentation of this file.

//
// DDSPaceModule.cxx
//
// A JobControl Module for filling an DDSPaceRecord from data stored
// in the SimSnarlRecord.
//
#include <iostream>
#include <cassert>
using namespace std;

#include "TSystem.h"

#include "MessageService/MsgService.h"
#include "Record/RecMinos.h"
#include "JobControl/JobCModuleRegistry.h"
#include "JobControl/JobCommand.h"
#include "MinosObjectMap/MomNavigator.h"
#include "Validity/VldContext.h"
#include "Dispatcher/test/DDSPaceModule.h"


ClassImp(DDSPaceModule)

//   Definition of static data members
//   *********************************

CVSID("$Id: DDSPaceModule.cxx,v 1.2 2005/02/01 18:42:18 tagg Exp $");
JOBMODULE(DDSPaceModule, "DDSPaceModule",
         "A pace maker module for record sets.");


// Definition of methods (alphabetical order)
// ***************************************************


//......................................................................

DDSPaceModule::DDSPaceModule() : fVldStartTime(0,0) {
  // Default constructor

  fStopwatch.Reset();
  fStopwatch.Stop();
  
}

  
const Registry& DDSPaceModule::DefaultConfig() const {
  //
  // Purpose: Method to return default configuration.
  // 
  // Arguments: none.
  //
  // Return: Registry containing default configuration
  //

  MSG("DDSPace",Msg::kDebug) << 
    "DDSPaceModule::DefaultConfig" << endl;

  static Registry r; 
  std::string name = this->JobCModule::GetName();
  name += ".config.default";
  r.SetName(name.c_str());

  r.UnLockValues();
  r.LockValues();

  return r;
}

//......................................................................

void DDSPaceModule::Config(const Registry& /* r */) {
  //
  // Purpose: Configure the module given a registry.
  //
  // Arguments: Registry to use to configure the module.
  //
  // Return: none.
  //

  MSG("DDSPace",Msg::kDebug) << "DDSPaceModule::Config" << endl;
  
  //Int_t tmpi;
  //  Double_t tmpd;
  //  const Char_t* tmps;

}

//......................................................................

JobCResult DDSPaceModule::Ana(const MomNavigator *mom) {
  //
  //  Purpose:  Create and fill ntuple record.
  //
  //  Arguments: mom.
  //  
  //  Return: status.
  // 

  JobCResult result(JobCResult::kPassed);  
  MSG("DDSPace",Msg::kDebug) << "DDSPaceModule::Ana" << endl;

  // Check that mom exists.
  assert(mom);

  // Blindly look at first record, this module is very simple
  // Assumption is that its only of interest to RawRecords with RecMinos base
  TIter fiter = mom->FragmentIter();
  RecMinos* record = dynamic_cast<RecMinos*>(fiter());
  if ( !record ) {
    MSG("DDS",Msg::kWarning) << "First record not RecMinos record" << endl;
    result.SetWarning().SetFailed();
    return result;
  }
  VldTimeStamp vldCurrentTime = record->GetVldContext()->GetTimeStamp();
  
  if ( fVldStartTime.GetSec() == 0 ) {
    // first call
    fVldStartTime = vldCurrentTime;
    fStopwatch.Start();  // start timer
  }
  
  Double_t vldtimediff = vldCurrentTime-fVldStartTime;  // seconds
  Double_t realtime = fStopwatch.RealTime();  // seconds
  // RealTime will stop it, need to restart w/o resetting
  fStopwatch.Start(false); 

  Double_t timediff = vldtimediff - realtime;
  MSG("DDS",Msg::kDebug) << "Delta VldTime " << vldtimediff 
                         << " RealTime " << realtime << " => sleep for " 
                         << timediff << " seconds." << endl;

  if ( timediff > 0 ) {
    // Sleep for specified length of time in msec
    gSystem->Sleep((Int_t)(timediff*1000));
  }
  
  
  return result;

}

---