VP1AvailEvents::Imp Class Reference

Collaboration diagram for VP1AvailEvents::Imp:

Classes
class	EventID

Public Member Functions
QString	attemptGenerationOfTmpSubdir (const QString &preferredname, QString &cachevar)
void	cleanupTmpLocalFiles ()

Static Public Member Functions
static EventID	evtToID (const VP1EventFile &evt)

Public Attributes
VP1AvailEvents *	theclass {}
int	timeCutForNew {}
QString	tmpDir
int	maxLocalFilesToKeep {}
QString	tmpLocalFileDir
QString	tmpActiveRetrievalDir
QList< EventID >	historyOrdered
std::set< EventID >	historySorted
QList< VP1EventFile >	lastAllLocal
QList< VP1EventFile >	lastFresh
std::map< QString, std::pair< QDateTime, QList< VP1EventFile > > >	dircache

Detailed Description

Definition at line 27 of file VP1AvailEvents.cxx.

Member Function Documentation

attemptGenerationOfTmpSubdir()

QString VP1AvailEvents::Imp::attemptGenerationOfTmpSubdir	(	const QString &	preferredname,
		QString &	cachevar )

Definition at line 248 of file VP1AvailEvents.cxx.

{
  if (!cachevar.isEmpty())
    return cachevar=="bad"?"":cachevar;
 
  QFileInfo fi(tmpDir);
  if (!( fi.exists()&&fi.isDir())) {
    theclass->message("Could not create subdir in "+tmpDir+", since it does not exists or is not a directory" );
    cachevar="bad";
    return "";
  }
  int i(0);
  while (true) {
    ++i;
    QString dir = tmpDir+(tmpDir.endsWith("/")?"":"/")+preferredname+(i==1?QString(""):QString::number(i))+"/";
    if (!QFile::exists(dir)) {
      bool ok = QDir().mkdir(dir);
      if (!ok) {
    theclass->message("Could not create directory:: "+dir );
    cachevar="bad";
    return "";
      }
      cachevar = dir;
      return dir;
    }
  }
}

cleanupTmpLocalFiles()

void VP1AvailEvents::Imp::cleanupTmpLocalFiles

(

)

Definition at line 289 of file VP1AvailEvents.cxx.

{
  if (maxLocalFilesToKeep<=2)
    return;
  if (tmpLocalFileDir.isEmpty())
    return;
  QString dir = theclass->tmpLocalFileDir();
  if (dir.isEmpty())
    return;
 
  QList<VP1EventFile> events = theclass->allLocalEvents();
  int ntoremove = events.count()-maxLocalFilesToKeep;
  if (ntoremove<=3)//3 instead of 0 to keep down the times we call the machinery below.
    return;
 
  //Rules of engagement:
  //We never delete the current event. We never delete the previous
  //event. We never delete the maxLocalFilesToKeep newest of the fresh
  //events.
 
  QList<Imp::EventID> protectedEvents;
  if (!historyOrdered.isEmpty()) {
    protectedEvents << historyOrdered.back();
    if (historyOrdered.count()>1)
      protectedEvents << historyOrdered.at(historyOrdered.count()-2);
  }
  QList<VP1EventFile> freshEvts = theclass->freshEvents();
  int ifreshkept(0);
  for (VP1EventFile evt : theclass->freshEvents()) {
    protectedEvents << Imp::evtToID(evt);
    if (++ifreshkept==maxLocalFilesToKeep)
      break;
  }
 
  //Remove:
  for (int i = events.count()-1; i>=0; --i ) {
    if (protectedEvents.contains(Imp::evtToID(events.at(i)))) {
      continue;
    }
    QFile::remove(events.at(i).fileName());
    if (--ntoremove<=0)
      break;
  }
  theclass->invalidateDirCache(theclass->tmpLocalFileDir());
}

evtToID()

EventID VP1AvailEvents::Imp::evtToID ( const VP1EventFile & evt )

inlinestatic

Definition at line 55 of file VP1AvailEvents.cxx.

                                                  {
    return EventID(evt.runNumber(),evt.eventNumber());
  }

Member Data Documentation

dircache

std::map<QString,std::pair<QDateTime,QList<VP1EventFile> > > VP1AvailEvents::Imp::dircache

Definition at line 64 of file VP1AvailEvents.cxx.

historyOrdered

QList<EventID> VP1AvailEvents::Imp::historyOrdered

Definition at line 59 of file VP1AvailEvents.cxx.

historySorted

std::set<EventID> VP1AvailEvents::Imp::historySorted

Definition at line 60 of file VP1AvailEvents.cxx.

lastAllLocal

QList<VP1EventFile> VP1AvailEvents::Imp::lastAllLocal

Definition at line 61 of file VP1AvailEvents.cxx.

lastFresh

QList<VP1EventFile> VP1AvailEvents::Imp::lastFresh

Definition at line 62 of file VP1AvailEvents.cxx.

maxLocalFilesToKeep

int VP1AvailEvents::Imp::maxLocalFilesToKeep {}

Definition at line 32 of file VP1AvailEvents.cxx.

{};

theclass

VP1AvailEvents* VP1AvailEvents::Imp::theclass {}

Definition at line 29 of file VP1AvailEvents.cxx.

{};

timeCutForNew

int VP1AvailEvents::Imp::timeCutForNew {}

Definition at line 30 of file VP1AvailEvents.cxx.

{};

tmpActiveRetrievalDir

QString VP1AvailEvents::Imp::tmpActiveRetrievalDir

Definition at line 35 of file VP1AvailEvents.cxx.

tmpDir

QString VP1AvailEvents::Imp::tmpDir

Definition at line 31 of file VP1AvailEvents.cxx.

tmpLocalFileDir

QString VP1AvailEvents::Imp::tmpLocalFileDir

Definition at line 34 of file VP1AvailEvents.cxx.

---

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

• VP1AvailEvents.cxx