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