ATLAS Offline Software
Public Member Functions | Public Attributes | List of all members
VP1EvtsOnServerInfo::Imp Class Reference
Collaboration diagram for VP1EvtsOnServerInfo::Imp:

Public Member Functions

 Imp (const QString &infofile)
 
QString init (const QString &infofile)
 

Public Attributes

QString error
 
QList< VP1EventFileevents
 

Detailed Description

Definition at line 24 of file VP1EvtsOnServerInfo.cxx.

Constructor & Destructor Documentation

◆ Imp()

VP1EvtsOnServerInfo::Imp::Imp ( const QString &  infofile)
inline

Definition at line 26 of file VP1EvtsOnServerInfo.cxx.

27  {
28  error = init(infofile);
29  }

Member Function Documentation

◆ init()

QString VP1EvtsOnServerInfo::Imp::init ( const QString &  infofile)

Definition at line 89 of file VP1EvtsOnServerInfo.cxx.

90 {
91  //Example of file we are trying to parse:
92  //
93  //begin_copyresult
94  //source dir /client/VP1_events
95  //dest dir /www/web_files/html/vp1events
96  //vp1_69629_5487_1211316972.pool.root copy success
97  //end_copyresult
98  //begin_checksums
99  //vp1_69629_5487_1211316972.pool.root 30fa3c9a05251a4d741fce52c304a341
100  //vp1_69629_5270_1211316960.pool.root 7a38564cdd2f2951e76ec37c565dbbf9
101  //vp1_69629_3968_1211316900.pool.root 6c716952a7fdb0371b1541a45d0029f8
102  //end_checksums
103  //
104  //The format of the event file names are: vp1_[run#]_[evt#]_[unixtime].pool.root
105  //
106  //In principle we are only interested in the checksums section, but
107  //it might be a good sanity check to see that the last copied file
108  //(from copyresult) is also the one with the highest time.
109 
111  // Basic check that file exists, is readable, etc. //
113 
114  if (infofile.isEmpty())
115  return "Given empty path to info file";
116  QFileInfo fi(infofile);
117  if (!fi.exists())
118  return "infofile "+infofile+" does not exist";
119  if (!fi.isReadable())
120  return "infofile "+infofile+" is not readable";
121  if (fi.size()==0)
122  return "infofile "+infofile+" is not empty";
123 
125  // Read file into stringlist, ignoring empty lines and excess whitespace //
127 
128  int i_begin_copyresult(-1), i_end_copyresult(-1);
129  int i_begin_checksums(-1), i_end_checksums(-1);
130 
131 
132  QStringList lines;
133  QFile file(infofile);
134  if (!file.open(QFile::ReadOnly))
135  return "Could not open file in readonly mode";
136 
137  //Just to avoid any potential performance problems if pointed to a
138  //wrong input file:
139  const qint64 max_linelength(1000);
140  const qint64 max_numberoflines(2000);
141  qint64 ilines(0);
142 
143  QTextStream stream(&file);
144  while (!stream.atEnd()) {
145 
146  if (ilines++>max_numberoflines)
147  return "Too many lines in file";
148 
149  //Read and prune next line:
150  QString rawline = stream.readLine(max_linelength).simplified();
151  if (rawline.isEmpty())
152  continue;
153 
154  //Get section boundaries:
155  if (rawline=="begin_copyresult") {
156  if (i_begin_copyresult!=-1)
157  return "Saw two lines with begin_copyresult";
158  i_begin_copyresult = lines.count();
159  } else if (rawline=="end_copyresult") {
160  if (i_end_copyresult!=-1)
161  return "Saw two lines with end_copyresult";
162  i_end_copyresult = lines.count();
163  } else if (rawline=="begin_checksums") {
164  if (i_begin_checksums!=-1)
165  return "Saw two lines with begin_checksums";
166  i_begin_checksums = lines.count();
167  } else if (rawline=="end_checksums") {
168  if (i_end_checksums!=-1)
169  return "Saw two lines with end_checksums";
170  i_end_checksums = lines.count();
171  }
172 
173  //Store line:
174  lines << rawline;
175  }
176  if (lines.isEmpty())
177  return "Did not read any lines from file";
178 
179  //copy result is only used for a sanity check, so we keep it optional
180  const bool hascopyresult(i_begin_copyresult!=-1||i_end_copyresult!=-1);
181 
182  if (i_begin_checksums==-1) return "File did not have begin_checksums line";
183  if (i_end_checksums==-1) return "File did not have end_checksums line";
184  if (i_end_checksums<=i_begin_checksums) return "checksum section delimiters out of order";
185 
186  if (hascopyresult) {
187  if (i_begin_copyresult==-1) return "File had end_copyresult but no begin_copyresult line";
188  if (i_end_copyresult==-1) return "File had begin_copyresult but no end_copyresult line";
189  if (i_end_copyresult<=i_begin_copyresult) return "copyresult section delimiters out of order";
190  if (i_begin_copyresult>i_begin_checksums&&i_begin_copyresult<i_end_checksums)
191  return "copyresult and checksum sections mixed";
192  if (i_end_copyresult>i_begin_checksums&&i_end_copyresult<i_end_checksums)
193  return "copyresult and checksum sections mixed";
194  }
195 
197  // Let the parsing begin!! //
199 
200  for (int i = i_begin_checksums+1;i < i_end_checksums; ++i) {
201 #if QTCORE_VERSION >= 0x050E00
202  QStringList parts = lines.at(i).split ( ' ', Qt::SkipEmptyParts );
203 #else
204  QStringList parts = lines.at(i).split ( ' ', QString::SkipEmptyParts );
205 #endif
206  if (parts.count()!=2)
207  return "Invalid line in checksums section";
208  QString filename(parts.at(0));
209  QString md5sum(VP1MD5Sum::sumToStandardFormat(parts.at(1)));
210  if (!VP1MD5Sum::validMD5Sum(md5sum))
211  return "Invalid md5sum in checksums section: "+md5sum;
212  VP1EventFile evt(filename,md5sum);
213  if (!evt.isValid())
214  return "Failed to decode event file information from filename: "+filename;
215  events << evt;
216  }
217 
218  std::sort(events.begin(), events.end());
219 
220  if (hascopyresult) {
221  //Todo: Use the copy result lines for a sanity check of that the
222  //newest file is also the one copied last (if copy succesful).
223  }
224 
225  return "";
226 }

