This commit was generated by cvs2svn to compensate for changes in r2,

[ircu2.10.12-pk.git] / ircd / packet.c

diff --git a/ircd/packet.c b/ircd/packet.c
new file mode 100644 (file)
index 0000000..e4ef0dc
--- /dev/null
+++ b/ircd/packet.c
@@ -0,0 +1,153 @@
+/*
+ * IRC - Internet Relay Chat, common/packet.c
+ * Copyright (C) 1990  Jarkko Oikarinen and
+ *                     University of Oulu, Computing Center
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 1, or (at your option)
+ * any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ */
+
+#include "sys.h"
+#include "h.h"
+#include "struct.h"
+#include "s_misc.h"
+#include "s_bsd.h"
+#include "ircd.h"
+#include "msg.h"
+#include "parse.h"
+#include "send.h"
+#include "packet.h"
+#include "s_serv.h"
+
+#include <assert.h>
+
+RCSTAG_CC("$Id$");
+
+/*
+ * dopacket
+ *
+ *    cptr - pointer to client structure for which the buffer data
+ *           applies.
+ *    buffer - pointer to the buffer containing the newly read data
+ *    length - number of valid bytes of data in the buffer
+ *
+ *  Note:
+ *    It is implicitly assumed that dopacket is called only
+ *    with cptr of "local" variation, which contains all the
+ *    necessary fields (buffer etc..)
+ */
+int dopacket(aClient *cptr, char *buffer, int length)
+{
+  Reg1 char *ch1;
+  Reg2 char *ch2;
+  register char *cptrbuf;
+  aClient *acpt = cptr->acpt;
+
+  cptrbuf = cptr->buffer;
+  me.receiveB += length;       /* Update bytes received */
+  cptr->receiveB += length;
+  if (cptr->receiveB > 1023)
+  {
+    cptr->receiveK += (cptr->receiveB >> 10);
+    cptr->receiveB &= 0x03ff;  /* 2^10 = 1024, 3ff = 1023 */
+  }
+  if (acpt != &me)
+  {
+    acpt->receiveB += length;
+    if (acpt->receiveB > 1023)
+    {
+      acpt->receiveK += (acpt->receiveB >> 10);
+      acpt->receiveB &= 0x03ff;
+    }
+  }
+  else if (me.receiveB > 1023)
+  {
+    me.receiveK += (me.receiveB >> 10);
+    me.receiveB &= 0x03ff;
+  }
+  ch1 = cptrbuf + cptr->count;
+  ch2 = buffer;
+  while (--length >= 0)
+  {
+    register char g;
+    g = (*ch1 = *ch2++);
+    /*
+     * Yuck.  Stuck.  To make sure we stay backward compatible,
+     * we must assume that either CR or LF terminates the message
+     * and not CR-LF.  By allowing CR or LF (alone) into the body
+     * of messages, backward compatibility is lost and major
+     * problems will arise. - Avalon
+     */
+    if (g < '\16' && (g == '\n' || g == '\r'))
+    {
+      if (ch1 == cptrbuf)
+       continue;               /* Skip extra LF/CR's */
+      *ch1 = '\0';
+      me.receiveM += 1;                /* Update messages received */
+      cptr->receiveM += 1;
+      if (cptr->acpt != &me)
+       cptr->acpt->receiveM += 1;
+      if (IsServer(cptr))
+      {
+       if (parse_server(cptr, cptr->buffer, ch1) == CPTR_KILLED)
+         return CPTR_KILLED;
+      }
+      else if (parse_client(cptr, cptr->buffer, ch1) == CPTR_KILLED)
+       return CPTR_KILLED;
+      /*
+       *  Socket is dead so exit
+       */
+      if (IsDead(cptr))
+       return exit_client(cptr, cptr, &me, LastDeadComment(cptr));
+      ch1 = cptrbuf;
+    }
+    else if (ch1 < cptrbuf + (sizeof(cptr->buffer) - 1))
+      ch1++;                   /* There is always room for the null */
+  }
+  cptr->count = ch1 - cptr->buffer;
+  return 0;
+}
+
+/*
+ * client_dopacket - handle client messages
+ */
+int client_dopacket(aClient *cptr, size_t length)
+{
+  assert(0 != cptr);
+
+  me.receiveB += length;       /* Update bytes received */
+  cptr->receiveB += length;
+
+  if (cptr->receiveB > 1023)
+  {
+    cptr->receiveK += (cptr->receiveB >> 10);
+    cptr->receiveB &= 0x03ff;  /* 2^10 = 1024, 3ff = 1023 */
+  }
+  if (me.receiveB > 1023)
+  {
+    me.receiveK += (me.receiveB >> 10);
+    me.receiveB &= 0x03ff;
+  }
+  cptr->count = 0;
+
+  ++me.receiveM;               /* Update messages received */
+  ++cptr->receiveM;
+
+  if (CPTR_KILLED == parse_client(cptr, cptr->buffer, cptr->buffer + length))
+    return CPTR_KILLED;
+  else if (IsDead(cptr))
+    return exit_client(cptr, cptr, &me, LastDeadComment(cptr));
+
+  return 0;
+}