ART event display service. More...

#include "EventDisplay.h"

Public Member Functions
	EventDisplay (fhicl::ParameterSet const &pset, art::ActivityRegistry &reg)

void	reconfigure (fhicl::ParameterSet const &pset)

Public Attributes
unsigned int	fAutoAdvanceInterval
	Wait time in milliseconds. More...

int	fAutoPrintCount
	Number of events printed so far. More...

int	fAutoPrintMax
	How many events to print (zero = disable printing). More...

std::string	fAutoPrintPattern
	Pattern for printing output filenames. Must contain "%s" and "%d", in that order. More...

bool	fEchoPrint
	Copy what you see in X to a .gif for each event. More...

std::string	fEchoPrintFile
	The file to dump that .gif to. Only one file, if you want a different file for each event, use AutoPrint instead. More...

std::string	fEchoPrintTempFile
	a temporary file to enable atomic writes More...

Private Member Functions
void	postBeginJob ()

void	postBeginJobWorkers (art::InputSource inputs, std::vector< art::Worker > const &workers)

void	preProcessEvent (art::Event const &, art::ScheduleContext)

void	postProcessEvent (art::Event const &, art::ScheduleContext)

Private Attributes
art::InputSource *	fInputSource
	Input source of events. More...

Detailed Description

ART event display service.

Definition at line 26 of file EventDisplay.h.

Constructor & Destructor Documentation

evdb::EventDisplay::EventDisplay	(	fhicl::ParameterSet const &	pset,
		art::ActivityRegistry &	reg
	)

Definition at line 72 of file EventDisplay.cc.

References postBeginJob(), postBeginJobWorkers(), postProcessEvent(), preProcessEvent(), reconfigure(), art::ActivityRegistry::sPostBeginJob, art::ActivityRegistry::sPostBeginJobWorkers, art::ActivityRegistry::sPostProcessEvent, and art::ActivityRegistry::sPreProcessEvent.

                                                        :
   fAutoPrintCount(0)
   {
     //   evdb::DisplayWindow::Register("Test1","Test display #1",600,900,mk_canvas1);
     //   evdb::DisplayWindow::OpenWindow(0);
 
     this->reconfigure(pset);
 
     reg.sPostBeginJob.watch       (this, &EventDisplay::postBeginJob);
     reg.sPostBeginJobWorkers.watch(this, &EventDisplay::postBeginJobWorkers);
     reg.sPreProcessEvent.watch    (this, &EventDisplay::preProcessEvent);
     reg.sPostProcessEvent.watch   (this, &EventDisplay::postProcessEvent);
   }

Member Function Documentation

void evdb::EventDisplay::postBeginJob ( )

private

Definition at line 141 of file EventDisplay.cc.

References evdb::DisplayWindow::SetServicesAll().

Referenced by EventDisplay().

   {
     DisplayWindow::SetServicesAll();
   }

void evdb::EventDisplay::postBeginJobWorkers	(	art::InputSource *	inputs,
		std::vector< art::Worker * > const &	workers
	)

private

Definition at line 133 of file EventDisplay.cc.

References fInputSource.

Referenced by EventDisplay().

   {
     fInputSource = input_source;
   }

void evdb::EventDisplay::postProcessEvent	(	art::Event const &	evt,
		art::ScheduleContext
	)

private

Definition at line 155 of file EventDisplay.cc.

References evdb::ServiceTable::ApplyEdits(), evdb::DisplayWindow::DrawAll(), art::Event::event(), fAutoPrintCount, fAutoPrintMax, fAutoPrintPattern, fEchoPrint, fEchoPrintFile, fEchoPrintTempFile, fInputSource, evdb::Printable::GetPrintables(), art::Event::id(), evdb::EventHolder::Instance(), evdb::ServiceTable::Instance(), art::SubRunID::invalidSubRun(), evdb::kGOTO_EVENT, evdb::kNEXT_EVENT, evdb::kPREV_EVENT, evdb::kRELOAD_EVENT, evdb::kSEQUENTIAL_ONLY, art::errors::LogicError, MF_LOG_DEBUG, evdb::Printable::Print(), evdb::Printable::PrintTag(), evdb::NavState::Set(), evdb::EventHolder::SetEvent(), evdb::NavState::TargetEvent(), evdb::NavState::TargetRun(), and evdb::NavState::Which().