Member Data Documentation

◆ error

QString VP1EvtsOnServerInfo::Imp::error

Definition at line 31 of file VP1EvtsOnServerInfo.cxx.

◆ events

QList<VP1EventFile> VP1EvtsOnServerInfo::Imp::events

Definition at line 34 of file VP1EvtsOnServerInfo.cxx.


The documentation for this class was generated from the following file:
LArG4FSStartPointFilter.evt
evt
Definition: LArG4FSStartPointFilter.py:42
AthenaPoolTestWrite.stream
string stream
Definition: AthenaPoolTestWrite.py:12
VP1MD5Sum::validMD5Sum
static bool validMD5Sum(const QString &)
Definition: VP1MD5Sum.cxx:88
CaloCondBlobAlgs_fillNoiseFromASCII.lines
lines
Definition: CaloCondBlobAlgs_fillNoiseFromASCII.py:104
lumiFormat.i
int i
Definition: lumiFormat.py:85
VP1EvtsOnServerInfo::Imp::events
QList< VP1EventFile > events
Definition: VP1EvtsOnServerInfo.cxx:34
file
TFile * file
Definition: tile_monitor.h:29
VP1MD5Sum::sumToStandardFormat
static QString sumToStandardFormat(const QString &)
Definition: VP1MD5Sum.cxx:96
VP1EventFile
Definition: VP1EventFile.h:23
std::sort
void sort(typename std::reverse_iterator< DataModel_detail::iterator< DVL > > beg, typename std::reverse_iterator< DataModel_detail::iterator< DVL > > end, const Compare &comp)
Specialization of sort for DataVector/List.
Definition: DVL_algorithms.h:623
CaloCellTimeCorrFiller.filename
filename
Definition: CaloCellTimeCorrFiller.py:24
checkFileSG.fi
fi
Definition: checkFileSG.py:65
doL1CaloHVCorrections.parts
parts
Definition: doL1CaloHVCorrections.py:334
error
Definition: IImpactPoint3dEstimator.h:70
VP1EvtsOnServerInfo::Imp::init
QString init(const QString &infofile)
Definition: VP1EvtsOnServerInfo.cxx:89