--- deliantra/server/socket/info.C	2007/04/24 12:32:16	1.37
+++ deliantra/server/socket/info.C	2007/04/25 18:47:51	1.38
@@ -88,81 +88,51 @@
     esrv_print_msg (pl->contr->ns, colr, (char *) tmp);
 }
 
-/**
- * Prints out the contents of specified buffer structures,
- * and clears the string.
- */
-void
-flush_output_element (const object *pl, Output_Buf * outputs)
+bool
+client::msg_suppressed (const char *msg)
 {
-  char tbuf[MAX_BUF];
+  if (!pl)
+    return false;
 
-  if (outputs->buf == NULL)
-    return;
-  if (outputs->count > 1)
-    {
-      snprintf (tbuf, MAX_BUF, "%d times %s", outputs->count, &outputs->buf);
-      print_message (NDI_BLACK, pl, tbuf);
-    }
-  else
-    print_message (NDI_BLACK, pl, &outputs->buf);
+  if (pl->outputs_count <= 1 || !pl->outputs_sync)
+    return false;
 
-  outputs->buf = NULL;
-  outputs->first_update = 0;    /* This way, it will be reused */
-}
+  int len = strlen (msg);
 
-/**
- * Sends message to player through output buffers.
- * \param pl player to send message
- * \param buf message to send
- *
- * If player's output_count is 1, sends message directly.
- *
- * Else checks output buffers for specified message.
- *
- * If found, checks if message should be sent now.
- *
- * If message not already in buffers, flushes olders buffer,
- * and adds message to queue.
- */
-static void
-check_output_buffers (const object *pl, const char *buf)
-{
-  int i, oldest = 0;
+  if (len > MSG_BUF_SIZE)
+    return false;
 
-  if (pl->contr->outputs_count < 2)
-    {
-      print_message (NDI_BLACK, pl, buf);
-      return;
-    }
-  else
+  msg_buf *lru = msgbuf;
+  for (msg_buf *buf = msgbuf; buf < msgbuf + MSG_BUF_COUNT; ++buf)
     {
-      for (i = 0; i < NUM_OUTPUT_BUFS; i++)
+      if (len == buf->len && !memcmp (msg, buf->msg, len))
         {
-          if (pl->contr->outputs[i].buf && !strcmp (buf, pl->contr->outputs[i].buf))
-            break;
-          else if (pl->contr->outputs[i].first_update < pl->contr->outputs[oldest].first_update)
-            oldest = i;
-        }
-      /* We found a match */
-      if (i < NUM_OUTPUT_BUFS)
-        {
-          pl->contr->outputs[i].count++;
-          if (pl->contr->outputs[i].count >= pl->contr->outputs_count)
+          // found matching buf, see if expired
+          if (buf->expire <= pticks || !buf->count)
             {
-              flush_output_element (pl, &pl->contr->outputs[i]);
+              // yes, take over matching buffer, print
+              buf->expire = pticks + pl->outputs_sync;
+              buf->count  = pl->outputs_count;
+
+              return false;
             }
-        }
-      /* No match - flush the oldest, and put the new one in */
-      else
-        {
-          flush_output_element (pl, &pl->contr->outputs[oldest]);
 
-          pl->contr->outputs[oldest].first_update = pticks;
-          pl->contr->outputs[oldest].count = 1;
-          pl->contr->outputs[oldest].buf = buf;
+          // no, suppress
+          --buf->count;
+          return true;
         }
+
+      if (lru->expire > buf->expire)
+        lru = buf;
     }
+
+  // new message, evoke oldest buffer
+  lru->expire = pticks + pl->outputs_sync;
+  lru->count  = pl->outputs_count;
+  lru->len    = len;
+  memcpy (lru->msg, msg, len);
+
+  return false;
 }
 
 /**
@@ -181,7 +151,6 @@
  * If message is black, and not NDI_UNIQUE, gets sent through output buffers.
  *
  */
-
 void
 new_draw_info (int flags, int pri, const object *pl, const char *buf)
 {
@@ -199,9 +168,8 @@
   if (pri >= pl->contr->listening)
     return;
 
-  if ((flags & NDI_COLOR_MASK) == NDI_BLACK && !(flags & NDI_UNIQUE))
-    check_output_buffers (pl, buf);
-  else
+  if ((flags & (NDI_COLOR_MASK | NDI_UNIQUE)) != NDI_BLACK
+      || !pl->contr->ns->msg_suppressed (buf))
     print_message (flags & NDI_COLOR_MASK, pl, buf);
 }