#include <Server.h>
Inheritance diagram for Impala::Job::Server:
Public Types | |
typedef Impala::Job::Server::Job | Job |
Public Member Functions | |
Server (int port, int nrPorts, CString passwordFile) | |
virtual | ~Server () |
virtual void | HandleIdle () |
virtual void | HandleDisconnect (int port) |
bool | JobQueueFull () |
int | AddToJobQueue (Job *job) |
Job * | FindJob (int jobId) |
Job * | PopFirstFromJobQueue () |
Protected Member Functions | |
virtual int | AcceptRequest (char *buf, int len, int bufSize, CString conn, int port) |
virtual void | AcceptNewJob (char *buf, int len, int bufSize, CString conn, int port) |
virtual void | AcceptRequestForStatus (char *buf, int len, int bufSize, CString conn, int port) |
virtual void | AcceptRequestForJob (char *buf, int len, int bufSize, CString conn, int port) |
virtual void | AcceptJobStatus (char *buf, int len, int bufSize, CString conn, int port) |
Private Types | |
typedef Job::State | JobState |
typedef Job::State::StateType | JobStateType |
Private Member Functions | |
void | Init () |
void | RemoveJobsAccepted (int srcPort) |
void | RescheduleJob (int port) |
Private Attributes | |
bool | mPoisoned |
int | mNextJobId |
std::deque< Job * > | mJobsWaiting |
std::deque< Job * > | mJobsDone |
std::map< int, Job * > | mJobByPort |
ILOG_VAR_DECL | |
Classes | |
struct | Job |
Definition at line 23 of file Server.h.