VP1AvailEvtsLocalDir Class Reference

#include <VP1AvailEvtsLocalDir.h>

Inheritance diagram for VP1AvailEvtsLocalDir:

Collaboration diagram for VP1AvailEvtsLocalDir:

Classes
class	Imp

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

Public Member Functions
	VP1AvailEvtsLocalDir (int timeCutForNew, const QString &sourcedir, const QString &tmpcopydir, int maxLocalFilesToKeep=-1, QObject *parent=0)
void	setSourceDir (const QString &)
const QString &	currentSourceDir () const
void	setAvailableSourceDirectories (const QStringList &)
const QStringList &	availableSourceDirectories () const
virtual	~VP1AvailEvtsLocalDir ()
virtual void	init ()
QList< VP1EventFile >	allLocalEvents () const
QList< VP1EventFile >	freshEvents () const
VP1EventFile	newestEvent () const
void	setCurrentEvent (int run, int event)
int	maxLocalFilesToKeep () const

Protected Member Functions
QList< VP1EventFile >	freshEvents (VP1EventFile newestEvt, const QList< VP1EventFile > &) const
void	cleanupAndCheckForEventListChanges ()
void	invalidateDirCache (const QString &dir)
bool	inHistory (int run, int event) const
QList< VP1EventFile >	allEventFilesInDir (const QString &dir) 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

Friends
class	VP1LocalEvtRetriever

Detailed Description

Definition at line 24 of file VP1AvailEvtsLocalDir.h.

Constructor & Destructor Documentation

VP1AvailEvtsLocalDir()

VP1AvailEvtsLocalDir::VP1AvailEvtsLocalDir	(	int	timeCutForNew,
		const QString &	sourcedir,
		const QString &	tmpcopydir,
		int	maxLocalFilesToKeep = -1,
		QObject *	parent = 0 )

Definition at line 33 of file VP1AvailEvtsLocalDir.cxx.

  : VP1AvailEvents(timeCutForNew,tmpcopydir,maxLocalFilesToKeep,parent),
    m_d(new Imp(sourcedir+(sourcedir.endsWith("/")?"":"/")))
{
}

~VP1AvailEvtsLocalDir()

VP1AvailEvtsLocalDir::~VP1AvailEvtsLocalDir ( )

virtual

Definition at line 52 of file VP1AvailEvtsLocalDir.cxx.

{
  delete m_d;
}

Member Function Documentation

actualCheckForEventListChanges

void VP1AvailEvents::actualCheckForEventListChanges ( )

privateslotinherited

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 ( )

privateslotinherited

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

protectedinherited

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

inherited

Definition at line 241 of file VP1AvailEvents.cxx.

{
  return allEventFilesInDir(tmpLocalFileDir());
}

allLocalEventsChanged

void VP1AvailEvents::allLocalEventsChanged ( )

signalinherited

availableSourceDirectories()

const QStringList & VP1AvailEvtsLocalDir::availableSourceDirectories

(

)

const

Definition at line 78 of file VP1AvailEvtsLocalDir.cxx.

{
  return m_d->availablesourcedirs;
}

cleanupAndCheckForEventListChanges()

void VP1AvailEvents::cleanupAndCheckForEventListChanges ( )

protectedinherited

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()));
 
}

currentSourceDir()

const QString & VP1AvailEvtsLocalDir::currentSourceDir

(

)

const

Definition at line 58 of file VP1AvailEvtsLocalDir.cxx.

{
  return m_d->sourcedir;
}

freshEvents() [1/2]

QList< VP1EventFile > VP1AvailEvents::freshEvents ( ) const

inherited

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

protectedinherited

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 ( )

signalinherited

inHistory()

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

protectedinherited

Definition at line 187 of file VP1AvailEvents.cxx.

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

init()

void VP1AvailEvtsLocalDir::init ( )

virtual

Implements VP1AvailEvents.

Definition at line 45 of file VP1AvailEvtsLocalDir.cxx.

{
  m_d->retriever = new VP1LocalEvtRetriever(this,m_d->sourcedir); // Memleak
  m_d->retriever->start();
}

invalidateDirCache()

void VP1AvailEvents::invalidateDirCache ( const QString & dir )

protectedinherited

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

protectedinherited

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

inherited

Definition at line 98 of file VP1AvailEvents.cxx.

{
  return m_d->maxLocalFilesToKeep;
}

message

void VP1AvailEvents::message ( const QString & ) const

signalinherited

messageDebug()

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

protectedinherited

Definition at line 351 of file VP1AvailEvents.cxx.

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

newestEvent()

VP1EventFile VP1AvailEvents::newestEvent ( ) const

inherited

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

inlineprotectedinherited

Definition at line 62 of file VP1AvailEvents.h.

{ return false; /*fixme*/ }

setAvailableSourceDirectories()

void VP1AvailEvtsLocalDir::setAvailableSourceDirectories

(

const QStringList &

l

)

Definition at line 71 of file VP1AvailEvtsLocalDir.cxx.

{
  m_d->availablesourcedirs = l;
}

setCurrentEvent()

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

inherited

Definition at line 144 of file VP1AvailEvents.cxx.

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

setSourceDir()

void VP1AvailEvtsLocalDir::setSourceDir

(

const QString &

dir

)

Definition at line 64 of file VP1AvailEvtsLocalDir.cxx.

{
  m_d->retriever->setSourceDir(dir);
  m_d->sourcedir = dir;
}

timeCutForNew()

int VP1AvailEvents::timeCutForNew ( ) const

protectedinherited

Definition at line 92 of file VP1AvailEvents.cxx.

{
  return m_d->timeCutForNew;
}

tmpActiveRetrievalDir()

QString VP1AvailEvents::tmpActiveRetrievalDir ( )

protectedinherited

Definition at line 277 of file VP1AvailEvents.cxx.

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

tmpDir()

const QString & VP1AvailEvents::tmpDir ( ) const

protectedinherited

Definition at line 104 of file VP1AvailEvents.cxx.

{
  return m_d->tmpDir;
}

tmpLocalFileDir()

QString VP1AvailEvents::tmpLocalFileDir ( ) const

protectedinherited

Definition at line 283 of file VP1AvailEvents.cxx.

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

Friends And Related Symbol Documentation

VP1LocalEvtRetriever

friend class VP1LocalEvtRetriever

friend

Definition at line 30 of file VP1AvailEvtsLocalDir.h.

Member Data Documentation

m_d

Imp* VP1AvailEvtsLocalDir::m_d

private

Definition at line 50 of file VP1AvailEvtsLocalDir.h.

---

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

• VP1AvailEvtsLocalDir.h
• VP1AvailEvtsLocalDir.cxx