| Job* Impala::Job::Server::FindJob | ( | int | jobId | ) | [inline] |
Definition at line 127 of file Server.h.
References Impala::Util::ChannelServer::FirstPort(), mJobByPort, mJobsDone, mJobsWaiting, and Impala::Util::ChannelServer::NrOfPorts().
Referenced by AcceptRequestForStatus().
00128 { 00129 // check running jobs... 00130 int maxPort = FirstPort() + NrOfPorts() - 1; 00131 for (int port = (FirstPort() + 1); port <= maxPort; port++) 00132 if (mJobByPort[port] != 0 && mJobByPort[port]->id == jobId) 00133 return mJobByPort[port]; 00134 00135 // ...and new jobs... 00136 int len = mJobsWaiting.size(); 00137 for (int i = 0; i < len; i++) 00138 if (mJobsWaiting[i]->id == jobId) 00139 return mJobsWaiting[i]; 00140 00141 // ...and terminated job 00142 len = mJobsDone.size(); 00143 for (int i = 0; i < len; i++) 00144 if (mJobsDone[i]->id == jobId) 00145 return mJobsDone[i]; 00146 00147 //ILOG_ERROR("Job ID " << jobId << " unknown"); 00148 return 0; 00149 }
Here is the call graph for this function:
