/*
* $Log$
+ * Revision 1.20 2008/02/28 16:57:51 james
+ * *** empty log message ***
+ *
+ * Revision 1.19 2008/02/28 16:37:16 james
+ * *** empty log message ***
+ *
+ * Revision 1.18 2008/02/28 11:27:48 james
+ * *** empty log message ***
+ *
+ * Revision 1.17 2008/02/27 09:42:53 james
+ * *** empty log message ***
+ *
+ * Revision 1.16 2008/02/27 09:42:21 james
+ * *** empty log message ***
+ *
+ * Revision 1.15 2008/02/27 01:31:38 james
+ * *** empty log message ***
+ *
+ * Revision 1.14 2008/02/27 01:31:14 james
+ * *** empty log message ***
+ *
+ * Revision 1.13 2008/02/26 23:56:12 james
+ * *** empty log message ***
+ *
+ * Revision 1.12 2008/02/26 23:23:16 james
+ * *** empty log message ***
+ *
+ * Revision 1.11 2008/02/24 00:43:55 james
+ * *** empty log message ***
+ *
+ * Revision 1.10 2008/02/23 13:05:57 staffcvs
+ * *** empty log message ***
+ *
+ * Revision 1.9 2008/02/23 11:48:51 james
+ * *** empty log message ***
+ *
+ * Revision 1.8 2008/02/22 23:39:30 james
+ * *** empty log message ***
+ *
+ * Revision 1.7 2008/02/20 20:16:07 james
+ * *** empty log message ***
+ *
+ * Revision 1.6 2008/02/20 19:44:37 james
+ * @@
+ *
+ * Revision 1.5 2008/02/20 18:31:44 james
+ * *** empty log message ***
+ *
+ * Revision 1.4 2008/02/20 17:18:33 james
+ * *** empty log message ***
+ *
+ * Revision 1.3 2008/02/20 02:11:35 james
+ * *** empty log message ***
+ *
* Revision 1.2 2008/02/16 10:58:52 james
* *** empty log message ***
*
#include <sys/time.h>
#include <sympathy.h>
+#include "mainloop.h"
-#include "client.h"
#include "clients.h"
+Context *context;
+
typedef struct
{
int nclients;
tty_get_status (t, &tty_status);
status.bootstrap = 1;
- status.nclients = cs->n;
+
+ if (cs)
+ status.nclients = cs->n;
+ else
+ status.nclients = 0;
+
status.lines = tty_status.lines;
status.baud = tty_status.baud;
status.crtscts = (tty_status.termios.c_cflag & CRTSCTS) ? 1 : 0;
status = get_status (c->t, cs);
if (!memcmp (&status, &old_status, sizeof (status)))
return;
- old_status = status;
-
log_line_changes (c, old_status.lines, status.lines);
+ old_status = status;
+
ptr += sprintf (ptr, "CTRL-B ");
t = c->t->name;
sprintf (ptr, ", %d client%s", status.nclients,
(status.nclients == 1) ? "" : "s");
+ if (c->tp->biterrs)
+ {
+
+ 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);
+ }
+ }
+
*ptr = 0;
- send_status (cs, buf);
+#if 0
+ log_f (c->l, "%s:%d %s", __FILE__, __LINE__, buf);
+#endif
+
+ if (cs)
+ send_status (cs, buf);
+ else
+ cmd_new_status (c->d, c, buf);
+
}
- TTY *t;
- Log *l;
- t= ptty_open (NULL, NULL);
- //t = serial_open ("/dev/cellmodem", 0);
-l=file_log_new ("log");
+static int
+msg_from_server (ANSI * a, 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_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);
+ return 1;
+ }
+ break;
+ case IPC_MSG_TYPE_TERM:
+ 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 0;
+}
-void mainloop (TTY *tty,Socket *server_socket,Socket *client_socket,Ansi *a,Log *log)
+void
+mainloop (TTY * tty, Socket * server_socket, Socket * client_socket,
+ ANSI * ansi, Log * log, int nhistory, CRT_Pos * size)
{
fd_set rfds, wfds;
- Context c;
+ Context c = { 0 };
Clients *clients;
- c.v = vt102_new ();
- c.h = history_new (200);
- c.l = log
+ context = &c;
+ c.tp = tty_parser_new ();
+ c.u = utf8_new ();
+
+ c.v = vt102_new (size);
+ c.h = history_new (nhistory);
+ c.l = log;
/* are we being fed by a tty or a socket */
- if (client_socket) {
- if (server_socket) abort();
- c.s = client_socket;
- c.k = keydis_ipc_new (client_socket);
- } else {
- if (!tty) abort();
- c.t = tty;
- c.k = keydis_vt102_new ();
- }
-
- /* do we have an upstream terminal to talk to*/
- if (ansi) {
- c.d = cmd_new ();
- } else {
- c.d = NULL;
- }
-
-
- if (server_socket) {
- if(client_socket) abort();
- clients = clients_new ();
- } else {
- clients=NULL;
- }
+ if (client_socket)
+ {
+ if (server_socket)
+ abort ();
+ c.k = keydis_ipc_new (client_socket);
+ }
+ else
+ {
+ if (!tty)
+ abort ();
+ c.t = tty;
+ 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;
+ }
+
+
+ vt102_reset (&c);
+
+
+ if (server_socket)
+ {
+ if (client_socket)
+ abort ();
+ clients = clients_new ();
+ }
+ else
+ {
+ clients = NULL;
+ }
for (;;)
{
- struct timeval tv = { 1, 0 };
+ struct timeval tv = { 0, 250000 };
+
+ if ((c.d) && (c.d->disconnect))
+ break;
- check_status (&c, clients);
+ /*update the status lines, locally or remotely */
+ if (c.t)
+ check_status (&c, clients);
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);
select (FD_SETSIZE, &rfds, &wfds, NULL, &tv);
- /*any message from clients, or new connexions*/
- if (server_socket) {
- Socket *cs;
- if (FD_ISSET (server_socket->fd, &rfds) && ((cs = socket_accept (s))))
+ /*any message from clients, or new connexions */
+ if (server_socket)
{
- {
- Client *cl;
- /*New client connexion */
- cl = clients_new_client (clients, cs, &c);
+ 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, cl);
- send_vt102 (c.v, cl);
+ send_history (c.h, new_client);
+ send_vt102 (c.v, new_client);
- }
- }
+ }
+ }
- clients_post_select (clients, &c, &rfds, &wfds);
- }
+ clients_post_select (clients, &c, &rfds, &wfds);
+ }
- /*any data from the port*/
+ /*any data from the port */
if (c.t && FD_ISSET (c.t->rfd, &rfds))
{
char buf[IPC_MAX_BUF];
if (red)
{
- send_output (clients, buf, red);
- vt102_parse (&c, buf, red);
+ if (clients)
+ send_output (clients, buf, red);
+ tty_parse (&c, buf, red);
}
}
+ /*any data from the server */
+ if (client_socket)
+ {
+ int one_shot;
+ if (socket_post_select (client_socket, &rfds, &wfds))
+ break;
+
+ while (client_socket->msg)
+ {
+ if (msg_from_server (ansi, client_socket->msg, &c))
+ one_shot++;
+
+ socket_consume_msg (client_socket);
+ }
+ if (one_shot)
+ break;
+ }
+
+
+ /*update our local screen */
+ if (ansi)
+ {
+ if (ansi->dispatch)
+ ansi->dispatch (ansi, &c);
+
+ if (ansi->update)
+ ansi->update (ansi, &c);
+ }
}
- clients_shutdown (clients);
- terminal_atexit ();
- printf ("QUAT\n");
+ if (clients)
+ clients_shutdown (clients);
}