Definition at line 159 of file ServerProxy.h. References Impala::Util::StringParser::GetInt(), Impala::Util::StringParser::GetString(), ILOG_ERROR, Impala::MakeString(), mChannelProxy, Impala::Util::StringParser::Position(), and Impala::Util::ChannelProxy::Send(). Referenced by Impala::Application::IDash::mainIDashServer(), Impala::Core::VideoJob::Manager::MonitorJobs(), and Impala::Core::IDash::Server::StatusJob(). 00160 { 00161 String request = "ProvideStatus:jobId=" + MakeString(jobId); 00162 String response = mChannelProxy->Send(request); 00163 Util::StringParser parser(response); 00164 if (parser.GetString(':') == "JobStatus" && 00165 parser.GetString('=') == "jobId" && 00166 parser.GetInt(';', true, true) == jobId && 00167 parser.GetString('=') == "state") 00168 { 00169 state = (StateType) parser.GetInt(';', true, true); 00170 if (parser.GetString('=') == "exitCode") 00171 { 00172 exitCode = parser.GetInt(';', true, true); 00173 if (parser.GetString('=') == "errorLog") 00174 errorLog = response.substr(parser.Position()); 00175 return 0; 00176 } 00177 } 00178 ILOG_ERROR("Job report request failed: " << response); 00179 return -1; 00180 }
Here is the call graph for this function:
|