This is exp_inter.c in view mode; [Download] [Up]
/* interact (using select) - give user keyboard control
Written by: Don Libes, NIST, 2/6/90
Design and implementation of this program was paid for by U.S. tax
dollars. Therefore it is public domain. However, the author and NIST
would appreciate credit if this program or parts of it are used.
$Revision: 1.2 $
$Date: 1993/03/03 00:21:20 $
*/
#include "exp_conf.h"
#include <stdio.h>
#include <sys/types.h>
/*#include <sys/time.h> seems to not be present on SVR3 systems */
/* and it's not used anyway as far as I can tell */
#include <ctype.h>
#include "tcl.h"
#include "string.h"
#include "exp_tty.h"
#include "exp_rename.h"
#include "exp_global.h"
#include "exp_command.h"
#include "exp_log.h"
#include "regexp.h"
#include "exp_regexp.h"
extern int errno;
extern int fd_max;
#define new(x) (x *)ckalloc(sizeof(x))
struct action {
char *statement;
#ifdef OLD_FAST
int fast; /* if true, skip tty mode changing */
#else
int tty_reset;
#endif
int iread; /* if true, reread indirects */
int iwrite; /* if true, write spawn_id element */
int timestamp; /* if true, generate timestamp */
struct action *next; /* chain only for later for freeing */
};
struct keymap {
char *keys; /* original pattern provided by user */
regexp *re;
int case_sensitive;
int echo; /* if keystrokes should be echoed */
int writethru; /* if keystrokes should go through to process */
struct action action;
struct keymap *next;
};
struct output {
struct exp_i *i_list;
#if 0
int spawn_id;
struct f *f;
#endif
struct action *action_eof;
struct output *next;
};
struct input {
#if 0
int spawn_id;
struct f *f;
#endif
struct exp_i *i_list;
struct output *output;
struct action *action_eof;
struct action *action_timeout;
struct keymap *keymap;
int timeout_nominal; /* timeout nominal */
int timeout_remaining; /* timeout remaining */
struct input *next;
};
#if 0
/* record any use of implicit spawn_id here in the event that it */
/* needs updating */
struct update {
int *spawn_id;
struct update *next;
};
#endif
static void free_input();
static void free_keymap();
static void free_output();
static void free_action();
#if 0
static void free_update();
#endif
static struct action *new_action();
#if 0
static struct update *new_update();
#endif
static int inter_eval();
/* special pattern that signifies the expect interpreter itself */
#define INTERPRETER_ACTION "interpreter"
/* NB: FOLLOWING DESCRIPTION HAS NOT BEEN REVISED SINCE ADDITION OF REGEXP */
/* This function accepts user keystrokes and returns one of the above values */
/* describing whether the keystrokes match a key sequence, and could or */
/* can't if more characters arrive */
/* The function assigns a matching keymap if there is a match or can-match */
/* The basic idea of how this works is it does a smart sequential search. */
/* It is optimized (if you can call it that) towards a small number of */
/* key mappings, but still works well for large maps, since no function */
/* calls are made, and we stop as soon as there is a single-char mismatch, */
/* and go on to the next one. A hash table or compiled DFA probably would */
/* not buy very much here for most maps. */
static
int
in_keymap(string,stringlen,keymap,km_match,match_length,skip)
char *string;
int stringlen;
struct keymap *keymap; /* linked list of keymaps */
struct keymap **km_match; /* keymap that matches or can match */
int *match_length; /* # of chars that matched */
int *skip; /* # of chars to skip */
{
struct keymap *km;
char *ks; /* string from a keymap */
char *start_search; /* where in the string to start searching */
char *string_end;
/* assert (*km == 0) */
/* a shortcut that should help master output which typically */
/* is lengthy and has no key maps. Otherwise it would mindlessly */
/* iterate on each character anyway. */
if (!keymap) {
*skip = stringlen;
return(EXP_CANTMATCH);
}
string_end = string + stringlen;
/* Mark beginning of line for ^ . */
regbol = string;
/* skip over nulls - Pascal Meheut, pascal@cnam.cnam.fr 18-May-1993 */
/* for (start_search = string;*start_search;start_search++) {*/
for (start_search = string;start_search<string_end;start_search++) {
if (*km_match) break; /* if we've already found a CAN_MATCH */
/* don't bother starting search from positions */
/* further along the string */
for (km=keymap;km;km=km->next) {
char *s; /* current character being examined */
if (!km->re) {
/* fixed string */
for (s = start_search,ks = km->keys ;;s++,ks++) {
/* if we hit the end of this map, must've matched! */
if (*ks == 0) {
*skip = start_search-string;
*match_length = s-start_search;
*km_match = km;
return(EXP_MATCH);
}
/* if we ran out of user-supplied characters, and */
/* still haven't matched, it might match if the user */
/* supplies more characters next time */
if (s == string_end) {
/* skip to next key entry, but remember */
/* possibility that this entry might match */
if (!*km_match) *km_match = km;
break;
}
/* skip to next key entry, if characters don't match */
if ((*s & 0x7f) != *ks) break;
}
} else {
/* regexp */
int r; /* regtry status */
regexp *prog = km->re;
/* if anchored, but we're not at beginning, skip pattern */
if (prog->reganch) {
if (string != start_search) continue;
}
/* known starting char - quick test 'fore lotta work */
if (prog->regstart) {
if ((*start_search & 0x7f) != prog->regstart) continue;
}
r = regtry(prog,start_search,match_length);
if (r == EXP_MATCH) {
*km_match = km;
*skip = start_search-string;
return(EXP_MATCH);
}
if (r == EXP_CANMATCH) {
if (!*km_match) *km_match = km;
}
}
}
}
if (*km_match) {
/* report a can-match */
*skip = (start_search-string)-1;
*match_length = stringlen - *skip;
return(EXP_CANMATCH);
}
*skip = start_search-string;
return(EXP_CANTMATCH);
}
#ifdef SIMPLE_EVENT
#ifndef WEXITSTATUS
#define WEXITSTATUS(stat) (((*((int *) &(stat))) >> 8) & 0xff)
#endif
#include <setjmp.h>
#include "exp_main.h" /* need exp_exit */
static jmp_buf env; /* for interruptable read() */
static int reading; /* while we are reading */
/* really, while "env" is valid */
static int deferred_interrupt = FALSE; /* if signal is received, but not */
/* in i_read record this here, so it will */
/* be handled next time through i_read */
void sigchld_handler()
{
if (reading) longjmp(env,1);
deferred_interrupt = TRUE;
}
#define EXP_CHILD_EOF -100
/* interruptable read */
static int
i_read(fd,buffer,length)
int fd;
char *buffer;
int length;
{
int cc = EXP_CHILD_EOF;
if (deferred_interrupt) return(cc);
if (0 == setjmp(env)) {
reading = TRUE;
cc = read(fd,buffer,length);
}
reading = FALSE;
return(cc);
}
/* exit status for the child process created by cmdInteract */
#define CHILD_DIED -2
#define SPAWNED_PROCESS_DIED -3
static void
clean_up_after_child(interp,master)
Tcl_Interp *interp;
int master;
{
/* should really be recoded using the common wait code in command.c */
int status;
int pid;
int i;
pid = wait(&status); /* for slave */
for (i=0;i<=fd_max;i++) {
if (fs[i].pid == pid) {
fs[i].sys_waited = TRUE;
fs[i].wait = status;
}
}
pid = wait(&status); /* for child */
for (i=0;i<=fd_max;i++) {
if (fs[i].pid == pid) {
fs[i].sys_waited = TRUE;
fs[i].wait = status;
}
}
deferred_interrupt = FALSE;
exp_close(interp,master);
master = -1;
}
#endif /*SIMPLE_EVENT*/
#define finish(x) { status = x; goto done; }
static char return_cmd[] = "return";
/*ARGSUSED*/
int
cmdInteract(clientData, interp, argc, argv)
ClientData clientData;
Tcl_Interp *interp;
int argc;
char **argv;
{
#ifdef SIMPLE_EVENT
int pid;
#endif /*SIMPLE_EVENT*/
/*declarations*/
int input_count; /* count of struct input descriptors */
struct input **fd_to_input; /* map from fd's to "struct input"s */
int *fd_list;
struct keymap *km; /* ptr for above while parsing */
extern char *tclRegexpError; /* declared in tclInt.h */
int master = EXP_SPAWN_ID_BAD;
int spawn_id_referenced = FALSE; /* if spawn_id is implicitly */
/* referenced */
#ifdef OLD_FAST
int all_fast = FALSE; /* by default, turn off -f */
int next_fast = FALSE; /* if we've seen a single -f */
#else
int next_tty_reset = FALSE;
#endif
int next_iread = FALSE;/* if we've seen a single -iread */
int next_iwrite = FALSE;/* if we've seen a single -iread */
int next_re = FALSE; /* if we've seen a single -re */
int next_writethru = FALSE;/*if macros should also go to proc output */
int next_echo = FALSE; /* if macros should be echoed */
int next_direct = TRUE; /* if next -i is direct */
int next_timestamp = FALSE; /* if we should generate a timestamp */
/* int next_case_sensitive = TRUE;*/
char **oldargv = 0; /* save original argv here if we split it */
int status = TCL_OK; /* final return value */
int i; /* trusty temp */
int timeout_simple = TRUE; /* if no or global timeout */
int real_tty; /* TRUE if we are interacting with real tty */
int tty_changed = FALSE;/* true if we had to change tty modes for */
/* interact to work (i.e., to raw, noecho) */
int was_raw;
int was_echo;
exp_tty tty_old;
int replace_user_by_process = EXP_SPAWN_ID_BAD; /* for -u flag */
int close_count; /* monitor exp_close_count */
struct input *input_base;
#define input_user input_base
struct input *input_default;
struct input *inp; /* overused ptr to struct input */
struct output *outp; /* overused ptr to struct output */
int dash_input_count = 0; /* # of "-input"s seen */
int dash_output_count = 0; /* # of "-output"s seen */
int arbitrary_timeout;
int default_timeout;
struct action action_timeout; /* common to all */
struct action action_eof; /* common to all */
struct action **action_eof_ptr; /* allow -input/ouput to */
/* leave their eof-action assignable by a later */
/* -eof */
struct action *action_base = 0;
#if 0
struct update *update_base = 0;
#endif
struct keymap **end_km;
int key;
if ((argc == 2) && exp_one_arg_braced(argv[1])) {
return(exp_eval_with_one_arg(clientData,interp,argc,argv));
} else if ((argc == 3) && streq(argv[1],"-brace")) {
char *new_argv[2];
new_argv[0] = argv[0];
new_argv[1] = argv[2];
return(exp_eval_with_one_arg(clientData,interp,argc,new_argv));
}
argv++;
argc--;
default_timeout = EXP_TIME_INFINITY;
arbitrary_timeout = EXP_TIME_INFINITY; /* if user specifies */
/* a bunch of timeouts with EXP_TIME_INFINITY, this will be */
/* left around for us to find. */
input_user = new(struct input);
input_user->i_list = exp_new_i_simple(interp,0); /* stdin by default */
#if 0
input_user->spawn_id = 0; /* stdin by default */
#endif
input_user->output = 0;
input_user->action_eof = &action_eof;
input_user->timeout_nominal = EXP_TIME_INFINITY;
input_user->action_timeout = 0;
input_user->keymap = 0;
end_km = &input_user->keymap;
inp = input_user;
action_eof_ptr = &input_user->action_eof;
input_default = new(struct input);
input_default->i_list = exp_new_i_simple(interp,EXP_SPAWN_ID_BAD); /* fix up later */
#if 0
input_default->spawn_id = EXP_SPAWN_ID_BAD; /* fix later */
#endif
input_default->output = 0;
input_default->action_eof = &action_eof;
input_default->timeout_nominal = EXP_TIME_INFINITY;
input_default->action_timeout = 0;
input_default->keymap = 0;
input_default->next = 0; /* no one else */
input_user->next = input_default;
#if 0
input_count = 2;
#endif
/* default and common -eof action */
action_eof.statement = return_cmd;
#ifdef OLD_FAST
action_eof.fast = TRUE;
#else
action_eof.tty_reset = FALSE;
#endif
action_eof.iread = FALSE;
action_eof.iwrite = FALSE;
action_eof.timestamp = FALSE;
for (;argc>0;argc--,argv++) {
if (streq(*argv,"--")) {
/* prevent other arguments from being matched */
argc--;argv++;
/* this is the only one of these if's that doesn't */
/* have a "continue" */
/* hmm, well, actually "-re" doesn't either */
} else if (streq(*argv,"-input")) {
dash_input_count++;
if (dash_input_count == 2) {
inp = input_default;
input_user->next = input_default;
} else if (dash_input_count > 2) {
struct input *previous_input = inp;
inp = new(struct input);
previous_input->next = inp;
#if 0
input_count++;
#endif
}
inp->output = 0;
inp->action_eof = &action_eof;
action_eof_ptr = &inp->action_eof;
inp->timeout_nominal = default_timeout;
inp->action_timeout = &action_timeout;
inp->keymap = 0;
end_km = &inp->keymap;
inp->next = 0;
argc--;argv++;
if (argc < 1) {
exp_error(interp,"-input needs argument");
return(TCL_ERROR);
}
/* inp->spawn_id = atoi(*argv);*/
inp->i_list = exp_new_i_complex(interp,/*next_direct,*/ *argv,FALSE);
if (!inp->i_list) return TCL_ERROR;
next_direct = TRUE;
continue;
} else if (streq(*argv,"-output")) {
struct output *tmp;
dash_output_count++;
/* imply a "-input" */
if (dash_input_count == 0) dash_input_count = 1;
outp = new(struct output);
/* link new output in front of others */
tmp = inp->output;
inp->output = outp;
outp->next = tmp;
argc--;argv++;
if (argc < 1) {
exp_error(interp,"-output needs argument");
return(TCL_ERROR);
}
/* accept Tcl file handles, too */
#if 0
/* the following expression looks stupid but we */
/* really have to verify that at least four chars */
/* exist before we bop on over to the 5th one so */
/* we might as well verify them while we're at it */
if ((argv[0][0] == 'f') && (argv[0][1] == 'i')
&& (argv[0][2] == 'l') && (argv[0][3] == 'e')) {
outp->spawn_id = atoi(*argv + 4);
} else outp->spawn_id = atoi(*argv);
#endif
outp->i_list = exp_new_i_complex(interp,/*next_direct,*/ *argv,FALSE);
if (!outp->i_list) return TCL_ERROR;
outp->action_eof = &action_eof;
action_eof_ptr = &outp->action_eof;
continue;
} else if (streq(*argv,"-u")) { /* treat process as user */
argc--;argv++;
if (argc < 1) {
exp_error(interp,"-u needs argument");
return(TCL_ERROR);
}
replace_user_by_process = atoi(*argv);
/* imply a "-input" */
if (dash_input_count == 0) dash_input_count = 1;
continue;
} else if (streq(*argv,"-o")) { /* apply following patterns */
/* to opposite side of */
/* interaction */
end_km = &input_default->keymap;
/* imply two "-input" */
if (dash_input_count < 2) {
dash_input_count = 2;
inp = input_default;
action_eof_ptr = &inp->action_eof;
}
continue;
} else if (streq(*argv,"-i")) { /* substitute master */
argc--;argv++;
master = atoi(*argv);
/* will be used later on */
/* imply two "-input" */
if (dash_input_count < 2) {
dash_input_count = 2;
inp = input_default;
action_eof_ptr = &inp->action_eof;
}
continue;
/* } else if (streq(*argv,"-nocase")) {*/
/* next_case_sensitive = FALSE;*/
/* continue;*/
} else if (streq(*argv,"-re")) {
if (argc < 1) {
exp_error(interp,"-re needs pattern");
return(TCL_ERROR);
}
next_re = TRUE;
argc--;
argv++;
/* go right to pattern handling from here */
} else if (streq(*argv,"-indirect")) {
next_direct = FALSE;
continue;
} else if (streq(*argv,"-echo")) {
next_echo = TRUE;
continue;
} else if (streq(*argv,"-nobuffer")) {
next_writethru = TRUE;
continue;
} else if (streq(*argv,"-f")) {
if (argc < 1) {
exp_error(interp,"-f needs pattern");
return(TCL_ERROR);
}
#if 0
next_fast = TRUE;
#endif
continue;
} else if (streq(*argv,"-F")) {
#if 0
all_fast = TRUE;
#endif
continue;
} else if (streq(*argv,"-reset")) {
next_tty_reset = TRUE;
continue;
} else if (streq(*argv,"-iread")) {
next_iread = TRUE;
continue;
} else if (streq(*argv,"-iwrite")) {
next_iwrite = TRUE;
continue;
} else if (streq(*argv,"-eof")) {
struct action *action;
argc--;argv++;
/* if -eof comes before "-input", then applies */
/* to all descriptors, else just the current one */
if (dash_input_count > 0 || dash_output_count > 0) {
*action_eof_ptr = action =
new_action(&action_base);
} else {
action = &action_eof;
}
action->statement = *argv;
#ifdef OLD_FAST
if (all_fast || next_fast) {
action->fast = TRUE;
next_fast = FALSE;
}
#else
if (next_tty_reset) {
action->tty_reset = TRUE;
next_tty_reset = FALSE;
}
#endif
if (next_iread) {
action->iread = TRUE;
next_iread = FALSE;
}
if (next_iwrite) {
action->iwrite = TRUE;
next_iwrite = FALSE;
}
if (next_timestamp) {
action->timestamp = TRUE;
next_timestamp = FALSE;
}
continue;
} else if (streq(*argv,"-timeout")) {
int t;
struct action *action;
argc--;argv++;
if (argc < 1) {
exp_error(interp,"-timeout needs time");
return(TCL_ERROR);
}
t = atoi(*argv);
argc--;argv++;
if (t != -1)
arbitrary_timeout = t;
/* we need an arbitrary timeout to start */
/* search for lowest one later */
/* if -timeout comes before "-input", then applies */
/* to all descriptors, else just the current one */
if (dash_input_count > 0) {
timeout_simple = FALSE;
action = inp->action_timeout;
inp->timeout_nominal = t;
} else {
action = &action_timeout;
default_timeout = t;
}
action->statement = *argv;
#ifdef OLD_FAST
action->fast = (all_fast || next_fast);
next_fast = FALSE;
#else
action->tty_reset = next_tty_reset;
next_tty_reset = FALSE;
#endif
action->iwrite = next_iwrite;
next_iwrite = FALSE;
action->iread = next_iread;
next_iread = FALSE;
action->timestamp = next_timestamp;
next_timestamp = FALSE;
continue;
} else if (streq(*argv,"-timestamp")) {
next_timestamp = TRUE;
continue;
}
/*
* pick up the pattern
*/
km = new(struct keymap);
/* so that we can match in order user specified */
/* link to end of keymap list */
*end_km = km;
km->next = 0;
end_km = &km->next;
km->echo = next_echo;
km->writethru = next_writethru;
#ifdef OLD_FAST
km->action.fast = (all_fast || next_fast);
#else
km->action.tty_reset = next_tty_reset;
#endif
km->action.iwrite = next_iwrite;
km->action.iread = next_iread;
km->action.timestamp = next_timestamp;
/* km->case_sensitive = next_case_sensitive;*/
next_echo = next_writethru = FALSE;
#ifdef OLD_FAST
next_fast = FALSE;
#else
next_tty_reset = FALSE;
#endif
next_iwrite = next_iread = FALSE;
/* next_case_sensitive = TRUE;*/
km->keys = *argv;
if (next_re) {
if (0 == (km->re = regcomp(*argv))) {
exp_error(interp,"bad regular expression: %s",
tclRegexpError);
return(TCL_ERROR);
}
} else {
km->re = 0;
}
argc--;argv++;
km->action.statement = *argv;
debuglog("defining key %s, action %s\r\n",
km->keys,
km->action.statement?(dprintify(km->action.statement))
:INTERPRETER_ACTION);
/* imply a "-input" */
if (dash_input_count == 0) dash_input_count = 1;
}
/* if the user has not supplied either "-output" for the */
/* default two "-input"s, fix them up here */
if (!input_user->output) {
#if 0
struct update *u;
#endif
struct output *o = new(struct output);
if (master == EXP_SPAWN_ID_BAD) {
if (0 == exp_update_master(interp,&master,1,1)) {
return(TCL_ERROR);
}
spawn_id_referenced = TRUE;
}
o->i_list = exp_new_i_simple(interp,master);
#if 0
o->spawn_id = master;
#endif
o->next = 0; /* no one else */
o->action_eof = &action_eof;
input_user->output = o;
#if 0
if (spawn_id_referenced) {
u = new_update(&update_base,&input_user->output->spawn_id);
}
#endif
}
if (!input_default->output) {
struct output *o = new(struct output);
#if 0
o->spawn_id = 1; /* stdout by default */
#endif
o->i_list = exp_new_i_simple(interp,1);/* stdout by default */
o->next = 0; /* no one else */
o->action_eof = &action_eof;
input_default->output = o;
}
/* if user has given "-u" flag, substitute process for user */
/* in first two -inputs */
if (replace_user_by_process != EXP_SPAWN_ID_BAD) {
#if 0
input_user->spawn_id = replace_user_by_process;
input_default->output->spawn_id = replace_user_by_process;
#endif
input_user->i_list->fd_list->fd = replace_user_by_process;
input_default->output->i_list->fd_list->fd= replace_user_by_process;
}
if (input_default->i_list->fd_list->fd == EXP_SPAWN_ID_BAD) {
#if 0
struct update *u;
#endif
if ((master == EXP_SPAWN_ID_BAD) || spawn_id_referenced) {
if (master == EXP_SPAWN_ID_BAD) {
if (0 == exp_update_master(interp,&master,1,1)) {
return(TCL_ERROR);
}
/* don't bother updating spawn_id_referenced */
/* after this point since no longer used */
}
#if 0
u = new_update(&update_base,&input_default->spawn_id);
#endif
}
input_default->i_list->fd_list->fd = master;
}
if (input_user->i_list->fd_list->fd == input_default->i_list->fd_list->fd) {
exp_error(interp,"cannot interact with self - set spawn_id to a spawned process");
return(TCL_ERROR);
}
fd_list = 0;
fd_to_input = 0;
/***************************************************************/
/* all data structures are sufficiently set up that we can now */
/* "finish()" to terminate this procedure */
/***************************************************************/
status = update_interact_fds(interp,&input_count,&fd_to_input,&fd_list,input_base,1,&close_count,&real_tty);
if (status == TCL_ERROR) finish(TCL_ERROR);
/* tests for if we are running this using /dev/tty */
#define real_tty_output(x) (((x) == 1) || ((x) == exp_dev_tty))
#define real_tty_input(x) (((x) == 0) || ((x) == exp_dev_tty))
if (real_tty) {
tty_changed = exp_tty_raw_noecho(interp,&tty_old,&was_raw,&was_echo);
}
#if 0
/* build args for ready() */
fd_list = (int *)malloc(input_count * sizeof(int));
fd_to_input = (struct input **)malloc((fd_max+1) * sizeof(struct input *));
/* at this point, we can now "goto done"; doing so earlier will */
/* screw up memory allocator */
#endif
for (inp = input_base,i=0;inp;inp=inp->next,i++) {
struct exp_fd_list *fdp;
for (fdp = inp->i_list->fd_list;fdp;fdp=fdp->next) {
#if 0
/* validate all the input descriptors */
if (!(fdp->f = exp_fd2f(interp,fdp->fd,1,1,"interact")))
finish(TCL_ERROR);
/* build map to translate from spawn_id to struct input */
fd_to_input[fdp->fd] = inp;
/* build input to ready() */
fd_list[i] = fdp->fd;
#endif
/* start timers */
inp->timeout_remaining = inp->timeout_nominal;
}
}
key = expect_key++;
#ifndef SIMPLE_EVENT
/* loop waiting (in event handler) for input */
for (;;) {
int te; /* result of Tcl_Eval */
struct f *u;
int rc; /* return code from ready. This is further */
/* refined by matcher. */
int cc; /* chars count from read() */
int m; /* master */
struct action *action = 0;
time_t previous_time;
time_t current_time;
int match_length, skip;
int change; /* if action requires cooked mode */
int attempt_match = TRUE;
struct input *soonest_input;
int print; /* # of chars to print */
int oldprinted; /* old version of u->printed */
int timeout; /* current as opposed to default_timeout */
/* calculate how long to wait */
/* by finding shortest remaining timeout */
if (timeout_simple) {
timeout = default_timeout;
} else {
timeout = arbitrary_timeout;
for (inp=input_base;inp;inp=inp->next) {
if ((inp->timeout_remaining != EXP_TIME_INFINITY) &&
(inp->timeout_remaining < timeout))
soonest_input = inp;
timeout = inp->timeout_remaining;
}
time(&previous_time);
/* timestamp here rather than simply saving old */
/* current time (after ready()) to account for */
/* possibility of slow actions */
/* timeout can actually be EXP_TIME_INFINITY here if user */
/* explicitly supplied it in a few cases (or */
/* the count-down code is broken) */
}
rc = exp_get_next_event(interp,fd_list,input_count,&m,timeout,key);
if (rc == EXP_TCLERROR)
return(TCL_ERROR);
if (rc == EXP_TIMEOUT) {
if (timeout_simple) {
action = &action_timeout;
goto got_action;
} else {
action = soonest_input->action_timeout;
}
}
if (!timeout_simple) {
int time_diff;
time(¤t_time);
time_diff = current_time - previous_time;
/* update all timers */
for (inp=input_base;inp;inp=inp->next) {
if (inp->timeout_remaining != EXP_TIME_INFINITY) {
inp->timeout_remaining -= time_diff;
if (inp->timeout_remaining < 0)
inp->timeout_remaining = 0;
}
}
}
/* at this point, we have some kind of event which can be */
/* immediately processed - i.e. something that doesn't block */
/* figure out who we are */
inp = fd_to_input[m];
/* u = inp->f;*/
u = fs+m;
/* reset timer */
inp->timeout_remaining = inp->timeout_nominal;
switch (rc) {
case EXP_DATA_NEW:
cc = read(m, u->buffer + u->size,
u->msize - u->size);
if (cc > 0) {
u->key = key;
u->size += cc;
u->buffer[u->size] = '\0';
/* strip parity if requested */
if (u->parity == 0) {
/* do it from end backwards */
char *p = u->buffer + u->size - 1;
int count = cc;
while (count--) {
*p-- &= 0x7f;
}
}
/* avoid another function call if possible */
if (debugfile || is_debugging) {
debuglog("spawn id %d sent {%s}\r\n",m,
exp_printify(u->buffer + u->size - cc));
}
break;
}
/*FALLTHRU*/
/* Most systems have read() return 0, allowing */
/* control to fall thru and into this code. On some */
/* systems (currently HP and new SGI), read() does */
/* see eof, and it must be detected earlier. Then */
/* control jumps directly to this EXP_EOF label. */
case EXP_EOF:
action = inp->action_eof;
attempt_match = FALSE;
skip = u->size;
rc = EXP_EOF;
debuglog("interact: received eof from spawn_id %d\r\n",m);
exp_close(interp,m);
break;
case EXP_DATA_OLD:
cc = 0;
break;
case EXP_TIMEOUT:
action = inp->action_timeout;
attempt_match = FALSE;
skip = u->size;
break;
}
km = 0;
if (attempt_match) {
rc = in_keymap(u->buffer,u->size,inp->keymap,
&km,&match_length,&skip);
} else {
attempt_match = TRUE;
}
/* put regexp result in variables */
if (km && km->re) {
#define INTER_OUT "interact_out"
#define out(var,val) debuglog("expect: set %s(%s) {%s}\r\n",INTER_OUT,var, \
dprintify(val)); \
Tcl_SetVar2(interp,INTER_OUT,var,val,0);
char name[20], value[20];
regexp *re = km->re;
char match_char;/* place to hold char temporarily */
/* uprooted by a NULL */
for (i=0;i<NSUBEXP;i++) {
int offset;
if (re->startp[i] == 0) break;
/* start index */
sprintf(name,"%d,start",i);
offset = re->startp[i]-u->buffer;
sprintf(value,"%d",offset);
out(name,value);
/* end index */
sprintf(name,"%d,end",i);
sprintf(value,"%d",re->endp[i]-u->buffer-1);
out(name,value);
/* string itself */
sprintf(name,"%d,string",i);
/* temporarily null-terminate in */
/* middle */
match_char = *re->endp[i];
*re->endp[i] = 0;
out(name,re->startp[i]);
*re->endp[i] = match_char;
}
}
/* dispose of chars that should be skipped */
/* skip is chars not involved in match */
/* print is with chars involved in match */
if (km && km->writethru) {
print = skip + match_length;
} else print = skip;
/* figure out if we should echo any chars */
if (km && km->echo) {
int seen; /* either printed or echoed */
/* echo to stdout rather than stdin */
if (m == 0) m = 1;
/* write is unlikely to fail, since we just read */
/* from same descriptor */
seen = u->printed + u->echoed;
if (skip >= seen) {
write(m,u->buffer+skip,match_length);
} else if ((match_length + skip - seen) > 0) {
write(m,u->buffer+seen,match_length+skip-seen);
}
u->echoed = match_length + skip - u->printed;
}
oldprinted = u->printed;
/* If expect has left characters in buffer, it has */
/* already echoed them to the screen, thus we must */
/* prevent them being rewritten. Unfortunately this */
/* gives the possibility of matching chars that have */
/* already been output, but we do so since the user */
/* could have avoided it by flushing the output */
/* buffers directly. */
if (print > u->printed) { /* usual case */
int wc; /* return code from write() */
for (outp = inp->output;outp;outp=outp->next) {
struct exp_fd_list *fdp;
for (fdp = outp->i_list->fd_list;fdp;fdp=fdp->next) {
int od; /* output descriptor */
/* send to logfile if open */
/* and user is seeing it */
if (logfile && real_tty_output(fdp->fd)) {
fwrite(u->buffer+u->printed,1,
print - u->printed,logfile);
}
/* send to each output descriptor */
od = fdp->fd;
/* if opened by Tcl, it may use a different */
/* output descriptor */
od = (fs[od].tcl_handle?fs[od].tcl_output:od);
wc = write(od,u->buffer+u->printed,
print - u->printed);
if (wc <= 0) {
debuglog("interact: write on spawn id %d failed (errno = %d)\r\n",fdp->fd,errno);
action = outp->action_eof;
#ifdef OLD_FAST
change = !(action && action->fast);
#else
change = (action && action->tty_reset);
#endif
if (change && tty_changed)
exp_tty_set(interp,&tty_old,was_raw,was_echo);
te = inter_eval(interp,action,&input_count,&fd_to_input,&fd_list,m,&close_count,&real_tty,input_base);
if (change && real_tty) tty_changed =
exp_tty_raw_noecho(interp,&tty_old,&was_raw,&was_echo);
switch (te) {
case TCL_BREAK:
case TCL_CONTINUE:
finish(te);
case TCL_RETURN_TCL:
finish(TCL_RETURN);
case TCL_RETURN:
finish(TCL_OK);
case TCL_OK:
/* god knows what the user might */
/* have done to us in the way of */
/* closed fds, so .... */
action = 0; /* reset action */
continue;
default:
finish(TCL_ERROR);
}
}
}
}
u->printed = print;
}
/* u->printed is now accurate with respect to the buffer */
/* However, we're about to shift the old data out of the */
/* buffer. Thus, u->size, printed, and echoed must be */
/* updated */
/* first update size based on skip information */
/* then set skip to the total amount skipped */
if (rc == EXP_MATCH) {
action = &km->action;
skip += match_length;
u->size -= skip;
if (u->size)
memcpy(u->buffer, u->buffer + skip, u->size);
exp_lowmemcpy(u->lower,u->buffer+ skip, u->size);
} else {
if (skip) {
u->size -= skip;
memcpy(u->buffer, u->buffer + skip, u->size);
exp_lowmemcpy(u->lower,u->buffer+ skip, u->size);
}
}
/* as long as buffer is still around, null terminate it */
if (rc != EXP_EOF) {
u->buffer[u->size] = '\0';
u->lower [u->size] = '\0';
}
/* now update printed based on total amount skipped */
u->printed -= skip;
/* if more skipped than printed (i.e., keymap encountered) */
/* for printed positive */
if (u->printed < 0) u->printed = 0;
/* if we are in the middle of a match, force the next event */
/* to wait for more data to arrive */
u->force_read = (rc == EXP_CANMATCH);
/* finally reset echoed if necessary */
if (rc != EXP_CANMATCH) {
if (skip >= oldprinted + u->echoed) u->echoed = 0;
}
if (action) {
got_action:
#ifdef OLD_FAST
change = !(action && action->fast);
#else
change = (action && action->tty_reset);
#endif
if (change && tty_changed)
exp_tty_set(interp,&tty_old,was_raw,was_echo);
te = inter_eval(interp,action,&input_count,&fd_to_input,&fd_list,m,&close_count,&real_tty,input_base);
if (change && real_tty) tty_changed =
exp_tty_raw_noecho(interp,&tty_old,&was_raw,&was_echo);
switch (te) {
case TCL_BREAK:
case TCL_CONTINUE:
finish(te);
case TCL_RETURN_TCL:
finish(TCL_RETURN);
case TCL_RETURN:
finish(TCL_OK);
case TCL_OK:
/* god knows what the user might */
/* have done to us in the way of */
/* closed fds, so .... */
action = 0; /* reset action */
continue;
default:
finish(TCL_ERROR);
}
}
}
#else /* SIMPLE_EVENT */
/* deferred_interrupt = FALSE;*/
{
int te; /* result of Tcl_Eval */
struct f *u;
int rc; /* return code from ready. This is further */
/* refined by matcher. */
int cc; /* chars count from read() */
int m; /* master */
struct action *action = 0;
time_t previous_time;
time_t current_time;
int match_length, skip;
int change; /* if action requires cooked mode */
int attempt_match = TRUE;
struct input *soonest_input;
int print; /* # of chars to print */
int oldprinted; /* old version of u->printed */
int timeout; /* current as opposed to default_timeout */
if (-1 == (pid = fork())) {
exp_error(interp,"fork: %s",sys_errlist[errno]);
finish(TCL_ERROR);
}
if (pid == 0) { /* child - send process output to user */
exp_close(interp,0);
m = fd_list[1]; /* get 2nd fd */
input_count = 1;
while (1) {
/* calculate how long to wait */
/* by finding shortest remaining timeout */
if (timeout_simple) {
timeout = default_timeout;
} else {
timeout = arbitrary_timeout;
for (inp=input_base;inp;inp=inp->next) {
if ((inp->timeout_remaining != EXP_TIME_INFINITY) &&
(inp->timeout_remaining < timeout))
soonest_input = inp;
timeout = inp->timeout_remaining;
}
time(&previous_time);
/* timestamp here rather than simply saving old */
/* current time (after ready()) to account for */
/* possibility of slow actions */
/* timeout can actually be EXP_TIME_INFINITY here if user */
/* explicitly supplied it in a few cases (or */
/* the count-down code is broken) */
}
/* +1 so we can look at the "other" file descriptor */
rc = exp_get_next_event(interp,fd_list+1,input_count,&m,timeout,key);
if (!timeout_simple) {
int time_diff;
time(¤t_time);
time_diff = current_time - previous_time;
/* update all timers */
for (inp=input_base;inp;inp=inp->next) {
if (inp->timeout_remaining != EXP_TIME_INFINITY) {
inp->timeout_remaining -= time_diff;
if (inp->timeout_remaining < 0)
inp->timeout_remaining = 0;
}
}
}
/* at this point, we have some kind of event which can be */
/* immediately processed - i.e. something that doesn't block */
/* figure out who we are */
inp = fd_to_input[m];
u = inp->f;
switch (rc) {
case EXP_DATA_NEW:
cc = read(m, u->buffer + u->size,
u->msize - u->size);
if (cc > 0) {
u->key = key;
u->size += cc;
u->buffer[u->size] = '\0';
/* strip parity if requested */
if (u->parity == 0) {
/* do it from end backwards */
char *p = u->buffer + u->size - 1;
int count = cc;
while (count--) {
*p-- &= 0x7f;
}
}
/* avoid another function call if possible */
if (debugfile || is_debugging) {
debuglog("spawn id %d sent {%s}\r\n",m,
exp_printify(u->buffer + u->size - cc));
}
break;
}
/*FALLTHRU*/
/* Most systems have read() return 0, allowing */
/* control to fall thru and into this code. On some */
/* systems (currently HP and new SGI), read() does */
/* see eof, and it must be detected earlier. Then */
/* control jumps directly to this EXP_EOF label. */
case EXP_EOF:
action = inp->action_eof;
attempt_match = FALSE;
skip = u->size;
rc = EXP_EOF;
debuglog("interact: child received eof from spawn_id %d\r\n",m);
exp_close(interp,m);
break;
case EXP_DATA_OLD:
cc = 0;
break;
}
km = 0;
if (attempt_match) {
rc = in_keymap(u->buffer,u->size,inp->keymap,
&km,&match_length,&skip);
} else {
attempt_match = TRUE;
}
/* put regexp result in variables */
if (km && km->re) {
#define INTER_OUT "interact_out"
#define out(i,val) debuglog("expect: set %s(%s) {%s}\r\n",INTER_OUT,i, \
dprintify(val)); \
Tcl_SetVar2(interp,INTER_OUT,i,val,0);
char name[20], value[20];
regexp *re = km->re;
char match_char;/* place to hold char temporarily */
/* uprooted by a NULL */
for (i=0;i<NSUBEXP;i++) {
int offset;
if (re->startp[i] == 0) break;
/* start index */
sprintf(name,"%d,start",i);
offset = re->startp[i]-u->buffer;
sprintf(value,"%d",offset);
out(name,value);
/* end index */
sprintf(name,"%d,end",i);
sprintf(value,"%d",re->endp[i]-u->buffer-1);
out(name,value);
/* string itself */
sprintf(name,"%d,string",i);
/* temporarily null-terminate in */
/* middle */
match_char = *re->endp[i];
*re->endp[i] = 0;
out(name,re->startp[i]);
*re->endp[i] = match_char;
}
}
/* dispose of chars that should be skipped */
/* skip is chars not involved in match */
/* print is with chars involved in match */
if (km && km->writethru) {
print = skip + match_length;
} else print = skip;
/* figure out if we should echo any chars */
if (km && km->echo) {
int seen; /* either printed or echoed */
/* echo to stdout rather than stdin */
if (m == 0) m = 1;
/* write is unlikely to fail, since we just read */
/* from same descriptor */
seen = u->printed + u->echoed;
if (skip >= seen) {
write(m,u->buffer+skip,match_length);
} else if ((match_length + skip - seen) > 0) {
write(m,u->buffer+seen,match_length+skip-seen);
}
u->echoed = match_length + skip - u->printed;
}
oldprinted = u->printed;
/* If expect has left characters in buffer, it has */
/* already echoed them to the screen, thus we must */
/* prevent them being rewritten. Unfortunately this */
/* gives the possibility of matching chars that have */
/* already been output, but we do so since the user */
/* could have avoided it by flushing the output */
/* buffers directly. */
if (print > u->printed) { /* usual case */
int wc; /* return code from write() */
for (outp = inp->output;outp;outp=outp->next) {
/* send to logfile if open */
/* and user is seeing it */
if (logfile && real_tty_output(outp->spawn_id)) {
fwrite(u->buffer+u->printed,1,
print - u->printed,logfile);
}
/* send to each output descriptor */
wc = write(outp->spawn_id,u->buffer+u->printed,
print - u->printed);
if (wc <= 0) {
debuglog("interact: write on spawn id %d failed (errno = %d)\r\n",outp->spawn_id,errno);
action = outp->action_eof;
te = inter_eval(interp,action,&input_count,&fd_to_input,&fd_list,m,&close_count,&real_tty,input_base);
switch (te) {
case TCL_BREAK:
case TCL_CONTINUE:
finish(te);
case TCL_RETURN_TCL:
finish(TCL_RETURN);
case TCL_RETURN:
finish(TCL_OK);
case TCL_OK:
if (eof) finish(TCL_OK);
/* god knows what the user might */
/* have done to us in the way of */
/* closed fds, so .... */
action = 0; /* reset action */
continue;
default:
finish(TCL_ERROR);
}
}
}
u->printed = print;
}
/* u->printed is now accurate with respect to the buffer */
/* However, we're about to shift the old data out of the */
/* buffer. Thus, u->size, printed, and echoed must be */
/* updated */
/* first update size based on skip information */
/* then set skip to the total amount skipped */
if (rc == EXP_MATCH) {
action = &km->action;
skip += match_length;
u->size -= skip;
if (u->size)
memcpy(u->buffer, u->buffer + skip, u->size);
exp_lowmemcpy(u->lower,u->buffer+ skip, u->size);
} else {
if (skip) {
u->size -= skip;
memcpy(u->buffer, u->buffer + skip, u->size);
exp_lowmemcpy(u->lower,u->buffer+ skip, u->size);
}
}
/* as long as buffer is still around, null terminate it */
if (rc != EXP_EOF) {
u->buffer[u->size] = '\0';
u->lower [u->size] = '\0';
}
/* now update printed based on total amount skipped */
u->printed -= skip;
/* if more skipped than printed (i.e., keymap encountered) */
/* for printed positive */
if (u->printed < 0) u->printed = 0;
/* if we are in the middle of a match, force the next event */
/* to wait for more data to arrive */
u->force_read = (rc == EXP_CANMATCH);
/* finally reset echoed if necessary */
if (rc != EXP_CANMATCH) {
if (skip >= oldprinted + u->echoed) u->echoed = 0;
}
if (action) {
got_action_2:
te = inter_eval(interp,action,&input_count,&fd_to_input,&fd_list,m,&close_count,&real_tty,input_base);
switch (te) {
case TCL_BREAK:
case TCL_CONTINUE:
finish(te);
case TCL_RETURN_TCL:
finish(TCL_RETURN);
case TCL_RETURN:
finish(TCL_OK);
case TCL_OK:
if (eof) finish(TCL_OK);
/* god knows what the user might */
/* have done to us in the way of */
/* closed fds, so .... */
action = 0; /* reset action */
continue;
default:
finish(TCL_ERROR);
}
}
}
} else { /* parent - send user keystrokes to process */
#include <signal.h>
debuglog("fork = %d\r\n",pid);
#ifdef SIGCHLD
signal(SIGCHLD,sigchld_handler);
#else
signal(SIGCLD,sigchld_handler);
#endif
/* restart:*/
/* tty_changed = exp_tty_raw_noecho(interp,&tty_old,&was_raw,&was_echo);*/
m = fd_list[0]; /* get 1st fd */
input_count = 1;
while (1) {
/* calculate how long to wait */
/* by finding shortest remaining timeout */
if (timeout_simple) {
timeout = default_timeout;
} else {
timeout = arbitrary_timeout;
for (inp=input_base;inp;inp=inp->next) {
if ((inp->timeout_remaining != EXP_TIME_INFINITY) &&
(inp->timeout_remaining < timeout))
soonest_input = inp;
timeout = inp->timeout_remaining;
}
time(&previous_time);
/* timestamp here rather than simply saving old */
/* current time (after ready()) to account for */
/* possibility of slow actions */
/* timeout can actually be EXP_TIME_INFINITY here if user */
/* explicitly supplied it in a few cases (or */
/* the count-down code is broken) */
}
rc = exp_get_next_event(interp,fd_list,input_count,&m,timeout,key);
if (!timeout_simple) {
int time_diff;
time(¤t_time);
time_diff = current_time - previous_time;
/* update all timers */
for (inp=input_base;inp;inp=inp->next) {
if (inp->timeout_remaining != EXP_TIME_INFINITY) {
inp->timeout_remaining -= time_diff;
if (inp->timeout_remaining < 0)
inp->timeout_remaining = 0;
}
}
}
/* at this point, we have some kind of event which can be */
/* immediately processed - i.e. something that doesn't block */
/* figure out who we are */
inp = fd_to_input[m];
u = inp->f;
switch (rc) {
case EXP_DATA_NEW:
cc = i_read(m, u->buffer + u->size,
u->msize - u->size);
if (cc > 0) {
u->key = key;
u->size += cc;
u->buffer[u->size] = '\0';
/* strip parity if requested */
if (u->parity == 0) {
/* do it from end backwards */
char *p = u->buffer + u->size - 1;
int count = cc;
while (count--) {
*p-- &= 0x7f;
}
}
/* avoid another function call if possible */
if (debugfile || is_debugging) {
debuglog("spawn id %d sent {%s}\r\n",m,
exp_printify(u->buffer + u->size - cc));
}
break;
} else if (cc == EXP_CHILD_EOF) {
/* user could potentially have two outputs in which */
/* case we might be looking at the wrong one, but */
/* the likelihood of this is nil */
action = inp->output->action_eof;
attempt_match = FALSE;
skip = u->size;
rc = EXP_EOF;
debuglog("interact: process died/eof\r\n");
clean_up_after_child(interp,fd_list[1]);
break;
}
/*FALLTHRU*/
/* Most systems have read() return 0, allowing */
/* control to fall thru and into this code. On some */
/* systems (currently HP and new SGI), read() does */
/* see eof, and it must be detected earlier. Then */
/* control jumps directly to this EXP_EOF label. */
case EXP_EOF:
action = inp->action_eof;
attempt_match = FALSE;
skip = u->size;
rc = EXP_EOF;
debuglog("user sent EOF or disappeared\n\n");
break;
case EXP_DATA_OLD:
cc = 0;
break;
}
km = 0;
if (attempt_match) {
rc = in_keymap(u->buffer,u->size,inp->keymap,
&km,&match_length,&skip);
} else {
attempt_match = TRUE;
}
/* put regexp result in variables */
if (km && km->re) {
#define INTER_OUT "interact_out"
#define out(i,val) debuglog("expect: set %s(%s) {%s}\r\n",INTER_OUT,i, \
dprintify(val)); \
Tcl_SetVar2(interp,INTER_OUT,i,val,0);
char name[20], value[20];
regexp *re = km->re;
char match_char;/* place to hold char temporarily */
/* uprooted by a NULL */
for (i=0;i<NSUBEXP;i++) {
int offset;
if (re->startp[i] == 0) break;
/* start index */
sprintf(name,"%d,start",i);
offset = re->startp[i]-u->buffer;
sprintf(value,"%d",offset);
out(name,value);
/* end index */
sprintf(name,"%d,end",i);
sprintf(value,"%d",re->endp[i]-u->buffer-1);
out(name,value);
/* string itself */
sprintf(name,"%d,string",i);
/* temporarily null-terminate in */
/* middle */
match_char = *re->endp[i];
*re->endp[i] = 0;
out(name,re->startp[i]);
*re->endp[i] = match_char;
}
}
/* dispose of chars that should be skipped */
/* skip is chars not involved in match */
/* print is with chars involved in match */
if (km && km->writethru) {
print = skip + match_length;
} else print = skip;
/* figure out if we should echo any chars */
if (km && km->echo) {
int seen; /* either printed or echoed */
/* echo to stdout rather than stdin */
if (m == 0) m = 1;
/* write is unlikely to fail, since we just read */
/* from same descriptor */
seen = u->printed + u->echoed;
if (skip >= seen) {
write(m,u->buffer+skip,match_length);
} else if ((match_length + skip - seen) > 0) {
write(m,u->buffer+seen,match_length+skip-seen);
}
u->echoed = match_length + skip - u->printed;
}
oldprinted = u->printed;
/* If expect has left characters in buffer, it has */
/* already echoed them to the screen, thus we must */
/* prevent them being rewritten. Unfortunately this */
/* gives the possibility of matching chars that have */
/* already been output, but we do so since the user */
/* could have avoided it by flushing the output */
/* buffers directly. */
if (print > u->printed) { /* usual case */
int wc; /* return code from write() */
for (outp = inp->output;outp;outp=outp->next) {
/* send to logfile if open */
/* and user is seeing it */
if (logfile && real_tty_output(outp->spawn_id)) {
fwrite(u->buffer+u->printed,1,
print - u->printed,logfile);
}
/* send to each output descriptor */
wc = write(outp->spawn_id,u->buffer+u->printed,
print - u->printed);
if (wc <= 0) {
debuglog("interact: write on spawn id %d failed (errno = %d)\r\n",outp->spawn_id,errno);
clean_up_after_child(interp,outp->spawn_id);
action = outp->action_eof;
#ifdef OLD_FAST
change = !(action && action->fast);
#else
change = (action && action->tty_reset);
#endif
if (change && tty_changed)
exp_tty_set(interp,&tty_old,was_raw,was_echo);
te = inter_eval(interp,action,&input_count,&fd_to_input,&fd_list,m,&close_count,&real_tty,input_base);
if (change && real_tty) tty_changed =
exp_tty_raw_noecho(interp,&tty_old,&was_raw,&was_echo);
switch (te) {
case TCL_BREAK:
case TCL_CONTINUE:
finish(te);
case TCL_RETURN_TCL:
finish(TCL_RETURN);
case TCL_RETURN:
finish(TCL_OK);
case TCL_OK:
/* god knows what the user might */
/* have done to us in the way of */
/* closed fds, so .... */
action = 0; /* reset action */
continue;
default:
finish(TCL_ERROR);
}
}
}
u->printed = print;
}
/* u->printed is now accurate with respect to the buffer */
/* However, we're about to shift the old data out of the */
/* buffer. Thus, u->size, printed, and echoed must be */
/* updated */
/* first update size based on skip information */
/* then set skip to the total amount skipped */
if (rc == EXP_MATCH) {
action = &km->action;
skip += match_length;
u->size -= skip;
if (u->size)
memcpy(u->buffer, u->buffer + skip, u->size);
exp_lowmemcpy(u->lower,u->buffer+ skip, u->size);
} else {
if (skip) {
u->size -= skip;
memcpy(u->buffer, u->buffer + skip, u->size);
exp_lowmemcpy(u->lower,u->buffer+ skip, u->size);
}
}
/* as long as buffer is still around, null terminate it */
if (rc != EXP_EOF) {
u->buffer[u->size] = '\0';
u->lower [u->size] = '\0';
}
/* now update printed based on total amount skipped */
u->printed -= skip;
/* if more skipped than printed (i.e., keymap encountered) */
/* for printed positive */
if (u->printed < 0) u->printed = 0;
/* if we are in the middle of a match, force the next event */
/* to wait for more data to arrive */
u->force_read = (rc == EXP_CANMATCH);
/* finally reset echoed if necessary */
if (rc != EXP_CANMATCH) {
if (skip >= oldprinted + u->echoed) u->echoed = 0;
}
if (action) {
got_action_3:
#ifdef OLD_FAST
change = !(action && action->fast);
#else
change = (action && action->tty_reset);
#endif
if (change && tty_changed)
exp_tty_set(interp,&tty_old,was_raw,was_echo);
te = inter_eval(interp,action,&input_count,&fd_to_input,&fd_list,m,&close_count,&real_tty,input_base);
if (change && real_tty) tty_changed =
exp_tty_raw_noecho(interp,&tty_old,&was_raw,&was_echo);
switch (te) {
case TCL_BREAK:
case TCL_CONTINUE:
finish(te);
case TCL_RETURN_TCL:
finish(TCL_RETURN);
case TCL_RETURN:
finish(TCL_OK);
case TCL_OK:
/* god knows what the user might */
/* have done to us in the way of */
/* closed fds, so .... */
action = 0; /* reset action */
continue;
default:
finish(TCL_ERROR);
}
}
}
}
}
#endif /* SIMPLE_EVENT */
done:
#ifdef SIMPLE_EVENT
/* force child to exit upon eof from master */
if (pid == 0) {
exit(SPAWNED_PROCESS_DIED);
}
#endif /* SIMPLE_EVENT */
if (tty_changed) exp_tty_set(interp,&tty_old,was_raw,was_echo);
if (oldargv) free((char *)argv);
if (fd_list) free((char *)fd_list);
if (fd_to_input) free((char *)fd_to_input);
free_input(input_base);
free_action(action_base);
#if 0
free_update(update_base);
#endif
return(status);
}
/* version of Tcl_Eval for interact */
static int
inter_eval(interp,action,input_count,fd_to_input,fd_list,spawn_id,previous_close_count,real_tty,input_base)
Tcl_Interp *interp;
struct action *action;
int *input_count;
struct input ***fd_to_input;
int **fd_list;
int spawn_id;
int *previous_close_count;
int *real_tty;
struct input *input_base;
{
int status;
char value[20];
if (action->timestamp) {
time_t current_time;
time(¤t_time);
exp_timestamp(interp,¤t_time,INTER_OUT);
}
if (action->iwrite) {
sprintf(value,"%d",spawn_id);
out("spawn_id",value);
}
if (action->statement) {
#if TCL_MAJOR_VERSION == 6
status = Tcl_Eval(interp,action->statement,0,(char **)0);
#else
status = Tcl_Eval(interp,action->statement);
#endif
} else {
nflog("\r\n",1);
status = exp_interpreter(interp);
}
/* don't validate if we're exiting anyway */
if (status != TCL_OK) return(status);
if (action->iread) {
status = update_interact_fds(interp,input_count,fd_to_input,&fd_list,input_base,1,previous_close_count,real_tty);
} else if (exp_close_count != *previous_close_count) {
/* if any fds have closed, revalidate without checking */
/* indirects */
status = update_interact_fds(interp,input_count,fd_to_input,&fd_list,input_base,0,previous_close_count,real_tty);
}
return status;
}
int
update_interact_fds(interp,fd_count,fd_to_input,fd_list,input_base,do_indirect,close_count,real_tty_caller)
Tcl_Interp *interp;
int *fd_count;
struct input ***fd_to_input; /* map from fd's to "struct input"s */
int **fd_list;
struct input *input_base;
int do_indirect; /* if true do indirects */
int *close_count;
int *real_tty_caller;
{
int te;
struct input *inp;
struct output *outp;
struct exp_fd_list *fdp;
int count;
int real_tty = FALSE;
*close_count = exp_close_count;
count = 0;
for (inp = input_base;inp;inp=inp->next) {
if (do_indirect) {
/* do not update "direct" entries (again) */
/* they were updated upon creation */
if (!inp->i_list->direct) {
te = exp_i_update(interp,inp->i_list);
if (te != TCL_OK) return te;
}
}
/* revalidate all input descriptors */
for (fdp = inp->i_list->fd_list;fdp;fdp=fdp->next) {
count++;
/* have to "adjust", just in case spawn id hasn't had a */
/* buffer sized yet */
if (!exp_fd2f(interp,fdp->fd,1,1,"interact"))
return(TCL_ERROR);
}
/* revalidate all output descriptors */
for (outp = inp->output;outp;outp=outp->next) {
for (fdp = outp->i_list->fd_list;fdp;fdp=fdp->next) {
/* make user_spawn_id point to stdout */
if (fdp->fd == 0) {
fdp->fd = 1;
} else if (fdp->fd == 1) {
/* do nothing */
} else if (!exp_fd2f(interp,fdp->fd,1,0,"interact"))
return(TCL_ERROR);
}
}
}
if (!do_indirect) return TCL_OK;
if (*fd_to_input == 0) {
*fd_to_input = (struct input **)malloc(
(fd_max+1) * sizeof(struct input *));
*fd_list = (int *)malloc(count * sizeof(int));
} else {
*fd_to_input = (struct input **)realloc((char *)*fd_to_input,
(fd_max+1) * sizeof(struct input *));
*fd_list = (int *)realloc((char *)*fd_list,count * sizeof(int));
}
count = 0;
for (inp = input_base;inp;inp=inp->next) {
for (fdp = inp->i_list->fd_list;fdp;fdp=fdp->next) {
/* build map to translate from spawn_id to struct input */
(*fd_to_input)[fdp->fd] = inp;
/* build input to ready() */
(*fd_list)[count] = fdp->fd;
if (real_tty_input(fdp->fd)) real_tty = TRUE;
count++;
}
}
*fd_count = count;
*real_tty_caller = real_tty; /* tell caller if we have found that */
/* we are using real tty */
return TCL_OK;
}
static void
free_keymap(km)
struct keymap *km;
{
if (km == 0) return;
free_keymap(km->next);
free((char *)km);
}
static void
free_action(a)
struct action *a;
{
struct action *next;
while (a) {
next = a->next;
free((char *)a);
a = next;
}
}
static void
free_input(i)
struct input *i;
{
if (i == 0) return;
free_input(i->next);
exp_free_i(i->i_list);
free_output(i->output);
free_keymap(i->keymap);
free((char *)i);
}
static struct action *
new_action(base)
struct action **base;
{
struct action *o = new(struct action);
/* stick new action into beginning of list of all actions */
o->next = *base;
*base = o;
return o;
}
#if 0
static struct update *
new_update(base,fd_ptr)
struct update **base;
int *fd_ptr;
{
struct update *u = new(struct update);
/* stick new update into beginning of list of all updates */
u->next = *base;
*base = u;
u->spawn_id = fd_ptr;
return u;
}
static void
free_update(u)
struct update *u;
{
struct update *next;
while (u) {
next = u->next;
free((char *)u);
u = next;
}
}
#endif
static void
free_output(o)
struct output *o;
{
if (o == 0) return;
free_output(o->next);
exp_free_i(o->i_list);
free((char *)o);
}
These are the contents of the former NiCE NeXT User Group NeXTSTEP/OpenStep software archive, currently hosted by Netfuture.ch.