|
ATLAS Offline Software
|
Go to the documentation of this file.
19 #include <QStringList>
57 ISvcLocator* svclocator,IToolSvc*toolSvc,
58 const std::vector<std::string>& initialvp1files,
59 const std::string& initialCruiseMode,
unsigned initialCruiseSeconds,
60 const std::string& singleEventSource,
const std::string& singleEventLocalTmpDir,
61 unsigned localFileCacheLimit,
62 const std::vector<std::string>& availableLocalInputDirectories )
75 std::vector<std::string>::const_iterator
it,
itE = initialvp1files.end();
76 for (
it = initialvp1files.begin();
it!=
itE;++
it)
79 itE = availableLocalInputDirectories.end();
80 for (
it = availableLocalInputDirectories.begin();
it!=
itE;++
it)
128 if (!
url.isValid()||
url.path().isEmpty()) {
137 && ! (QSslSocket::supportsSsl()) ) {
141 VP1Msg::message(
"VP1ExecutionScheduler::init ERROR: Unable to retrieve events over Https. The platform does not support SSL");
146 if (!fi_s.exists()||!fi_s.isDir()||!fi_s.isReadable()) {
150 if (!fi_l.exists()||!fi_l.isDir()||!fi_l.isReadable()||!fi_l.isWritable()) {
154 if (fi_l.canonicalFilePath()==fi_s.canonicalFilePath()) {
161 VP1Msg::message(
"ERROR: Only one of SourceDir and LocalCopyDir set. Set either both or none.");
167 VP1Msg::message(
"WARNING: Too low value of localFileCacheLimit. Setting to 3. (Set to 0 to disable removal of locally cached files.");
187 VP1Msg::message(
"===================================================");
189 VP1Msg::message(
"===================================================");
239 std::vector<std::string> retvector;
242 for(
int i=0;
i<inplist.size(); ++
i)
243 retvector.push_back(inplist.at(
i).toStdString());
QString singleEventLocalTmpDir
const QString & nextRequestedEventFile() const
VP1ExecutionScheduler * the_scheduler
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 >())
unsigned initialCruiseSeconds
bool executeNewEvent(const int &run, const uint64_t &event, const unsigned &triggerType=0, const unsigned &time=0)
QString singleEventSource
static VP1ExecutionScheduler * init(StoreGateSvc *eventStore, StoreGateSvc *detStore, ISvcLocator *svcLocator, IToolSvc *toolSvc, const QStringList &joboptions, QString initialCruiseMode="NONE", unsigned initialCruiseSeconds=10, const QString &singleEventSource="", const QString &singleEventLocalTmpDir="", unsigned localFileCacheLimit=10, const QStringList &availableLocalInputDirectories=QStringList())
The Athena Transient Store API.
QStringList userRequestedFiles()
POOL::TEvent event(POOL::TEvent::kClassAccess)
QStringList availableLocalInputDirectories
bool hasBeenInitialised()
QStringList initialvp1files
std::vector< std::string > userRequestedFiles()
unsigned localFileCacheLimit
static void messageDebug(const QString &)
def time(flags, cells_name, *args, **kw)
static void message(const QString &, IVP1System *sys=0)
bool argumentsAreValid() const
std::string nextRequestedEventFile() const
QString initialCruiseMode
static void cleanup(VP1ExecutionScheduler *)
bool executeNewEvent(const int &runnumber, const unsigned long long &eventnumber, const unsigned &triggerType=0, const unsigned &time=0)