X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=apps%2Fclients.c;h=65fea7d642eca9e87b36f3b737bc88a93c30c0b8;hb=564cf3eb28dfc5df9faae18ef7bd7d4384e2f11c;hp=cd7bcee8d7593829a1fef8beacfb6c34cc9eea4e;hpb=cd414751eb1367ac4d0da57630785fed7389d982;p=sympathy.git

diff --git a/apps/clients.c b/apps/clients.c
index cd7bcee..65fea7d 100644
--- a/apps/clients.c
+++ b/apps/clients.c
@@ -1,4 +1,4 @@
-/*
+/* 
  * clients.c:
  *
  * Copyright (c) 2008 James McKenzie <james@fishsoup.dhs.org>,
@@ -6,10 +6,73 @@
  *
  */
 
-static char rcsid[] = "$Id$";
+static char rcsid[] = "$Id: clients.c,v 1.25 2008/05/09 12:35:57 james Exp $";
 
-/*
- * $Log$
+/* 
+ * $Log: clients.c,v $
+ * Revision 1.25  2008/05/09 12:35:57  james
+ * *** empty log message ***
+ *
+ * Revision 1.24  2008/03/11 17:56:04  james
+ * *** empty log message ***
+ *
+ * Revision 1.23  2008/03/11 17:47:24  james
+ * *** empty log message ***
+ *
+ * Revision 1.22  2008/03/07 14:16:44  james
+ * *** empty log message ***
+ *
+ * Revision 1.21  2008/03/07 14:13:40  james
+ * *** empty log message ***
+ *
+ * Revision 1.20  2008/03/07 13:56:39  james
+ * *** empty log message ***
+ *
+ * Revision 1.19  2008/03/07 13:16:02  james
+ * *** empty log message ***
+ *
+ * Revision 1.18  2008/03/03 18:16:16  james
+ * *** empty log message ***
+ *
+ * Revision 1.17  2008/03/03 18:15:19  james
+ * *** empty log message ***
+ *
+ * Revision 1.16  2008/03/03 06:04:42  james
+ * *** empty log message ***
+ *
+ * Revision 1.15  2008/03/02 10:27:24  james
+ * *** empty log message ***
+ *
+ * Revision 1.14  2008/02/28 16:57:51  james
+ * *** empty log message ***
+ *
+ * Revision 1.13  2008/02/28 16:37:16  james
+ * *** empty log message ***
+ *
+ * Revision 1.12  2008/02/28 12:12:24  james
+ * *** empty log message ***
+ *
+ * Revision 1.11  2008/02/23 11:48:51  james
+ * *** empty log message ***
+ *
+ * Revision 1.10  2008/02/22 17:06:59  james
+ * *** empty log message ***
+ *
+ * Revision 1.9  2008/02/20 18:49:11  staffcvs
+ * *** empty log message ***
+ *
+ * Revision 1.8  2008/02/20 18:31:44  james
+ * *** empty log message ***
+ *
+ * Revision 1.7  2008/02/15 23:52:12  james
+ * *** empty log message ***
+ *
+ * Revision 1.6  2008/02/15 03:32:07  james
+ * *** empty log message ***
+ *
+ * Revision 1.5  2008/02/14 10:34:47  james
+ * *** empty log message ***
+ *
  * Revision 1.4  2008/02/14 10:34:30  james
  * *** empty log message ***
  *
@@ -25,27 +88,75 @@ static char rcsid[] = "$Id$";
  */
 
 #include <sympathy.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <strings.h>
+#include <malloc.h>
 #include "clients.h"
 
-static void
-client_msg (IPC_Msg * m, Context * c)
+
+void
+client_initialize (Client * c, Context * ctx)
+{
+  send_history (ctx->h, c);
+  send_vt102 (ctx->v, c);
+  c->initialized = 1;
+}
+
+void
+client_execute_message (Client * client, IPC_Msg * m, Context * c)
 {
   switch (m->hdr.type)
     {
-
     case IPC_MSG_TYPE_NOOP:
       break;
     case IPC_MSG_TYPE_DEBUG:
-      fprintf (stderr, "%p [%d] %s\n", m, m->hdr.size, m->debug.msg);
+      log_f (c->l, "<debug message %s>", m->debug.msg);
       break;
     case IPC_MSG_TYPE_KEY:
       vt102_send (c, m->key.key);
       break;
+    case IPC_MSG_TYPE_SETBAUD:
+      tty_set_baud (c->t, m->setbaud.baud);
+      tty_parse_reset (c);
+      log_f (c->l, "<baud changed to %d>", m->setbaud.baud);
+      break;
+    case IPC_MSG_TYPE_SENDBREAK:
+      log_f (c->l, "<break sent>");
+      tty_send_break (c->t);
+      break;
+    case IPC_MSG_TYPE_SETFLOW:
+      log_f (c->l, "<flow control turned %s>",
+             m->setflow.flow ? "on" : "off");
+      tty_set_flow (c->t, m->setflow.flow);
+      break;
+    case IPC_MSG_TYPE_SETANSI:
+      vt102_set_ansi (c->v, m->setansi.ansi);
+      break;
+    case IPC_MSG_TYPE_HANGUP:
+      log_f (c->l, "<hangup initiated>");
+      tty_hangup (c->t);
+      break;
+    case IPC_MSG_TYPE_SETSIZE:
+      vt102_resize (c, m->setsize.winsize);
+      break;
+    case IPC_MSG_TYPE_RESET:
+      vt102_reset (c);
+      break;
+    case IPC_MSG_TYPE_INITIALIZE:
+      client_initialize (client, c);
+      break;
+    case IPC_MSG_TYPE_KILLME:
+      client->dead++;
+      break;
+
     default:
-      fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type);
+      log_f (c->l, "<Unhandled message type %d>", m->hdr.type);
     }
 }
 
