VP1AvailEvents Class Reference

#include <VP1AvailEvents.h>

Inheritance diagram for VP1AvailEvents:

Collaboration diagram for VP1AvailEvents:

Classes
class	Imp

Signals
void	allLocalEventsChanged ()
void	freshEventsChanged ()
void	message (const QString &) const

Public Member Functions
	VP1AvailEvents (int timeCutForNew, const QString &tmpdir, int maxLocalFilesToKeep=-1, QObject *parent=0)
virtual void	init ()=0
virtual	~VP1AvailEvents ()
QList< VP1EventFile >	allLocalEvents () const
QList< VP1EventFile >	freshEvents () const
VP1EventFile	newestEvent () const
void	setCurrentEvent (int run, int event)
int	maxLocalFilesToKeep () const

Protected Member Functions
void	cleanupAndCheckForEventListChanges ()
void	invalidateDirCache (const QString &dir)
bool	inHistory (int run, int event) const
QList< VP1EventFile >	allEventFilesInDir (const QString &dir) const
QList< VP1EventFile >	freshEvents (VP1EventFile newestEvt, const QList< VP1EventFile > &) const
const QString &	tmpDir () const
QString	tmpLocalFileDir () const
QString	tmpActiveRetrievalDir ()
int	timeCutForNew () const
bool	requireNewestRunNumber () const
bool	isConsideredFresh (const VP1EventFile &evt, const VP1EventFile &newestEvt) const
void	messageDebug (const QString &) const

Private Slots
void	actualCleanup ()
void	actualCheckForEventListChanges ()

Private Attributes
Imp *	m_d

Detailed Description

Definition at line 25 of file VP1AvailEvents.h.

Constructor & Destructor Documentation

VP1AvailEvents()

VP1AvailEvents::VP1AvailEvents	(	int	timeCutForNew,
		const QString &	tmpdir,
		int	maxLocalFilesToKeep = -1,
		QObject *	parent = 0 )

Definition at line 71 of file VP1AvailEvents.cxx.

  : QObject(parent), m_d(new Imp)
{
  m_d->theclass = this;
  m_d->timeCutForNew = timeCutForNew;
  m_d->tmpDir = QString(td + (td.endsWith("/")?"":"/")).replace("//","/");
  m_d->maxLocalFilesToKeep = maxLocalFilesToKeep;
}

~VP1AvailEvents()

VP1AvailEvents::~VP1AvailEvents ( )

virtual

Definition at line 81 of file VP1AvailEvents.cxx.

{
  //Fixme: These two remove commands only has an effect when dir is empty!!
  if (!m_d->tmpActiveRetrievalDir.isEmpty()&&m_d->tmpActiveRetrievalDir!="bad")
    QFile::remove(m_d->tmpActiveRetrievalDir);
  if (!m_d->tmpLocalFileDir.isEmpty()&&m_d->tmpLocalFileDir!="bad")
    QFile::remove(m_d->tmpLocalFileDir);
  delete m_d;
}

Member Function Documentation

actualCheckForEventListChanges

void VP1AvailEvents::actualCheckForEventListChanges ( )

privateslot

Definition at line 161 of file VP1AvailEvents.cxx.

{
  QList<VP1EventFile> allLocal = allLocalEvents();
  QList<VP1EventFile> fresh = freshEvents();
  if (m_d->lastAllLocal != allLocal) {
    m_d->lastAllLocal = std::move(allLocal);
    allLocalEventsChanged();
  }
  if (m_d->lastFresh != fresh) {
    m_d->lastFresh = std::move(fresh);
    freshEventsChanged();
  }
}

actualCleanup

void VP1AvailEvents::actualCleanup ( )

privateslot

Definition at line 151 of file VP1AvailEvents.cxx.

{
  //First we cleanup:
  m_d->cleanupTmpLocalFiles();
 
  //Then we schedule a check for event list changes:
  QTimer::singleShot(10, this, SLOT(actualCheckForEventListChanges()));
}

