#include <Runner.h>
Collaboration diagram for Impala::Job::Runner:
Public Member Functions | |
| Runner () | |
| virtual | ~Runner () |
| bool | IsConnected () |
| void | Disconnect () |
| bool | Connect (CString serverName, int port, CString passwordFile) |
| void | PoisonServer () |
| void | StopServer () |
| void | RunJobs (int maxJobs, int maxIdleTimeSec, int maxJobTimeMinutes, int sleepIntervalSec, String cmdLineExtension) |
| const std::list< String > & | GetJobList () const |
Private Member Functions | |
| bool | WaitForJob (int &jobId, String &cmdLine) |
| bool | RunJob (int jobId, String cmdLine, String cmdLineExtension) |
| void | Sleep (int sec) |
| String | GetJobErrorLog (int jobId) |
Private Attributes | |
| ILOG_VAR_DECL | |
| Process::Manager * | mProcessManager |
| Util::ChannelProxy * | mJobServerProxy |
| int | mMaxJobs |
| int | mMaxIdleTimeSec |
| int | mMaxJobTimeMinutes |
| int | mSleepIntervalSec |
| std::list< int > | mJobIdList |
| std::list< String > | mJobCmdLineList |
Definition at line 25 of file Runner.h.
1.5.1