- {
- result = result2;
- }
- }
- else
- {
- result = cu->ReadData(ReadBuffer, sizeof(ReadBuffer));
- }
-
- 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)
- {
- // Make sure they arn't flooding long lines.
- if (Server->Time() > current->reset_due)
- {
- current->reset_due = Server->Time() + current->threshold;
- current->lines_in = 0;
- }
-
- current->lines_in++;
-
- if (current->flood && current->lines_in > current->flood)
- 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, MAXBUF-2);
- current->recvq.clear();
- }
- }
- else
- Server->FloodQuitUser(current);
-
- return;
- }
-
- Server->Parser->DoLines(current);
-
- return;
- }
-
- if ((result == -1) && (errno != EAGAIN) && (errno != EINTR))
- {
- User::QuitUser(Server, 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)
- {
- User::QuitUser(Server, cu, "Connection closed");
- return;