allEventFilesInDir()

QList< VP1EventFile > VP1AvailEvents::allEventFilesInDir ( const QString & dir ) const

protected

Definition at line 202 of file VP1AvailEvents.cxx.

{
  if (dir.isEmpty())
    return QList<VP1EventFile>();
 
  QFileInfo fi_dir(dir);
  if (!fi_dir.exists()||!fi_dir.isDir())
    return QList<VP1EventFile>();
 
  QDateTime modtime = fi_dir.lastModified();
  if (abs(modtime.time().msecsTo(QTime::currentTime()))>50) {
    std::map<QString,std::pair<QDateTime,QList<VP1EventFile> > >::iterator it = m_d->dircache.find(dir);
    if (it!=m_d->dircache.end()&&it->second.first==modtime)
      return it->second.second;
  }
 
  QStringList filters;
  filters << "*_*.pool.root";
  //fixme
  QDirIterator itDir(dir,filters,QDir::Files | QDir::NoDotAndDotDot | QDir::Readable | QDir::CaseSensitive);
 
  QList<VP1EventFile> l;
  while (itDir.hasNext()) {
    QString fn = itDir.next();
    fn.replace("//","/");
    VP1EventFile evt(fn);
    if (evt.isValid())
      l << evt;
    else
      message("Could not decode event file name: "+fn);
  }
 
  std::sort(l.begin(), l.end());
 
  m_d->dircache[dir]=std::make_pair(modtime,l);
  return l;
}

allLocalEvents()

QList< VP1EventFile > VP1AvailEvents::allLocalEvents

(

)

const

Definition at line 241 of file VP1AvailEvents.cxx.

{
  return allEventFilesInDir(tmpLocalFileDir());
}

allLocalEventsChanged

void VP1AvailEvents::allLocalEventsChanged ( )

signal

cleanupAndCheckForEventListChanges()

void VP1AvailEvents::cleanupAndCheckForEventListChanges ( )

protected

Definition at line 176 of file VP1AvailEvents.cxx.

{
  //We schedule the cleanup to take place shortly. The check for event
  //list changes will be scheduled after the cleanup:
 
  //Then we schedule a check for event list changes:
  QTimer::singleShot(10, this, SLOT(actualCleanup()));
 
}

freshEvents() [1/2]

QList< VP1EventFile > VP1AvailEvents::freshEvents

(

)

const

Definition at line 129 of file VP1AvailEvents.cxx.

{
  return freshEvents(newestEvent(),allLocalEvents());
}

freshEvents() [2/2]

QList< VP1EventFile > VP1AvailEvents::freshEvents ( VP1EventFile newestEvt, const QList< VP1EventFile > & inputEventList ) const

protected

Definition at line 110 of file VP1AvailEvents.cxx.

{
  QList<VP1EventFile> l;
  if (!newestEvt.isValid())
    return l;
  std::set<Imp::EventID>::const_iterator histIt, histItE(m_d->historySorted.end());
  if (m_d->timeCutForNew==0) {
    if (m_d->historySorted.find(Imp::evtToID(newestEvt))==histItE)
      l << newestEvt;
    return l;
  }
  for(VP1EventFile evt : inputEventList)
    if (m_d->historySorted.find(Imp::evtToID(evt))==histItE && isConsideredFresh(evt,newestEvt))
      l << evt;
  return l;
}

freshEventsChanged

void VP1AvailEvents::freshEventsChanged ( )

signal

inHistory()

bool VP1AvailEvents::inHistory ( int run, int event ) const

protected

Definition at line 187 of file VP1AvailEvents.cxx.

{
  return m_d->historySorted.find(Imp::EventID(run,event))!=m_d->historySorted.end();
}

init()

virtual void VP1AvailEvents::init ( )

pure virtual

Implemented in VP1AvailEvtsHttp, VP1AvailEvtsHttps, and VP1AvailEvtsLocalDir.

invalidateDirCache()

