Rethink the whole line discipline architecture. Instead of having
[u/mdw/putty] / terminal.c
index 856d5b1..0f4504a 100644 (file)
@@ -2,10 +2,12 @@
 
 #include <stdio.h>
 #include <stdlib.h>
+#include <ctype.h>
 
+#include <time.h>
 #include "putty.h"
 
-#define CL_ANSIMIN     0x0001  /* Everybody has these even MSDOS */
+#define CL_ANSIMIN     0x0001  /* Codes in all ANSI like terminals. */
 #define CL_VT100       0x0002  /* VT100 */
 #define CL_VT100AVO    0x0004  /* VT100 +AVO; 132x24 (not 132x14) & attrs */
 #define CL_VT102       0x0008  /* VT102 */
 #define CL_VT420       0x0040  /* VT420 */
 #define CL_VT510       0x0080  /* VT510, NB VT510 includes ANSI */
 #define CL_VT340TEXT   0x0100  /* VT340 extensions that appear in the VT420 */
-#define CL_ANSI                0x1000  /* ANSI ECMA-48 not in the VT100..VT420 */
-#define CL_OTHER       0x2000  /* Others, Xterm, linux, putty, dunno, etc */
+#define CL_SCOANSI     0x1000  /* SCOANSI not in ANSIMIN. */
+#define CL_ANSI                0x2000  /* ANSI ECMA-48 not in the VT100..VT420 */
+#define CL_OTHER       0x4000  /* Others, Xterm, linux, putty, dunno, etc */
 
