BadHardwareTableMaker.cxx

Go to the documentation of this file.

#include "BadHardwareTableMaker.h"
#include "DatabaseInterface/DbiWriter.h"
#include "DatabaseInterface/DbiTableProxyRegistry.h"
#include "DatabaseInterface/DbiCascader.h"

CVSID(" $Id: BadHardwareTableMaker.cxx,v 1.2 2005/05/19 17:44:12 tagg Exp $");

void CreateTables(const std::string& tablename)
{
  MSG("Morgue",Msg::kWarning) << "Creating " << tablename << " BadHardware table." << endl;
  int  dbNo = 0; // or whatever cascade entry you need
  DbiStatement* s = DbiTableProxyRegistry::Instance()
    .GetCascader()
    .CreateStatement(dbNo);
  
  
  s->ExecuteUpdate(Form("create table if not exists %sVLD ("
                        " SEQNO         int not null primary key auto_increment,"
                        " TIMESTART     datetime not null,"
                        " TIMEEND       datetime not null,"
                        " DETECTORMASK  tinyint,"
                        " SIMMASK       tinyint,"
                        " TASK          int,"
                        " AGGREGATENO   int,"
                        " CREATIONDATE  datetime not null,"
                        " INSERTDATE    datetime not null )",
                        tablename.c_str()));

  s->ExecuteUpdate(Form("create table if not exists %s ("
                        " SEQNO   integer,"
                        " TYPE    integer,"
                        " ID      integer, "
                        " START   integer, "
                        " STOP    integer, "
                        " BADNESS integer, "
                        " REASON  text,"
                        " index (SEQNO))", 
                        tablename.c_str()));
}



BadHardwareTableMaker::BadHardwareTableMaker(Int_t det,
                                             Int_t sim,
                                             Int_t task, 
                                             const std::string& comment,
                                             const std::string& name) :
  fDetector(det),
  fSimFlag(sim),
  fTask(task),
  fName(name),
  fComment(comment)
{
}


int BadHardwareTableMaker::Add(BadHardware* bh)
{
  fBadStuff.insert(std::pair<VldTimeStamp,BadHardware*>
                   (bh->GetStart(),bh)
                   );
                                                     
  return 0;
}


int BadHardwareTableMaker::Write(Double_t split_time,
                                 VldTimeStamp beg_vld,
                                 VldTimeStamp end_vld)
{

  // Create the tables if they don't exist.
  CreateTables(fName);

  // If not provided, get the absolute start and stop times.
  if(beg_vld.GetSec() == 0) beg_vld = fBadStuff.begin()->second->GetStart(); 
  if(end_vld.GetSec() == 0) {
    for(BadStuff_t::iterator i=fBadStuff.begin(); i!=fBadStuff.end(); ++i) 
      if(i->second->GetStop() > end_vld) end_vld = i->second->GetStop();
  }

  // The start time of the next chunk:
  VldTimeStamp beg_chunk = beg_vld;
  VldTimeStamp end_chunk;

  while(beg_chunk < end_vld) {
    // Do a new chunk!
    int chunk_rows = 0;
    
    // First, find where this chunk stops.
    end_chunk = beg_chunk;
    end_chunk.Add(split_time);
    if(end_chunk > end_vld) end_chunk = end_vld;

    VldRange chunk_range(fDetector,fSimFlag,beg_chunk, end_chunk, fComment.c_str());
    DbiWriter<BadHardware> writer( chunk_range,
                                   -1,
                                   fTask,
                                   VldTimeStamp(), //now
                                   0,
                                   fComment,
                                   fName);
    

    // Now find all entries that are valid during this time and write them.
    BadStuff_t::iterator it = fBadStuff.begin();
    while(it != fBadStuff.end()) {
      if((it->second->GetStart() <= end_chunk) && (it->second->GetStop() >= beg_chunk)) {
        // Write a copy of it:
        writer << *(it->second);
        chunk_rows++;
      }
      // Throw it out if it's finished.
      if(it->second->GetStop() < end_chunk) {
        delete it->second;
        fBadStuff.erase(it);
      }
      it++;
    }
  
    writer.Close();
    MSG("Morgue",Msg::kInfo) << "Wrote " << chunk_rows << " rows starting time " 
                             << beg_chunk.AsString() << std::endl;

    beg_chunk = end_chunk;
  }


  return 0;
}

---