-void ProcessUserHandler::Call(User* cu)
-{
- int result = EAGAIN;
-
- if (cu->GetFd() == FD_MAGIC_NUMBER)
- return;
-
- char* ReadBuffer = Server->GetReadBuffer();
-
- if (cu->io)
- {
- int result2 = 0;
- int MOD_RESULT = 0;
-
- try
- {
- MOD_RESULT = cu->io->OnRawSocketRead(cu->GetFd(), ReadBuffer, Server->Config->NetBufferSize, result2);
- }
- catch (CoreException& modexcept)
- {
- Server->Logs->Log("USERS",DEBUG, "%s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason());
- }
-
- if (MOD_RESULT < 0)
- {
- result = -EAGAIN;
- }
- else
- {
- result = result2;
- }
- }
- else
- {
- result = cu->ReadData(ReadBuffer, Server->Config->NetBufferSize);
- }
-
- if ((result) && (result != -EAGAIN))
- {
- User *current;
- int currfd;
-
- Server->stats->statsRecv += result;
- /*
- * perform a check on the raw buffer as an array (not a string!) to remove
- * character 0 which is illegal in the RFC - replace them with spaces.
- */
-
- for (int checker = 0; checker < result; checker++)
- {
- if (ReadBuffer[checker] == 0)
- ReadBuffer[checker] = ' ';
- }
-
- if (result > 0)
- ReadBuffer[result] = '\0';
-
- current = cu;
- currfd = current->GetFd();
-
- // add the data to the users buffer
- if (result > 0)
- {
- if (!current->AddBuffer(ReadBuffer))
- {
- // AddBuffer returned false, theres too much data in the user's buffer and theyre up to no good.
- if (current->registered == REG_ALL)
- {
- if (current->MyClass)
- {
- // Make sure they arn't flooding long lines.
- if (Server->Time() > current->reset_due)
- {
- current->reset_due = Server->Time() + current->MyClass->GetThreshold();
- current->lines_in = 0;
- }
-
- current->lines_in++;
-
- if (current->MyClass->GetFlood() && current->lines_in > current->MyClass->GetFlood())
- Server->FloodQuitUser(current);
- else
- {
- current->WriteServ("NOTICE %s :Your previous line was too long and was not delivered (Over %d chars) Please shorten it.", current->nick.c_str(), MAXBUF-2);
- current->recvq.clear();
- }
- }
- }
- else
- Server->FloodQuitUser(current);
-
- return;
- }
-
- /* If user is over penalty, dont process here, just build up */
- if (!current->OverPenalty)
- Server->Parser->DoLines(current);
-
- return;
- }
-
- if ((result == -1) && (errno != EAGAIN) && (errno != EINTR))
- {
- Server->Users->QuitUser(cu, errno ? strerror(errno) : "EOF from client");
- return;
- }
- }
-
- // result EAGAIN means nothing read
- else if ((result == EAGAIN) || (result == -EAGAIN))
- {
- /* do nothing */
- }
- else if (result == 0)
- {
- Server->Users->QuitUser(cu, "Connection closed");
- return;
- }
-}
-