VP1Gui Class Reference

#include <VP1Gui.h>

Collaboration diagram for VP1Gui:

Classes
class	Imp

Public Member Functions
	VP1Gui (StoreGateSvc *sg, StoreGateSvc *detstore, ISvcLocator *svclocator, IToolSvc *toolSvc, const std::vector< std::string > &initialvp1files=std::vector< std::string >(), const std::string &initialCruiseMode="NONE", unsigned initialCruiseSeconds=10, const std::string &singleEventSource="", const std::string &singleEventLocalTmpDir="", unsigned localFileCacheLimit=10, const std::vector< std::string > &availableLocalInputDirectories=std::vector< std::string >())
	~VP1Gui ()
bool	argumentsAreValid () const
void	init ()
bool	hasBeenInitialised ()
bool	executeNewEvent (const int &run, const uint64_t &event, const unsigned &triggerType=0, const unsigned &time=0)
void	cleanup ()
std::vector< std::string >	userRequestedFiles ()
std::string	nextRequestedEventFile () const

Private Member Functions
	VP1Gui (const VP1Gui &)
VP1Gui &	operator= (const VP1Gui &)

Private Attributes
Imp *	m_d

Detailed Description

Definition at line 28 of file VP1Gui.h.

Constructor & Destructor Documentation

VP1Gui() [1/2]

VP1Gui::VP1Gui	(	StoreGateSvc *	sg,
		StoreGateSvc *	detstore,
		ISvcLocator *	svclocator,
		IToolSvc *	toolSvc,
		const std::vector< std::string > &	initialvp1files = std::vector<std::string>(),
		const std::string &	initialCruiseMode = "NONE",
		unsigned	initialCruiseSeconds = 10,
		const std::string &	singleEventSource = "",
		const std::string &	singleEventLocalTmpDir = "",
		unsigned	localFileCacheLimit = 10,
		const std::vector< std::string > &	availableLocalInputDirectories = std::vector<std::string>()
	)

Definition at line 56 of file VP1Gui.cxx.

 : m_d(new Imp)
{
  m_d->sg = sg;
  m_d->detstore = detstore;
  m_d->svclocator = svclocator;
  m_d->toolSvc = toolSvc;
  m_d->initialCruiseMode = QString(initialCruiseMode.c_str()).simplified();
  m_d->initialCruiseSeconds = initialCruiseSeconds;
  m_d->singleEventSource = singleEventSource.c_str();
  m_d->singleEventLocalTmpDir = singleEventLocalTmpDir.c_str();
  m_d->localFileCacheLimit = localFileCacheLimit;
 
  std::vector<std::string>::const_iterator it, itE = initialvp1files.end();
  for (it = initialvp1files.begin();it!=itE;++it)
    m_d->initialvp1files << it->c_str();
 
  itE = availableLocalInputDirectories.end();
  for (it = availableLocalInputDirectories.begin();it!=itE;++it)
    m_d->availableLocalInputDirectories << it->c_str();
 
}

~VP1Gui()

VP1Gui::~VP1Gui

(

)

Definition at line 86 of file VP1Gui.cxx.

{
  delete m_d; m_d=0;
}

VP1Gui() [2/2]

VP1Gui::VP1Gui ( const VP1Gui &  )

private

Member Function Documentation

argumentsAreValid()

bool VP1Gui::argumentsAreValid

(

)

const

Definition at line 92 of file VP1Gui.cxx.

{
  //Athena pointers:
 
  if (!m_d->sg) {
    VP1Msg::message("ERROR: Null pointer to event store.");
    return false;
  }
  if (!m_d->detstore) {
    VP1Msg::message("ERROR: Null pointer to detector store.");
    return false;
  }
  if (!m_d->svclocator) {
    VP1Msg::message("ERROR: Null pointer to service locator.");
    return false;
  }
  if (!m_d->toolSvc) {
    VP1Msg::message("ERROR: Null pointer to tool service.");
    return false;
  }
 
  //Initial files:
 
  // ...no checks...
 
  //Cruise mode:
  if (m_d->initialCruiseMode!="NONE"&&m_d->initialCruiseMode!="EVENT"&&m_d->initialCruiseMode!="TAB"&&m_d->initialCruiseMode!="BOTH") {
      VP1Msg::message("WARNING: unknown initial cruise mode "+m_d->initialCruiseMode+" (valid are NONE/EVENT/TAB/BOTH). Assuming NONE.");
      m_d->initialCruiseMode = "NONE";
  }
 
  //Single-Event-Per-File modes:
  if (!m_d->singleEventSource.isEmpty()&&!m_d->singleEventLocalTmpDir.isEmpty()) {
    const bool httpmode = m_d->singleEventSource.startsWith("http://") || m_d->singleEventSource.startsWith("https://") ;
    if (httpmode) {
      QUrl url(m_d->singleEventSource);
      if (!url.isValid()||url.path().isEmpty()) {
    //Fixme: check that path ends with a filename!
    VP1Msg::message("VP1ExecutionScheduler::init ERROR: Source URL ("+m_d->singleEventSource+") incorrect format!");
    return false;
      }
 
      // For the https mode check if the platform supports SSL
      if(m_d->singleEventSource.startsWith("https://") 
#ifndef QT_NO_SSL
     && ! (QSslSocket::supportsSsl()) ) {
#else
         ) {
#endif
    VP1Msg::message("VP1ExecutionScheduler::init ERROR: Unable to retrieve events over Https. The platform does not support SSL");
    return false;
      }
    } else {
      QFileInfo fi_s(m_d->singleEventSource), fi_l(m_d->singleEventLocalTmpDir);
      if (!fi_s.exists()||!fi_s.isDir()||!fi_s.isReadable()) {
    VP1Msg::message("ERROR: Source directory ("+m_d->singleEventSource+") does not exist, is not readable, or is not a directory!");
    return false;
      }
      if (!fi_l.exists()||!fi_l.isDir()||!fi_l.isReadable()||!fi_l.isWritable()) {
    VP1Msg::message("ERROR: Local tmp directory ("+m_d->singleEventLocalTmpDir+") does not exist, had incorrect permissions, or is not a directory!");
    return false;
      }
      if (fi_l.canonicalFilePath()==fi_s.canonicalFilePath()) {
    VP1Msg::message("ERROR: Local tmp directory ("+m_d->singleEventLocalTmpDir+") is the same the source directory ("+m_d->singleEventSource+")");
    return false;
      }
    }
  } else {
    if (!m_d->singleEventSource.isEmpty()||!m_d->singleEventLocalTmpDir.isEmpty()) {
      VP1Msg::message("ERROR: Only one of SourceDir and LocalCopyDir set. Set either both or none.");
      return false;
    }
  }
 
  if (m_d->localFileCacheLimit==1||m_d->localFileCacheLimit==2) {
      VP1Msg::message("WARNING: Too low value of localFileCacheLimit. Setting to 3. (Set to 0 to disable removal of locally cached files.");
      m_d->localFileCacheLimit=3;
  }
 
  return true;
}

