Reimplemented from Impala::Util::ChannelServer. Definition at line 76 of file Server.h. References Impala::Util::ChannelServer::FirstPort(), ILOG_DEBUG, mJobByPort, mJobsDone, mJobsWaiting, and Impala::Util::ChannelServer::NrOfPorts(). 00077 { 00078 ChannelServer::HandleIdle(); 00079 00080 int jobsWaiting = mJobsWaiting.size(); 00081 int jobsDone = mJobsDone.size(); 00082 int runningJobs = 0; 00083 int maxPort = FirstPort() + NrOfPorts() - 1; 00084 for (int port = (FirstPort() + 1); port <= maxPort; port++) 00085 if (mJobByPort[port] != 0) 00086 runningJobs++; 00087 ILOG_DEBUG("Jobs: waiting=" << jobsWaiting << ", running=" << 00088 runningJobs << ", done=" << jobsDone); 00089 }
Here is the call graph for this function:
|