Impala Documentation

void Impala::Job::Runner::RunJobs	(	int	maxJobs,
		int	maxIdleTimeSec,
		int	maxJobTimeMinutes,
		int	sleepIntervalSec,
		String	cmdLineExtension
	)			`[inline]`

Definition at line 91 of file Runner.h.

References ILOG_ERROR, ILOG_INFO, IsConnected(), mJobCmdLineList, mMaxIdleTimeSec, mMaxJobs, mMaxJobTimeMinutes, mSleepIntervalSec, RunJob(), and WaitForJob().

Referenced by Impala::Application::mainJobRunner().

00093     {
00094         if (!IsConnected())
00095         {
00096             ILOG_ERROR("Not connected to a job server");
00097             return;
00098         }
00099 
00100         mMaxJobs = maxJobs;
00101         mMaxIdleTimeSec = maxIdleTimeSec;
00102         mMaxJobTimeMinutes = maxJobTimeMinutes;
00103         mSleepIntervalSec = sleepIntervalSec;
00104 
00105         while (true)
00106         {
00107             if (mMaxJobs > 0 && mJobCmdLineList.size() >= mMaxJobs)
00108             {
00109                 ILOG_INFO("Maximum of jobs to run was reached (" <<
00110                           mJobCmdLineList.size() << ")");
00111                 break;
00112             }
00113             
00114             int jobId = 0;
00115             String cmdLine = "";
00116             if (!WaitForJob(jobId, cmdLine) ||
00117                 !RunJob(jobId, cmdLine, cmdLineExtension))
00118             {
00119                 break;
00120             }
00121         }
00122     }

Here is the call graph for this function: