4 * Copyright (c) 2008 James McKenzie <sympathy@madingley.org>,
10 "$Id: mainloop.c,v 1.33 2008/05/09 12:35:57 james Exp $";
13 * $Log: mainloop.c,v $
14 * Revision 1.33 2008/05/09 12:35:57 james
15 * *** empty log message ***
17 * Revision 1.32 2008/03/11 17:56:50 james
18 * *** empty log message ***
20 * Revision 1.31 2008/03/11 17:56:04 james
21 * *** empty log message ***
23 * Revision 1.30 2008/03/11 17:47:24 james
24 * *** empty log message ***
26 * Revision 1.29 2008/03/10 11:49:32 james
27 * *** empty log message ***
29 * Revision 1.28 2008/03/07 13:56:39 james
30 * *** empty log message ***
32 * Revision 1.27 2008/03/07 13:16:02 james
33 * *** empty log message ***
35 * Revision 1.26 2008/03/06 21:34:09 james
36 * *** empty log message ***
38 * Revision 1.25 2008/03/06 21:33:02 james
39 * *** empty log message ***
41 * Revision 1.24 2008/03/06 16:49:39 james
42 * *** empty log message ***
44 * Revision 1.23 2008/03/06 16:49:05 james
45 * *** empty log message ***
47 * Revision 1.22 2008/03/03 06:04:42 james
48 * *** empty log message ***
50 * Revision 1.21 2008/03/02 10:27:24 james
51 * *** empty log message ***
53 * Revision 1.20 2008/02/28 16:57:51 james
54 * *** empty log message ***
56 * Revision 1.19 2008/02/28 16:37:16 james
57 * *** empty log message ***
59 * Revision 1.18 2008/02/28 11:27:48 james
60 * *** empty log message ***
62 * Revision 1.17 2008/02/27 09:42:53 james
63 * *** empty log message ***
65 * Revision 1.16 2008/02/27 09:42:21 james
66 * *** empty log message ***
68 * Revision 1.15 2008/02/27 01:31:38 james
69 * *** empty log message ***
71 * Revision 1.14 2008/02/27 01:31:14 james
72 * *** empty log message ***
74 * Revision 1.13 2008/02/26 23:56:12 james
75 * *** empty log message ***
77 * Revision 1.12 2008/02/26 23:23:16 james
78 * *** empty log message ***
80 * Revision 1.11 2008/02/24 00:43:55 james
81 * *** empty log message ***
83 * Revision 1.10 2008/02/23 13:05:57 staffcvs
84 * *** empty log message ***
86 * Revision 1.9 2008/02/23 11:48:51 james
87 * *** empty log message ***
89 * Revision 1.8 2008/02/22 23:39:30 james
90 * *** empty log message ***
92 * Revision 1.7 2008/02/20 20:16:07 james
93 * *** empty log message ***
95 * Revision 1.6 2008/02/20 19:44:37 james
98 * Revision 1.5 2008/02/20 18:31:44 james
99 * *** empty log message ***
101 * Revision 1.4 2008/02/20 17:18:33 james
102 * *** empty log message ***
104 * Revision 1.3 2008/02/20 02:11:35 james
105 * *** empty log message ***
107 * Revision 1.2 2008/02/16 10:58:52 james
108 * *** empty log message ***
110 * Revision 1.13 2008/02/15 23:52:12 james
111 * *** empty log message ***
113 * Revision 1.12 2008/02/15 03:32:07 james
114 * *** empty log message ***
116 * Revision 1.11 2008/02/14 16:21:17 james
117 * *** empty log message ***
119 * Revision 1.10 2008/02/14 10:39:14 james
120 * *** empty log message ***
122 * Revision 1.9 2008/02/14 10:34:47 james
123 * *** empty log message ***
125 * Revision 1.8 2008/02/14 10:34:30 james
126 * *** empty log message ***
128 * Revision 1.7 2008/02/14 02:46:44 james
129 * *** empty log message ***
131 * Revision 1.6 2008/02/14 00:57:58 james
132 * *** empty log message ***
134 * Revision 1.5 2008/02/13 18:05:06 james
135 * *** empty log message ***
137 * Revision 1.4 2008/02/13 17:21:55 james
138 * *** empty log message ***
140 * Revision 1.3 2008/02/08 15:06:52 james
141 * *** empty log message ***
143 * Revision 1.2 2008/02/07 15:42:49 james
144 * *** empty log message ***
146 * Revision 1.1 2008/02/05 14:25:49 james
147 * *** empty log message ***
151 #include <sys/time.h>
152 #include <sympathy.h>
153 #include "mainloop.h"
170 get_status (TTY * t, Clients * cs)
172 static struct timeval last_cd_edge = { 0 };
173 static int last_cd_state = -1;
175 struct timeval now, dif;
177 TTY_Status tty_status = { 0 };
180 tty_get_status (t, &tty_status);
182 status.bootstrap = 1;
185 status.nclients = cs->n;
189 status.lines = tty_status.lines;
190 status.baud = tty_status.baud;
191 status.crtscts = (tty_status.termios.c_cflag & CRTSCTS) ? 1 : 0;
192 status.blocked = tty_status.blocked;
194 cd = (tty_status.lines & TIOCM_CD) ? 1 : 0;
196 if (cd != last_cd_state)
198 gettimeofday (&last_cd_edge, NULL);
202 gettimeofday (&now, NULL);
203 timersub (&now, &last_cd_edge, &dif);
204 status.cd_edge_sec = dif.tv_sec;
256 log_line_changes (Context * ctx, int old, int new)
260 char buf[1024], *ptr = buf;
268 n = "<Modem lines changed:";
279 *(ptr++) = (new & c) ? '+' : '-';
280 n = line_to_name (c);
291 ctx->l->log (ctx->l, buf);
296 do_line (char *ptr, int lines, int line)
302 lname = line_to_name (line);
306 *(ptr++) = *(lname++);
314 check_status (Context * c, Clients * cs)
316 static Status old_status = { 0 };
322 status = get_status (c->t, cs);
323 if (!memcmp (&status, &old_status, sizeof (status)))
326 log_line_changes (c, old_status.lines, status.lines);
330 ptr += sprintf (ptr, "CTRL-B ");
333 if (!strncmp (t, "/dev/", 5))
338 ptr += sprintf (ptr, " %db", status.baud);
340 ptr = do_line (ptr, status.lines, TIOCM_RTS);
341 ptr = do_line (ptr, status.lines, TIOCM_CTS);
342 ptr = do_line (ptr, status.lines, TIOCM_DTR);
343 ptr = do_line (ptr, status.lines, TIOCM_DSR);
344 ptr = do_line (ptr, status.lines, TIOCM_RI);
345 ptr = do_line (ptr, status.lines, TIOCM_CD);
361 if (status.lines & TIOCM_CD)
364 sprintf (ptr, ", On %d.%d", status.cd_edge_sec / 60,
365 status.cd_edge_sec % 60);
370 sprintf (ptr, ", Off %d.%d", status.cd_edge_sec / 60,
371 status.cd_edge_sec % 60);
376 sprintf (ptr, ", %d client%s", status.nclients,
377 (status.nclients == 1) ? "" : "s");
383 sprintf (ptr, ", %d err%s", c->tp->biterrs,
384 (c->tp->biterrs == 1) ? "" : "s");
386 if (c->tp->guessed_baud == -1)
388 ptr += sprintf (ptr, " try higher");
390 else if (c->tp->guessed_baud > 0)
392 ptr += sprintf (ptr, " try %db", c->tp->guessed_baud);
399 log_f (c->l, "%s:%d %s", __FILE__, __LINE__, buf);
403 send_status (cs, buf);
405 cmd_new_status (c->d, c, buf);
411 msg_from_server (ANSI * a, IPC_Msg * m, Context * c)
417 case IPC_MSG_TYPE_NOOP:
419 case IPC_MSG_TYPE_DEBUG:
420 // fprintf (stderr,"%p [%d] %s\n", m, m->hdr.size , m->debug.msg );
422 case IPC_MSG_TYPE_HISTORY:
423 history_add (c->h, m->history.history.line);
425 case IPC_MSG_TYPE_VT102:
426 if (sizeof (VT102) != m->vt102.len)
427 crash_out ("sizeof(VT102) differs in client and server");
429 *(c->v) = m->vt102.vt102;
433 a->one_shot (a, &c->v->crt);
434 err++; /* Simulate a fatal write error enclosing tty
438 case IPC_MSG_TYPE_TERM:
439 err += tty_parse (c, m->term.term, m->term.len);
441 case IPC_MSG_TYPE_STATUS:
442 cmd_new_status (c->d, c, m->status.status);
445 fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type);
452 mainloop (Context * c, ANSI * ansi, Socket * server_socket,
453 Socket * client_socket)
458 c->tp = tty_parser_new ();
461 /* are we being fed by a tty or a socket */
465 crash_out ("mainloop cannot both be a server and a client");
466 c->k = keydis_ipc_new (client_socket);
471 crash_out ("mainloop must have either a client_socket or a terminal");
472 c->k = keydis_vt102_new ();
475 /* do we have an upstream terminal to talk to */
476 /* if so start a command parser */
493 crash_out ("mainloop cannot both be a server and a client");
494 clients = clients_new ();
503 struct timeval tv = { 0, 250000 };
505 if ((c->d) && (c->d->disconnect))
508 /* update the status lines, locally or remotely */
510 check_status (c, clients);
516 tty_pre_select (c->t, &rfds, &wfds);
520 FD_SET (server_socket->fd, &rfds);
521 clients_pre_select (clients, &rfds, &wfds);
525 socket_pre_select (client_socket, &rfds, &wfds);
527 if (ansi && ansi->terminal)
528 tty_pre_select (ansi->terminal, &rfds, &wfds);
530 select (FD_SETSIZE, &rfds, &wfds, NULL, &tv);
532 /* any message from clients, or new connexions */
535 Socket *new_client_socket;
536 if (FD_ISSET (server_socket->fd, &rfds)
537 && ((new_client_socket = socket_accept (server_socket))))
541 /* New client connexion */
543 clients_new_client (clients, new_client_socket, c);
549 clients_post_select (clients, c, &rfds, &wfds);
552 /* any data from the port */
553 if (c->t && FD_ISSET (c->t->rfd, &rfds))
555 char buf[IPC_MAX_BUF];
558 red = c->t->recv (c->t, buf, sizeof (buf));
566 send_output (clients, buf, red);
567 if (tty_parse (c, buf, red))
574 /* any data from the server */
579 if (socket_post_select (client_socket, &rfds, &wfds))
582 while (client_socket->msg && !err)
584 err += msg_from_server (ansi, client_socket->msg, c);
585 socket_consume_msg (client_socket);
593 /* update our local screen */
597 if (ansi->dispatch (ansi, c))
601 if (ansi->update (ansi, c))
607 clients_shutdown (clients, c);
608 log_f (c->l, "<sympathy is now terminating>");