IoModule.cxx

Go to the documentation of this file.

#include "EventDisplayBase/IoModule.h"
extern "C" {
#include <unistd.h>
}
#include <iostream>
#include <string>
#include <cstdio>
#include "TGMsgBox.h"
#include "EventDataModel/Event.h"
#include "EventDisplayBase/evdb.h"
#include "EventDisplayBase/AutoAdvance.h"
#include "EventDisplayBase/JobInterface.h"
#include "IoModules/ReadWriteModule.h"
#include "IoModules/Filter.h"
using namespace evdb;

AutoAdvance* gsAutoAdvance = 0;

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

void IoModule::StartAutoAdvance() 
{
  if (gsAutoAdvance==0) gsAutoAdvance = new AutoAdvance();
}

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

void IoModule::StopAutoAdvance() 
{
  if (gsAutoAdvance==0) return;
  delete gsAutoAdvance;
  gsAutoAdvance = 0;
}

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

io::ReadWriteModule& IoModule::IoMod() { return *fIoMod; }

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

IoModule* IoModule::Instance() 
{
  static IoModule* iom = 0;
  if (iom==0) iom = new IoModule();
  return iom; 
}

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

IoModule::IoModule() 
{
  fIoMod = new io::ReadWriteModule();
}

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

IoModule::~IoModule() { }

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

int IoModule::AddFile(const char* file_regexp)
{
  int n = 0;
  if (file_regexp) n = fIoMod->AddFile(file_regexp);
  if (n==0) {
    std::string s;
    s += "Add: No files matching '";
    if (file_regexp) s += file_regexp;
    else             s += "0x0";
    s += "' openned.";
    this->Warn(s.c_str());
  }
  fIoMod->Report();

  return n;
}

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

int IoModule::RemoveFile(const char* file_regexp) 
{
  int n = fIoMod->RemoveFile(file_regexp);
  if (n==0) {
    std::string s;
    s += "Remove: No files match '";
    s += file_regexp;
    s += "'.";
    this->Warn(s.c_str());
  }
  return n;
}

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

int IoModule::GoToFile(const char* file) 
{
  int istat = fIoMod->GoToFile(file);
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

int IoModule::AdvanceFile(int n) 
{
  int istat = fIoMod->AdvanceFile(n);
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

int IoModule::RewindFile(int n) 
{
  int istat = fIoMod->RewindFile(n);
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

int IoModule::GoTo(int run, int event) 
{
  int istat = fIoMod->GoTo(run,event);
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

int IoModule::Advance(int n) 
{
  int istat = fIoMod->Advance(n);
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

int IoModule::Rewind(int n) 
{
  int istat = fIoMod->Rewind(n);
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

int IoModule::Reload()
{
  int istat = fIoMod->Reload();
  JobInterface::ProcEvent(this->GetEvent());
  this->NewEvent();
  return istat;
}

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

void IoModule::SetOutputFileName(const char* n) 
{
  fIoMod->SetOutputFileName(n);
}

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

edm::EventHandle& IoModule::GetEvent() 
{
  return fIoMod->GetEvent();
}

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

int IoModule::WriteEvent() 
{
  int istat = fIoMod->WriteEvent();
  if (istat == 0) {
    this->Warn("Write failed.\n");
  }
  return istat;
}

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

const char* IoModule::CurrentFile() const
{
  return fIoMod->CurrentFile();
}

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

const char* IoModule::FileName(int i) const 
{
  return fIoMod->FileName(i);
}

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

void IoModule::Warn(const char* w) 
{
  new TGMsgBox(evdb::TopWindow(), evdb::TopWindow(), 
               "Warning", w, kMBIconExclamation);
}

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

void IoModule::NewEvent()
{
  Emit("NewEvent()"); 
}

---