void VP1AvailEvents::invalidateDirCache ( const QString & dir )

protected

Definition at line 194 of file VP1AvailEvents.cxx.

{
  std::map<QString,std::pair<QDateTime,QList<VP1EventFile> > >::iterator it = m_d->dircache.find(dir);
  if (it!=m_d->dircache.end())
    m_d->dircache.erase(it);
}

isConsideredFresh()

bool VP1AvailEvents::isConsideredFresh ( const VP1EventFile & evt, const VP1EventFile & newestEvt ) const

protected

Definition at line 336 of file VP1AvailEvents.cxx.

{
  //Notice: Logic here must be similar to logic in VP1EvtsOnServerInfo::events
 
  if (m_d->timeCutForNew==0) {
    //Special case where only the newest event is fresh
    return evt.rawTime()==newestEvt.rawTime() &&  evt.runNumber()==newestEvt.runNumber();
  }
  if (requireNewestRunNumber()&&evt.runNumber()!=newestEvt.runNumber())
    return false;
  const unsigned oldest_time = (m_d->timeCutForNew<0||unsigned(m_d->timeCutForNew)>newestEvt.rawTime()) ? 0 : newestEvt.rawTime() - m_d->timeCutForNew;
  return evt.rawTime() >= oldest_time;
}

maxLocalFilesToKeep()

int VP1AvailEvents::maxLocalFilesToKeep

(

)

const

Definition at line 98 of file VP1AvailEvents.cxx.

{
  return m_d->maxLocalFilesToKeep;
}

message

void VP1AvailEvents::message ( const QString & ) const

signal

messageDebug()

void VP1AvailEvents::messageDebug ( const QString & s ) const

protected

Definition at line 351 of file VP1AvailEvents.cxx.

{
  std::cout<<VP1Msg::prefix_verbose()<<": "<<s.toStdString()<<std::endl;
}

newestEvent()

VP1EventFile VP1AvailEvents::newestEvent

(

)

const

Definition at line 135 of file VP1AvailEvents.cxx.

{
  QList<VP1EventFile> evts(allLocalEvents());
  if (evts.isEmpty())
    return VP1EventFile();//invalid
  return evts.front();
}

requireNewestRunNumber()

bool VP1AvailEvents::requireNewestRunNumber ( ) const

inlineprotected

Definition at line 62 of file VP1AvailEvents.h.

{ return false; /*fixme*/ }

setCurrentEvent()

void VP1AvailEvents::setCurrentEvent	(	int	run,
		int	event )

Definition at line 144 of file VP1AvailEvents.cxx.

{
  m_d->historyOrdered << Imp::EventID(run,event);
  m_d->historySorted.insert(Imp::EventID(run,event));
}

timeCutForNew()

int VP1AvailEvents::timeCutForNew ( ) const

protected

Definition at line 92 of file VP1AvailEvents.cxx.

{
  return m_d->timeCutForNew;
}

tmpActiveRetrievalDir()

QString VP1AvailEvents::tmpActiveRetrievalDir ( )

protected

Definition at line 277 of file VP1AvailEvents.cxx.

{
  return m_d->attemptGenerationOfTmpSubdir("activeretrievals",m_d->tmpActiveRetrievalDir);
}

tmpDir()

const QString & VP1AvailEvents::tmpDir ( ) const

protected

Definition at line 104 of file VP1AvailEvents.cxx.

{
  return m_d->tmpDir;
}

tmpLocalFileDir()

QString VP1AvailEvents::tmpLocalFileDir ( ) const

protected

Definition at line 283 of file VP1AvailEvents.cxx.

{
  return m_d->attemptGenerationOfTmpSubdir("eventfiles",m_d->tmpLocalFileDir);
}

Member Data Documentation

m_d

Imp* VP1AvailEvents::m_d

private

Definition at line 79 of file VP1AvailEvents.h.

---

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

• VP1AvailEvents.h
• VP1AvailEvents.cxx