Impala Documentation

int Impala::Job::Server::AddToJobQueue ( Job * job ) [inline]

Definition at line 107 of file Server.h.

References ILOG_ERROR, ILOG_INFO, JobQueueFull(), mJobsWaiting, mNextJobId, and Impala::Job::State::SCHEDULED.

00108     {
00109         if (JobQueueFull())
00110         {
00111             ILOG_ERROR("Job queue full; cannot add job");
00112             return 0;
00113         }
00114         else
00115         {
00116             job->id = mNextJobId++; // doesnt account for overflow
00117             ILOG_INFO("Assigning job ID: " << job->id);
00118             job->state = State::SCHEDULED;
00119             job->portUsed = -1; // undefined
00120             job->exitCode = -99; // undefined
00121             mJobsWaiting.push_back(job);
00122             return job->id;
00123         }
00124     }

Here is the call graph for this function: