--- deliantra/server/socket/lowlevel.C	2006/12/20 01:19:11	1.27
+++ deliantra/server/socket/lowlevel.C	2007/03/01 12:28:17	1.34
@@ -1,25 +1,26 @@
 /*
-    CrossFire, A Multiplayer game for X-windows
-
-    Copyright (C) 1992 Frank Tore Johansen
-
-    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 2 of the License, 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.
-
-    The author can be reached via e-mail to mark@pyramid.com
-*/
-
+ * CrossFire, A Multiplayer game for X-windows
+ * 
+ * Copyright (C) 2005, 2006, 2007 Marc Lehmann & Crossfire+ Development Team
+ * Copyright (C) 1992 Frank Tore Johansen
+ *
+ * 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 2 of the License, 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.
+ * 
+ * The author can be reached via e-mail to mark@pyramid.com
+ */
+ 
 /**
  * \file
  * Low-level socket-related functions.
@@ -53,6 +54,9 @@
 void
 client::flush ()
 {
+  if (destroyed ())
+    return;
+
 #ifdef __linux__
   // check time of last ack, and, if too old, kill connection
   struct tcp_info tcpi;
@@ -184,12 +188,11 @@
  * Dispatch table for the server.
  */
 static struct packet_type packets[] = {
-  {"ncom",        PC(NewPlayerCmd) PF_PLAYING },
-  {"command",     PC(PlayerCmd)    PF_PLAYING },
+  {"ncom",        PC(NewPlayerCmd) PF_PLAYING | PF_COMMAND6 },
+  {"command",     PC(PlayerCmd)    PF_PLAYING | PF_COMMAND0 },
 
   {"examine",     PC(ExamineCmd)   PF_PLAYING },
   {"apply",       PC(ApplyCmd)     PF_PLAYING },
-  {"reply",       PC(ReplyCmd)     0 },
   {"lookat",      PC(LookAt)       PF_PLAYING },
   {"lock",        PC(LockItem)     PF_PLAYING },
   {"mark",        PC(MarkItem)     PF_PLAYING },
@@ -198,6 +201,7 @@
   {"mapredraw",   PC(MapRedrawCmd) 0 },       /* Added: phil */
   {"mapinfo",     PC(MapInfoCmd)   0 },   /* CF+ */
 
+  {"reply",       SC(ReplyCmd)     0 },
   {"exti",        SC(ExtiCmd)      0 }, /* CF+ */
   {"addme",       SC(AddMeCmd)     0 },
   {"askface",     SC(SendFaceCmd)  0 },     /* Added: phil */
@@ -215,13 +219,41 @@
 client::may_execute (const packet_type *pkt) const
 {
   return (!(pkt->flags & PF_PLAYER)  || pl)
-      && (!(pkt->flags & PF_PLAYING) || (pl && pl->state == ST_PLAYING));
+      && (!(pkt->flags & PF_PLAYING) || state == ST_PLAYING);
+}
+
+// HACK: some commands currently should be executed 
+// even when the player is frozen. this hack detects
+// those commands. it should be folded into may_execute,
+// but kept seperate to emphasise the hack aspect, i.e.
+// do it better, then remove.
+static bool
+always_immediate (const client *ns, const packet_type *pkt, const char *data, int len)
+{
+  if (!(pkt->flags & (PF_COMMAND0 | PF_COMMAND6)))
+    return false;
+
+  if (!ns->pl || !ns->pl->ob || !ns->pl->ob->map)
+    return false;
+
+  if (pkt->flags & PF_COMMAND6)
+    {
+      data += 6;
+      len  -= 6;
+    }
+
+  if (len > 4 && !strncmp (data, "say " , 4))
+    return true;
+  if (len > 5 && !strncmp (data, "chat ", 5))
+    return true;
+
+  return false;
 }
 
 void
 client::execute (const packet_type *pkt, char *data, int datalen)
 {
-  if (may_execute (pkt))
+  if (may_execute (pkt) || always_immediate (this, pkt, data, datalen))
     {
       //TODO: only one format
       if (pkt->flags & PF_PLAYER)
@@ -272,7 +304,7 @@
   for (packet_type *pkt = packets; pkt < packets + (sizeof (packets) / sizeof (packets[0])); ++pkt)
     if (!strcmp ((char *)inbuf + 2, pkt->name))
       {
-        if (pkt->flags & PF_PLAYER)
+        if (pkt->flags & PF_PLAYER && !always_immediate (this, pkt, data, datalen))
           queue_command (pkt, data, datalen);
         else
           execute (pkt, data, datalen);
@@ -296,7 +328,7 @@
 client::socket_cb (iow &w, int got)
 {
   //TODO remove when we have better socket cleanup logic
-  if (status == Ns_Dead)
+  if (destroyed ())
     {
       socket_ev.poll (0);
       return;
@@ -379,13 +411,11 @@
 client::send (void *buf_, int len)
 {
   char *buf = (char *)buf_;
-  char *pos = buf;
-  int amt = 0;
 
-  if (status == Ns_Dead || !buf)
+  if (destroyed () || !buf)
     return;
 
-  if ((len + outputbuffer.len) > SOCKETBUFSIZE)
+  if (len + outputbuffer.len > SOCKETBUFSIZE)
     {
       LOG (llevDebug, "socket on fd %d has overrun internal buffer - marking as dead\n", fd);
       destroy ();
@@ -423,7 +453,7 @@
 void
 client::send_packet (packet &sl)
 {
-  if (status == Ns_Dead)
+  if (destroyed ())
     return;
 
   if (sl.length () >= MAXSOCKBUF)