-#define TM_ANSIMIN     (CL_ANSIMIN)
-#define TM_VT100       (CL_ANSIMIN+CL_VT100)
-#define TM_VT100AVO    (TM_VT100+CL_VT100AVO)
-#define TM_VT102       (TM_VT100AVO+CL_VT102)
-#define TM_PUTTY       (-1)
+#define TM_VT100       (CL_ANSIMIN|CL_VT100)
+#define TM_VT100AVO    (TM_VT100|CL_VT100AVO)
+#define TM_VT102       (TM_VT100AVO|CL_VT102)
+#define TM_VT220       (TM_VT102|CL_VT220)
+#define TM_VTXXX       (TM_VT220|CL_VT340TEXT|CL_VT510|CL_VT420|CL_VT320)
+#define TM_SCOANSI     (CL_ANSIMIN|CL_SCOANSI)
+
+#define TM_PUTTY       (0xFFFF)
 
 #define compatibility(x) \
     if ( ((CL_##x)&compatibility_level) == 0 ) {       \
        termstate=TOPLEVEL;                             \
        break;                                          \
     }
+#define compatibility2(x,y) \
+    if ( ((CL_##x|CL_##y)&compatibility_level) == 0 ) { \
+       termstate=TOPLEVEL;                             \
+       break;                                          \
+    }
 
 #define has_compat(x) ( ((CL_##x)&compatibility_level) != 0 )
 
@@ -38,6 +49,7 @@ static unsigned long *text;          /* buffer of text on terminal screen */
 static unsigned long *scrtop;         /* top of working screen */
 static unsigned long *disptop;        /* top of displayed screen */
 static unsigned long *sbtop;          /* top of scrollback */
+static unsigned long *sbbot;          /* furthest extent of scrollback */
 static unsigned long *cpos;           /* cursor position (convenience) */
 static unsigned long *disptext;               /* buffer of text on real screen */
 static unsigned long *wanttext;               /* buffer of text we want on screen */
@@ -64,7 +76,10 @@ static int cursor_on;                       /* cursor enabled flag */
 static int reset_132;                 /* Flag ESC c resets to 80 cols */
 static int use_bce;                   /* Use Background coloured erase */
 static int blinker;                   /* When blinking is the cursor on ? */
-static int vt52_mode;                 /* Is VT100+ in vt52 mode ? */
+static int tblinker;                  /* When the blinking text is on */
+static int blink_is_real;             /* Actually blink blinking text */
+static int term_echoing;               /* Does terminal want local echo? */
+static int term_editing;               /* Does terminal want local edit? */
 
 static unsigned long cset_attr[2];
 
@@ -89,6 +104,8 @@ static int osc_strlen;
 static char osc_string[OSC_STR_MAX+1];
 static int osc_w;
 
+static char id_string[1024] = "\033[?6c";
+
 static unsigned char *tabs;
 
 static enum {
@@ -130,6 +147,8 @@ static short wordness[256] = {
 };
 
 static unsigned char sel_nl[] = SEL_NL;
+static char * paste_buffer = 0;
+static int paste_len, paste_pos, paste_hold;
 
 /*
  * Internal prototypes.
@@ -139,6 +158,9 @@ static void erase_lots (int, int, int);
 static void swap_screen (int);
 static void update_sbar (void);
 static void deselect (void);
+/* log session to file stuff ... */
+static FILE *lgfp = NULL;
+static void logtraffic(unsigned char c, int logmode);
 
 /*
  * Set up power-on settings for the terminal.
@@ -163,9 +185,12 @@ static void power_on(void) {
     rvideo = 0;
     cursor_on = 1;
     save_attr = curr_attr = ATTR_DEFAULT;
+    term_editing = term_echoing = FALSE;
+    ldisc_send(NULL, 0);               /* cause ldisc to notice changes */
     app_cursor_keys = cfg.app_cursor;
     app_keypad_keys = cfg.app_keypad;
-    use_bce = 0;
+    use_bce = cfg.bce;
+    blink_is_real = cfg.blinktext;
     erase_char = ERASE_CHAR;
     alt_which = 0;
     {
@@ -188,12 +213,14 @@ void term_update(void) {
     Context ctx;
     ctx = get_ctx();
     if (ctx) {
-        if ( (seen_key_event && (unscroll_event & US_KEY)) ||
-            (seen_disp_event && (unscroll_event & US_DISP)) ) {
+        if ( (seen_key_event && (cfg.scroll_on_key)) ||
+            (seen_disp_event && (cfg.scroll_on_disp)) ) {
            disptop = scrtop;
            seen_disp_event = seen_key_event = 0;
+           update_sbar();
        }
        do_paint (ctx, TRUE);
+        sys_cursor(curs_x, curs_y + (scrtop - disptop) / (cols+1));
        free_ctx (ctx);
     }
 }
@@ -221,7 +248,7 @@ void term_clrsb(void) {
  * Initialise the terminal.
  */
 void term_init(void) {
-    text = sbtop = scrtop = disptop = cpos = NULL;
+    text = sbtop = sbbot = scrtop = disptop = cpos = NULL;
     disptext = wanttext = NULL;
     tabs = NULL;
     selspace = NULL;
@@ -249,27 +276,32 @@ void term_size(int newrows, int newcols, int newsavelines) {
     alt_b = marg_b = newrows - 1;
 
     newtext = smalloc ((newrows+newsavelines)*(newcols+1)*TSIZE);
-    disptop = newtext + newsavelines*(newcols+1);
+    sbbot = newtext + newsavelines*(newcols+1);
     for (i=0; i<(newrows+newsavelines)*(newcols+1); i++)
-       newtext[i] = ERASE_CHAR;
+       newtext[i] = erase_char;
     if (rows != -1) {
        crows = rows + (scrtop - sbtop) / (cols+1);
        if (crows > newrows+newsavelines)
            crows = newrows+newsavelines;
+       if (newrows>crows)
+           disptop = newtext;
+       else
+            disptop = newtext + (crows-newrows)*(newcols+1);
        ccols = (cols < newcols ? cols : newcols);
        for (i=0; i<crows; i++) {
-           int oldidx = (rows + savelines - crows + i) * (cols+1);
-           int newidx = (newrows + newsavelines - crows + i) * (newcols+1);
+           int oldidx = (rows - crows + i) * (cols+1);
+           int newidx = (newrows - crows + i) * (newcols+1);
+
            for (j=0; j<ccols; j++)
-               newtext[newidx+j] = text[oldidx+j];
-           newtext[newidx+newcols] =
-               (cols == newcols ? text[oldidx+cols] : 0);
+               disptop[newidx+j] = scrtop[oldidx+j];
+           disptop[newidx+newcols] =
+               (cols == newcols ? scrtop[oldidx+cols] 
+                                : (scrtop[oldidx+cols]&LATTR_MODE));
        }
-       sbtop = disptop - (crows - newrows) * (newcols+1);
-       if (sbtop > disptop)
-           sbtop = disptop;
-    } else
-       sbtop = disptop;
+       sbtop = newtext;
+    } else {
+       sbtop = disptop = newtext;
+    }
     scrtop = disptop;
     sfree (text);
     text = newtext;
@@ -354,19 +386,6 @@ static void swap_screen (int which) {
 }
 
 /*
- * Retrieve a character from `inbuf'.
- */
-static int inbuf_getc(void) {
-    if (inbuf_head == inbuf_reap)
-       return -1;                     /* EOF */
-    else {
-       int n = inbuf_reap;
-       inbuf_reap = (inbuf_reap+1) & INBUF_MASK;
-       return inbuf[n];
-    }
-}
-
-/*
  * Update the scroll bar.
  */
 static void update_sbar(void) {
@@ -394,7 +413,14 @@ static void check_selection (unsigned long *from, unsigned long *to) {
  */
 static void scroll (int topline, int botline, int lines, int sb) {
     unsigned long *scroll_top;
+    unsigned long *newscr;
     int scroll_size, size, i;
+    int scrtop_is_disptop = (scrtop==disptop);
+static int recursive = 0;
+
+    /* Only scroll more than the window if we're doing a 10% scroll */
+    if (!recursive && lines > botline - topline + 1)
+        lines = botline - topline + 1;
 
     scroll_top = scrtop + topline*(cols+1);
     size = (lines < 0 ? -lines : lines) * (cols+1);
@@ -403,14 +429,89 @@ static void scroll (int topline, int botline, int lines, int sb) {
     if (lines > 0 && topline == 0 && alt_which == 0 && sb) {
        /*
         * Since we're going to scroll the top line and we're on the 
-        * scrolling screen let's also affect the scrollback buffer.
+        * scrolling screen let's also effect the scrollback buffer.
+        *
+        * This is normally done by moving the position the screen
+        * painter reads from to reduce the amount of memory copying
+        * required.
         */
-       sbtop -= lines * (cols+1);
-       if (sbtop < text)
-           sbtop = text;
-       scroll_size += scroll_top - sbtop;
-       scroll_top = sbtop;
-       update_sbar();
+       if (scroll_size >= 0 && !recursive) {
+           newscr = scrtop + lines * (cols+1);
+
+           if (newscr > sbbot && botline == rows-1) {
+               /* We've hit the bottom of memory, so we have to do a 
+                * physical scroll. But instead of just 1 line do it
+                * by 10% of the available memory.
+                *
+                * If the scroll region isn't the whole screen then we can't
+                * do this as it stands. We would need to recover the bottom
+                * of the screen from the scroll buffer after being sure that
+                * it doesn't get deleted.
+                */
+
+               i = (rows+savelines)/10;
+
+               /* Make it simple and ensure safe recursion */
+               if ( i<savelines-1) {
+                   recursive ++;
+                   scroll(topline, botline, i, sb);
+                   recursive --;
+
+                   newscr = scrtop - i * (cols+1);
+                   if (scrtop_is_disptop) disptop = newscr;
+                   scrtop = newscr;
+               }
+
+               newscr = scrtop + lines * (cols+1);
+           }
+
+           if (newscr <= sbbot) {
+               if (scrtop_is_disptop) disptop = newscr;
+               scrtop = newscr;
+
+               if (botline == rows-1 )
+                   for (i = 0; i < size; i++)
+                       scrtop[i+scroll_size] = erase_char;
+
+               update_sbar();
+               fix_cpos;
+
+               if (botline != rows-1) {
+                   /* This fastscroll only works for full window scrolls. 
+                    * If the caller wanted a partial one we have to reverse
+                    * scroll the bottom of the screen.
+                    */
+                   scroll(botline-lines+1, rows-1, -lines, 0);
+               }
+               return ;
+           }
+
+           /* If we can't scroll by memory remapping do it physically.
+            * But rather than expensivly doing the scroll buffer just
+            * scroll the screen. All it means is that sometimes we choose
+            * to not add lines from a scroll region to the scroll buffer.
+            */
+
+           if (savelines <= 400) {
+               sbtop -= lines * (cols+1);
+               if (sbtop < text)
+                   sbtop = text;
+               scroll_size += scroll_top - sbtop;
+               scroll_top = sbtop;
+    
+               update_sbar();
+           }
+       } else { 
+           /* Ho hum, expensive scroll required. */
+
+           sbtop -= lines * (cols+1);
+           if (sbtop < text)
+               sbtop = text;
+           scroll_size += scroll_top - sbtop;
+           scroll_top = sbtop;
+
+           update_sbar();
+       }
     }
 
     if (scroll_size < 0) {
@@ -435,6 +536,15 @@ static void scroll (int topline, int botline, int lines, int sb) {
            if (selend < scroll_top)
                selend = scroll_top;
        }
+       if (scrtop_is_disptop)
+           disptop = scrtop;
+       else
+           if (disptop > scroll_top &&
+               disptop < scroll_top + size + scroll_size) {
+               disptop -= size;
+               if (disptop < scroll_top)
+                   disptop = scroll_top;
+       }
     } else {
        if (scroll_size)
            memmove (scroll_top + size, scroll_top, scroll_size*TSIZE);
@@ -452,6 +562,14 @@ static void scroll (int topline, int botline, int lines, int sb) {
            if (selend > scroll_top + size + scroll_size)
                selend = scroll_top + size + scroll_size;
        }
+       if (scrtop_is_disptop)
+           disptop = scrtop;
+       else if (disptop > scroll_top &&
+               disptop < scroll_top + size + scroll_size) {
+               disptop += size;
+               if (disptop > scroll_top + size + scroll_size)
+                   disptop = scroll_top + size + scroll_size;
+       }
     }
 }
 
@@ -495,6 +613,10 @@ static void save_cursor(int save) {
     } else {
        curs_x = save_x;
        curs_y = save_y;
+       /* Make sure the window hasn't shrunk since the save */
+       if (curs_x >= cols) curs_x = cols-1;
+       if (curs_y >= rows) curs_y = rows-1;
+
        curr_attr = save_attr;
        cset = save_cset;
        cset_attr[cset] = save_csattr;
@@ -512,7 +634,10 @@ static void erase_lots (int line_only, int from_begin, int to_end) {
 
     if (line_only) {
        startpos = cpos - curs_x;
-       endpos = startpos + cols+1;
+       endpos = startpos + cols;
+       /* I've removed the +1 so that the Wide screen stuff is not
+        * removed when it shouldn't be.
+        */
     } else {
        startpos = scrtop;
        endpos = startpos + rows * (cols+1);
@@ -583,8 +708,15 @@ static void toggle_mode (int mode, int query, int state) {
       case 7:                         /* auto wrap */
        wrap = state;
        break;
+      case 8:                         /* auto key repeat */
+       repeat_off = !state;
+       break;
+      case 10:                        /* set local edit mode */
+        term_editing = state;
+        ldisc_send(NULL, 0);           /* cause ldisc to notice changes */
+       break;
       case 25:                        /* enable/disable cursor */
-       compatibility(VT220);
+       compatibility2(OTHER,VT220);
        cursor_on = state;
        seen_disp_event = TRUE;
        break;
@@ -600,16 +732,11 @@ static void toggle_mode (int mode, int query, int state) {
        insert = state;
        break;
       case 12:                        /* set echo mode */
-       /* 
-        * This may be very good in smcup and rmcup (or smkx & rmkx) if you
-        * have a long RTT and the telnet client/daemon doesn't understand
-        * linemode.
-        *
-        * DONT send TS_RECHO/TS_LECHO; the telnet daemon tries to fix the
-        * tty and _really_ confuses some programs.
-        */
-       compatibility(VT220);
-        ldisc = (state? &ldisc_simple : &ldisc_term);
+        term_echoing = !state;
+        ldisc_send(NULL, 0);           /* cause ldisc to notice changes */
+       break;
+      case 20:                        /* Return sends ... */
+       cr_lf_return = state;
        break;
     }
 }
@@ -644,23 +771,27 @@ static void do_osc(void) {
  * process escape sequences...
  */
 void term_out(void) {
-    int c;
+    int c, inbuf_reap;
+
+static int beep_overload = 0;
+    int beep_count = 0;
 
-    while ( (c = inbuf_getc()) != -1) {
-        /*
+    for(inbuf_reap = 0; inbuf_reap < inbuf_head; inbuf_reap++)
+    {
+        c = inbuf[inbuf_reap];
+
+       /*
          * Optionally log the session traffic to a file. Useful for
          * debugging and possibly also useful for actual logging.
          */
-       if (logfile) {
-           static FILE *fp = NULL;
-           if (!fp) fp = fopen(logfile, "wb");
-           if (fp) fputc (c, fp);
-       }
+       logtraffic((unsigned char)c, LGTYP_DEBUG);
+
        /* Note only VT220+ are 8-bit VT102 is seven bit, it shouldn't even
         * be able to display 8-bit characters, but I'll let that go 'cause
         * of i18n.
         */
-       if( (c&0x60) == 0 && termstate < DO_CTRLS &&
+       if( ( (c&0x60) == 0 || c == '\177') && 
+            termstate < DO_CTRLS &&
            ( (c&0x80) == 0 || has_compat(VT220))) {
            switch (c) {
              case '\005':             /* terminal type query */
@@ -673,14 +804,17 @@ void term_out(void) {
                 * An xterm returns "xterm" (5 characters)
                 */
                compatibility(OTHER);
-               ldisc->send ("PuTTY", 5);
+               ldisc_send ("PuTTY", 5);
                break;
              case '\007':
-                if(cfg.beep) beep();
+               beep_count++; 
+               if(beep_count>6) beep_overload=1;
                disptop = scrtop;
                break;
              case '\b':
-               if (curs_x == 0 && curs_y > 0)
+               if (curs_x == 0 && curs_y == 0)
+                   ;
+               else if (curs_x == 0 && curs_y > 0)
                    curs_x = cols-1, curs_y--;
                else if (wrapnext)
                    wrapnext = FALSE;
@@ -722,6 +856,8 @@ void term_out(void) {
                wrapnext = FALSE;
                fix_cpos;
                seen_disp_event = TRUE;
+               paste_hold = 0;
+               logtraffic((unsigned char)c,LGTYP_ASCII);
                break;
              case '\013':
              case '\014':
@@ -736,27 +872,49 @@ void term_out(void) {
                fix_cpos;
                wrapnext = FALSE;
                seen_disp_event = 1;
+               paste_hold = 0;
+               logtraffic((unsigned char)c,LGTYP_ASCII);
                break;
              case '\t':
-               do {
-                   curs_x++;
-               } while (curs_x < cols-1 && !tabs[curs_x]);
-               if (curs_x >= cols)
-                   curs_x = cols-1;
                {
                    unsigned long *old_cpos = cpos;
+                   unsigned long *p = scrtop + curs_y * (cols+1) + cols;
+
+                   do {
+                       curs_x++;
+                   } while (curs_x < cols-1 && !tabs[curs_x]);
+
+                   if ((*p & LATTR_MODE) != LATTR_NORM)
+                   {
+                       if (curs_x >= cols/2)
+                           curs_x = cols/2-1;
+                   }
+                   else
+                   {
+                       if (curs_x >= cols)
+                           curs_x = cols-1;
+                   }
+
                    fix_cpos;
                    check_selection (old_cpos, cpos);
                }
                seen_disp_event = TRUE;
                break;
+             case '\177': /* Destructive backspace
+                             This does nothing on a real VT100 */
+               compatibility(OTHER);
+               if (curs_x && !wrapnext) curs_x--;
+               wrapnext = FALSE;
+               fix_cpos;
+               *cpos = (' ' | curr_attr | ATTR_ASCII);
+               break;
            }
        }
        else switch (termstate) {
          case TOPLEVEL:
          /* Only graphic characters get this far, ctrls are stripped above */
-           if (wrapnext) {
-               cpos[1] = ATTR_WRAPPED;
+           if (wrapnext && wrap) {
+               cpos[1] |= ATTR_WRAPPED;
                if (curs_y == marg_b)
                    scroll (marg_t, marg_b, 1, TRUE);
                else if (curs_y < rows-1)
@@ -775,22 +933,33 @@ void term_out(void) {
                 * we use the same font as well as the same encoding.
                 */
            case ATTR_LINEDRW:
-               if (c<0x60 || c>0x7F)
+               if (c<0x5f || c>0x7F)
                    *cpos++ = xlat_tty2scr((unsigned char)c) | curr_attr |
                              ATTR_ASCII;
+               else if (c==0x5F)
+                  *cpos++ = ' ' | curr_attr | ATTR_ASCII;
                else
                    *cpos++ = ((unsigned char)c) | curr_attr | ATTR_LINEDRW;
                break;
+           case ATTR_GBCHR:
+               /* If UK-ASCII, make the '#' a LineDraw Pound */
+               if (c == '#') {
+                   *cpos++ = '}' | curr_attr | ATTR_LINEDRW;
+                   break;
+               }
+               /*FALLTHROUGH*/
            default:
-               *cpos++ = xlat_tty2scr((unsigned char)c) | curr_attr |
+               *cpos = xlat_tty2scr((unsigned char)c) | curr_attr |
                    (c <= 0x7F ? cset_attr[cset] : ATTR_ASCII);
+               logtraffic((unsigned char)c, LGTYP_ASCII);
+               cpos++;
                break;
            }
            curs_x++;
            if (curs_x == cols) {
                cpos--;
                curs_x--;
-               wrapnext = wrap;
+               wrapnext = TRUE;
            }
            seen_disp_event = 1;
            break;
@@ -867,7 +1036,6 @@ void term_out(void) {
              case 'E':                /* exactly equivalent to CR-LF */
                compatibility(VT100);
                curs_x = 0;
-               wrapnext = FALSE;
                if (curs_y == marg_b)
                    scroll (marg_t, marg_b, 1, TRUE);
                else if (curs_y < rows-1)
@@ -888,7 +1056,7 @@ void term_out(void) {
                break;
              case 'Z':                /* terminal type query */
                compatibility(VT100);
-               ldisc->send ("\033[?6c", 5);
+               ldisc_send (id_string, strlen(id_string));
                break;
              case 'c':                /* restore power-on settings */
                compatibility(VT100);
@@ -1031,20 +1199,16 @@ void term_out(void) {
              case 'c':                /* terminal type query */
                compatibility(VT100);
                /* This is the response for a VT102 */
-               ldisc->send ("\033[?6c", 5);
+               ldisc_send (id_string, strlen(id_string));
                break;
              case 'n':                /* cursor position query */
                if (esc_args[0] == 6) {
-                   /* Wonder of wonders ANSI.SYS has this!! */
                    char buf[32];
                    sprintf (buf, "\033[%d;%dR", curs_y + 1, curs_x + 1);
-                   ldisc->send (buf, strlen(buf));
+                   ldisc_send (buf, strlen(buf));
                }
                else if (esc_args[0] == 5) {
-                   /* Are we working ... well I suppose so :-) */
-                   /* But ANSI.SYS doesn't say it's working :-) :-) */
-                   compatibility(VT100);
-                   ldisc->send ("\033[0n", 4);
+                   ldisc_send ("\033[0n", 4);
                }
                break;
              case 'h':                /* toggle modes to high */
@@ -1081,20 +1245,15 @@ void term_out(void) {
                compatibility(VT100);
                if (esc_nargs <= 2) {
                    int top, bot;
-                   /* VTTEST Bug 9 if the first arg is default _or_ zero
-                    * this is a full screen region irrespective of 2nd arg.
-                    */
-                   if (esc_args[0] <= 0) {
-                      top=0;
-                      bot=rows-1;
-                   } else {
-                      top = def(esc_args[0], 1) - 1;
-                      bot = (esc_nargs <= 1 || esc_args[1] == 0 ? rows :
-                             def(esc_args[1], rows)) - 1;
-                   }
+                   top = def(esc_args[0], 1) - 1;
+                   bot = (esc_nargs <= 1 || esc_args[1] == 0 ? rows :
+                          def(esc_args[1], rows)) - 1;
                    if (bot >= rows)
                        bot = rows-1;
-                   if (top <= bot) {
+                   /* VTTEST Bug 9 - if region is less than 2 lines
+                    * don't change region.
+                    */
+                   if (bot-top > 0) {
                        marg_t = top;
                        marg_b = bot;
                        curs_x = 0;
@@ -1156,16 +1315,16 @@ void term_out(void) {
                          case 7:      /* enable reverse video */
                            curr_attr |= ATTR_REVERSE; break;
                          case 22:     /* disable bold */
-                           compatibility(VT220);
+                           compatibility2(OTHER,VT220);
                            curr_attr &= ~ATTR_BOLD; break;
                          case 24:     /* disable underline */
-                           compatibility(VT220);
+                           compatibility2(OTHER,VT220);
                            curr_attr &= ~ATTR_UNDER; break;
                          case 25:     /* disable blink */
-                           compatibility(VT220);
+                           compatibility2(OTHER,VT220);
                            curr_attr &= ~ATTR_BLINK; break;
                          case 27:     /* disable reverse video */
-                           compatibility(VT220);
+                           compatibility2(OTHER,VT220);
                            curr_attr &= ~ATTR_REVERSE; break;
                          case 30: case 31: case 32: case 33:
                          case 34: case 35: case 36: case 37:
@@ -1190,7 +1349,10 @@ void term_out(void) {
                        }
                    }
                    if (use_bce) 
-                      erase_char = (' '|(curr_attr&(ATTR_FGMASK|ATTR_BGMASK)));
+                      erase_char = 
+                           (' '|
+                             (curr_attr&(ATTR_FGMASK|ATTR_BGMASK|ATTR_BLINK))
+                           );
                }
                break;
              case 's':                /* save cursor */
@@ -1209,11 +1371,7 @@ void term_out(void) {
                 */
                compatibility(VT340TEXT);
                if (esc_nargs<=1 && (esc_args[0]<1 || esc_args[0]>=24)) {
-                   unsigned int newrows = def(esc_args[0], 24);
-                   /* Hack: prevent big-resize DoS attack. */
-                   if (newrows > max(512, cfg.height))
-                       newrows = max(512, cfg.height);
-                   request_resize (cols, newrows, 0);
+                   request_resize (cols, def(esc_args[0], 24), 0);
                    deselect();
                }
                break;
@@ -1224,12 +1382,8 @@ void term_out(void) {
                 * reasonable range (24..49 AIUI) with no default specified.
                 */
                compatibility(VT420);
-               if (esc_nargs==1 && esc_args[0]>=24) {
-                   unsigned int newrows = def(esc_args[0], cfg.height);
-                   /* Hack: prevent big-resize DoS attack. */
-                   if (newrows > max(512, cfg.height))
-                       newrows = max(512, cfg.height);
-                   request_resize (cols, newrows, 0);
+               if (esc_nargs==1 && esc_args[0]>0) {
+                   request_resize (cols, def(esc_args[0], cfg.height), 0);
                    deselect();
                }
                break;
@@ -1240,17 +1394,13 @@ void term_out(void) {
                 */
                compatibility(VT340TEXT);
                if (esc_nargs<=1) {
-                   unsigned int newcols = def(esc_args[0], cfg.width);
-                   /* Hack: prevent big-resize DoS attack. */
-                   if (newcols > max(512, cfg.width))
-                       newcols = max(512, cfg.width);
-                   request_resize (newcols, rows, 0);
+                   request_resize (def(esc_args[0], cfg.width), rows, 0);
                    deselect();
                }
                break;
              case 'X':                /* write N spaces w/o moving cursor */
                /* XXX VTTEST says this is vt220, vt510 manual says vt100 */
-               compatibility(VT100);
+               compatibility(ANSIMIN);
                {
                    int n = def(esc_args[0], 1);
                    unsigned long *p = cpos;
@@ -1270,7 +1420,7 @@ void term_out(void) {
                    if (i == 0 || i == 1) {
                        strcpy (buf, "\033[2;1;1;112;112;1;0x");
                        buf[2] += i;
-                       ldisc->send (buf, 20);
+                       ldisc_send (buf, 20);
                    }
                }
                break;
@@ -1281,13 +1431,17 @@ void term_out(void) {
                if (use_bce)
                    erase_char = (' '|(curr_attr&(ATTR_FGMASK|ATTR_BGMASK)));
                break;
+             case ANSI('E','='):
+               compatibility(OTHER);
+               blink_is_real = (esc_args[0]>=1);
+               break;
              case ANSI('p','"'):
                /* Allow the host to make this emulator a 'perfect' VT102.
                 * This first appeared in the VT220, but we do need to get 
                 * back to PuTTY mode so I won't check it.
                 *
-                * The arg == 60 is a PuTTY extension.
-                * The 2nd arg, 8bit vs 7bit is not obeyed.
+                * The arg in 40..42 are a PuTTY extension.
+                * The 2nd arg, 8bit vs 7bit is not checked.
                 *
                 * Setting VT102 mode should also change the Fkeys to
                 * generate PF* codes as a real VT102 has no Fkeys.
@@ -1297,9 +1451,47 @@ void term_out(void) {
                 * Note ESC c will NOT change this!
                 */
 
-               if (esc_args[0] == 61)      compatibility_level = TM_VT102;
-               else if (esc_args[0] == 60) compatibility_level = TM_ANSIMIN;
-               else                        compatibility_level = TM_PUTTY;
+               switch (esc_args[0]) {
+               case 61: compatibility_level &= ~TM_VTXXX;
+                        compatibility_level |=  TM_VT102;      break;
+               case 62: compatibility_level &= ~TM_VTXXX;
+                        compatibility_level |=  TM_VT220;      break;
+
+               default: if( esc_args[0] > 60 && esc_args[0] < 70 )
+                           compatibility_level |= TM_VTXXX;    
+                        break;
+
+               case 40: compatibility_level &=  TM_VTXXX;      break;
+               case 41: compatibility_level  =  TM_PUTTY;      break;
+               case 42: compatibility_level  =  TM_SCOANSI;    break;
+
+               case ARG_DEFAULT: 
+                        compatibility_level  =  TM_PUTTY;      break;
+               case 50: break;
+               }
+
+               /* Change the response to CSI c */
+               if (esc_args[0] == 50) {
+                  int i;
+                  char lbuf[64];
+                  strcpy(id_string, "\033[?");
+                  for (i=1; i<esc_nargs; i++) {
+                     if (i!=1) strcat(id_string, ";");
+                     sprintf(lbuf, "%d", esc_args[i]);
+                     strcat(id_string, lbuf);
+                  }
+                  strcat(id_string, "c");
+               }
+
+#if 0
+               /* Is this a good idea ? 
+                * Well we should do a soft reset at this point ...
+                */
+               if (!has_compat(VT420) && has_compat(VT100)) {
+                   if (reset_132) request_resize (132, 24, 1);
+                   else           request_resize ( 80, 24, 1);
+               }
+#endif
                break;
            }
            break;
@@ -1419,14 +1611,31 @@ void term_out(void) {
            }
            break;
          case SEEN_ESCHASH:
-           if (c == '8') {
-               unsigned long *p = scrtop;
-               int n = rows * (cols+1);
-               while (n--)
-                   *p++ = ATTR_DEFAULT | 'E';
-               disptop = scrtop;
-               seen_disp_event = TRUE;
-               check_selection (scrtop, scrtop + rows * (cols+1));
+           {
+               unsigned long *p;
+               unsigned long nlattr;
+               int n;
+
+               switch (c) {
+               case '8':
+                   p = scrtop;
+                   n = rows * (cols+1);
+                   while (n--)
+                       *p++ = ATTR_DEFAULT | 'E';
+                   disptop = scrtop;
+                   seen_disp_event = TRUE;
+                   check_selection (scrtop, scrtop + rows * (cols+1));
+                   break;
+
+               case '3': nlattr = LATTR_TOP;     if(0) {
+               case '4': nlattr = LATTR_BOT;   } if(0) {
+               case '5': nlattr = LATTR_NORM;  } if(0) {
+               case '6': nlattr = LATTR_WIDE;  }
+
+                   p = scrtop + curs_y * (cols+1) + cols;
+                   *p &= ~LATTR_MODE;
+                   *p |=  nlattr;
+               }
            }
            termstate = TOPLEVEL;
            break;
@@ -1483,13 +1692,13 @@ void term_out(void) {
                termstate = VT52_Y1;
                break;
              case 'Z':
-               ldisc->send ("\033/Z", 3);
+               ldisc_send ("\033/Z", 3);
                break;
              case '=':
-               app_cursor_keys = TRUE;
+               app_keypad_keys = TRUE;
                break;
              case '>':
-               app_cursor_keys = FALSE;
+               app_keypad_keys = FALSE;
                break;
              case '<':
                /* XXX This should switch to VT100 mode not current or default
@@ -1521,6 +1730,14 @@ void term_out(void) {
        if (selstate != NO_SELECTION)
            check_selection (cpos, cpos+1);
     }
+    inbuf_head = 0;
+
+    if (beep_overload)
+    {
+       if(!beep_count) beep_overload=0;
+    }
+    else if(beep_count && beep_count<5 && cfg.beep)
+       beep(beep_count/3);
 }
 
 /*
@@ -1540,7 +1757,7 @@ static int linecmp (unsigned long *a, unsigned long *b) {
  * Given a context, update the window. Out of paranoia, we don't
  * allow WM_PAINT responses to do scrolling optimisations.
  */
-static void do_paint (Context ctx, int may_optimise){ 
+static void do_paint (Context ctx, int may_optimise){
     int i, j, start, our_curs_y;
     unsigned long attr, rv, cursor;
     char ch[1024];
@@ -1554,6 +1771,8 @@ static void do_paint (Context ctx, int may_optimise){
         }
         else
             cursor = ATTR_PASCURS;
+       if (wrapnext)
+           cursor |= ATTR_RIGHTCURS;
     }
     else           cursor = 0;
     rv = (rvideo ? ATTR_REVERSE : 0);
@@ -1561,12 +1780,21 @@ static void do_paint (Context ctx, int may_optimise){
 
     for (i=0; i<rows; i++) {
        int idx = i*(cols+1);
+       int lattr = (disptop[idx+cols] & LATTR_MODE);
        for (j=0; j<=cols; j++,idx++) {
            unsigned long *d = disptop+idx;
-           wanttext[idx] = ((*d ^ rv
+           wanttext[idx] = lattr | (((*d &~ ATTR_WRAPPED) ^ rv
                              ^ (selstart <= d && d < selend ?
                                 ATTR_REVERSE : 0)) |
                             (i==our_curs_y && j==curs_x ? cursor : 0));
+           if (blink_is_real) {
+               if (has_focus && tblinker && (wanttext[idx]&ATTR_BLINK) )
+               {
+                   wanttext[idx] &= ATTR_MASK;
+                   wanttext[idx] += ' ';
+               }
+               wanttext[idx] &= ~ATTR_BLINK;
+           }
        }
     }
 
@@ -1579,6 +1807,7 @@ static void do_paint (Context ctx, int may_optimise){
 
     for (i=0; i<rows; i++) {
        int idx = i*(cols+1);
+       int lattr = (wanttext[idx+cols] & LATTR_MODE);
        start = -1;
        for (j=0; j<=cols; j++,idx++) {
            unsigned long t = wanttext[idx];
@@ -1587,7 +1816,7 @@ static void do_paint (Context ctx, int may_optimise){
                              (t & ATTR_MASK) == attr &&
                              j-start < sizeof(ch));
            if (start != -1 && !keep_going) {
-               do_text (ctx, start, i, ch, j-start, attr);
+               do_text (ctx, start, i, ch, j-start, attr, lattr);
                start = -1;
            }
            if (needs_update) {
@@ -1608,14 +1837,24 @@ static void do_paint (Context ctx, int may_optimise){
 
 void term_blink(int flg) {
 static long last_blink = 0;
+static long last_tblink = 0;
     long now, blink_diff;
 
+    now = GetTickCount();
+    blink_diff = now-last_tblink;
+
+    /* Make sure the text blinks no more than 2Hz */
+    if (blink_diff<0 || blink_diff>450)
+    {
+        last_tblink = now;
+       tblinker = !tblinker;
+    }
+
     if (flg) {
         blinker = 1;
-        last_blink = GetTickCount();
+        last_blink = now;
        return;
     } 
-    now = GetTickCount();
 
     blink_diff = now-last_blink;
 
@@ -1648,8 +1887,14 @@ void term_paint (Context ctx, int l, int t, int r, int b) {
     top = t / font_height;
     bottom = (b - 1) / font_height;
     for (i = top; i <= bottom && i < rows ; i++)
-      for (j = left; j <= right && j < cols ; j++)
-           disptext[i*(cols+1)+j] = ATTR_INVALID;
+    {
+       if ( (disptext[i*(cols+1)+cols]&LATTR_MODE) == LATTR_NORM)
+           for (j = left; j <= right && j < cols ; j++)
+               disptext[i*(cols+1)+j] = ATTR_INVALID;
+       else
+           for (j = left/2; j <= right/2+1 && j < cols ; j++)
+               disptext[i*(cols+1)+j] = ATTR_INVALID;
+    }
 
     /* This should happen soon enough, also for some reason it sometimes 
      * fails to actually do anything when re-sizing ... painting the wrong
@@ -1678,6 +1923,85 @@ void term_scroll (int rel, int where) {
     term_update();
 }
 
+static void clipme(unsigned long *top, unsigned long *bottom, char *workbuf) {
+    char *wbptr;               /* where next char goes within workbuf */
+    int wblen = 0;             /* workbuf len */
+    int buflen;                        /* amount of memory allocated to workbuf */
+
+    if ( workbuf != NULL ) {   /* user supplied buffer? */
+       buflen = -1;            /* assume buffer passed in is big enough */
+       wbptr = workbuf;        /* start filling here */
+    }
+    else
+       buflen = 0;             /* No data is available yet */
+
+    while (top < bottom) {
+       int nl = FALSE;
+       unsigned long *lineend = top - (top-text) % (cols+1) + cols;
+       unsigned long *nlpos = lineend;
+
+       if (!(*nlpos & ATTR_WRAPPED)) {
+           while ((nlpos[-1] & CHAR_MASK) == 0x20 && nlpos > top)
+               nlpos--;
+           if (nlpos < bottom)
+               nl = TRUE;
+       }
+       while (top < nlpos && top < bottom)
+       {
+#if 0
+           /* VT Specials -> ISO8859-1  */
+           static const char poorman2[] =
+"* # HTFFCRLF\xB0 \xB1 NLVT+ + + + + - - - - - + + + + | <=>=PI!=\xA3 \xB7 ";
+#endif
+
+           int ch = (*top & CHAR_MASK);
+
+#if 0
+           if ((*top & ATTR_LINEDRW) && ch >= 0x60 && ch < 0x7F) {
+               int x;
+               *wbptr++ = poorman2[2*(ch-0x60)];
+               if ( (x = poorman2[2*(ch-0x60)+1]) != ' ')
+                   *wbptr++ = x;
+           } else
+#endif
+#if 0
+           if ((*top & ATTR_GBCHR) && ch == '#')
+               *wbptr++ = (unsigned char) 0xA3;
+           else
+#endif
+           if ( wblen == buflen )
+           {
+               workbuf = srealloc(workbuf, buflen += 100);
+               wbptr = workbuf + wblen;
+           }
+           wblen++;
+           *wbptr++ = (unsigned char) ch;
+           top++;
+       }
+       if (nl) {
+           int i;
+           for (i=0; i<sizeof(sel_nl); i++)
+           {
+               if ( wblen == buflen )
+               {
+                   workbuf = srealloc(workbuf, buflen += 100);
+                   wbptr = workbuf + wblen;
+               }
+               wblen++;
+               *wbptr++ = sel_nl[i];
+           }
+       }
+       top = lineend + 1;       /* start of next line */
+    }
+    write_clip (workbuf, wblen, FALSE);        /* transfer to clipboard */
+    if ( buflen > 0 )  /* indicates we allocated this buffer */
+       sfree(workbuf);
+
+}
+void term_copyall (void) {
+    clipme(sbtop, cpos, NULL /* dynamic allocation */);
+}
+
 /*
  * Spread the selection outwards according to the selection mode.
  */
@@ -1749,7 +2073,11 @@ void term_mouse (Mouse_Button b, Mouse_Action a, int x, int y) {
     }
     if (x>=cols) x = cols-1;
 
-    selpoint = disptop + y * (cols+1) + x;
+    selpoint = disptop + y * (cols+1);
+    if ((selpoint[cols]&LATTR_MODE) != LATTR_NORM)
+       selpoint += x/2;
+    else
+       selpoint += x;
 
     if (b == MB_SELECT && a == MA_CLICK) {
        deselect();
@@ -1791,30 +2119,7 @@ void term_mouse (Mouse_Button b, Mouse_Action a, int x, int y) {
             * We've completed a selection. We now transfer the
             * data to the clipboard.
             */
-           unsigned char *p = selspace;
-           unsigned long *q = selstart;
-
-           while (q < selend) {
-               int nl = FALSE;
-               unsigned long *lineend = q - (q-text) % (cols+1) + cols;
-               unsigned long *nlpos = lineend;
-
-               if (!(*nlpos & ATTR_WRAPPED)) {
-                   while ((nlpos[-1] & CHAR_MASK) == 0x20 && nlpos > q)
-                       nlpos--;
-                   if (nlpos < selend)
-                       nl = TRUE;
-               }
-               while (q < nlpos && q < selend)
-                   *p++ = (unsigned char) (*q++ & CHAR_MASK);
-               if (nl) {
-                   int i;
-                   for (i=0; i<sizeof(sel_nl); i++)
-                       *p++ = sel_nl[i];
-               }
-               q = lineend + 1;       /* start of next line */
-           }
-           write_clip (selspace, p - selspace);
+           clipme(selstart, selend, selspace);
            selstate = SELECTED;
        } else
            selstate = NO_SELECTION;
@@ -1825,6 +2130,11 @@ void term_mouse (Mouse_Button b, Mouse_Action a, int x, int y) {
        get_clip((void **) &data, &len);
        if (data) {
            char *p, *q;
+
+           if (paste_buffer) sfree(paste_buffer);
+           paste_pos = paste_hold = paste_len = 0;
+           paste_buffer = smalloc(len);
+
            p = q = data;
            while (p < data+len) {
                while (p < data+len &&
@@ -1838,17 +2148,25 @@ void term_mouse (Mouse_Button b, Mouse_Action a, int x, int y) {
                    for(i=0;i<p-q;i++)
                    {
                        c=xlat_kbd2tty(q[i]);
-                       ldisc->send(&c,1);
+                       paste_buffer[paste_len++] = c;
                    }
                }
 
                if (p <= data+len-sizeof(sel_nl) &&
                    !memcmp(p, sel_nl, sizeof(sel_nl))) {
-                   ldisc->send ("\r", 1);
+                   paste_buffer[paste_len++] = '\r';
                    p += sizeof(sel_nl);
                }
                q = p;
            }
+
+           /* Assume a small paste will be OK in one go. */
+           if (paste_len<256) {
+               ldisc_send (paste_buffer, paste_len);
+               if (paste_buffer) sfree(paste_buffer);
+               paste_buffer = 0;
+               paste_pos = paste_hold = paste_len = 0;
+           }
        }
        get_clip(NULL, NULL);
     }
@@ -1856,6 +2174,48 @@ void term_mouse (Mouse_Button b, Mouse_Action a, int x, int y) {
     term_update();
 }
 
+void term_nopaste() {
+    if(paste_len == 0) return;
+    sfree(paste_buffer);
+    paste_buffer = 0;
+    paste_len = 0;
+}
+
+void term_paste() {
+    static long last_paste = 0;
+    long now, paste_diff;
+
+    if(paste_len == 0) return;
+
+    /* Don't wait forever to paste */
+    if(paste_hold) {
+       now = GetTickCount();
+       paste_diff = now-last_paste;
+       if (paste_diff>=0 && paste_diff<450)
+           return;
+    }
+    paste_hold = 0;
+
+    while(paste_pos<paste_len)
+    {
+       int n = 0;
+       while (n + paste_pos < paste_len) {
+           if (paste_buffer[paste_pos + n++] == '\r')
+               break;
+       }
+       ldisc_send (paste_buffer+paste_pos, n);
+       paste_pos += n;
+
+       if (paste_pos < paste_len) {
+           paste_hold = 1;
+           return;
+       }
+    }
+    sfree(paste_buffer);
+    paste_buffer = 0;
+    paste_len = 0;
+}
+
 static void deselect (void) {
     selstate = NO_SELECTION;
     selstart = selend = scrtop;
@@ -1865,3 +2225,82 @@ void term_deselect (void) {
     deselect();
     term_update();
 }
+
+int term_ldisc(int option) {
+    if (option == LD_ECHO) return term_echoing;
+    if (option == LD_EDIT) return term_editing;
+    return FALSE;
+}
+
+/*
+ * from_backend(), to get data from the backend for the terminal.
+ */
+void from_backend(int is_stderr, char *data, int len) {
+    while (len--) {
+       if (inbuf_head >= INBUF_SIZE)
+           term_out();
+       inbuf[inbuf_head++] = *data++;
+    }
+}
+
+/*
+ * Log session traffic.
+ */
+void logtraffic(unsigned char c, int logmode) {
+    if (cfg.logtype > 0) {
+       if (cfg.logtype == logmode) {
+           /* deferred open file from pgm start? */
+           if (!lgfp) logfopen();
+           if (lgfp) fputc (c, lgfp);
+       }
+    }
+}
+
+/* open log file append/overwrite mode */
+void logfopen(void) {
+    char buf[256];
+    time_t t;
+    struct tm *tm;
+    char writemod[4];
+
+    if (!cfg.logtype)
+       return;
+    sprintf (writemod, "wb");         /* default to rewrite */
+    lgfp = fopen(cfg.logfilename, "r");  /* file already present? */
+    if (lgfp) {
+       int i;
+       fclose(lgfp);
+       i = askappend(cfg.logfilename);
+       if (i == 1)
+           writemod[0] = 'a';         /* set append mode */
+       else if (i == 0) {             /* cancelled */
+           lgfp = NULL;
+            cfg.logtype = 0;           /* disable logging */
+           return;
+       }
+    }
+
+    lgfp = fopen(cfg.logfilename, writemod);
+    if (lgfp) { /* enter into event log */
+       sprintf(buf, "%s session log (%s mode) to file : ",
+               (writemod[0] == 'a') ? "Appending" : "Writing new",
+               (cfg.logtype == LGTYP_ASCII ? "ASCII" :
+                cfg.logtype == LGTYP_DEBUG ? "raw" : "<ukwn>")  );
+       /* Make sure we do not exceed the output buffer size */
+       strncat (buf, cfg.logfilename, 128);
+       buf[strlen(buf)] = '\0';
+       logevent(buf);
+
+        /* --- write header line iinto log file */
+       fputs ("=~=~=~=~=~=~=~=~=~=~=~= PuTTY log ", lgfp);
+       time(&t);
+       tm = localtime(&t);
+       strftime(buf, 24, "%Y.%m.%d %H:%M:%S", tm);
+       fputs (buf, lgfp);
+       fputs (" =~=~=~=~=~=~=~=~=~=~=~=\r\n", lgfp);
+    }
+}
+
+void logfclose (void) {
+    if (lgfp) { fclose(lgfp); lgfp = NULL; }
+}