Referenced by EventDisplay().

   {
     // stuff the event into the holder
     evdb::EventHolder *holder = evdb::EventHolder::Instance();
     holder->SetEvent(&evt);
 
     evdb::DisplayWindow::DrawAll();
 
     if(fAutoPrintMax == 0){
       TApplication* app = gROOT->GetApplication();
 
       // Hold here for user input from the GUI...
       app->Run(kTRUE);
     }
 
     //
     // Apply edits to any services that may have been reconfigured
     //
     ServiceTable::Instance().ApplyEdits();
 
     if(fAutoPrintMax > 0){
       ++fAutoPrintCount;
       std::map<std::string, Printable*>& ps = Printable::GetPrintables();
       for(std::map<std::string,Printable*>::iterator it = ps.begin(); it != ps.end(); ++it){
         Printable* p = it->second;
           // Ensure the format string is well-formed
         if(fAutoPrintPattern.find("%s") == std::string::npos)
           throw cet::exception("EventDisplay") << "Cannot find AutoPrintPattern"
           << " format for %s";
         if(fAutoPrintPattern.find("%d") == std::string::npos)
           throw cet::exception("EventDisplay") << "Cannot find AutoPrintPattern"
           << " format for %d";
           // png doesn't seem to work for some reason
         p->Print(TString::Format(fAutoPrintPattern.c_str(), p->PrintTag(), evt.event()));
       }
       if(fAutoPrintCount >= fAutoPrintMax) exit(0);
     }
 
     // if fEchoPrint is set, do so
     if (fEchoPrint){
       std::map<std::string, Printable*>& ps = Printable::GetPrintables();
       for(std::map<std::string,Printable*>::iterator it = ps.begin(); it != ps.end(); ++it){
         Printable* p = it->second;
           // lack of more parameters to Print() call means use the file format
           // that's specified by the file name extension
         p->Print(fEchoPrintTempFile.c_str());
       }
         // move temporary file to final file.  This makes the creation of the
         // newly printed file close to atomic
       int result;
       result=rename(fEchoPrintTempFile.c_str(),fEchoPrintFile.c_str());
       if (result==0)
         MF_LOG_DEBUG("EventDisplayBase") << fEchoPrintTempFile
         << " tempfile successfully renamed to "
         << fEchoPrintFile;
       else
         mf::LogWarning("EventDisplayBase") << "Error renaming file "
                                            << fEchoPrintTempFile
                                            << " to " << fEchoPrintFile
                                            << " " << strerror(errno) <<"\n";
     }
 
     art::RootInput* rootInput = dynamic_cast<art::RootInput*>(fInputSource);
 
     if(!rootInput && NavState::Which() != kSEQUENTIAL_ONLY){
       NavState::Set(kSEQUENTIAL_ONLY);
       mf::LogWarning("EventDisplayBase")
       << "Random access for the EventDisplay requires a RootInput source for proper operation.\n"
       << "You do not have a RootInput source so only sequential access works.\n";
     }
 
 
     // Figure out where to go in the input stream from here
     switch (NavState::Which()) {
     case kSEQUENTIAL_ONLY: break;
     case kNEXT_EVENT: {
       // Contrary to appearances, this is *not* a NOP: it ensures run and
       // subRun are (re-)read as necessary if we've been doing random
       // access. Come the revolution ...
       //
       // 2011/04/10 CG.
       if(rootInput) rootInput->seekToEvent(0);
       break;
     }
     case kPREV_EVENT: {
       if(rootInput) rootInput->seekToEvent(-2);
       break;
     }
     case kRELOAD_EVENT: {
       if(rootInput) rootInput->seekToEvent(evt.id());
       break;
     }
     case kGOTO_EVENT: {
       art::EventID id(art::SubRunID::invalidSubRun(art::RunID(NavState::TargetRun())), NavState::TargetEvent());
       if(rootInput){
         if (!rootInput->seekToEvent(id)) { // Couldn't find event
           mf::LogWarning("EventDisplayBase") << "Unable to find "
                                              << id
                                              << " -- reloading current event.";
             // Reload current event.
           rootInput->seekToEvent(evt.id());
         }
       }// end if not a RootInput
       break;
     }
     default: {
       throw art::Exception(art::errors::LogicError)
       << "EvengtDisplay in unhandled state "
       << NavState::Which()
       << ".\n";
     }
     } // end switch statement
 
   }

void evdb::EventDisplay::preProcessEvent	(	art::Event const &	evt,
		art::ScheduleContext
	)

private

Definition at line 148 of file EventDisplay.cc.

References art::EventID::event(), art::Event::id(), art::EventID::run(), and evdb::DisplayWindow::SetRunEventAll().

Referenced by EventDisplay().

   {
     evdb::DisplayWindow::SetRunEventAll(evt.id().run(), evt.id().event());
   }

void evdb::EventDisplay::reconfigure ( fhicl::ParameterSet const & pset )

Definition at line 89 of file EventDisplay.cc.

References fAutoAdvanceInterval, fAutoPrintMax, fAutoPrintPattern, fEchoPrint, fEchoPrintFile, fEchoPrintTempFile, fhicl::ParameterSet::get(), and w.

Referenced by EventDisplay().

   {
     fAutoAdvanceInterval = pset.get<unsigned int>("AutoAdvanceInterval" );
     fAutoPrintMax        = pset.get<int         >("AutoPrintMax",     0 );
     fAutoPrintPattern    = pset.get<std::string >("AutoPrintPattern", "");
     fEchoPrint           = pset.get<bool        >("EchoPrint",        false);
     fEchoPrintFile       = pset.get<std::string >("EchoPrintFile",    "$HOME/evt_echo.gif");
     // Sanitize filename: root's OK with env variables, straight system
     // calls are not.  So, force a substitution of env. variables in the
     // filename so we can do atomic-write "renames" later using a tmp file
     if (fEchoPrint) {
       wordexp_t p;
       char** w;
       wordexp( fEchoPrintFile.c_str(), &p, 0 );
       w = p.we_wordv;
       fEchoPrintFile = std::string(*w);
       // the tempfile has to end with the same extension (eg, ".gif") as
       // the specified filename.  root's printing takes the format of the file
       // from that extension.  So, we have to construct a name with the same
       // path, and extension: need to insert a "tmp" before the final .gif
       // Sp, simply grab the file extension and stick it back on the end
       std::string::size_type idx;
       std::string extension;
       idx = fEchoPrintFile.rfind('.');
       if(idx != std::string::npos) {
         extension = fEchoPrintFile.substr(idx);
         fEchoPrintTempFile = std::string(*w) + ".tmp" + extension;
       } else {
         // No extension found, can't do this
         fEchoPrint = false;
         fEchoPrintTempFile = "";
         mf::LogWarning("EventDisplayBase")
         << "No file extension given to EchoPrintFile "
         << fEchoPrintFile
         << " so cannot determine file format, disabling EchoPrint\n";
       }
       wordfree(&p);
     } else {
       fEchoPrintTempFile = "";
     }
   }