/*
* $Log$
+ * Revision 1.11 2008/02/23 11:48:51 james
+ * *** empty log message ***
+ *
* Revision 1.10 2008/02/22 17:06:59 james
* *** empty log message ***
*
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);
/*
* $Log$
+ * 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 ***
*
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 %d", status.baud / c->tp->guessed_baud);
+ }
+ }
+
*ptr = 0;
+#if 0
+ log_f (c->l, "%s:%d %s", __FILE__, __LINE__, buf);
+#endif
+
if (cs)
send_status (cs, buf);
else
static int
-msg_from_server (ANSI *a,IPC_Msg * m, Context * c)
+msg_from_server (ANSI * a, IPC_Msg * m, Context * c)
{
switch (m->hdr.type)
{
*(c->v) = m->vt102.vt102;
- if (a->one_shot) {
- a->one_shot(a,&c->v->crt);
- return 1;
- }
+ if (a->one_shot)
+ {
+ a->one_shot (a, &c->v->crt);
+ return 1;
+ }
//FIXME HTML hook
break;
case IPC_MSG_TYPE_TERM:
default:
fprintf (stderr, "Unhandeled message type %d\n", m->hdr.type);
}
-return 0;
+ return 0;
}
Context c = { 0 };
Clients *clients;
+ c.tp = tty_parser_new ();
+ c.u = utf8_new ();
c.v = vt102_new ();
c.h = history_new (nhistory);
for (;;)
{
- struct timeval tv = { 1, 0 };
+ struct timeval tv = { 0, 250000 };
if ((c.d) && (c.d->disconnect))
break;
/*any data from the server */
if (client_socket)
{
- int one_shot;
+ 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++;
-
+ if (msg_from_server (ansi, client_socket->msg, &c))
+ one_shot++;
+
socket_consume_msg (client_socket);
}
- if (one_shot) break;
+ if (one_shot)
+ break;
}
if (ansi)
{
if (ansi->dispatch)
- ansi->dispatch (ansi, &c);
+ ansi->dispatch (ansi, &c);
- if (ansi->update)
- ansi->update (ansi, &c);
+ if (ansi->update)
+ ansi->update (ansi, &c);
}
}
*
*/
-static char rcsid[] = "$Id$";
+static char rcsid[] =
+ "$Id$";
/*
* $Log$
+ * Revision 1.12 2008/02/23 11:48:52 james
+ * *** empty log message ***
+ *
* Revision 1.11 2008/02/20 20:16:07 james
* *** empty log message ***
*
if (oflags['H'])
{
- ansi=ansi_new_html(stdout);
+ ansi = ansi_new_html (stdout);
}
else
{
terminal_register_handlers ();
- ansi=ansi_new_from_terminal(terminal_open(0,1));
- ansi->reset(ansi, NULL);
+ ansi = ansi_new_from_terminal (terminal_open (0, 1));
+ ansi->reset (ansi, NULL);
}
}
if (ansi)
{
- ansi->close(ansi);
+ ansi->close (ansi);
terminal_atexit ();
}
socket_free (client_socket);
if (!oflags['H'])
- printf ("you have now exited sympathy\n");
+ printf ("you have now exited sympathy\n");
return 0;
}
/*
* $Log$
+ * Revision 1.7 2008/02/23 11:48:52 james
+ * *** empty log message ***
+ *
* Revision 1.6 2008/02/20 18:49:11 staffcvs
* *** empty log message ***
*
fprintf (stderr, "Usage:\n"
"sympathy -t [-K] [-d serialdev|-p] [-b baud] [-f] [-L log]\n"
"sympathy -s [-K] [-d serialdev|-p] [-b baud] [-f] [-L log] [-F] [-k skt]\n"
- " [-n hlines]\n"
+ " [-n hlines]\n"
"sympathy [-s -c] [-K] [-d serialdev|-p] [-b baud] [-f] [-L log] [-k skt]\n"
- " [-n hlines]\n"
+ " [-n hlines]\n"
"sympathy -c [-H] -k skt\n"
"sympathy -r id [-H]\n"
"sympathy {-l|-ls}\n"
" -H instead of connecting the user's terminal to the session\n"
" emit HTML of the current state of the screen on stdout\n"
" -L log activity on the device to the file log\n"
- " -n hlines the number of lines of history to store in the\n"
- " server, that are replayed on connexion\n"
-);
+ " -n hlines the number of lines of history to store in the\n"
+ " server, that are replayed on connexion\n");
exit (1);
}
/*
* $Log$
+ * Revision 1.29 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.28 2008/02/22 17:07:00 james
* *** empty log message ***
*
/*Roll HISTORY_GUESS_SCROLL lines up putting the top line into the xterm's history */
- /*Make extra lines a predictable colour*/
+ /*Make extra lines a predictable colour */
ansi_set_color (a, CRT_COLOR_NORMAL);
ansi_showhide_cursor (a, 1);
/* erase new line */
s.y = e.y;
e.x = CRT_COLS - 1;
- crt_erase (&a->crt, s, e, 1,CRT_COLOR_NORMAL);
+ crt_erase (&a->crt, s, e, 1, CRT_COLOR_NORMAL);
}
}
/*
* $Log$
+ * Revision 1.12 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.11 2008/02/20 20:16:07 james
* *** empty log message ***
*
int history_ptr;
FILE *file;
- int (*dispatch)(struct ANSI_struct *,struct Context_struct *);
- void (*update)(struct ANSI_struct *,struct Context_struct *);
- void (*one_shot)(struct ANSI_struct *,struct CRT_struct *);
- void (*reset)(struct ANSI_struct *,struct CRT_struct *);
- void (*terminal_reset)(struct ANSI_struct *);
- void (*close)(struct ANSI_struct *);
+ int (*dispatch) (struct ANSI_struct *, struct Context_struct *);
+ void (*update) (struct ANSI_struct *, struct Context_struct *);
+ void (*one_shot) (struct ANSI_struct *, struct CRT_struct *);
+ void (*reset) (struct ANSI_struct *, struct CRT_struct *);
+ void (*terminal_reset) (struct ANSI_struct *);
+ void (*close) (struct ANSI_struct *);
} ANSI;
/*
* $Log$
+ * Revision 1.2 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.1 2008/02/15 15:14:19 james
* *** empty log message ***
*
#ifndef __CMD_H__
#define __CMD_H__
-#define CMD_KEY 2 /*CTRL B*/
+#define CMD_KEY 2 /*CTRL B */
-typedef struct {
- int active;
- int disconnect;
- char csl[128];
- char buf[128];
- int ptr;
+typedef struct
+{
+ int active;
+ int disconnect;
+ char csl[128];
+ char buf[128];
+ int ptr;
} Cmd;
#endif /* __CMD_H__ */
/*
* $Log$
+ * Revision 1.8 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.7 2008/02/22 23:39:27 james
* *** empty log message ***
*
{
VT102 *v;
TTY *t;
+ TTY_Parser *tp;
History *h;
Log *l;
KeyDis *k;
/*
* $Log$
+ * Revision 1.11 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.10 2008/02/22 17:07:00 james
* *** empty log message ***
*
#include "project.h"
void
-crt_erase (CRT * c, CRT_Pos s, CRT_Pos e, int ea,int color)
+crt_erase (CRT * c, CRT_Pos s, CRT_Pos e, int ea, int color)
{
CRT_CA *ps = &c->screen[CRT_ADDR_POS (&s)];
CRT_CA *pe = &c->screen[CRT_ADDR_POS (&e)];
}
void
-crt_scroll_up (CRT * c, CRT_Pos s, CRT_Pos e, int ea,int color)
+crt_scroll_up (CRT * c, CRT_Pos s, CRT_Pos e, int ea, int color)
{
int l, n;
int p;
}
s.y = e.y;
- crt_erase (c, s, e, ea,color);
+ crt_erase (c, s, e, ea, color);
}
void
-crt_scroll_down (CRT * c, CRT_Pos s, CRT_Pos e, int ea,int color)
+crt_scroll_down (CRT * c, CRT_Pos s, CRT_Pos e, int ea, int color)
{
int l, n;
int p;
}
e.y = s.y;
- crt_erase (c, s, e, ea,color);
+ crt_erase (c, s, e, ea, color);
}
/*
* $Log$
+ * Revision 1.5 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.4 2008/02/22 17:07:00 james
* *** empty log message ***
*
char msg[0];
} IPC_Msg_debug;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
History_ent history;
} IPC_Msg_history;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
} IPC_Msg_VT102;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
int32_t key;
} IPC_Msg_key;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
} IPC_Msg_term;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
- char status[0];
+ char status[0];
} IPC_Msg_status;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
} IPC_Msg_setbaud;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
} IPC_Msg_sendbreak;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
} IPC_Msg_setflow;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
} IPC_Msg_setansi;
-typedef struct
+typedef struct
{
int32_t size;
int32_t type;
-typedef union
+typedef union
{
-IPC_Msg_hdr hdr;
-IPC_Msg_noop noop;
-IPC_Msg_debug debug;
-IPC_Msg_history history;
-IPC_Msg_VT102 vt102;
-IPC_Msg_key key;
-IPC_Msg_term term;
-IPC_Msg_status status;
-IPC_Msg_setbaud setbaud;
-IPC_Msg_sendbreak sendbreak;
-IPC_Msg_setflow setflow;
-IPC_Msg_setansi setansi;
-IPC_Msg_hangup hangup;
+ IPC_Msg_hdr hdr;
+ IPC_Msg_noop noop;
+ IPC_Msg_debug debug;
+ IPC_Msg_history history;
+ IPC_Msg_VT102 vt102;
+ IPC_Msg_key key;
+ IPC_Msg_term term;
+ IPC_Msg_status status;
+ IPC_Msg_setbaud setbaud;
+ IPC_Msg_sendbreak sendbreak;
+ IPC_Msg_setflow setflow;
+ IPC_Msg_setansi setansi;
+ IPC_Msg_hangup hangup;
} IPC_Msg;
/*
* $Log$
+ * Revision 1.5 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.4 2008/02/22 17:07:00 james
* *** empty log message ***
*
{
KeyDis_IPC *t = (KeyDis_IPC *) _t;
- vt102_set_ansi (c->v, ansi);
+ vt102_set_ansi (c->v, ansi);
ipc_msg_send_setansi (t->s, ansi);
KeyDis_VT102 *t = (KeyDis_VT102 *) _t;
tty_set_baud (c->t, baud);
+ tty_parse_reset (c);
+
+ log_f (c->l, "<baud changed to %d>", baud);
return 0;
}
KeyDis_VT102 *t = (KeyDis_VT102 *) _t;
if (c->v)
- c->v->xn_glitch=ansi ? 0:1;
+ c->v->xn_glitch = ansi ? 0 : 1;
return 0;
}
/*
* $Log$
+ * Revision 1.5 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.4 2008/02/22 17:07:00 james
* *** empty log message ***
*
int (*set_ansi)(struct KeyDis_struct *,struct Context_struct *,int ansi); \
int (*hangup)(struct KeyDis_struct *,struct Context_struct *)
-
+
typedef struct KeyDis_struct
{
/*
* $Log$
+ * Revision 1.7 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.6 2008/02/15 23:52:12 james
* *** empty log message ***
*
#define FILE_LIST_MAX_LEN 1024
-typedef struct Filelist_ent {
- char name[FILE_LIST_MAX_LEN];
- struct Filelist_ent *next;
+typedef struct Filelist_ent
+{
+ char name[FILE_LIST_MAX_LEN];
+ struct Filelist_ent *next;
} Filelist_ent;
-typedef struct {
- Filelist_ent *head;
+typedef struct
+{
+ Filelist_ent *head;
} Filelist;
/*
* $Log$
+ * Revision 1.3 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.2 2008/02/22 14:51:54 james
* *** empty log message ***
*
{
File_Log *l;
FILE *f;
- int dc=1;
+ int dc = 1;
- if (fn && strcmp(fn,"-")) {
- f = fopen (fn, "a+");
- if (!f)
- return NULL;
- } else {
- f=stderr;
- dc=0;
- }
+ if (fn && strcmp (fn, "-"))
+ {
+ f = fopen (fn, "a+");
+ if (!f)
+ return NULL;
+ }
+ else
+ {
+ f = stderr;
+ dc = 0;
+ }
l = malloc (sizeof (File_Log));
l->log = flog_log;
l->close = flog_close;
l->fp = f;
- l->do_close=dc;
+ l->do_close = dc;
return (Log *) l;
}
-void
-log_f (Log *log,char *fmt, ...)
+
+void
+log_f (Log * log, char *fmt, ...)
{
int n;
va_list ap;
static int size;
- if (!log) return;
+ if (!log)
+ return;
- if (!size) {
- size = 128;
- buf = malloc (size);
- }
+ if (!size)
+ {
+ size = 128;
+ buf = malloc (size);
+ }
if (!buf)
return;
while (1)
{
va_start (ap, fmt);
- n = vsnprintf (buf , size, fmt, ap);
+ n = vsnprintf (buf, size, fmt, ap);
va_end (ap);
- if (n > -1 && n < size) {
- log->log(log,buf);
- return;
- }
+ if (n > -1 && n < size)
+ {
+ log->log (log, buf);
+ return;
+ }
if (n > -1) /* glibc 2.1 */
size = n + 1;
buf = realloc (buf, size);
if (!buf)
- return;
+ return;
}
}
/*
* $Log$
+ * Revision 1.2 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.1 2008/02/14 12:14:50 james
* *** empty log message ***
*
void (*log)(struct Log_struct *,char *); \
void (*close)(struct Log_struct *)
-typedef struct Log_struct {
- LOG_SIGNATURE;
+typedef struct Log_struct
+{
+ LOG_SIGNATURE;
} Log;
/* ansi.c */
-extern int ansi_dispatch(ANSI *a, Context *c);
-extern ANSI *ansi_new_from_terminal(TTY *t);
+extern int ansi_dispatch (ANSI * a, Context * c);
+extern ANSI *ansi_new_from_terminal (TTY * t);
/* crt.c */
-extern void crt_erase(CRT *c, CRT_Pos s, CRT_Pos e, int ea, int color);
-extern void crt_cls(CRT *c);
-extern void crt_scroll_up(CRT *c, CRT_Pos s, CRT_Pos e, int ea, int color);
-extern void crt_scroll_down(CRT *c, CRT_Pos s, CRT_Pos e, int ea, int color);
-extern void crt_reset(CRT *c);
-extern void crt_insert(CRT *c, CRT_CA ca);
+extern void crt_erase (CRT * c, CRT_Pos s, CRT_Pos e, int ea, int color);
+extern void crt_cls (CRT * c);
+extern void crt_scroll_up (CRT * c, CRT_Pos s, CRT_Pos e, int ea, int color);
+extern void crt_scroll_down (CRT * c, CRT_Pos s, CRT_Pos e, int ea,
+ int color);
+extern void crt_reset (CRT * c);
+extern void crt_insert (CRT * c, CRT_CA ca);
/* html.c */
-extern ANSI *ansi_new_html(FILE *f);
+extern ANSI *ansi_new_html (FILE * f);
/* libsympathy.c */
/* render.c */
/* version.c */
/* vt102.c */
-extern void vt102_log_line(Context *c, int line);
-extern void vt102_history(Context *c, CRT_Pos t, CRT_Pos b);
-extern void vt102_clip_cursor(VT102 *v, CRT_Pos tl, CRT_Pos br);
-extern void vt102_cursor_normalize(VT102 *v);
-extern void vt102_cursor_carriage_return(VT102 *v);
-extern void vt102_cursor_advance_line(Context *c);
-extern void vt102_do_pending_wrap(Context *c);
-extern void vt102_cursor_advance(Context *c);
-extern void vt102_cursor_retard(VT102 *v);
-extern void vt102_reset_tabs(VT102 *v);
-extern void vt102_cursor_advance_tab(VT102 *v);
-extern void vt102_cursor_retard_tab(VT102 *v);
-extern int vt102_cursor_home(VT102 *v);
-extern int vt102_cursor_absolute(VT102 *v, int x, int y);
-extern int vt102_cursor_relative(VT102 *v, int x, int y);
-extern void vt102_delete_from_line(VT102 *v, CRT_Pos p);
-extern void vt102_insert_into_line(VT102 *v, CRT_Pos p);
-extern void vt102_change_mode(VT102 *v, int private, char *ns, int set);
-extern void vt102_parse_mode_string(VT102 *v, char *buf, int len);
-extern void vt102_change_attr(VT102 *v, char *na);
-extern void vt102_parse_attr_string(VT102 *v, char *buf, int len);
-extern void vt102_save_state(VT102 *v);
-extern void vt102_restore_state(VT102 *v);
-extern void vt102_regular_char(Context *c, VT102 *v, char ch);
-extern void vt102_scs(Context *c, int g, int s);
-extern void vt102_parse_esc(Context *c, int ch);
-extern void vt102_parse_csi(Context *c, char *buf, int len);
-extern void vt102_status_line(VT102 *v, char *str);
-extern void vt102_parser_reset(VT102_parser *p);
-extern void vt102_reset_state(VT102 *v);
-extern void vt102_parse_char(Context *c, int ch);
-extern void vt102_send(Context *c, uint8_t key);
-extern void vt102_reset(VT102 *v);
-extern VT102 *vt102_new(void);
-extern void vt102_set_ansi(VT102 *v, int ansi);
-extern void vt102_free(VT102 *v);
+extern void vt102_log_line (Context * c, int line);
+extern void vt102_history (Context * c, CRT_Pos t, CRT_Pos b);
+extern void vt102_clip_cursor (VT102 * v, CRT_Pos tl, CRT_Pos br);
+extern void vt102_cursor_normalize (VT102 * v);
+extern void vt102_cursor_carriage_return (VT102 * v);
+extern void vt102_cursor_advance_line (Context * c);
+extern void vt102_do_pending_wrap (Context * c);
+extern void vt102_cursor_advance (Context * c);
+extern void vt102_cursor_retard (VT102 * v);
+extern void vt102_reset_tabs (VT102 * v);
+extern void vt102_cursor_advance_tab (VT102 * v);
+extern void vt102_cursor_retard_tab (VT102 * v);
+extern int vt102_cursor_home (VT102 * v);
+extern int vt102_cursor_absolute (VT102 * v, int x, int y);
+extern int vt102_cursor_relative (VT102 * v, int x, int y);
+extern void vt102_delete_from_line (VT102 * v, CRT_Pos p);
+extern void vt102_insert_into_line (VT102 * v, CRT_Pos p);
+extern void vt102_change_mode (VT102 * v, int private, char *ns, int set);
+extern void vt102_parse_mode_string (VT102 * v, char *buf, int len);
+extern void vt102_change_attr (VT102 * v, char *na);
+extern void vt102_parse_attr_string (VT102 * v, char *buf, int len);
+extern void vt102_save_state (VT102 * v);
+extern void vt102_restore_state (VT102 * v);
+extern void vt102_regular_char (Context * c, VT102 * v, char ch);
+extern void vt102_scs (Context * c, int g, int s);
+extern void vt102_parse_esc (Context * c, int ch);
+extern void vt102_parse_csi (Context * c, char *buf, int len);
+extern void vt102_status_line (VT102 * v, char *str);
+extern void vt102_parser_reset (VT102_parser * p);
+extern void vt102_reset_state (VT102 * v);
+extern void vt102_parse_char (Context * c, int ch);
+extern void vt102_send (Context * c, uint8_t key);
+extern void vt102_reset (VT102 * v);
+extern VT102 *vt102_new (void);
+extern void vt102_set_ansi (VT102 * v, int ansi);
+extern void vt102_free (VT102 * v);
/* tty.c */
-extern void tty_pre_select(TTY *t, fd_set *rfds, fd_set *wfds);
-extern int tty_get_status(TTY *t, TTY_Status *s);
-extern void tty_set_baud(TTY *t, int rate);
-extern void tty_send_break(TTY *t);
-extern void tty_set_flow(TTY *t, int flow);
-extern void tty_hangup(TTY *t);
-extern void tty_stats(TTY_Parser *p, int err, int ch);
-extern void tty_parse(Context *c, uint8_t *buf, int len);
+extern void tty_pre_select (TTY * t, fd_set * rfds, fd_set * wfds);
+extern int tty_get_status (TTY * t, TTY_Status * s);
+extern void tty_set_baud (TTY * t, int rate);
+extern void tty_send_break (TTY * t);
+extern void tty_set_flow (TTY * t, int flow);
+extern void tty_hangup (TTY * t);
+extern void tty_parse_reset (Context * c);
+extern void analyse (Context * c);
+extern TTY_Parser *tty_parser_new (void);
+extern void tty_parse (Context * c, uint8_t * buf, int len);
/* keydis.c */
-extern KeyDis *keydis_vt102_new(void);
-extern KeyDis *keydis_ipc_new(Socket *s);
-extern int keydis_key(KeyDis *t, Context *c, int key);
+extern KeyDis *keydis_vt102_new (void);
+extern KeyDis *keydis_ipc_new (Socket * s);
+extern int keydis_key (KeyDis * t, Context * c, int key);
/* history.c */
-extern History *history_new(int n);
-extern void history_free(History *h);
-extern void history_add(History *h, CRT_CA *c);
+extern History *history_new (int n);
+extern void history_free (History * h);
+extern void history_add (History * h, CRT_CA * c);
/* ring.c */
-extern int ring_read(Ring *r, void *b, int n);
-extern int ring_write(Ring *r, void *b, int n);
-extern int ring_space(Ring *r);
-extern int ring_bytes(Ring *r);
-extern Ring *ring_new(int n);
+extern int ring_read (Ring * r, void *b, int n);
+extern int ring_write (Ring * r, void *b, int n);
+extern int ring_space (Ring * r);
+extern int ring_bytes (Ring * r);
+extern Ring *ring_new (int n);
/* ptty.c */
-extern TTY *ptty_open(char *path, char *argv[]);
+extern TTY *ptty_open (char *path, char *argv[]);
/* terminal.c */
extern int terminal_winches;
-extern void terminal_atexit(void);
-extern void terminal_getsize(TTY *_t);
-extern void terminal_dispatch(void);
-extern void terminal_register_handlers(void);
-extern TTY *terminal_open(int rfd, int wfd);
+extern void terminal_atexit (void);
+extern void terminal_getsize (TTY * _t);
+extern void terminal_dispatch (void);
+extern void terminal_register_handlers (void);
+extern TTY *terminal_open (int rfd, int wfd);
/* util.c */
-extern int wrap_read(int fd, void *buf, int len);
-extern int wrap_write(int fd, void *buf, int len);
-extern void set_nonblocking(int fd);
-extern void set_blocking(int fd);
-extern void raw_termios(struct termios *termios);
-extern void default_termios(struct termios *termios);
+extern int wrap_read (int fd, void *buf, int len);
+extern int wrap_write (int fd, void *buf, int len);
+extern void set_nonblocking (int fd);
+extern void set_blocking (int fd);
+extern void raw_termios (struct termios *termios);
+extern void default_termios (struct termios *termios);
/* log.c */
-extern Log *file_log_new(char *fn);
-extern void log_f(Log *log, char *fmt, ...);
+extern Log *file_log_new (char *fn);
+extern void log_f (Log * log, char *fmt, ...);
/* ipc.c */
-extern IPC_Msg *ipc_check_for_message_in_slide(Slide *s);
-extern void ipc_consume_message_in_slide(Slide *s);
-extern int ipc_msg_send(Socket *s, IPC_Msg *m);
-extern int ipc_msg_send_debug(Socket *s, char *msg);
-extern int ipc_msg_send_history(Socket *s, History_ent *l);
-extern int ipc_msg_send_vt102(Socket *s, VT102 *v);
-extern int ipc_msg_send_key(Socket *s, int key);
-extern int ipc_msg_send_term(Socket *s, void *buf, int len);
-extern int ipc_msg_send_status(Socket *s, char *buf);
-extern int ipc_msg_send_setbaud(Socket *s, int baud);
-extern int ipc_msg_send_sendbreak(Socket *s);
-extern int ipc_msg_send_setflow(Socket *s, int flow);
-extern int ipc_msg_send_setansi(Socket *s, int ansi);
-extern int ipc_msg_send_hangup(Socket *s);
+extern IPC_Msg *ipc_check_for_message_in_slide (Slide * s);
+extern void ipc_consume_message_in_slide (Slide * s);
+extern int ipc_msg_send (Socket * s, IPC_Msg * m);
+extern int ipc_msg_send_debug (Socket * s, char *msg);
+extern int ipc_msg_send_history (Socket * s, History_ent * l);
+extern int ipc_msg_send_vt102 (Socket * s, VT102 * v);
+extern int ipc_msg_send_key (Socket * s, int key);
+extern int ipc_msg_send_term (Socket * s, void *buf, int len);
+extern int ipc_msg_send_status (Socket * s, char *buf);
+extern int ipc_msg_send_setbaud (Socket * s, int baud);
+extern int ipc_msg_send_sendbreak (Socket * s);
+extern int ipc_msg_send_setflow (Socket * s, int flow);
+extern int ipc_msg_send_setansi (Socket * s, int ansi);
+extern int ipc_msg_send_hangup (Socket * s);
/* slide.c */
-extern void slide_free(Slide *s);
-extern void slide_consume(Slide *s, int n);
-extern void slide_added(Slide *s, int n);
-extern Slide *slide_new(int n);
-extern void slide_expand(Slide *s, int n);
+extern void slide_free (Slide * s);
+extern void slide_consume (Slide * s, int n);
+extern void slide_added (Slide * s, int n);
+extern Slide *slide_new (int n);
+extern void slide_expand (Slide * s, int n);
/* symsocket.c */
-extern int wrap_recv(int fd, void *buf, int len);
-extern int wrap_send(int fd, void *buf, int len);
-extern void socket_free(Socket *s);
-extern void socket_free_parent(Socket *s);
-extern Socket *socket_listen(char *path);
-extern Socket *socket_accept(Socket *l);
-extern Socket *socket_connect(char *path);
-extern void socket_consume_msg(Socket *s);
-extern void socket_pre_select(Socket *s, fd_set *rfds, fd_set *wfds);
-extern int socket_post_select(Socket *s, fd_set *rfds, fd_set *wfds);
-extern int socket_write(Socket *s, void *buf, int len);
+extern int wrap_recv (int fd, void *buf, int len);
+extern int wrap_send (int fd, void *buf, int len);
+extern void socket_free (Socket * s);
+extern void socket_free_parent (Socket * s);
+extern Socket *socket_listen (char *path);
+extern Socket *socket_accept (Socket * l);
+extern Socket *socket_connect (char *path);
+extern void socket_consume_msg (Socket * s);
+extern void socket_pre_select (Socket * s, fd_set * rfds, fd_set * wfds);
+extern int socket_post_select (Socket * s, fd_set * rfds, fd_set * wfds);
+extern int socket_write (Socket * s, void *buf, int len);
/* serial.c */
-extern TTY *serial_open(char *path, int lock_mode);
+extern TTY *serial_open (char *path, int lock_mode);
/* cmd.c */
-extern void cmd_parse(Cmd *c, Context *ctx, char *buf);
-extern void cmd_show_status(Cmd *c, Context *ctx);
-extern int cmd_key(Cmd *c, Context *ctx, int key);
-extern int cmd_activate(Cmd *c, Context *ctx);
-extern void cmd_new_status(Cmd *c, Context *ctx, char *msg);
-extern Cmd *cmd_new(void);
+extern void cmd_parse (Cmd * c, Context * ctx, char *buf);
+extern void cmd_show_status (Cmd * c, Context * ctx);
+extern int cmd_key (Cmd * c, Context * ctx, int key);
+extern int cmd_activate (Cmd * c, Context * ctx);
+extern void cmd_new_status (Cmd * c, Context * ctx, char *msg);
+extern Cmd *cmd_new (void);
/* lockfile.c */
-extern Filelist *filelist_new(void);
-extern void filelist_remove(Filelist *fl, Filelist_ent *fle);
-extern void filelist_add(Filelist *fl, char *fn);
-extern void filelist_free(Filelist *fl);
-extern void filelist_print(Filelist *fl, FILE *f);
-extern int lockfile_make(char *name);
-extern void lockfile_add_places(Filelist *fl, char *leaf);
-extern void lockfile_regularize_and_add(Filelist *fl, char *leaf);
-extern void lockfile_add_name_from_path(Filelist *fl, char *file);
-extern void lockfile_add_name_from_dev(Filelist *fl, dev_t dev);
-extern void lockfile_check_dir_for_dev(Filelist *fl, char *dir, dev_t dev);
-extern Filelist *lockfile_make_list(char *device);
-extern void lockfile_remove_stale(Filelist *fl);
-extern Filelist *lockfile_lock(Filelist *fl);
-extern void lockfile_unlock(Filelist *fl);
-extern int serial_lock_check(Serial_lock *l);
-extern void serial_lock_free(Serial_lock *l);
-extern Serial_lock *serial_lock_new(char *dev, int mode);
+extern Filelist *filelist_new (void);
+extern void filelist_remove (Filelist * fl, Filelist_ent * fle);
+extern void filelist_add (Filelist * fl, char *fn);
+extern void filelist_free (Filelist * fl);
+extern void filelist_print (Filelist * fl, FILE * f);
+extern int lockfile_make (char *name);
+extern void lockfile_add_places (Filelist * fl, char *leaf);
+extern void lockfile_regularize_and_add (Filelist * fl, char *leaf);
+extern void lockfile_add_name_from_path (Filelist * fl, char *file);
+extern void lockfile_add_name_from_dev (Filelist * fl, dev_t dev);
+extern void lockfile_check_dir_for_dev (Filelist * fl, char *dir, dev_t dev);
+extern Filelist *lockfile_make_list (char *device);
+extern void lockfile_remove_stale (Filelist * fl);
+extern Filelist *lockfile_lock (Filelist * fl);
+extern void lockfile_unlock (Filelist * fl);
+extern int serial_lock_check (Serial_lock * l);
+extern void serial_lock_free (Serial_lock * l);
+extern Serial_lock *serial_lock_new (char *dev, int mode);
/* utf8.c */
-extern void utf8_flush(Context *c);
-extern int utf8_parse(Context *c, int ch);
-extern UTF8 *utf8_new(void);
+extern void utf8_flush (Context * c);
+extern void utf8_parse (Context * c, int ch);
+extern UTF8 *utf8_new (void);
/*
* $Log$
+ * Revision 1.8 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.7 2008/02/22 17:07:00 james
* *** empty log message ***
*
return NULL;
case 0: /*waaah */
setenv ("TERM", "xterm", 1);
- setenv ("LANG", "C", 1);
if (!path)
path = "/bin/sh";
/*
* $Log$
+ * Revision 1.13 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.12 2008/02/22 23:39:27 james
* *** empty log message ***
*
} \
while (0)
-void
-tty_stats (TTY_Parser * p, int err, int ch)
+static void
+tty_bit_analyse (TTY_Parser * p, int err, int ch)
{
int c = 128;
int zc = 0, oc = 0;
if (err)
- p->biterrs++;
+ {
+ p->biterrs++;
+ gettimeofday (&p->lasterr, NULL);
+ }
bit (p, 0, zc, oc);
while (c)
{
- bit (p,ch & c,zc,oc);
+ bit (p, ch & c, zc, oc);
c >>= 1;
}
bit (p, 1, zc, oc);
}
+void
+tty_parse_reset (Context * c)
+{
+ TTY_Parser *p = c->tp;
+ memset (p->bitfreq, 0, sizeof (p->bitfreq));
+ p->biterrs = 0;
+ p->guessed_baud = 0;
+}
+
+void
+analyse (Context * c)
+{
+ TTY_Parser *p = c->tp;
+ struct timeval now, dif;
+ int i;
+
+ if (!p->biterrs)
+ {
+ p->guessed_baud = 0;
+ return;
+ }
+
+ gettimeofday (&now, NULL);
+
+ timersub (&now, &p->lasterr, &dif);
+
+ if (dif.tv_sec > 10)
+ {
+ tty_parse_reset (c);
+ return;
+ }
+
+#define TTY_BITFREQ_LEN 10
+
+ for (i = 0; i < TTY_BITFREQ_LEN && (!p->bitfreq[i]); ++i);
+
+ if (!i)
+ {
+ /*Closest bit edge is one bit, so the baud rate is too low */
+ p->guessed_baud = -1;
+
+ }
+
+ p->guessed_baud = i;
+
+}
+
+TTY_Parser *
+tty_parser_new (void)
+{
+ TTY_Parser *p;
+
+ p = (TTY_Parser *) malloc (sizeof (TTY_Parser));
+
+ memset (p, 0, sizeof (TTY_Parser));
+
+ return p;
+}
+
void
tty_parse (Context * c, uint8_t * buf, int len)
{
- TTY_Parser *p = &c->t->parser;
+ TTY_Parser *p;
+
+ p = c->tp;
while (len--)
{
p->in_errmark = 1;
break;
default:
- log_f (c->l, "%s:%d DLE parsing error: \\377 \\%03o", *buf);
+ log_f (c->l, "%s:%d DLE parsing error: \\377 \\%03o", __FILE__,
+ __LINE__, *buf);
}
}
else if (p->in_errmark)
{
p->in_errmark = 0;
- log_f (c->l, "%s:%d tty reports error: \\377 \\000 \\%03o", *buf);
- utf8_parse (c, *buf);
+ log_f (c->l, "%s:%d tty reports error: \\377 \\000 \\%03o",
+ __FILE__, __LINE__, *buf);
+
+
tty_bit_analyse (p, 1, *buf);
+
+ analyse (c);
+
+ utf8_parse (c, *buf);
+
utf8_parse (c, SYM_CHAR_RESET);
+
+ }
+ else if (*buf == DLE)
+ {
+ p->in_dle = 1;
+
}
else
{
tty_bit_analyse (p, 0, *buf);
+
+ analyse (c);
+
utf8_parse (c, *buf);
+
}
buf++;
}
/*
* $Log$
+ * Revision 1.11 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.10 2008/02/22 23:39:27 james
* *** empty log message ***
*
int rfd; \
int wfd; \
int hanging_up; \
- struct timeval hangup_clock; \
- TTY_Parser parser;
-
+ struct timeval hangup_clock;
+
+
+#define TTY_BITFREQ_LEN 10
typedef struct
{
int in_dle;
int in_errmark;
- int bitfreq[8];
+ int bitfreq[TTY_BITFREQ_LEN];
int biterrs;
+
+ struct timeval lasterr;
+ int guessed_baud;
} TTY_Parser;
/*
* $Log$
+ * Revision 1.3 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.2 2008/02/22 23:39:27 james
* *** empty log message ***
*
#include "project.h"
-void utf8_flush(Context *c)
+void
+utf8_flush (Context * c)
{
-UTF8 *u=c->u;
-int i;
+ UTF8 *u = c->u;
+ int i;
-for (i=0;i<u->utf_ptr;++i)
- vt102_parse(c,u->utf_buf[i]);
+ switch (u->utf_ptr)
+ {
+ case 1:
+ log_f (c->l, "%s:%d invalid utf-8 sequence: \\%03o",
+ __FILE__, __LINE__, u->utf_buf[0]);
+ break;
+ case 2:
+ log_f (c->l, "%s:%d invalid utf-8 sequence: \\%03o \\%03o",
+ __FILE__, __LINE__, u->utf_buf[0], u->utf_buf[1]);
+ break;
+ case 3:
+ log_f (c->l, "%s:%d invalid utf-8 sequence: \\%03o \\%03o \\%03o",
+ __FILE__, __LINE__, u->utf_buf[0], u->utf_buf[1], u->utf_buf[2]);
+ break;
+ case 4:
+ log_f (c->l,
+ "%s:%d invalid utf-8 sequence: \\%03o \\%03o \\%03o \\%03o",
+ __FILE__, __LINE__,
+ u->utf_buf[0], u->utf_buf[1], u->utf_buf[2], u->utf_buf[3]);
+ break;
+ }
-u->utf_ptr=0;
-u->in_utf8=0;
+ for (i = 0; i < u->utf_ptr; ++i)
+ vt102_parse_char (c, u->utf_buf[i]);
+
+ u->utf_ptr = 0;
+ u->in_utf8 = 0;
}
-int utf8_parse(Context *c,int ch)
+void
+utf8_parse (Context * c, int ch)
{
-UTF8 *u=&c->u;
-
- if (!u->in_utf8) {
- /*FIXME: for the moment we bodge utf8 support*/
- if (ch==0xb9) { /*CSI, not a valid utf8 start char*/
- vt102_parse(c,ch);
- } else if ((ch & 0xe0) == 0xc0) { /*Start of two byte unicode sequence*/
- u->in_utf8=2;
- u->utf_ptr=0;
- u->utf_buf[u->utf_ptr++]=ch;
- } else if ((ch & 0xf0) ==0xe0) { /*Start of three byte unicode sequence*/
- u->in_utf8=3;
- u->utf_ptr=0;
- u->utf_buf[u->utf_ptr++]=ch;
- } else if ((ch & 0xf8) ==0xf0) {
- u->in_utf8=4;
- u->utf_ptr=0;
- u->utf_buf[u->utf_ptr++]=ch;
- } else {
- vt102_parse(c,ch);
- }
- } else {
- if ((ch & 0xc0) != 0x80) {
- utf8_flush(c);
- vt102_parse(c,ch);
- } else {
- u->utf_buf[u->utf_ptr++]=ch;
- u->in_utf8--;
- }
- }
+ UTF8 *u = c->u;
+
+ if (ch == SYM_CHAR_RESET)
+ {
+ u->in_utf8 = 0;
+ vt102_parse_char (c, ch);
+ return;
+ }
+
+ if (!u->in_utf8)
+ {
+ /*FIXME: for the moment we bodge utf8 support */
+ if (ch == 0xb9)
+ { /*CSI, not a valid utf8 start char */
+ vt102_parse_char (c, ch);
+ }
+ else if ((ch & 0xe0) == 0xc0)
+ { /*Start of two byte unicode sequence */
+ u->in_utf8 = 1;
+ u->utf_ptr = 0;
+ u->utf_buf[u->utf_ptr++] = ch;
+ u->ch = (ch & 0x1f) << 6;
+ u->sh = 0;
+ }
+ else if ((ch & 0xf0) == 0xe0)
+ { /*Start of three byte unicode sequence */
+ u->in_utf8 = 2;
+ u->utf_ptr = 0;
+ u->utf_buf[u->utf_ptr++] = ch;
+ u->ch = (ch & 0x0f) << 12;
+ u->sh = 6;
+ }
+ else if ((ch & 0xf8) == 0xf0)
+ {
+ u->in_utf8 = 3;
+ u->utf_ptr = 0;
+ u->utf_buf[u->utf_ptr++] = ch;
+ u->ch = (ch & 0x07) << 18;
+ u->sh = 12;
+ }
+ else
+ {
+ vt102_parse_char (c, ch);
+ }
+ }
+ else
+ {
+ if ((ch & 0xc0) != 0x80)
+ {
+ utf8_flush (c);
+ vt102_parse_char (c, ch);
+ }
+ else
+ {
+ u->utf_buf[u->utf_ptr++] = ch;
+ u->ch |= (ch & 0x3f) << u->sh;
+ u->sh -= 6;
+ u->in_utf8--;
+
+ if (!u->in_utf8)
+ vt102_parse_char (c, ch);
+ }
+ }
}
-UTF8 *utf8_new(void)
+UTF8 *
+utf8_new (void)
{
-UTF8 *ret;
+ UTF8 *ret;
-ret=(UTF8 *) malloc(sizeof(UTF8));
+ ret = (UTF8 *) malloc (sizeof (UTF8));
-ret->in_utf8=0;
+ ret->in_utf8 = 0;
}
-
/*
* $Log$
+ * Revision 1.3 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.2 2008/02/22 23:39:27 james
* *** empty log message ***
*
typedef struct
{
int in_utf8;
+
uint8_t utf_buf[4];
int utf_ptr;
+
+ int ch;
+ int sh;
} UTF8;
#endif /* __UTF8_H__ */
/*
* $Log$
+ * Revision 1.34 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.33 2008/02/22 23:39:27 james
* *** empty log message ***
*
static inline int
-safe_ch(int c) {
-if (c<32) return ' ';
-if (c>126) return ' ';
-return c;
+safe_ch (int c)
+{
+ if (c < 32)
+ return ' ';
+ if (c > 126)
+ return ' ';
+ return c;
}
static inline int
return;
}
- if (v->pos.y!=v->screen_end.y) v->pos.y++;
+ if (v->pos.y != v->screen_end.y)
+ v->pos.y++;
v->pending_wrap = 0;
}
}
v->pending_wrap++;
if (!c->v->xn_glitch)
- vt102_do_pending_wrap(c);
+ vt102_do_pending_wrap (c);
}
{
vt102_log_line (c, v->pos.y);
vt102_history (c, v->top_margin, v->bottom_margin);
- crt_scroll_up (&v->crt, v->top_margin, v->bottom_margin, 1,v->color);
+ crt_scroll_up (&v->crt, v->top_margin, v->bottom_margin, 1,
+ v->color);
}
else
{
case 'M':
if (v->pos.y == v->top_margin.y)
{
- crt_scroll_down (&v->crt, v->top_margin, v->bottom_margin, 1,v->color);
+ crt_scroll_down (&v->crt, v->top_margin, v->bottom_margin, 1,
+ v->color);
}
else
{
case '>':
v->application_keypad_mode = 0;
break;
+ case ']':
+ v->parser.ignore_until_bell++;
+ break;
default:
- log_f (c->l, "<%s:%d unhandled ESC: \\033 \\%03o (ESC %c)>", __FILE__,__LINE__,ch,safe_ch(ch));
+ log_f (c->l, "<%s:%d unhandled ESC: \\033 \\%03o (ESC %c)>", __FILE__,
+ __LINE__, ch, safe_ch (ch));
;
}
vt102_cursor_advance_tab (c->v);
break;
case 'J':
- if (len == 2)
- narg = 0; /*Different default */
+ if (len == 2)
+ narg = 0; /*Different default */
switch (narg)
{
case 0:
- crt_erase (&v->crt, v->pos, v->screen_end, 1,v->color);
+ crt_erase (&v->crt, v->pos, v->screen_end, 1, v->color);
break;
case 1:
- crt_erase (&v->crt, v->screen_start, v->pos, 1,v->color);
+ crt_erase (&v->crt, v->screen_start, v->pos, 1, v->color);
break;
case 2:
- crt_erase (&v->crt, v->screen_start, v->screen_end, 1,v->color);
+ crt_erase (&v->crt, v->screen_start, v->screen_end, 1,
+ v->color);
break;
}
break;
switch (narg)
{
case 0:
- crt_erase (&v->crt, v->pos, le, 1,v->color);
+ crt_erase (&v->crt, v->pos, le, 1, v->color);
break;
case 1:
- crt_erase (&v->crt, ls, v->pos, 1,v->color);
+ crt_erase (&v->crt, ls, v->pos, 1, v->color);
break;
case 2:
- crt_erase (&v->crt, ls, le, 1,v->color);
+ crt_erase (&v->crt, ls, le, 1, v->color);
break;
}
}
&& (v->pos.y <= v->bottom_margin.y))
{
while (narg--)
- crt_scroll_down (&v->crt, v->pos, v->bottom_margin, 1,v->color);
+ crt_scroll_down (&v->crt, v->pos, v->bottom_margin, 1,
+ v->color);
}
break;
while (narg--)
{
vt102_history (c, v->pos, v->bottom_margin);
- crt_scroll_up (&v->crt, v->pos, v->bottom_margin, 1,v->color);
+ crt_scroll_up (&v->crt, v->pos, v->bottom_margin, 1,
+ v->color);
}
}
break;
while (narg--)
{
vt102_history (c, v->top_margin, v->bottom_margin);
- crt_scroll_up (&v->crt, v->top_margin, v->bottom_margin, 1,v->color);
+ crt_scroll_up (&v->crt, v->top_margin, v->bottom_margin, 1,
+ v->color);
}
break;
case 'T':
while (narg--)
- crt_scroll_down (&v->crt, v->top_margin, v->bottom_margin, 1,v->color);
+ crt_scroll_down (&v->crt, v->top_margin, v->bottom_margin, 1,
+ v->color);
break;
case 'X':
{
CRT_Pos end = v->pos;
- if (!narg) narg++;
+ if (!narg)
+ narg++;
- end.x += narg-1;
+ end.x += narg - 1;
if (end.x > v->bottom_margin.x)
end.x = v->bottom_margin.x;
- crt_erase (&v->crt, v->pos, end, 1,v->color);
+ crt_erase (&v->crt, v->pos, end, 1, v->color);
}
break;
case 'Z':
break;
default:
- log_f (c->l, "<%s:%d unhandled CSI: \\033%s>", __FILE__,__LINE__,buf);
+ log_f (c->l, "<%s:%d unhandled CSI: \\033%s>", __FILE__, __LINE__,
+ buf);
;
}
break;
default:
- log_f (c->l, "<%s:%d unhandled sequence: \\033%s>", __FILE__,__LINE__,buf);
+ log_f (c->l, "<%s:%d unhandled sequence: \\033%s>", __FILE__, __LINE__,
+ buf);
;
}
{
p->in_csi = 0;
p->in_escape = 0;
+ p->ignore_until_bell = 0;
}
void
-vt102_reset_state(VT102 *v)
+vt102_reset_state (VT102 * v)
{
- vt102_parser_reset(&v->parser);
+ vt102_parser_reset (&v->parser);
v->attr = CRT_ATTR_NORMAL;
v->color = CRT_COLOR_NORMAL;
VT102 *v = c->v;
VT102_parser *p = &v->parser;
-#if 1
- log_f (c->l, "char %3d %c pc %d %d %d %2d %2d %d",ch,safe_ch(ch),
- p->in_utf8,p->in_escape, p->in_csi, v->pos.x, v->pos.y,v->pending_wrap);
+#if 0
+ log_f (c->l, "char %3d %c pc %d %d %d %2d %2d %d", ch, safe_ch (ch),
+ p->ignore_until_bell, p->in_escape, p->in_csi, v->pos.x, v->pos.y,
+ v->pending_wrap);
#endif
- if (ch==SYM_CHAR_RESET) {
- vt102_reset_state(v);
- } else if (p->in_csi)
+/* Turn anything non-ascii into '?' */
+ if ((ch != SYM_CHAR_RESET) && (ch != 0xb9) && (ch > 127))
+ {
+ ch = '?';
+ }
+
+
+ if (ch == SYM_CHAR_RESET)
+ {
+ vt102_reset_state (v);
+ }
+ if (p->ignore_until_bell)
+ {
+ if (ch == 7)
+ p->ignore_until_bell = 0;
+ }
+ else if (p->in_csi)
{
p->csi_buf[p->csi_ptr++] = ch;
if (csi_ender (ch) || (p->csi_ptr == VT102_CSI_LEN))
}
else
{
- log_f (c->l, "<%s:%d no dispatcher for sequence starting \\033 \\%03o (ESC %c)>", __FILE__,__LINE__,p->csi_buf[0],safe_ch(p->csi_buf[0]));
+ log_f (c->l,
+ "<%s:%d no dispatcher for sequence starting \\033 \\%03o (ESC %c)>",
+ __FILE__, __LINE__, p->csi_buf[0],
+ safe_ch (p->csi_buf[0]));
}
p->in_csi = 0;
}
vt102_parse_esc (c, ch);
}
}
- else if (ch==0x9b) /*One byte CSI*/
+ else if (ch == 0x9b) /*One byte CSI */
{
- p->csi_ptr = 0;
- p->csi_buf[p->csi_ptr++] = '[';
- p->in_csi++;
- }
+ p->csi_ptr = 0;
+ p->csi_buf[p->csi_ptr++] = '[';
+ p->in_csi++;
+ }
else
{
/*EOT*/ case 4:
break;
/*ENQ*/ case 5:
- if (c->t)
- c->t->xmit (c->t, "vt102", 5);
+ if (c->t)
+ c->t->xmit (c->t, "vt102", 5);
break;
/*ACK*/ case 6:
/*BEL*/ case 7:
{
VT102_parser *p = &v->parser;
- vt102_parser_reset (p);
- vt102_reset_state(v);
crt_cls (&v->crt);
v->current_line = v->pos;
vt102_reset_tabs (v);
v->current_line = v->pos;
+ vt102_parser_reset (p);
+ vt102_reset_state (v);
+
vt102_save_state (v);
v->last_reg_char = ' ';
}
+
VT102 *
vt102_new (void)
{
v = (VT102 *) malloc (sizeof (VT102));
- v->xn_glitch=1;
+ v->xn_glitch = 1;
vt102_reset (v);
return v;
}
-void vt102_set_ansi(VT102 *v,int ansi)
+void
+vt102_set_ansi (VT102 * v, int ansi)
{
-v->xn_glitch=ansi ? 0:1;
+ v->xn_glitch = ansi ? 0 : 1;
}
void
/*
* $Log$
+ * Revision 1.14 2008/02/23 11:48:37 james
+ * *** empty log message ***
+ *
* Revision 1.13 2008/02/22 17:07:00 james
* *** empty log message ***
*
{
int in_escape;
int in_csi;
- int in_utf8;
int csi_ptr;
+ int ignore_until_bell;
char csi_buf[VT102_CSI_LEN];
} VT102_parser;
~ianmdlvl / sympathy.git / commitdiff