4 * Copyright (c) 2008 James McKenzie <james@fishsoup.dhs.org>,
9 static char rcsid[] = "$Id$";
13 * Revision 1.5 2008/02/20 18:31:44 james
14 * *** empty log message ***
16 * Revision 1.4 2008/02/20 17:18:33 james
17 * *** empty log message ***
19 * Revision 1.3 2008/02/20 02:11:35 james
20 * *** empty log message ***
22 * Revision 1.2 2008/02/16 10:58:52 james
23 * *** empty log message ***
25 * Revision 1.13 2008/02/15 23:52:12 james
26 * *** empty log message ***
28 * Revision 1.12 2008/02/15 03:32:07 james
29 * *** empty log message ***
31 * Revision 1.11 2008/02/14 16:21:17 james
32 * *** empty log message ***
34 * Revision 1.10 2008/02/14 10:39:14 james
35 * *** empty log message ***
37 * Revision 1.9 2008/02/14 10:34:47 james
38 * *** empty log message ***
40 * Revision 1.8 2008/02/14 10:34:30 james
41 * *** empty log message ***
43 * Revision 1.7 2008/02/14 02:46:44 james
44 * *** empty log message ***
46 * Revision 1.6 2008/02/14 00:57:58 james
47 * *** empty log message ***
49 * Revision 1.5 2008/02/13 18:05:06 james
50 * *** empty log message ***
52 * Revision 1.4 2008/02/13 17:21:55 james
53 * *** empty log message ***
55 * Revision 1.3 2008/02/08 15:06:52 james
56 * *** empty log message ***
58 * Revision 1.2 2008/02/07 15:42:49 james
59 * *** empty log message ***
61 * Revision 1.1 2008/02/05 14:25:49 james
62 * *** empty log message ***
84 get_status (TTY * t, Clients * cs)
86 static struct timeval last_cd_edge = { 0 };
87 static int last_cd_state = -1;
89 struct timeval now, dif;
91 TTY_Status tty_status = { 0 };
94 tty_get_status (t, &tty_status);
99 status.nclients = cs->n;
103 status.lines = tty_status.lines;
104 status.baud = tty_status.baud;
105 status.crtscts = (tty_status.termios.c_cflag & CRTSCTS) ? 1 : 0;
106 status.blocked = tty_status.blocked;
108 cd = (tty_status.lines & TIOCM_CD) ? 1 : 0;
110 if (cd != last_cd_state)
112 gettimeofday (&last_cd_edge, NULL);
116 gettimeofday (&now, NULL);
117 timersub (&now, &last_cd_edge, &dif);
118 status.cd_edge_sec = dif.tv_sec;
170 log_line_changes (Context * ctx, int old, int new)
174 char buf[1024], *ptr = buf;
182 n = "<Modem lines changed:";
193 *(ptr++) = (new & c) ? '+' : '-';
194 n = line_to_name (c);
205 ctx->l->log (ctx->l, buf);
210 do_line (char *ptr, int lines, int line)
216 lname = line_to_name (line);
220 *(ptr++) = *(lname++);
228 check_status (Context * c, Clients * cs)
230 static Status old_status = { 0 };
236 status = get_status (c->t, cs);
237 if (!memcmp (&status, &old_status, sizeof (status)))
240 log_line_changes (c, old_status.lines, status.lines);
244 ptr += sprintf (ptr, "CTRL-B ");
247 if (!strncmp (t, "/dev/", 5))
252 ptr += sprintf (ptr, " %db", status.baud);
254 ptr = do_line (ptr, status.lines, TIOCM_RTS);
255 ptr = do_line (ptr, status.lines, TIOCM_CTS);
256 ptr = do_line (ptr, status.lines, TIOCM_DTR);
257 ptr = do_line (ptr, status.lines, TIOCM_DSR);
258 ptr = do_line (ptr, status.lines, TIOCM_RI);
259 ptr = do_line (ptr, status.lines, TIOCM_CD);
276 if (status.lines & TIOCM_CD)
279 sprintf (ptr, ", On %d.%d", status.cd_edge_sec / 60,
280 status.cd_edge_sec % 60);
285 sprintf (ptr, ", Off %d.%d", status.cd_edge_sec / 60,
286 status.cd_edge_sec % 60);
291 sprintf (ptr, ", %d client%s", status.nclients,
292 (status.nclients == 1) ? "" : "s");
297 send_status (cs, buf);
299 cmd_new_status (c->d, c, buf);
305 msg_from_server (IPC_Msg * m, Context * c)
310 case IPC_MSG_TYPE_NOOP:
312 case IPC_MSG_TYPE_DEBUG:
313 // fprintf (stderr,"%p [%d] %s\n", m, m->hdr.size , m->debug.msg );
315 case IPC_MSG_TYPE_HISTORY:
316 history_add (c->h, m->history.history.line);
318 case IPC_MSG_TYPE_VT102:
319 if (sizeof (VT102) != m->vt102.len)
322 *(c->v) = m->vt102.vt102;
325 case IPC_MSG_TYPE_TERM:
326 vt102_parse (c, m->term.term, m->term.len);
328 case IPC_MSG_TYPE_STATUS:
329 cmd_new_status (c->d, c, m->status.status);
332 fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type);
338 mainloop (TTY * tty, Socket * server_socket, Socket * client_socket,
339 ANSI * ansi, Log * log, int nhistory)
347 c.h = history_new (nhistory);
349 /* are we being fed by a tty or a socket */
354 c.k = keydis_ipc_new (client_socket);
361 c.k = keydis_vt102_new ();
364 /* do we have an upstream terminal to talk to */
365 /* if so start a command parser */
380 clients = clients_new ();
389 struct timeval tv = { 1, 0 };
391 if ((c.d) && (c.d->disconnect))
394 /*update the status lines, locally or remotely */
396 check_status (&c, clients);
402 tty_pre_select (c.t, &rfds, &wfds);
406 FD_SET (server_socket->fd, &rfds);
407 clients_pre_select (clients, &rfds, &wfds);
411 socket_pre_select (client_socket, &rfds, &wfds);
414 tty_pre_select (ansi->terminal, &rfds, &wfds);
416 select (FD_SETSIZE, &rfds, &wfds, NULL, &tv);
418 /*any message from clients, or new connexions */
421 Socket *new_client_socket;
422 if (FD_ISSET (server_socket->fd, &rfds)
423 && ((new_client_socket = socket_accept (server_socket))))
427 /*New client connexion */
429 clients_new_client (clients, new_client_socket, &c);
431 send_history (c.h, new_client);
432 send_vt102 (c.v, new_client);
437 clients_post_select (clients, &c, &rfds, &wfds);
440 /*any data from the port */
441 if (c.t && FD_ISSET (c.t->rfd, &rfds))
443 char buf[IPC_MAX_BUF];
446 red = c.t->recv (c.t, buf, sizeof (buf));
454 send_output (clients, buf, red);
455 vt102_parse (&c, buf, red);
461 /*any data from the server */
464 if (socket_post_select (client_socket, &rfds, &wfds))
467 while (client_socket->msg)
469 msg_from_server (client_socket->msg, &c);
470 socket_consume_msg (client_socket);
475 /*update our local screen */
478 if (ansi_dispatch (ansi, &c))
481 ansi_update (ansi, &c);
486 clients_shutdown (clients);