From be42afab1c325fae5c3c270876a3447220adcca5 Mon Sep 17 00:00:00 2001 From: james <> Date: Fri, 7 Mar 2008 13:16:02 +0000 Subject: *** empty log message *** --- apps/clients.c | 165 ++++++++----- apps/clients.h | 10 +- apps/mainloop.c | 408 ++++++++++++++---------------- apps/mainloop.h | 9 +- apps/sympathy.c | 749 +++++++++++++++++++++++++------------------------------- apps/usage.c | 7 +- 6 files changed, 652 insertions(+), 696 deletions(-) (limited to 'apps') diff --git a/apps/clients.c b/apps/clients.c index 621c21c..0dcd863 100644 --- a/apps/clients.c +++ b/apps/clients.c @@ -1,4 +1,4 @@ -/* +/* * clients.c: * * Copyright (c) 2008 James McKenzie , @@ -8,8 +8,11 @@ static char rcsid[] = "$Id$"; -/* +/* * $Log$ + * 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 *** * @@ -74,6 +77,61 @@ static char rcsid[] = "$Id$"; #include #include "clients.h" + +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: + log_f (c->l, "", 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, "", m->setbaud.baud); + break; + case IPC_MSG_TYPE_SENDBREAK: + log_f (c->l, ""); + tty_send_break (c->t); + break; + case IPC_MSG_TYPE_SETFLOW: + log_f (c->l, "", 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, ""); + 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; + default: + log_f (c->l, "", m->hdr.type); + } +} + + void client_free (Client * c) { @@ -91,8 +149,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; @@ -117,27 +176,23 @@ 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 * clients_new (void) { - Clients *ret = (Clients *) malloc (sizeof (Clients)); + Clients *ret = (Clients *) xmalloc (sizeof (Clients)); ret->n = 0; ret->head = NULL; @@ -150,10 +205,9 @@ 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 @@ -163,21 +217,19 @@ 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++; - } - - if (c->s->msg) - { - socket_execute_msg (c->s, ctx); - } + for (c = cs->head; c; c = c->next) { + if (socket_post_select (c->s, rfds, wfds)) { + c->dead++; + deaded++; + } + if (c->s->msg) { + client_execute_message (c,c->s->msg,ctx); + socket_consume_msg (c->s); } + } + if (deaded) clients_reap (cs); } @@ -188,10 +240,9 @@ 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); @@ -225,12 +276,11 @@ 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 && c->initialized) + if (ipc_msg_send (c->s, (IPC_Msg *) m)) + c->dead++; + } return len; } @@ -254,12 +304,11 @@ 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 && c->initialized) + if (ipc_msg_send (c->s, (IPC_Msg *) m)) + c->dead++; + } return len; @@ -273,18 +322,16 @@ 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 diff --git a/apps/clients.h b/apps/clients.h index 3396f5c..8a1625e 100644 --- a/apps/clients.h +++ b/apps/clients.h @@ -1,4 +1,4 @@ -/* +/* * clients.h: * * Copyright (c) 2008 James McKenzie , @@ -6,12 +6,15 @@ * */ -/* +/* * $Id$ */ -/* +/* * $Log$ + * Revision 1.8 2008/03/07 13:16:02 james + * *** empty log message *** + * * Revision 1.7 2008/03/03 06:04:42 james * *** empty log message *** * @@ -41,6 +44,7 @@ typedef struct Client_struct { struct Client_struct *next; + int initialized; Socket *s; int dead; } Client; diff --git a/apps/mainloop.c b/apps/mainloop.c index a3697f3..6eec7be 100644 --- a/apps/mainloop.c +++ b/apps/mainloop.c @@ -1,4 +1,4 @@ -/* +/* * mainloop.c: * * Copyright (c) 2008 James McKenzie , @@ -9,8 +9,11 @@ static char rcsid[] = "$Id$"; -/* +/* * $Log$ + * Revision 1.27 2008/03/07 13:16:02 james + * *** empty log message *** + * * Revision 1.26 2008/03/06 21:34:09 james * *** empty log message *** * @@ -172,11 +175,10 @@ get_status (TTY * t, Clients * cs) cd = (tty_status.lines & TIOCM_CD) ? 1 : 0; - if (cd != last_cd_state) - { - gettimeofday (&last_cd_edge, NULL); - last_cd_state = cd; - } + if (cd != last_cd_state) { + gettimeofday (&last_cd_edge, NULL); + last_cd_state = cd; + } gettimeofday (&now, NULL); timersub (&now, &last_cd_edge, &dif); @@ -189,45 +191,44 @@ static char * line_to_name (int l) { - switch (l) - { + switch (l) { #ifdef TIOCM_LE - case TIOCM_LE: - return "LE"; + case TIOCM_LE: + return "LE"; #endif #ifdef TIOCM_DTR - case TIOCM_DTR: - return "DTR"; + case TIOCM_DTR: + return "DTR"; #endif #ifdef TIOCM_RTS - case TIOCM_RTS: - return "RTS"; + case TIOCM_RTS: + return "RTS"; #endif #ifdef TIOCM_ST - case TIOCM_ST: - return "ST"; + case TIOCM_ST: + return "ST"; #endif #ifdef TIOCM_SR - case TIOCM_SR: - return "SR"; + case TIOCM_SR: + return "SR"; #endif #ifdef TIOCM_CTS - case TIOCM_CTS: - return "CTS"; + case TIOCM_CTS: + return "CTS"; #endif #ifdef TIOCM_CD - case TIOCM_CD: - return "CD"; + case TIOCM_CD: + return "CD"; #endif #ifdef TIOCM_RI - case TIOCM_RI: - return "RI"; + case TIOCM_RI: + return "RI"; #endif #ifdef TIOCM_DSR - case TIOCM_DSR: - return "DSR"; + case TIOCM_DSR: + return "DSR"; #endif - } + } return "??"; } @@ -249,20 +250,18 @@ log_line_changes (Context * ctx, int old, int new) while (*n) *(ptr++) = *(n++); - while (dif >= c) - { + while (dif >= c) { - if (dif & c) - { - *(ptr++) = ' '; - *(ptr++) = (new & c) ? '+' : '-'; - n = line_to_name (c); - while (*n) - *(ptr++) = *(n++); - } - - c <<= 1; + if (dif & c) { + *(ptr++) = ' '; + *(ptr++) = (new & c) ? '+' : '-'; + n = line_to_name (c); + while (*n) + *(ptr++) = *(n++); } + + c <<= 1; + } *(ptr++) = '>'; *ptr = 0; @@ -323,54 +322,45 @@ check_status (Context * c, Clients * cs) ptr = do_line (ptr, status.lines, TIOCM_RI); ptr = do_line (ptr, status.lines, TIOCM_CD); - if (status.blocked) - { - t = ", Locked"; - while (*t) - *(ptr++) = *(t++); - } - - if (status.crtscts) - { - t = ", Flow"; - while (*t) - *(ptr++) = *(t++); - } + if (status.blocked) { + t = ", Locked"; + while (*t) + *(ptr++) = *(t++); + } + + if (status.crtscts) { + t = ", Flow"; + while (*t) + *(ptr++) = *(t++); + } #if 0 - if (status.lines & TIOCM_CD) - { - ptr += - sprintf (ptr, ", On %d.%d", status.cd_edge_sec / 60, - status.cd_edge_sec % 60); - } - else - { - ptr += - sprintf (ptr, ", Off %d.%d", status.cd_edge_sec / 60, - status.cd_edge_sec % 60); - } + if (status.lines & TIOCM_CD) { + ptr += + sprintf (ptr, ", On %d.%d", status.cd_edge_sec / 60, + status.cd_edge_sec % 60); + } else { + ptr += + sprintf (ptr, ", Off %d.%d", status.cd_edge_sec / 60, + status.cd_edge_sec % 60); + } #endif ptr += sprintf (ptr, ", %d client%s", status.nclients, (status.nclients == 1) ? "" : "s"); - if (c->tp->biterrs) - { + if (c->tp->biterrs) { - ptr += - sprintf (ptr, ", %d err%s", c->tp->biterrs, - (c->tp->biterrs == 1) ? "" : "s"); + ptr += + sprintf (ptr, ", %d err%s", c->tp->biterrs, + (c->tp->biterrs == 1) ? "" : "s"); - if (c->tp->guessed_baud == -1) - { - ptr += sprintf (ptr, " try higher"); - } - else if (c->tp->guessed_baud > 0) - { - ptr += sprintf (ptr, " try %db", c->tp->guessed_baud); - } + if (c->tp->guessed_baud == -1) { + ptr += sprintf (ptr, " try higher"); + } else if (c->tp->guessed_baud > 0) { + ptr += sprintf (ptr, " try %db", c->tp->guessed_baud); } + } *ptr = 0; @@ -390,38 +380,37 @@ static int msg_from_server (ANSI * a, IPC_Msg * m, Context * c) { int err = 0; - 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_HISTORY: - history_add (c->h, m->history.history.line); - break; - case IPC_MSG_TYPE_VT102: - if (sizeof (VT102) != m->vt102.len) - abort (); - - *(c->v) = m->vt102.vt102; - - if (a->one_shot) - { - a->one_shot (a, &c->v->crt); - err++; /*Simulate a fatal write error enclosing tty */ - } - break; - case IPC_MSG_TYPE_TERM: - err += tty_parse (c, m->term.term, m->term.len); - break; - case IPC_MSG_TYPE_STATUS: - cmd_new_status (c->d, c, m->status.status); - 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_HISTORY: + history_add (c->h, m->history.history.line); + break; + case IPC_MSG_TYPE_VT102: + if (sizeof (VT102) != m->vt102.len) + crash_out("sizeof(VT102) differs in client and server"); + + *(c->v) = m->vt102.vt102; + + if (a->one_shot) { + a->one_shot (a, &c->v->crt); + err++; /* Simulate a fatal write error enclosing tty + */ } + break; + case IPC_MSG_TYPE_TERM: + err += tty_parse (c, m->term.term, m->term.len); + break; + case IPC_MSG_TYPE_STATUS: + cmd_new_status (c->d, c, m->status.status); + break; + default: + fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type); + } return err; } @@ -437,151 +426,130 @@ mainloop (Context * c, ANSI * ansi, Socket * server_socket, c->u = utf8_new (); /* are we being fed by a tty or a socket */ - if (client_socket) - { - if (server_socket) - abort (); - c->k = keydis_ipc_new (client_socket); - } - else - { - if (!c->t) - abort (); - c->k = keydis_vt102_new (); - } + if (client_socket) { + if (server_socket) + crash_out("mainloop cannot both be a server and a client"); + c->k = keydis_ipc_new (client_socket); + } else { + if (!c->t) + crash_out("mainloop must have either a client_socket or a terminal"); + c->k = keydis_vt102_new (); + } /* do we have an upstream terminal to talk to */ /* if so start a command parser */ - if (ansi) - { - c->d = cmd_new (); - } - else - { - c->d = NULL; - } + if (ansi) { + c->d = cmd_new (); + } else { + c->d = NULL; + } vt102_reset (c); - if (server_socket) - { - if (client_socket) - abort (); - clients = clients_new (); - } - else - { - clients = NULL; - } + if (server_socket) { + if (client_socket) + crash_out("mainloop cannot both be a server and a client"); + clients = clients_new (); + } else { + clients = NULL; + } - for (;;) - { - struct timeval tv = { 0, 250000 }; + for (;;) { + struct timeval tv = { 0, 250000 }; - if ((c->d) && (c->d->disconnect)) - break; + if ((c->d) && (c->d->disconnect)) + break; - /*update the status lines, locally or remotely */ - if (c->t) - check_status (c, clients); + /* update the status lines, locally or remotely */ + if (c->t) + check_status (c, clients); - FD_ZERO (&rfds); - FD_ZERO (&wfds); + FD_ZERO (&rfds); + FD_ZERO (&wfds); - if (c->t) - tty_pre_select (c->t, &rfds, &wfds); + if (c->t) + tty_pre_select (c->t, &rfds, &wfds); - if (server_socket) - { - FD_SET (server_socket->fd, &rfds); - clients_pre_select (clients, &rfds, &wfds); - } + if (server_socket) { + FD_SET (server_socket->fd, &rfds); + clients_pre_select (clients, &rfds, &wfds); + } - if (client_socket) - socket_pre_select (client_socket, &rfds, &wfds); + if (client_socket) + socket_pre_select (client_socket, &rfds, &wfds); - if (ansi && ansi->terminal) - tty_pre_select (ansi->terminal, &rfds, &wfds); + if (ansi && ansi->terminal) + tty_pre_select (ansi->terminal, &rfds, &wfds); - select (FD_SETSIZE, &rfds, &wfds, NULL, &tv); + select (FD_SETSIZE, &rfds, &wfds, NULL, &tv); - /*any message from clients, or new connexions */ - if (server_socket) + /* any message from clients, or new connexions */ + if (server_socket) { + Socket *new_client_socket; + if (FD_ISSET (server_socket->fd, &rfds) + && ((new_client_socket = socket_accept (server_socket)))) { { - Socket *new_client_socket; - if (FD_ISSET (server_socket->fd, &rfds) - && ((new_client_socket = socket_accept (server_socket)))) - { - { - Client *new_client; - /*New client connexion */ - new_client = - clients_new_client (clients, new_client_socket, c); - - send_history (c->h, new_client); - send_vt102 (c->v, new_client); - - } - } - - clients_post_select (clients, c, &rfds, &wfds); + Client *new_client; + /* New client connexion */ + new_client = clients_new_client (clients, new_client_socket, c); + + } + } - /*any data from the port */ - if (c->t && FD_ISSET (c->t->rfd, &rfds)) - { - char buf[IPC_MAX_BUF]; - int red; + clients_post_select (clients, c, &rfds, &wfds); + } - red = c->t->recv (c->t, buf, sizeof (buf)); + /* any data from the port */ + if (c->t && FD_ISSET (c->t->rfd, &rfds)) { + char buf[IPC_MAX_BUF]; + int red; - if (red < 0) - break; + red = c->t->recv (c->t, buf, sizeof (buf)); - if (red) - { - if (clients) - send_output (clients, buf, red); - if (tty_parse (c, buf, red)) - break; - } - } + if (red < 0) + break; + if (red) { + if (clients) + send_output (clients, buf, red); + if (tty_parse (c, buf, red)) + break; + } + } - /*any data from the server */ - if (client_socket) - { - int err = 0; - if (socket_post_select (client_socket, &rfds, &wfds)) - break; + /* any data from the server */ + if (client_socket) { + int err = 0; - while (client_socket->msg && !err) - { - err += msg_from_server (ansi, client_socket->msg, c); - socket_consume_msg (client_socket); - } + if (socket_post_select (client_socket, &rfds, &wfds)) + break; - if (err) - break; - } + while (client_socket->msg && !err) { + err += msg_from_server (ansi, client_socket->msg, c); + socket_consume_msg (client_socket); + } + if (err) + break; + } - /*update our local screen */ - if (ansi) - { - if (ansi->dispatch) - if (ansi->dispatch (ansi, c)) - break; - if (ansi->update) - if (ansi->update (ansi, c)) - break; - } + /* update our local screen */ + if (ansi) { + if (ansi->dispatch) + if (ansi->dispatch (ansi, c)) + break; + + if (ansi->update) + if (ansi->update (ansi, c)) + break; } + } if (clients) clients_shutdown (clients); diff --git a/apps/mainloop.h b/apps/mainloop.h index 2c7f2b9..d94d02a 100644 --- a/apps/mainloop.h +++ b/apps/mainloop.h @@ -1,4 +1,4 @@ -/* +/* * mainloop.h: * * Copyright (c) 2008 James McKenzie , @@ -6,12 +6,15 @@ * */ -/* +/* * $Id$ */ -/* +/* * $Log$ + * Revision 1.10 2008/03/07 13:16:02 james + * *** empty log message *** + * * Revision 1.9 2008/03/06 16:49:39 james * *** empty log message *** * diff --git a/apps/sympathy.c b/apps/sympathy.c index 357f1df..bb141b1 100644 --- a/apps/sympathy.c +++ b/apps/sympathy.c @@ -1,4 +1,4 @@ -/* +/* * sympathy.c: * * Copyright (c) 2008 James McKenzie , @@ -9,8 +9,11 @@ static char rcsid[] = "$Id$"; -/* +/* * $Log$ + * Revision 1.37 2008/03/07 13:16:02 james + * *** empty log message *** + * * Revision 1.36 2008/03/06 21:34:09 james * *** empty log message *** * @@ -182,7 +185,7 @@ sigchld (int dummy) wait3 (&status, WNOHANG, NULL); } -/*Dispell zombies, from for example log compression*/ +/* Dispell zombies, from for example log compression */ void garlic (void) { @@ -204,26 +207,25 @@ teedious_snprintf (char *fmt, va_list ap) if (!buf) fatal_moan ("malloc failed"); - while (1) - { + while (1) { - va_copy (aq, ap); - n = vsnprintf (buf, size, fmt, aq); - va_end (aq); + va_copy (aq, ap); + n = vsnprintf (buf, size, fmt, aq); + va_end (aq); - if (n > -1 && n < (size)) - return buf; + if (n > -1 && n < (size)) + return buf; - if (n > -1) /* glibc 2.1 */ - size = n + 1; - else /* glibc 2.0 */ - size *= 2; /* twice the old size */ + if (n > -1) /* glibc 2.1 */ + size = n + 1; + else /* glibc 2.0 */ + size *= 2; /* twice the old size */ - buf = realloc (buf, size); + buf = realloc (buf, size); - if (!buf) - fatal_moan ("malloc failed"); - } + if (!buf) + fatal_moan ("malloc failed"); + } } @@ -236,7 +238,7 @@ gloo_paths (char *dir, char *leaf) dir = ""; if (!leaf) leaf = ""; - ret = ptr = malloc (strlen (dir) + strlen (leaf) + 2); + ret = ptr = xmalloc (strlen (dir) + strlen (leaf) + 2); while (*dir) *(ptr++) = *(dir++); @@ -249,7 +251,7 @@ gloo_paths (char *dir, char *leaf) } -/*make the path in fmt from home (hence the name) */ +/* make the path in fmt from home (hence the name) */ char * mome (char *fmt, ...) { @@ -261,16 +263,13 @@ mome (char *fmt, ...) if (!home) return NULL; - if (fmt) - { - va_start (ap, fmt); - leaf = teedious_snprintf (fmt, ap); - va_end (ap); - } - else - { - leaf = NULL; - } + if (fmt) { + va_start (ap, fmt); + leaf = teedious_snprintf (fmt, ap); + va_end (ap); + } else { + leaf = NULL; + } ret = gloo_paths (home, leaf); if (leaf) @@ -289,56 +288,45 @@ find_socket (char **retpath, char *fmt, ...) va_list ap; - if (fmt) - { - va_start (ap, fmt); - leaf = teedious_snprintf (fmt, ap); - va_end (ap); - } - else - { - leaf = NULL; - } - + if (fmt) { + va_start (ap, fmt); + leaf = teedious_snprintf (fmt, ap); + va_end (ap); + } else { + leaf = NULL; + } - for (ptr = socket_dirs; *ptr; ptr++) - { - if (**ptr == '~') - { - h = mome (*ptr + 1); - } - else - { - h = *ptr; - } - if (!h) - continue; + for (ptr = socket_dirs; *ptr; ptr++) { + if (**ptr == '~') { + h = mome (*ptr + 1); + } else { + h = *ptr; + } + if (!h) + continue; - path = gloo_paths (h, leaf); - if (**ptr == '~') - free (h); - ret = socket_connect (path); + path = gloo_paths (h, leaf); + if (**ptr == '~') + free (h); + ret = socket_connect (path); - if (ret) - { - if (retpath) - { - *retpath = path; - } - else - { - free (path); - } - free (leaf); - return ret; - } - free (path); + if (ret) { + if (retpath) { + *retpath = path; + } else { + free (path); + } + free (leaf); + return ret; } + free (path); + + } free (leaf); return NULL; @@ -366,38 +354,30 @@ list_sockets_in_dir (char *sockdir) rewinddir (dir); - while ((ent = readdir (dir))) - { - sn = gloo_paths (sockdir, ent->d_name); - if (stat (sn, &buf) || (!S_ISSOCK (buf.st_mode))) - { - free (sn); - continue; - } - - s = socket_connect (sn); - - if (s) - { - printf ("\t%s (Active)\n", sn); - socket_free (s); - } - else - { - if (strncmp (ent->d_name, hostname, hostname_len)) - { - printf ("\t%s (Unknown - not this host)\n", sn); - } - else - { - printf ("\t%s (Dead, wiped)\n", sn); - unlink (sn); - } - } - + while ((ent = readdir (dir))) { + sn = gloo_paths (sockdir, ent->d_name); + if (stat (sn, &buf) || (!S_ISSOCK (buf.st_mode))) { free (sn); + continue; } + s = socket_connect (sn); + + if (s) { + printf ("\t%s (Active)\n", sn); + socket_free (s); + } else { + if (strncmp (ent->d_name, hostname, hostname_len)) { + printf ("\t%s (Unknown - not this host)\n", sn); + } else { + printf ("\t%s (Dead, wiped)\n", sn); + unlink (sn); + } + } + + free (sn); + } + closedir (dir); return 0; @@ -409,26 +389,22 @@ list_sockets (void) char **ptr, *h; - for (ptr = socket_dirs; *ptr; ptr++) - { - if (**ptr == '~') - { - h = mome (*ptr + 1); - } - else - { - h = *ptr; - } + for (ptr = socket_dirs; *ptr; ptr++) { + if (**ptr == '~') { + h = mome (*ptr + 1); + } else { + h = *ptr; + } - if (!h) - continue; + if (!h) + continue; - list_sockets_in_dir (h); + list_sockets_in_dir (h); - if (**ptr == '~') - free (h); + if (**ptr == '~') + free (h); - } + } return 0; } @@ -439,11 +415,10 @@ get_hostname (void) { struct utsname name; - if (uname (&name)) - { - strcpy (hostname, "unknown."); - return; - } + if (uname (&name)) { + strcpy (hostname, "unknown."); + return; + } strcpy (hostname, name.nodename); @@ -479,35 +454,28 @@ main (int argc, char *argv[]) memset (oflags, 0, sizeof (oflags)); memset (oargs, 0, sizeof (oargs)); - while ((c = getopt (argc, argv, "I:NRP:vw:utscr:lKHd:pb:fL:Fk:n:")) != EOF) - { - switch (c) - { - case ':': - case 'h': - case '?': - usage (); - default: - if ((c > 64) && (c < 91)) - { - oflags[c]++; - oargs[c] = optarg; - } - else if ((c > 96) && (c < 123)) - { - oflags[c]++; - oargs[c] = optarg; - } - else - { - fprintf (stderr, "unknown option %c\n", c); - usage (); - } - } - + while ((c = getopt (argc, argv, "I:NRP:vw:utscr:lKHd:pb:fL:Fk:n:")) != EOF) { + switch (c) { + case ':': + case 'h': + case '?': + usage (); + default: + if ((c > 64) && (c < 91)) { + oflags[c]++; + oargs[c] = optarg; + } else if ((c > 96) && (c < 123)) { + oflags[c]++; + oargs[c] = optarg; + } else { + fprintf (stderr, "unknown option %c\n", c); + usage (); + } } - /*Compatability for screen's ls */ + } + + /* Compatability for screen's ls */ if (oflags['l']) oflags['s'] = 0; @@ -520,25 +488,23 @@ main (int argc, char *argv[]) sum += oflags['l']; sum += oflags['v']; - if (!sum) - { - /*If no mode is specified behave like screen */ - oflags['s']++; - oflags['c']++; - sum++; - } + if (!sum) { + /* If no mode is specified behave like screen */ + oflags['s']++; + oflags['c']++; + sum++; + } if (sum != 1) fatal_moan ("specifiy exactly one of ( -c and or -s ), -t, -r, -l and -v"); } - if (oflags['v']) - { - fprintf (stderr, "Version: %s\n", libsympathy_version ()); - fprintf (stderr, "Version: %s\n", rcsid); - return 0; - } + if (oflags['v']) { + fprintf (stderr, "Version: %s\n", libsympathy_version ()); + fprintf (stderr, "Version: %s\n", rcsid); + return 0; + } if (oflags['l']) return list_sockets (); @@ -548,17 +514,16 @@ main (int argc, char *argv[]) fatal_moan ("-k is incompatible with -r"); - if (oflags['n']) - { - history = safe_atoi (oargs['n']); - if (history < 0) - fatal_moan ("cannot parse -n %s as an integer", oargs['n']); + if (oflags['n']) { + history = safe_atoi (oargs['n']); + if (history < 0) + fatal_moan ("cannot parse -n %s as an integer", oargs['n']); - if (!history) - fatal_moan ("agrument to -n must be greater than zero"); - } + if (!history) + fatal_moan ("agrument to -n must be greater than zero"); + } - /*Fold -r implies -c */ + /* Fold -r implies -c */ if (oflags['r']) oflags['c']++; @@ -572,68 +537,64 @@ main (int argc, char *argv[]) if (oflags['H'] && oflags['N']) fatal_moan ("-H is incompatible with -N"); - /*implement server and client: this process forks. The parent */ - /*becomes the client and the child forks again to become the */ - /*server. If there's no -k argument the client (parent) needs */ - /*to find out the pid of the server, we use a pipe */ - - if (oflags['s'] && oflags['c']) - { - if (!oflags['k']) - { - csnok++; - pipe (csnok_pipe); - } - - switch (pid = fork ()) - { - case 0: /*child becomes the server */ - oflags['c'] = 0; - oflags['H'] = 0; - oflags['N'] = 0; - oflags['I'] = 0; - - if (csnok) - close (csnok_pipe[0]); - break; - case -1: - fatal_moan ("fork failed"); - default: /*parent becomes client */ - oflags['s'] = 0; - oflags['K'] = 0; - oflags['d'] = 0; - oflags['p'] = 0; - oflags['b'] = 0; - oflags['f'] = 0; - oflags['L'] = 0; - oflags['R'] = 0; - oflags['P'] = 0; - oflags['n'] = 0; - oflags['w'] = 0; - - /*Collect the child */ - waitpid (pid, NULL, 0); - - /*if there was no k argument we need to find the */ - /*pid of the server process so that we can work out */ - /*what the socket is called. The server tells us on */ - /*a pipe */ - - if (csnok) - { - close (csnok_pipe[1]); - - if (read (csnok_pipe[0], &pid, sizeof (pid)) != sizeof (pid)) - fatal_moan ("Failed to receive pid of server process"); - - close (csnok_pipe[0]); - - oargs['k'] = mome ("/.sympathy/%s%d", hostname, pid); - oflags['k']++; - } - } + /* implement server and client: this process forks. The parent */ + /* becomes the client and the child forks again to become the */ + /* server. If there's no -k argument the client (parent) needs */ + /* to find out the pid of the server, we use a pipe */ + + if (oflags['s'] && oflags['c']) { + if (!oflags['k']) { + csnok++; + pipe (csnok_pipe); } + switch (pid = fork ()) { + case 0: /* child becomes the server */ + oflags['c'] = 0; + oflags['H'] = 0; + oflags['N'] = 0; + oflags['I'] = 0; + + if (csnok) + close (csnok_pipe[0]); + break; + case -1: + fatal_moan ("fork failed"); + default: /* parent becomes client */ + oflags['s'] = 0; + oflags['K'] = 0; + oflags['d'] = 0; + oflags['p'] = 0; + oflags['b'] = 0; + oflags['f'] = 0; + oflags['L'] = 0; + oflags['R'] = 0; + oflags['P'] = 0; + oflags['n'] = 0; + oflags['w'] = 0; + + /* Collect the child */ + waitpid (pid, NULL, 0); + + /* if there was no k argument we need to find the */ + /* pid of the server process so that we can work out */ + /* what the socket is called. The server tells us on */ + /* a pipe */ + + if (csnok) { + close (csnok_pipe[1]); + + if (read (csnok_pipe[0], &pid, sizeof (pid)) != sizeof (pid)) + fatal_moan ("Failed to receive pid of server process"); + + close (csnok_pipe[0]); + + oargs['k'] = mome ("/.sympathy/%s%d", hostname, pid); + oflags['k']++; + } + } + } + if (oflags['c'] && !oflags['k'] && !oflags['r']) fatal_moan ("-c requires a socket to be specified with -s or -k or -r"); @@ -646,223 +607,193 @@ main (int argc, char *argv[]) fatal_moan ("-c or -r are incompatible with -p, -d, -K, -b, -f, -R, -P or -L"); - if (oflags['t'] || oflags['s']) - { - if (!oflags['p'] && !oflags['d']) - oflags['p']++; + if (oflags['t'] || oflags['s']) { + if (!oflags['p'] && !oflags['d']) + oflags['p']++; + } + + if (oflags['w']) { + char buf[128], *ptr; + strcpy (buf, oargs['w']); + ptr = index (buf, 'x'); + if (ptr) { + *ptr = 0; + ptr++; + size.y = safe_atoi (ptr); } + size.x = safe_atoi (buf); - if (oflags['w']) - { - char buf[128], *ptr; - strcpy (buf, oargs['w']); - ptr = index (buf, 'x'); - if (ptr) - { - *ptr = 0; - ptr++; - size.y = safe_atoi (ptr); - } - size.x = safe_atoi (buf); - - if ((size.x > VT102_MAX_COLS) || (size.x < 1)) - fatal_moan ("-w requires a width between 1 and %d\n", VT102_MAX_COLS); - - if ((size.y > VT102_MAX_ROWS) || (size.y < 1)) - fatal_moan ("-w requires a height between 1 and %d\n", - VT102_MAX_ROWS); + if ((size.x > VT102_MAX_COLS) || (size.x < 1)) + fatal_moan ("-w requires a width between 1 and %d\n", VT102_MAX_COLS); - } + if ((size.y > VT102_MAX_ROWS) || (size.y < 1)) + fatal_moan ("-w requires a height between 1 and %d\n", VT102_MAX_ROWS); - if (oflags['s'] && !oflags['F']) - { - /*nochdir incase socket is relative path, unlink then will fail */ - daemon (1, 0); + } - } + if (oflags['s'] && !oflags['F']) { + /* nochdir incase socket is relative path, unlink then will fail */ + daemon (1, 0); + + } - if (oflags['s']) - { - char *path; - path = mome ("/.sympathy"); - mkdir (path, 0700); - free (path); + if (oflags['s']) { + char *path; + path = mome ("/.sympathy"); + mkdir (path, 0700); + free (path); - if (!oflags['k']) - { - pid = getpid (); + if (!oflags['k']) { + pid = getpid (); - oargs['k'] = mome ("/.sympathy/%s%d", hostname, pid); - oflags['k']++; - } + oargs['k'] = mome ("/.sympathy/%s%d", hostname, pid); + oflags['k']++; + } - server_socket = socket_listen (oargs['k']); + server_socket = socket_listen (oargs['k']); - /*Tell our parent's parent what our pid is */ - if (csnok) - { - pid = getpid (); + /* Tell our parent's parent what our pid is */ + if (csnok) { + pid = getpid (); + + write (csnok_pipe[1], &pid, sizeof (pid)); + close (csnok_pipe[1]); + } - write (csnok_pipe[1], &pid, sizeof (pid)); - close (csnok_pipe[1]); - } + if (!server_socket) + fatal_moan ("failed to create socket %s for listening", oargs['k']); - if (!server_socket) - fatal_moan ("failed to create socket %s for listening", oargs['k']); + } + if (oflags['s'] || oflags['t']) { + if (oflags['P']) { + FILE *fp; + pid_file = oargs['P']; + fp = fopen (pid_file, "w"); + if (fp) { + fprintf (fp, "%d", getpid ()); + fclose (fp); + } } - if (oflags['s'] || oflags['t']) - { - if (oflags['P']) - { - FILE *fp; - pid_file = oargs['P']; - fp = fopen (pid_file, "w"); - if (fp) - { - fprintf (fp, "%d", getpid ()); - fclose (fp); - } - } - - if (oflags['L']) - { - ctx->l = file_log_new (oargs['L'], oflags['R']); - if (!ctx->l) - fatal_moan ("unable to access log file %s", oargs['L']); - } - - if (oflags['p']) - { - ctx->t = ptty_open (NULL, NULL, &size); - if (!ctx->t) - fatal_moan ("unable to open a ptty"); - } - else - { - /*HACK-- check that console=device does not occur in */ - /*/proc/cmdline */ - if (!oargs['d']) - fatal_moan ("no argument to -d"); - - { - char kernel_cmdline[4096] = { 0 }; - char search_string[1024] = "console="; - char *ptr = oargs['d']; - int fd; - - if (!strncmp ("/dev/", ptr, 5)) - ptr += 5; - - strcat (search_string, ptr); - - fd = open ("/proc/cmdline", O_RDONLY); - read (fd, kernel_cmdline, sizeof (kernel_cmdline)); - close (fd); - - kernel_cmdline[sizeof (kernel_cmdline) - 1] = 0; - - if (strstr (kernel_cmdline, search_string)) - fatal_moan ("/proc/cmdline contains %s", search_string); - } - - ctx->t = - serial_open (oargs['d'], - oflags['K'] ? SERIAL_LOCK_ACTIVE : - SERIAL_LOCK_PASSIVE); - if (!ctx->t) - fatal_moan ("unable to open serial port %s", oargs['d']); - } - - if (oflags['b']) - { - int baud = safe_atoi (oargs['b']); - - if (baud < 0) - fatal_moan ("Unable to parse baudrate %s", oargs['b']); - - tty_set_baud (ctx->t, baud); - - } - - tty_set_flow (ctx->t, oflags['f'] ? 1 : 0); + if (oflags['L']) { + ctx->l = file_log_new (oargs['L'], oflags['R']); + if (!ctx->l) + fatal_moan ("unable to access log file %s", oargs['L']); } + if (oflags['p']) { + ctx->t = ptty_open (NULL, NULL, &size); + if (!ctx->t) + fatal_moan ("unable to open a ptty"); + } else { + /* HACK-- check that console=device does not occur in */ + /* /proc/cmdline */ + if (!oargs['d']) + fatal_moan ("no argument to -d"); - if (oflags['r']) - { - char *id = oargs['r']; + { + char kernel_cmdline[4096] = { 0 }; + char search_string[1024] = "console="; + char *ptr = oargs['d']; + int fd; + + if (!strncmp ("/dev/", ptr, 5)) + ptr += 5; - if (!id) - fatal_moan ("-r requires an argument"); + strcat (search_string, ptr); - if (safe_atoi (id) > 0) - { - client_socket = - find_socket (&oargs['k'], "%s%d", hostname, safe_atoi (id)); - } - else - { - client_socket = find_socket (&oargs['k'], "%s", id); - } + fd = open ("/proc/cmdline", O_RDONLY); + read (fd, kernel_cmdline, sizeof (kernel_cmdline)); + close (fd); - if (!client_socket) - fatal_moan ("failed to find socket %s", oargs['r']); + kernel_cmdline[sizeof (kernel_cmdline) - 1] = 0; + + if (strstr (kernel_cmdline, search_string)) + fatal_moan ("/proc/cmdline contains %s", search_string); + } + + ctx->t = + serial_open (oargs['d'], + oflags['K'] ? SERIAL_LOCK_ACTIVE : SERIAL_LOCK_PASSIVE); + if (!ctx->t) + fatal_moan ("unable to open serial port %s", oargs['d']); + } + + if (oflags['b']) { + int baud = safe_atoi (oargs['b']); + + if (baud < 0) + fatal_moan ("Unable to parse baudrate %s", oargs['b']); + + tty_set_baud (ctx->t, baud); } - else if (oflags['c']) - { - client_socket = socket_connect (oargs['k']); - if (!client_socket) - fatal_moan ("failed to connect to socket %s", oargs['k']); + tty_set_flow (ctx->t, oflags['f'] ? 1 : 0); + } + + + if (oflags['r']) { + char *id = oargs['r']; + if (!id) + fatal_moan ("-r requires an argument"); + + if (safe_atoi (id) > 0) { + client_socket = + find_socket (&oargs['k'], "%s%d", hostname, safe_atoi (id)); + } else { + client_socket = find_socket (&oargs['k'], "%s", id); } + if (!client_socket) + fatal_moan ("failed to find socket %s", oargs['r']); + + } else if (oflags['c']) { + client_socket = socket_connect (oargs['k']); + + if (!client_socket) + fatal_moan ("failed to connect to socket %s", oargs['k']); + + } - if (oflags['c'] || oflags['t']) - { - if (oflags['N']) - { - ctx->r = rx_new_raw (0, 1); - ansi = ansi_new_raw (0, 1); - } - else if (oflags['H']) - { - ansi = ansi_new_html (stdout); - } - else - { - terminal_register_handlers (); - ansi = - ansi_new_from_terminal (terminal_open (0, 1), - oflags['u'] ? 0 : 1); - ansi->reset (ansi, NULL); - if (ansi->set_title) - ansi->set_title (ansi, oargs['k']); - } - if (oflags['I']) - { - //FIXME ... - } + if (oflags['I']) { + // FIXME ... + + } else { + if (client_socket) + ipc_msg_send_initialize(client_socket); + + if (oflags['c'] || oflags['t']) { + if (oflags['N']) { + ctx->r = rx_new_raw (0, 1); + ansi = ansi_new_raw (0, 1); + } else if (oflags['H']) { + ansi = ansi_new_html (stdout); + } else { + terminal_register_handlers (); + ansi = + ansi_new_from_terminal (terminal_open (0, 1), oflags['u'] ? 0 : 1); + ansi->reset (ansi, NULL); + if (ansi->set_title) + ansi->set_title (ansi, oargs['k']); } + } ctx->v = vt102_new (&size); ctx->h = history_new (history); mainloop (ctx, ansi, server_socket, client_socket); + } -// mainloop (tty, server_socket, client_socket, ansi, log, history, &size); - - if (ansi) - { - ansi->close (ansi); - terminal_atexit (); - } + if (ansi) { + ansi->close (ansi); + terminal_atexit (); + } if (ctx->t) ctx->t->close (ctx->t); diff --git a/apps/usage.c b/apps/usage.c index abad505..cbf3a09 100644 --- a/apps/usage.c +++ b/apps/usage.c @@ -1,4 +1,4 @@ -/* +/* * usage.c: * * Copyright (c) 2008 James McKenzie , @@ -8,8 +8,11 @@ static char rcsid[] = "$Id$"; -/* +/* * $Log$ + * Revision 1.22 2008/03/07 13:16:02 james + * *** empty log message *** + * * Revision 1.21 2008/03/06 21:34:09 james * *** empty log message *** * -- cgit v1.2.3