/*
* Supdup backend
*/
#include <stdio.h>
#include <stdlib.h>
#include <limits.h>
#include "putty.h"
/*
* TTYOPT FUNCTION BITS (36-bit bitmasks)
*/
#define TOALT 0200000000000LL // Characters 0175 and 0176 are converted to altmode (0033) on input
#define TOCLC 0100000000000LL // (user option bit) Convert lower-case input to upper-case
#define TOERS 0040000000000LL // Selective erase is supported
#define TOMVB 0010000000000LL // Backspacing is supported
#define TOSAI 0004000000000LL // Stanford/ITS extended ASCII graphics character set is supported
#define TOSA1 0002000000000LL // (user option bit) Characters 0001-0037 displayed using Stanford/ITS chars
#define TOOVR 0001000000000LL // Overprinting is supported
#define TOMVU 0000400000000LL // Moving cursor upwards is supported
#define TOMOR 0000200000000LL // (user option bit) System should provide **MORE** processing
#define TOROL 0000100000000LL // (user option bit) Terminal should scroll instead of wrapping
#define TOLWR 0000020000000LL // Lowercase characters are supported
#define TOFCI 0000010000000LL // Terminal can generate CONTROL and META characters
#define TOLID 0000002000000LL // Line insert/delete operations supported
#define TOCID 0000001000000LL // Character insert/delete operations supported
#define TPCBS 0000000000040LL // Terminal is using the "intelligent terminal protocol" (must be on)
#define TPORS 0000000000010LL // Server should process output resets
// Initialization words (36-bit constants)
#define WORDS 0777773000000 // Negative number of config words to send (6) in high 18 bits
#define TCTYP 0000000000007 // Defines the terminal type (MUST be 7)
#define TTYROL 0000000000001 // Scroll amount for terminal (1 line at a time)
// %TD opcodes
//
#define TDMOV 0200 // Cursor positioning
#define TDMV1 0201 // Internal cursor positioning
#define TDEOF 0202 // Erase to end of screen
#define TDEOL 0203 // Erase to end of line
#define TDDLF 0204 // Clear the character the cursor is on
#define TDCRL 0207 // Carriage return
#define TDNOP 0210 // No-op; should be ignored.
#define TDBS 0211 // Backspace (not in official SUPDUP spec)
#define TDLF 0212 // Linefeed (not in official SUPDUP spec)
#define TDCR 0213 // Carriage Return (ditto)
#define TDORS 0214 // Output reset
#define TDQOT 0215 // Quotes the following character
#define TDFS 0216 // Non-destructive forward space
#define TDMV0 0217 // General cursor positioning code
#define TDCLR 0220 // Erase the screen, home cursor
#define TDBEL 0221 // Generate an audio tone, bell, whatever
#define TDILP 0223 // Insert blank lines at the cursor
#define TDDLP 0224 // Delete lines at the cursor
#define TDICP 0225 // Insert blanks at cursor
#define TDDCP 0226 // Delete characters at cursor
#define TDBOW 0227 // Display black chars on white screen
#define TDRST 0230 // Reset %TDBOW
/* Maximum number of octets following a %TD code. */
#define TD_ARGS_MAX 4
typedef struct supdup_tag Supdup;
struct supdup_tag
{
Socket *s;
bool socket_connected;
bool closed_on_socket_error;
Seat *seat;
LogContext *logctx;
Ldisc *ldisc;
int term_width, term_height;
char *description;
long long ttyopt;
long tcmxv;
long tcmxh;
bool sent_location;
Conf *conf;
int bufsize;
enum {
CONNECTING, // waiting for %TDNOP from server after sending connection params
CONNECTED // %TDNOP received, connected.
} state;
enum {
TD_TOPLEVEL,
TD_ARGS,
TD_ARGSDONE
} tdstate;
int td_code;
int td_argcount;
char td_args[TD_ARGS_MAX];
int td_argindex;
void (*print) (strbuf *outbuf, int c);
Pinger *pinger;
Plug plug;
Backend backend;
Interactor interactor;
};
#define SUPDUP_MAX_BACKLOG 4096
static void c_write(Supdup *supdup, unsigned char *buf, int len)
{
size_t backlog = seat_stdout(supdup->seat, buf, len);
sk_set_frozen(supdup->s, backlog > SUPDUP_MAX_BACKLOG);
}
static void supdup_send_location(Supdup *supdup)
{
char locHeader[] = { 0300, 0302 };
char* locString = conf_get_str(supdup->conf, CONF_supdup_location);
sk_write(supdup->s, locHeader, sizeof(locHeader));
sk_write(supdup->s, locString, strlen(locString) + 1); // include NULL terminator
}
static void print_ascii(strbuf *outbuf, int c)
{
/* In ASCII mode, ignore control characters. The server shouldn't
send them. */
if (c >= 040 && c < 0177)
put_byte (outbuf, c);
}
static void print_its(strbuf *outbuf, int c)
{
/* The ITS character set is documented in RFC 734. */
static const char *map[] = {
"\xc2\xb7", "\342\206\223", "\316\261", "\316\262",
"\342\210\247", "\302\254", "\316\265", "\317\200",
"\316\273", "\xce\xb3", "\xce\xb4", "\xe2\x86\x91",
"\xc2\xb1", "\xe2\x8a\x95", "\342\210\236", "\342\210\202",
"\342\212\202", "\342\212\203", "\342\210\251", "\342\210\252",
"\342\210\200", "\342\210\203", "\xe2\x8a\x97", "\342\206\224",
"\xe2\x86\x90", "\342\206\222", "\xe2\x89\xa0", "\xe2\x97\x8a",
"\342\211\244", "\342\211\245", "\342\211\241", "\342\210\250",
" ", "!", "\"", "#", "$", "%", "&", "'",
"(", ")", "*", "+", ",", "-", ".", "/",
"0", "1", "2", "3", "4", "5", "6", "7",
"8", "9", ":", ";", "<", "=", ">", "?",
"@", "A", "B", "C", "D", "E", "F", "G",
"H", "I", "J", "K", "L", "M", "N", "O",
"P", "Q", "R", "S", "T", "U", "V", "W",
"X", "Y", "Z", "[", "\\", "]", "^", "_",
"`", "a", "b", "c", "d", "e", "f", "g",
"h", "i", "j", "k", "l", "m", "n", "o",
"p", "q", "r", "s", "t", "u", "v", "w",
"x", "y", "z", "{", "|", "}", "~", "\xe2\x88\xab"
};
put_data (outbuf, map[c], strlen(map[c]));
}
static void print_waits(strbuf *outbuf, int c)
{
/* The WAITS character set used at the Stanford AI Lab is documented
here: https://www.saildart.org/allow/sail-charset-utf8.html */
static const char *map[] = {
"", "\342\206\223", "\316\261", "\316\262",
"\342\210\247", "\302\254", "\316\265", "\317\200",
"\316\273", "", "", "",
"", "", "\342\210\236", "\342\210\202",
"\342\212\202", "\342\212\203", "\342\210\251", "\342\210\252",
"\342\210\200", "\342\210\203", "\xe2\x8a\x97", "\342\206\224",
"_", "\342\206\222", "~", "\xe2\x89\xa0",
"\342\211\244", "\342\211\245", "\342\211\241", "\342\210\250",
" ", "!", "\"", "#", "$", "%", "&", "'",
"(", ")", "*", "+", ",", "-", ".", "/",
"0", "1", "2", "3", "4", "5", "6", "7",
"8", "9", ":", ";", "<", "=", ">", "?",
"@", "A", "B", "C", "D", "E", "F", "G",
"H", "I", "J", "K", "L", "M", "N", "O",
"P", "Q", "R", "S", "T", "U", "V", "W",
"X", "Y", "Z", "[", "\\", "]", "\xe2\x86\x91", "\xe2\x86\x90",
"`", "a", "b", "c", "d", "e", "f", "g",
"h", "i", "j", "k", "l", "m", "n", "o",
"p", "q", "r", "s", "t", "u", "v", "w",
"x", "y", "z", "{", "|", "\xe2\x97\x8a", "}", ""
};
put_data (outbuf, map[c], strlen(map[c]));
}
static void do_toplevel(Supdup *supdup, strbuf *outbuf, int c)
{
// Toplevel: Waiting for a %TD code or a printable character
if (c >= 0200) {
// Handle SUPDUP %TD codes (codes greater than or equal to 200)
supdup->td_argindex = 0;
supdup->td_code = c;
switch (c) {
case TDMOV:
// %TD codes using 4 arguments
supdup->td_argcount = 4;
supdup->tdstate = TD_ARGS;
break;
case TDMV0:
case TDMV1:
// %TD codes using 2 arguments
supdup->td_argcount = 2;
supdup->tdstate = TD_ARGS;
break;
case TDQOT:
case TDILP:
case TDDLP:
case TDICP:
case TDDCP:
// %TD codes using 1 argument
supdup->td_argcount = 1;
supdup->tdstate = TD_ARGS;
break;
case TDEOF:
case TDEOL:
case TDDLF:
case TDCRL:
case TDNOP:
case TDORS:
case TDFS:
case TDCLR:
case TDBEL:
case TDBOW:
case TDRST:
case TDBS:
case TDCR:
case TDLF:
// %TD codes using 0 arguments
supdup->td_argcount = 0;
supdup->tdstate = TD_ARGSDONE;
break;
default:
// Unhandled, ignore
break;
}
} else {
supdup->print(outbuf, c);
}
}
static void do_args(Supdup *supdup, strbuf *outbuf, int c)
{
// Collect up args for %TD code
if (supdup->td_argindex < TD_ARGS_MAX) {
supdup->td_args[supdup->td_argindex] = c;
supdup->td_argindex++;
if (supdup->td_argcount == supdup->td_argindex) {
// No more args, %TD code is ready to go.
supdup->tdstate = TD_ARGSDONE;
}
} else {
// Should never hit this state, if we do we will just
// return to TOPLEVEL.
supdup->tdstate = TD_TOPLEVEL;
}
}
static void do_argsdone(Supdup *supdup, strbuf *outbuf, int c)
{
char buf[4];
int x, y;
// Arguments for %TD code have been collected; dispatch based
// on the %TD code we're handling.
switch (supdup->td_code) {
case TDMOV:
/*
General cursor position code. Followed by four bytes;
the first two are the "old" vertical and horizontal
positions and may be ignored. The next two are the new
vertical and horizontal positions. The cursor should be
moved to this position.
*/
// We only care about the new position.
put_fmt(outbuf, "\033[%d;%dH", supdup->td_args[2]+1, supdup->td_args[3]+1);
break;
case TDMV0:
case TDMV1:
/*
General cursor position code. Followed by two bytes;
the new vertical and horizontal positions.
*/
put_fmt(outbuf, "\033[%d;%dH", supdup->td_args[0]+1, supdup->td_args[1]+1);
break;
case TDEOF:
/*
Erase to end of screen. This is an optional function
since many terminals do not support this. If the
terminal does not support this function, it should be
treated the same as %TDEOL.
%TDEOF does an erase to end of line, then erases all
lines lower on the screen than the cursor. The cursor
does not move.
*/
put_fmt(outbuf, "\033[J");
break;
case TDEOL:
/*
Erase to end of line. This erases the character
position the cursor is at and all positions to the right
on the same line. The cursor does not move.
*/
put_fmt(outbuf, "\033[K");
break;
case TDDLF:
/*
Clear the character position the cursor is on. The
cursor does not move.
*/
put_fmt(outbuf, "\033[X");
break;
case TDCRL:
/*
If the cursor is not on the bottom line of the screen,
move cursor to the beginning of the next line and clear
that line. If the cursor is at the bottom line, scroll
up.
*/
put_fmt(outbuf, "\015\012\033[K");
break;
case TDNOP:
/*
No-op; should be ignored.
*/
break;
case TDORS:
/*
Output reset. This code serves as a data mark for
aborting output much as IAC DM does in the ordinary
TELNET protocol.
*/
outbuf->len = 0;
if (!seat_get_cursor_position(supdup->seat, &x, &y))
x = y = 0;
buf[0] = 034;
buf[1] = 020;
buf[2] = y;
buf[3] = x;
sk_write(supdup->s, buf, 4);
break;
case TDQOT:
/*
Quotes the following character. This is used when
sending 8-bit codes which are not %TD codes, for
instance when loading programs into an intelligent
terminal. The following character should be passed
through intact to the terminal.
*/
put_byte(outbuf, supdup->td_args[0]);
break;
case TDFS:
/*
Non-destructive forward space. The cursor moves right
one position; this code will not be sent at the end of a
line.
*/
put_fmt(outbuf, "\033[C");
break;
case TDCLR:
/*
Erase the screen. Home the cursor to the top left hand
corner of the screen.
*/
put_fmt(outbuf, "\033[2J\033[H");
break;
case TDBEL:
/*
Generate an audio tone, bell, whatever.
*/
put_fmt(outbuf, "\007");
break;
case TDILP:
/*
Insert blank lines at the cursor; followed by a byte
containing a count of the number of blank lines to
insert. The cursor is unmoved. The line the cursor is
on and all lines below it move down; lines moved off the
bottom of the screen are lost.
*/
put_fmt(outbuf, "\033[%dL", supdup->td_args[0]);
break;
case TDDLP:
/*
Delete lines at the cursor; followed by a count. The
cursor is unmoved. The first line deleted is the one
the cursor is on. Lines below those deleted move up.
Newly- created lines at the bottom of the screen are
blank.
*/
put_fmt(outbuf, "\033[%dM", supdup->td_args[0]);
break;
case TDICP:
/*
Insert blank character positions at the cursor; followed
by a count. The cursor is unmoved. The character the
cursor is on and all characters to the right on the
current line move to the right; characters moved off the
end of the line are lost.
*/
put_fmt(outbuf, "\033[%d@", supdup->td_args[0]);
break;
case TDDCP:
/*
Delete characters at the cursor; followed by a count.
The cursor is unmoved. The first character deleted is
the one the cursor is on. Newly-created characters at
the end of the line are blank.
*/
put_fmt(outbuf, "\033[%dP", supdup->td_args[0]);
break;
case TDBOW:
case TDRST:
/*
Display black characters on white screen.
HIGHLY OPTIONAL.
*/
// Since this is HIGHLY OPTIONAL, I'm not going
// to implement it yet.
break;
/*
* Non-standard (whatever "standard" means here) SUPDUP
* commands. These are used (at the very least) by
* Genera's SUPDUP implementation. Cannot find any
* official documentation, behavior is based on UNIX
* SUPDUP implementation from MIT.
*/
case TDBS:
/*
* Backspace -- move cursor back one character (does not
* appear to wrap...)
*/
put_byte(outbuf, '\010');
break;
case TDLF:
/*
* Linefeed -- move cursor down one line (again, no wrapping)
*/
put_byte(outbuf, '\012');
break;
case TDCR:
/*
* Carriage return -- move cursor to start of current line.
*/
put_byte(outbuf, '\015');
break;
}
// Return to top level to pick up the next %TD code or
// printable character.
supdup->tdstate = TD_TOPLEVEL;
}
static void term_out_supdup(Supdup *supdup, strbuf *outbuf, int c)
{
if (supdup->tdstate == TD_TOPLEVEL) {
do_toplevel (supdup, outbuf, c);
} else if (supdup->tdstate == TD_ARGS) {
do_args (supdup, outbuf, c);
}
// If all arguments for a %TD code are ready, we will execute the code now.
if (supdup->tdstate == TD_ARGSDONE) {
do_argsdone (supdup, outbuf, c);
}
}
static void do_supdup_read(Supdup *supdup, const char *buf, size_t len)
{
strbuf *outbuf = strbuf_new();
while (len--) {
int c = (unsigned char)*buf++;
switch (supdup->state) {
case CONNECTING:
// "Following the transmission of the terminal options by
// the user, the server should respond with an ASCII
// greeting message, terminated with a %TDNOP code..."
if (TDNOP == c) {
// Greeting done, switch to the CONNECTED state.
supdup->state = CONNECTED;
supdup->tdstate = TD_TOPLEVEL;
} else {
// Forward the greeting message (which is straight
// ASCII, no controls) on so it gets displayed TODO:
// filter out only printable chars?
put_byte(outbuf, c);
}
break;
case CONNECTED:
// "All transmissions from the server after the %TDNOP
// [see above] are either printing characters or virtual
// terminal display codes." Forward these on to the
// frontend which will decide what to do with them.
term_out_supdup(supdup, outbuf, c);
/*
* Hack to make Symbolics Genera SUPDUP happy: Wait until
* after we're connected (finished the initial handshake
* and have gotten additional data) before sending the
* location string. For some reason doing so earlier
* causes the Symbolics SUPDUP to end up in an odd state.
*/
if (!supdup->sent_location) {
supdup_send_location(supdup);
supdup->sent_location = true;
}
break;
}
if (outbuf->len >= 4096) {
c_write(supdup, outbuf->u, outbuf->len);
outbuf->len = 0;
}
}
if (outbuf->len)
c_write(supdup, outbuf->u, outbuf->len);
strbuf_free(outbuf);
}
static void supdup_log(Plug *plug, Socket *s, PlugLogType type, SockAddr *addr,
int port, const char *error_msg, int error_code)
{
Supdup *supdup = container_of(plug, Supdup, plug);
backend_socket_log(supdup->seat, supdup->logctx, s, type, addr, port,
error_msg, error_code,
supdup->conf, supdup->socket_connected);
if (type == PLUGLOG_CONNECT_SUCCESS) {
supdup->socket_connected = true;
if (supdup->ldisc)
ldisc_check_sendok(supdup->ldisc);
}
}
static void supdup_closing(Plug *plug, PlugCloseType type,
const char *error_msg)
{
Supdup *supdup = container_of(plug, Supdup, plug);
/*
* We don't implement independent EOF in each direction for Telnet
* connections; as soon as we get word that the remote side has
* sent us EOF, we wind up the whole connection.
*/
if (supdup->s) {
sk_close(supdup->s);
supdup->s = NULL;
if (error_msg)
supdup->closed_on_socket_error = true;
seat_notify_remote_exit(supdup->seat);
seat_notify_remote_disconnect(supdup->seat);
}
if (type != PLUGCLOSE_NORMAL) {
logevent(supdup->logctx, error_msg);
if (type != PLUGCLOSE_USER_ABORT)
seat_connection_fatal(supdup->seat, "%s", error_msg);
}
/* Otherwise, the remote side closed the connection normally. */
}
static void supdup_receive(Plug *plug, int urgent, const char *data, size_t len)
{
Supdup *supdup = container_of(plug, Supdup, plug);
do_supdup_read(supdup, data, len);
}
static void supdup_sent(Plug *plug, size_t bufsize)
{
Supdup *supdup = container_of(plug, Supdup, plug);
supdup->bufsize = bufsize;
seat_sent(supdup->seat, supdup->bufsize);
}
static void supdup_send_36bits(Supdup *supdup, unsigned long long thirtysix)
{
//
// From RFC734:
// "Each word is sent through the 8-bit connection as six
// 6-bit bytes, most-significant first."
//
// Split the 36-bit word into 6 6-bit "bytes", packed into
// 8-bit bytes and send, most-significant byte first.
//
for (int i = 5; i >= 0; i--) {
char sixBits = (thirtysix >> (i * 6)) & 077;
sk_write(supdup->s, &sixBits, 1);
}
}
static void supdup_send_config(Supdup *supdup)
{
supdup_send_36bits(supdup, WORDS); // negative length
supdup_send_36bits(supdup, TCTYP); // terminal type
supdup_send_36bits(supdup, supdup->ttyopt); // options
supdup_send_36bits(supdup, supdup->tcmxv); // height
supdup_send_36bits(supdup, supdup->tcmxh); // width
supdup_send_36bits(supdup, TTYROL); // scroll amount
}
static char *supdup_description(Interactor *itr)
{
Supdup *supdup = container_of(itr, Supdup, interactor);
return dupstr(supdup->description);
}
static LogPolicy *supdup_logpolicy(Interactor *itr)
{
Supdup *supdup = container_of(itr, Supdup, interactor);
return log_get_policy(supdup->logctx);
}
static Seat *supdup_get_seat(Interactor *itr)
{
Supdup *supdup = container_of(itr, Supdup, interactor);
return supdup->seat;
}
static void supdup_set_seat(Interactor *itr, Seat *seat)
{
Supdup *supdup = container_of(itr, Supdup, interactor);
supdup->seat = seat;
}
static const InteractorVtable Supdup_interactorvt = {
.description = supdup_description,
.logpolicy = supdup_logpolicy,
.get_seat = supdup_get_seat,
.set_seat = supdup_set_seat,
};
/*
* Called to set up the Supdup connection.
*
* Returns an error message, or NULL on success.
*
* Also places the canonical host name into `realhost'. It must be
* freed by the caller.
*/
static char *supdup_init(const BackendVtable *x, Seat *seat,
Backend **backend_handle,
LogContext *logctx, Conf *conf,
const char *host, int port, char **realhost,
bool nodelay, bool keepalive)
{
static const PlugVtable fn_table = {
.log = supdup_log,
.closing = supdup_closing,
.receive = supdup_receive,
.sent = supdup_sent,
};
SockAddr *addr;
const char *err;
Supdup *supdup;
char *loghost;
int addressfamily;
const char *utf8 = "\033%G";
supdup = snew(struct supdup_tag);
memset(supdup, 0, sizeof(Supdup));
supdup->plug.vt = &fn_table;
supdup->backend.vt = &supdup_backend;
supdup->interactor.vt = &Supdup_interactorvt;
supdup->backend.interactor = &supdup->interactor;
supdup->logctx = logctx;
supdup->conf = conf_copy(conf);
supdup->s = NULL;
supdup->socket_connected = false;
supdup->closed_on_socket_error = false;
supdup->seat = seat;
supdup->term_width = conf_get_int(supdup->conf, CONF_width);
supdup->term_height = conf_get_int(supdup->conf, CONF_height);
supdup->pinger = NULL;
supdup->sent_location = false;
supdup->description = default_description(supdup->backend.vt, host, port);
*backend_handle = &supdup->backend;
switch (conf_get_int(supdup->conf, CONF_supdup_ascii_set)) {
case SUPDUP_CHARSET_ASCII:
supdup->print = print_ascii;
break;
case SUPDUP_CHARSET_ITS:
supdup->print = print_its;
break;
case SUPDUP_CHARSET_WAITS:
supdup->print = print_waits;
break;
}
/*
* Try to find host.
*/
{
char *buf;
addressfamily = conf_get_int(supdup->conf, CONF_addressfamily);
buf = dupprintf("Looking up host \"%s\"%s", host,
(addressfamily == ADDRTYPE_IPV4 ? " (IPv4)" :
(addressfamily == ADDRTYPE_IPV6 ? " (IPv6)" :
"")));
logevent(supdup->logctx, buf);
sfree(buf);
}
addr = name_lookup(host, port, realhost, supdup->conf, addressfamily, NULL, "");
if ((err = sk_addr_error(addr)) != NULL) {
sk_addr_free(addr);
return dupstr(err);
}
if (port < 0)
port = 0137; /* default supdup port */
/*
* Open socket.
*/
supdup->s = new_connection(addr, *realhost, port, false, true,
nodelay, keepalive, &supdup->plug, supdup->conf,
&supdup->interactor);
if ((err = sk_socket_error(supdup->s)) != NULL)
return dupstr(err);
supdup->pinger = pinger_new(supdup->conf, &supdup->backend);
/*
* We can send special commands from the start.
*/
seat_update_specials_menu(supdup->seat);
/*
* loghost overrides realhost, if specified.
*/
loghost = conf_get_str(supdup->conf, CONF_loghost);
if (*loghost) {
char *colon;
sfree(*realhost);
*realhost = dupstr(loghost);
colon = host_strrchr(*realhost, ':');
if (colon)
*colon++ = '\0';
}
/*
* Set up TTYOPTS based on config
*/
int ascii_set = conf_get_int(supdup->conf, CONF_supdup_ascii_set);
int more_processing = conf_get_bool(supdup->conf, CONF_supdup_more);
int scrolling = conf_get_bool(supdup->conf, CONF_supdup_scroll);
supdup->ttyopt =
TOERS |
TOMVB |
(ascii_set == SUPDUP_CHARSET_ASCII ? 0 : TOSAI | TOSA1) |
TOMVU |
TOLWR |
TOLID |
TOCID |
TPCBS |
(scrolling ? TOROL : 0) |
(more_processing ? TOMOR : 0) |
TPORS;
supdup->tcmxh = supdup->term_width - 1; // -1 "..one column is used to indicate line continuation."
supdup->tcmxv = supdup->term_height;
/*
* Send our configuration words to the server
*/
supdup_send_config(supdup);
/*
* We next expect a connection message followed by %TDNOP from the server
*/
supdup->state = CONNECTING;
seat_set_trust_status(supdup->seat, false);
/* Make sure the terminal is in UTF-8 mode. */
c_write(supdup, (unsigned char *)utf8, strlen(utf8));
return NULL;
}
static void supdup_free(Backend *be)
{
Supdup *supdup = container_of(be, Supdup, backend);
if (is_tempseat(supdup->seat))
tempseat_free(supdup->seat);
if (supdup->s)
sk_close(supdup->s);
if (supdup->pinger)
pinger_free(supdup->pinger);
conf_free(supdup->conf);
sfree(supdup->description);
sfree(supdup);
}
/*
* Reconfigure the Supdup backend.
*/
static void supdup_reconfig(Backend *be, Conf *conf)
{
/* Nothing to do; SUPDUP cannot be reconfigured while running. */
}
/*
* Called to send data down the Supdup connection.
*/
static void supdup_send(Backend *be, const char *buf, size_t len)
{
Supdup *supdup = container_of(be, Supdup, backend);
char c;
int i;
if (supdup->s == NULL)
return;
for (i = 0; i < len; i++) {
if (buf[i] == 034)
supdup->bufsize = sk_write(supdup->s, "\034\034", 2);
else {
c = buf[i] & 0177;
supdup->bufsize = sk_write(supdup->s, &c, 1);
}
}
}
/*
* Called to query the current socket sendability status.
*/
static size_t supdup_sendbuffer(Backend *be)
{
Supdup *supdup = container_of(be, Supdup, backend);
return supdup->bufsize;
}
/*
* Called to set the size of the window from Supdup's POV.
*/
static void supdup_size(Backend *be, int width, int height)
{
Supdup *supdup = container_of(be, Supdup, backend);
supdup->term_width = width;
supdup->term_height = height;
//
// SUPDUP does not support resizing the terminal after connection
// establishment.
//
}
/*
* Send Telnet special codes.
*/
static void supdup_special(Backend *be, SessionSpecialCode code, int arg)
{
}
static const SessionSpecial *supdup_get_specials(Backend *be)
{
return NULL;
}
static bool supdup_connected(Backend *be)
{
Supdup *supdup = container_of(be, Supdup, backend);
return supdup->s != NULL;
}
static bool supdup_sendok(Backend *be)
{
Supdup *supdup = container_of(be, Supdup, backend);
return supdup->socket_connected;
}
static void supdup_unthrottle(Backend *be, size_t backlog)
{
Supdup *supdup = container_of(be, Supdup, backend);
sk_set_frozen(supdup->s, backlog > SUPDUP_MAX_BACKLOG);
}
static bool supdup_ldisc(Backend *be, int option)
{
/* No support for echoing or local editing. */
return false;
}
static void supdup_provide_ldisc(Backend *be, Ldisc *ldisc)
{
Supdup *supdup = container_of(be, Supdup, backend);
supdup->ldisc = ldisc;
}
static int supdup_exitcode(Backend *be)
{
Supdup *supdup = container_of(be, Supdup, backend);
if (supdup->s != NULL)
return -1; /* still connected */
else if (supdup->closed_on_socket_error)
return INT_MAX; /* a socket error counts as an unclean exit */
else
/* Supdup doesn't transmit exit codes back to the client */
return 0;
}
/*
* cfg_info for Supdup does nothing at all.
*/
static int supdup_cfg_info(Backend *be)
{
return 0;
}
const BackendVtable supdup_backend = {
.init = supdup_init,
.free = supdup_free,
.reconfig = supdup_reconfig,
.send = supdup_send,
.sendbuffer = supdup_sendbuffer,
.size = supdup_size,
.special = supdup_special,
.get_specials = supdup_get_specials,
.connected = supdup_connected,
.exitcode = supdup_exitcode,
.sendok = supdup_sendok,
.ldisc_option_state = supdup_ldisc,
.provide_ldisc = supdup_provide_ldisc,
.unthrottle = supdup_unthrottle,
.cfg_info = supdup_cfg_info,
.id = "supdup",
.displayname_tc = "SUPDUP",
.displayname_lc = "SUPDUP", /* proper name, so capitalise it anyway */
.protocol = PROT_SUPDUP,
.default_port = 0137,
.flags = BACKEND_RESIZE_FORBIDDEN | BACKEND_NEEDS_TERMINAL,
};