SpillTimeCreateKeyFile.cxx

Go to the documentation of this file.

#include "SpillTimeCreateKeyFile.h"
#include "SpillTimeRecord.h"
#include "MessageService/MsgService.h"
#include "Persistency/Per.h"
#include "Persistency/PerOutputStreamManager.h"
#include "Persistency/PerOutputStream.h"
#include "MinosObjectMap/MomNavigator.h"
#include "Conventions/Munits.h"

CVSID(" $Id: SpillTimeCreateKeyFile.cxx,v 1.1 2005/05/20 17:46:32 tagg Exp $ ");

int SpillTimeCreateKeyFile(
                                   const char* filename,
                                   int task,
                                   VldTimeStamp start,
                                   VldTimeStamp stop  
                                   )
{
  
 
  PerOutputStreamManager perOutputStreamManager;

  PerOutputStream* outstream =    
    perOutputStreamManager.OpenStream("BeamMon","BeamMon",
                                      "SpillTimeRecord","","",Per::kRecSplit);
  if(!outstream) {
    MSG("SpillTime",Msg::kError) << "OpenStream failed!" << endl;
    return 1;
  }

  bool open_ok = perOutputStreamManager.SetFile("BeamMon",filename,Per::kRecreate);
  if(!open_ok) {
    MSG("SpillTime",Msg::kError) << "SetFile failed!" << endl;
    return 1;
  }
  
  // Start with the first one in VTM table:
  SpillTimeFinder stf;
  stf.Set("Task",task);
  VldTimeStamp ts1 = start;
  VldContext context(Detector::kFar,SimFlag::kData,ts1);
  MomNavigator mom;
 
  bool done = false;
  do {
    // Get the next spill time.
    ts1 = stf.GetTimeOfNextSpill(context);

    while(ts1.GetSec()==0) { // Invalid query.
      VldTimeStamp jumptime = stf.GetLastQueryRangeEnd();
      if(jumptime == context.GetTimeStamp()) {
        // That's it.. we're done.
        done = true;
        break;
      }
      if(jumptime > stop){
        done=true;
        break;
      }
      context = VldContext(Detector::kFar,SimFlag::kData,jumptime);
      MSG("SpillTime",Msg::kInfo) << "Found no spills.. skipping to " << context.AsString() << endl;
      ts1 = stf.GetTimeOfNextSpill(context);      
    }

    if(ts1>stop) done= true;

    if(!done) {

      MSG("SpillTime",Msg::kDebug) << ts1.AsString() << endl;
      // Rebuild the context for this.
      context = VldContext(Detector::kFar,SimFlag::kData,ts1);
      
      // Create the record.
      mom.Clear();
      RecHeader* header = new RecHeader(context);
      SpillTimeRecord* record = new SpillTimeRecord(*header);
      mom.AdoptFragment(record);
      perOutputStreamManager.Put(&mom);

    }
  } while(!done); //(ts1 > VldTimeStamp(1990,1,1,0,0,0,0,0)) && (ts1<stop));
 
  perOutputStreamManager.Write(); // write the trees on all streams to file
  perOutputStreamManager.CloseFile(); // close files on all streams
  perOutputStreamManager.CloseStream();

  

  return 0;
}

---