Impala Documentation

void Impala::Job::Server::RescheduleJob ( int port ) [inline, private]

Definition at line 472 of file Server.h.

References ILOG_ERROR, ILOG_INFO, Impala::Job::State::RESCHEDULED, and Impala::Job::State::RUNNING.

00473     {
00474         Job* job = mJobByPort[port];
00475         if (job)
00476         {
00477             if (job->state != State::RUNNING)
00478                 ILOG_ERROR("Unexpected state of job at port " << port << ": "
00479                            << job->state);
00480             mJobByPort[port] = 0;
00481             mJobsWaiting.push_front(job);
00482             job->state = State::RESCHEDULED;
00483             job->portUsed = -99; // undefined
00484             ILOG_INFO("Job " << job->id << " rescheduled for execution");
00485         }
00486     }