+
 void
 client_free (Client * c)
 {
@@ -53,7 +164,9 @@ client_free (Client * c)
     socket_free (c->s);
 
   free (c);
+#if 0
   fprintf (stderr, "Client at %p freed\n", c);
+#endif
 }
 
 Client *
@@ -61,8 +174,9 @@ clients_new_client (Clients * cs, Socket * s, Context * ctx)
 {
   Client *c;
 
-  c = (Client *) malloc (sizeof (Client));
+  c = (Client *) xmalloc (sizeof (Client));
 
+  c->initialized = 0;
   c->dead = 0;
   c->s = s;
   c->next = cs->head;
@@ -70,8 +184,11 @@ clients_new_client (Clients * cs, Socket * s, Context * ctx)
   cs->head = c;
   cs->n++;
 
+#if 0
   fprintf (stderr, "Client at %p created\n", c);
+#endif
 
+  log_f (ctx->l, "<client %p connected - now %d clients>", c, cs->n);
 
   if (ipc_msg_send_debug (s, "new_client"))
     c->dead++;
@@ -80,7 +197,7 @@ clients_new_client (Clients * cs, Socket * s, Context * ctx)
 }
 
 void
-clients_reap (Clients * cs)
+clients_reap (Clients * cs, Context * ctx)
 {
   Client **p, *c;
 
@@ -94,6 +211,8 @@ clients_reap (Clients * cs)
           *p = c->next;
           client_free (c);
           cs->n--;
+          log_f (ctx->l, "<client %p disconnected - now %d clients>", c,
+                 cs->n);
         }
       else
         {
@@ -105,7 +224,7 @@ clients_reap (Clients * cs)
 Clients *
 clients_new (void)
 {
-  Clients *ret = (Clients *) malloc (sizeof (Clients));
+  Clients *ret = (Clients *) xmalloc (sizeof (Clients));
 
   ret->n = 0;
   ret->head = NULL;
@@ -141,19 +260,21 @@ clients_post_select (Clients * cs, Context * ctx, fd_set * rfds,
 
       if (c->s->msg)
         {
-          client_msg (c->s->msg, ctx);
+          client_execute_message (c, c->s->msg, ctx);
           socket_consume_msg (c->s);
+          if (c->dead)
+            deaded++;
         }
 
     }
 
   if (deaded)
-    clients_reap (cs);
+    clients_reap (cs, ctx);
 }
 
 
 void
-clients_shutdown (Clients * cs)
+clients_shutdown (Clients * cs, Context * ctx)
 {
   Client *c;
 
@@ -163,7 +284,7 @@ clients_shutdown (Clients * cs)
     }
 
 
-  clients_reap (cs);
+  clients_reap (cs, ctx);
 }
 
 
@@ -180,8 +301,9 @@ send_status (Clients * cs, char *msg)
 
   Client *c;
 
-  if (!msg) return;
-  len=strlen(msg)+1;
+  if (!msg)
+    return;
+  len = strlen (msg) + 1;
 
   if (!len)
     return;
@@ -190,12 +312,12 @@ send_status (Clients * cs, char *msg)
 
   m->size = len + sizeof (IPC_Msg_status);
   m->type = IPC_MSG_TYPE_STATUS;
-  strncpy(m->status,msg, IPC_MAX_BUF);
-  m->status[IPC_MAX_BUF-1]=0;
+  strncpy (m->status, msg, IPC_MAX_BUF);
+  m->status[IPC_MAX_BUF - 1] = 0;
 
   for (c = cs->head; c; c = c->next)
     {
-      if (!c->dead)
+      if (!c->dead && c->initialized)
         if (ipc_msg_send (c->s, (IPC_Msg *) m))
           c->dead++;
     }
@@ -224,7 +346,7 @@ send_output (Clients * cs, void *buf, int len)
 
   for (c = cs->head; c; c = c->next)
     {
-      if (!c->dead)
+      if (!c->dead && c->initialized)
         if (ipc_msg_send (c->s, (IPC_Msg *) m))
           c->dead++;
     }
@@ -262,5 +384,3 @@ send_vt102 (VT102 * v, Client * c)
     c->dead++;
 
 }
-
-