AcceptDisconnect(int port) | Impala::Util::ChannelServer | [inline, protected, virtual] |
AcceptJobStatus(char *buf, int len, int bufSize, CString conn, int port) | Impala::Job::Server | [inline, protected, virtual] |
AcceptNewJob(char *buf, int len, int bufSize, CString conn, int port) | Impala::Job::Server | [inline, protected, virtual] |
AcceptRequest(char *buf, int len, int bufSize, CString conn, int port) | Impala::Job::Server | [inline, protected, virtual] |
AcceptRequestForJob(char *buf, int len, int bufSize, CString conn, int port) | Impala::Job::Server | [inline, protected, virtual] |
AcceptRequestForStatus(char *buf, int len, int bufSize, CString conn, int port) | Impala::Job::Server | [inline, protected, virtual] |
AcceptRequestPortAssignment(char *buf, int len, int bufSize, CString conn, int port) | Impala::Util::ChannelServer | [inline, protected, virtual] |
AcceptRequestPortMode(char *buf, int len, int bufSize, CString conn, int port) | Impala::Util::ChannelServer | [inline, protected, virtual] |
AddToJobQueue(Job *job) | Impala::Job::Server | [inline] |
AllowWrite(int port) | Impala::Util::ChannelServer | [inline, protected] |
ChannelServer(int port, int nrPorts, bool doDynaPorts, CString passwordFile) | Impala::Util::ChannelServer | [inline] |
ConnectionDescr() | Impala::Util::ChannelServer | [inline, protected, virtual] |
FindJob(int jobId) | Impala::Job::Server | [inline] |
FirstPort() | Impala::Util::ChannelServer | [inline] |
GetStatusBuffer() | Impala::Util::ChannelServer | [inline, protected] |
HandleDisconnect(int port) | Impala::Job::Server | [inline, virtual] |
HandleError(CString msg) | Impala::Util::ChannelServer | [inline, virtual] |
HandleIdle() | Impala::Job::Server | [inline, virtual] |
HandleInfo(CString msg) | Impala::Util::ChannelServer | [inline, virtual] |
HandleRequest(char *buf, int len, int bufSize) | Impala::Util::ChannelServer | [inline, virtual] |
ILOG_VAR_DECL | Impala::Job::Server | [private] |
Init() | Impala::Job::Server | [inline, private] |
Job typedef | Impala::Job::Server | |
JobQueueFull() | Impala::Job::Server | [inline] |
JobState typedef | Impala::Job::Server | [private] |
JobStateType typedef | Impala::Job::Server | [private] |
mJobByPort | Impala::Job::Server | [private] |
mJobsDone | Impala::Job::Server | [private] |
mJobsWaiting | Impala::Job::Server | [private] |
mNextJobId | Impala::Job::Server | [private] |
mPoisoned | Impala::Job::Server | [private] |
NrOfPorts() | Impala::Util::ChannelServer | [inline] |
PopFirstFromJobQueue() | Impala::Job::Server | [inline] |
ReadQuotedString(const char *buf, int &index, int len) | Impala::Util::ChannelServer | [inline, protected] |
RemoveJobsAccepted(int srcPort) | Impala::Job::Server | [inline, private] |
RescheduleJob(int port) | Impala::Job::Server | [inline, private] |
Server(int port, int nrPorts, CString passwordFile) | Impala::Job::Server | [inline] |
SplitTime() | Impala::Util::ChannelServer | [inline, protected] |
Start(bool doIdle) | Impala::Util::ChannelServer | [inline, virtual] |
UpdateStatusBuf() | Impala::Util::ChannelServer | [inline, protected, virtual] |
UsesDynamicPortAssignment() | Impala::Util::ChannelServer | [inline] |
~ChannelServer() | Impala::Util::ChannelServer | [inline, virtual] |
~Server() | Impala::Job::Server | [inline, virtual] |