Impala Documentation

virtual int Impala::Core::IDash::Server::AcceptRequest	(	char *	buf,
		int	len,
		int	bufSize,
		CString	conn,
		int	port
	)			`[inline, protected, virtual]`

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: