Reimplemented from Impala::Util::ChannelServer. Definition at line 48 of file Server.h. References DeleteCases(), Impala::ILogErrors::GetInstance(), GetJobs(), Impala::ILogErrors::GetLastErrorSinceMark(), Impala::ILogErrors::GetNrErrorsSinceMark(), Impala::ILogErrors::Mark(), ScheduleJob(), and StatusJob(). 00049 { 00050 int rcBase = ChannelServer::AcceptRequest(buf, len, bufSize, conn, port); 00051 if (rcBase >= 0) 00052 return rcBase; 00053 00054 ILogErrors& errors = ILogErrors::GetInstance(); 00055 errors.Mark(); 00056 00057 if (strncmp(buf, "ScheduleJob", 11) == 0) 00058 ScheduleJob(buf, len, bufSize, conn, port); 00059 else if (strncmp(buf, "GetJobs", 7) == 0) 00060 GetJobs(buf, len, bufSize, conn, port); 00061 else if (strncmp(buf, "StatusJob", 9) == 0) 00062 StatusJob(buf, len, bufSize, conn, port); 00063 else if (strncmp(buf, "DeleteCases", 11) == 0) 00064 DeleteCases(buf, len, bufSize, conn, port); 00065 else 00066 return -1; 00067 00068 if (errors.GetNrErrorsSinceMark() > 0) 00069 { 00070 String last = errors.GetLastErrorSinceMark(); 00071 sprintf(buf, "ERROR: 500: Last error at server : %s\0", last.c_str()); 00072 } 00073 00074 return strlen(buf) + 1; 00075 }
Here is the call graph for this function:
|