cleanup()

void VP1Gui::cleanup

(

)

Definition at line 205 of file VP1Gui.cxx.

{
  assert(m_d->the_scheduler&&"Cant cleanup before init");
  VP1ExecutionScheduler::cleanup(m_d->the_scheduler);
}

executeNewEvent()

bool VP1Gui::executeNewEvent	(	const int &	run,
		const uint64_t &	event,
		const unsigned &	triggerType = 0,
		const unsigned &	time = 0
	)

Definition at line 212 of file VP1Gui.cxx.

{
  VP1Msg::messageDebug("Examining new event ( run# "+QString::number(run)+", event# "+QString::number(event)+" )");
 
  bool b = m_d->the_scheduler->executeNewEvent(run,event,triggerType,time);
 
  // NOTE:
  // we will go on to the lines here below
  // only when the user clicks on the "Next event" button.
 
  VP1Msg::messageDebug("Leaving event ( run# "+QString::number(run)+", event# "+QString::number(event)+" )"
               +(nextRequestedEventFile().empty()?QString(""):". Next requested event file: "+QString(nextRequestedEventFile().c_str())));
 
  VP1Msg::messageDebug("end of VP1Gui::executeNewEvent().");
 
  return b;
}

hasBeenInitialised()

bool VP1Gui::hasBeenInitialised

(

)

Definition at line 175 of file VP1Gui.cxx.

{
  return m_d->the_scheduler != 0;
}

init()

void VP1Gui::init

(

)

Definition at line 181 of file VP1Gui.cxx.

{
  VP1Msg::messageDebug("Start of VP1Gui::init()...");
 
  assert(!m_d->the_scheduler&&"Dont init twice!!");
  VP1Msg::message("");
  VP1Msg::message("===================================================");
  VP1Msg::message("               Launching the VP1 GUI");
  VP1Msg::message("===================================================");
  VP1Msg::message("");
  m_d->the_scheduler = VP1ExecutionScheduler::init(m_d->sg,
                         m_d->detstore,
                         m_d->svclocator,
                         m_d->toolSvc,
                         m_d->initialvp1files,
                         m_d->initialCruiseMode,m_d->initialCruiseSeconds,
                         m_d->singleEventSource,m_d->singleEventLocalTmpDir,
                         m_d->localFileCacheLimit,
                         m_d->availableLocalInputDirectories);
 
  VP1Msg::messageDebug("end of VP1Gui::init().");
}

nextRequestedEventFile()

std::string VP1Gui::nextRequestedEventFile

(

)

const

Definition at line 231 of file VP1Gui.cxx.

{
  return m_d->the_scheduler->nextRequestedEventFile().toStdString();
}

operator=()

VP1Gui& VP1Gui::operator= ( const VP1Gui &  )

private

userRequestedFiles()

std::vector< std::string > VP1Gui::userRequestedFiles

(

)

Definition at line 237 of file VP1Gui.cxx.

{
  std::vector<std::string> retvector;
  if(m_d->the_scheduler) {
    const QStringList& inplist = m_d->the_scheduler->userRequestedFiles();
    for(int i=0; i<inplist.size(); ++i) 
      retvector.push_back(inplist.at(i).toStdString());
  }
  return retvector;
}

Member Data Documentation

m_d

Imp* VP1Gui::m_d

private

Definition at line 72 of file VP1Gui.h.

---

The documentation for this class was generated from the following files:

• VP1Gui.h
• VP1Gui.cxx