38{
39 void LLDriver ::
40 testInvariant () const
41 {
43 }
44
45
46
47 LLDriver ::
48 LLDriver ()
49 {
51 }
52
53
54
55 ::StatusCode LLDriver ::
56 doManagerStep (Detail::ManagerData&
data)
const
57 {
59 using namespace msgEventLoop;
62 {
63 case Detail::ManagerStep::batchScriptVar:
64 {
65 data.batchName =
"run{JOBID}.cmd";
67 "#\n"
68 "# @ job_name = EventLoopAnalysis{JOBID}\n"
69 "# @ job_type = serial\n"
70 "# @ error = $(Cluster).err\n"
71 "# @ output = $(Cluster).out\n"
72 "# @ class = " +
queue +
"\n"
73 "# @ resources = ConsumableCpus(1) ConsumableMemory(4gb)\n"
74 "# @ wall_clock_limit = 00:20:00\n"
75 "# @ queue\n";
76 }
77 break;
78
79 case Detail::ManagerStep::submitJob:
80 case Detail::ManagerStep::doResubmit:
81 {
82
83
84
85 for (std::size_t iter :
data.batchJobIndices)
86 {
87
88
89 std::ostringstream
cmd;
90 cmd <<
"cd " <<
data.submitDir <<
"/submit && llsubmit "
91 <<
data.options.castString (Job::optSubmitFlags)
92 <<
" run"<<
iter<<
".cmd";
93
94 if (gSystem->Exec (
cmd.str().c_str()) != 0)
96 }
97 data.submitted =
true;
98 }
99 break;
100
101 default:
102 break;
103 }
104 return ::StatusCode::SUCCESS;
105 }
106}
#define RCU_NEW_INVARIANT(x)
#define RCU_READ_INVARIANT(x)
char data[hepevt_bytes_allocation_ATLAS]
#define RCU_THROW_MSG(message)