From f2c620137fa5290d913373e5579a97f0fee25fa3 Mon Sep 17 00:00:00 2001
From: james <>
Date: Mon, 3 Mar 2008 06:04:42 +0000
Subject: *** empty log message ***

---
 apps/clients.c | 177 +++++++++++++++++++++++++++++++--------------------------
 1 file changed, 97 insertions(+), 80 deletions(-)

(limited to 'apps/clients.c')

diff --git a/apps/clients.c b/apps/clients.c
index 4c4ea21..919f730 100644
--- a/apps/clients.c
+++ b/apps/clients.c
@@ -10,6 +10,9 @@ static char rcsid[] = "$Id$";
 
 /*
  * $Log$
+ * 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 ***
  *
@@ -68,43 +71,44 @@ static char rcsid[] = "$Id$";
 void
 client_msg (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);
-    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:
-    tty_send_break (c->t);
-    break;
-  case IPC_MSG_TYPE_SETFLOW:
-    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:
-    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;
-  default:
-    fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type);
-  }
+  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);
+      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:
+      tty_send_break (c->t);
+      break;
+    case IPC_MSG_TYPE_SETFLOW:
+      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:
+      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;
+    default:
+      fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type);
+    }
 }
 
 void
@@ -150,17 +154,21 @@ clients_reap (Clients * cs)
   Client **p, *c;
 
 
-  for (p = &cs->head; *p;) {
-    Client *c = *p;
-
-    if (c->dead) {
-      *p = c->next;
-      client_free (c);
-      cs->n--;
-    } else {
-      p = &(c->next);
+  for (p = &cs->head; *p;)
+    {
+      Client *c = *p;
+
+      if (c->dead)
+        {
+          *p = c->next;
+          client_free (c);
+          cs->n--;
+        }
+      else
+        {
+          p = &(c->next);
+        }
     }
-  }
 }
 
 Clients *
@@ -179,9 +187,10 @@ clients_pre_select (Clients * cs, fd_set * rfds, fd_set * wfds)
 {
   Client *c;
 
-  for (c = cs->head; c; c = c->next) {
-    socket_pre_select (c->s, rfds, wfds);
-  }
+  for (c = cs->head; c; c = c->next)
+    {
+      socket_pre_select (c->s, rfds, wfds);
+    }
 }
 
 void
@@ -191,18 +200,21 @@ clients_post_select (Clients * cs, Context * ctx, fd_set * rfds,
   Client *c;
   int deaded = 0;
 
-  for (c = cs->head; c; c = c->next) {
-    if (socket_post_select (c->s, rfds, wfds)) {
-      c->dead++;
-      deaded++;
-    }
+  for (c = cs->head; c; c = c->next)
+    {
+      if (socket_post_select (c->s, rfds, wfds))
+        {
+          c->dead++;
+          deaded++;
+        }
 
-    if (c->s->msg) {
-      client_msg (c->s->msg, ctx);
-      socket_consume_msg (c->s);
-    }
+      if (c->s->msg)
+        {
+          client_msg (c->s->msg, ctx);
+          socket_consume_msg (c->s);
+        }
 
-  }
+    }
 
   if (deaded)
     clients_reap (cs);
@@ -214,9 +226,10 @@ clients_shutdown (Clients * cs)
 {
   Client *c;
 
-  for (c = cs->head; c; c = c->next) {
-    c->dead++;
-  }
+  for (c = cs->head; c; c = c->next)
+    {
+      c->dead++;
+    }
 
 
   clients_reap (cs);
@@ -250,11 +263,12 @@ send_status (Clients * cs, char *msg)
   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 (ipc_msg_send (c->s, (IPC_Msg *) m))
-        c->dead++;
-  }
+  for (c = cs->head; c; c = c->next)
+    {
+      if (!c->dead)
+        if (ipc_msg_send (c->s, (IPC_Msg *) m))
+          c->dead++;
+    }
 
   return len;
 }
@@ -278,11 +292,12 @@ send_output (Clients * cs, void *buf, int len)
   m->len = len;
   memcpy (m->term, buf, len);
 
-  for (c = cs->head; c; c = c->next) {
-    if (!c->dead)
-      if (ipc_msg_send (c->s, (IPC_Msg *) m))
-        c->dead++;
-  }
+  for (c = cs->head; c; c = c->next)
+    {
+      if (!c->dead)
+        if (ipc_msg_send (c->s, (IPC_Msg *) m))
+          c->dead++;
+    }
 
 
   return len;
@@ -296,16 +311,18 @@ send_history (History * h, Client * c)
   HISTORY_INC (h, rptr);
 
   HISTORY_INC (h, rptr);
-  while (rptr != h->wptr) {
-    History_ent *l = &h->lines[rptr];
-    if (l->valid) {
+  while (rptr != h->wptr)
+    {
+      History_ent *l = &h->lines[rptr];
+      if (l->valid)
+        {
 
-      if (ipc_msg_send_history (c->s, l))
-        c->dead++;
+          if (ipc_msg_send_history (c->s, l))
+            c->dead++;
 
+        }
+      HISTORY_INC (h, rptr);
     }
-    HISTORY_INC (h, rptr);
-  }
 }
 
 void
-- 
cgit v1.2.3