Home | History | Annotate | Line # | Download | only in ksh
history.c revision 1.11
      1  1.11    plunky /*	$NetBSD: history.c,v 1.11 2011/08/31 16:24:54 plunky Exp $	*/
      2   1.2       tls 
      3   1.1       jtc /*
      4   1.1       jtc  * command history
      5   1.1       jtc  *
      6   1.1       jtc  * only implements in-memory history.
      7   1.1       jtc  */
      8   1.1       jtc 
      9   1.1       jtc /*
     10   1.1       jtc  *	This file contains
     11   1.1       jtc  *	a)	the original in-memory history  mechanism
     12   1.1       jtc  *	b)	a simple file saving history mechanism done by  sjg@zen
     13   1.1       jtc  *		define EASY_HISTORY to get this
     14   1.1       jtc  *	c)	a more complicated mechanism done by  pc (at) hillside.co.uk
     15   1.1       jtc  *		that more closely follows the real ksh way of doing
     16   1.1       jtc  *		things. You need to have the mmap system call for this
     17   1.1       jtc  *		to work on your system
     18   1.1       jtc  */
     19   1.5       agc #include <sys/cdefs.h>
     20   1.5       agc 
     21   1.5       agc #ifndef lint
     22  1.11    plunky __RCSID("$NetBSD: history.c,v 1.11 2011/08/31 16:24:54 plunky Exp $");
     23   1.5       agc #endif
     24   1.5       agc 
     25   1.1       jtc 
     26   1.1       jtc #include "sh.h"
     27   1.1       jtc #include "ksh_stat.h"
     28   1.1       jtc 
     29   1.1       jtc #ifdef HISTORY
     30   1.1       jtc # ifdef EASY_HISTORY
     31   1.1       jtc 
     32   1.1       jtc #  ifndef HISTFILE
     33   1.1       jtc #   ifdef OS2
     34   1.1       jtc #    define HISTFILE "history.ksh"
     35   1.1       jtc #   else /* OS2 */
     36   1.4   hubertf #    define HISTFILE ".pdksh_history"
     37   1.1       jtc #   endif /* OS2 */
     38   1.1       jtc #  endif
     39   1.1       jtc 
     40   1.1       jtc # else
     41   1.1       jtc /*	Defines and includes for the complicated case */
     42   1.1       jtc 
     43   1.1       jtc #  include <sys/file.h>
     44   1.1       jtc #  include <sys/mman.h>
     45   1.1       jtc 
     46   1.1       jtc /*
     47   1.1       jtc  *	variables for handling the data file
     48   1.1       jtc  */
     49   1.1       jtc static int	histfd;
     50   1.1       jtc static int	hsize;
     51   1.1       jtc 
     52   1.1       jtc static int hist_count_lines ARGS((unsigned char *, int));
     53   1.1       jtc static int hist_shrink ARGS((unsigned char *, int));
     54   1.1       jtc static unsigned char *hist_skip_back ARGS((unsigned char *,int *,int));
     55   1.1       jtc static void histload ARGS((Source *, unsigned char *, int));
     56   1.1       jtc static void histinsert ARGS((Source *, int, unsigned char *));
     57   1.1       jtc static void writehistfile ARGS((int, char *));
     58   1.1       jtc static int sprinkle ARGS((int));
     59   1.1       jtc 
     60   1.1       jtc #  ifdef MAP_FILE
     61   1.1       jtc #   define MAP_FLAGS	(MAP_FILE|MAP_PRIVATE)
     62   1.1       jtc #  else
     63   1.1       jtc #   define MAP_FLAGS	MAP_PRIVATE
     64   1.1       jtc #  endif
     65   1.1       jtc 
     66   1.1       jtc # endif	/* of EASY_HISTORY */
     67   1.1       jtc 
     68   1.9  christos static int	hist_execute ARGS((char *));
     69   1.9  christos static int	hist_replace ARGS((char **, const char *, const char *, int));
     70   1.9  christos static char   **hist_get ARGS((const char *, int, int));
     71   1.9  christos static char   **hist_get_newest ARGS((int));
     72   1.3  christos static char   **hist_get_oldest ARGS((void));
     73   1.1       jtc static void	histbackup ARGS((void));
     74   1.1       jtc 
     75   1.7   mycroft static char   **current;	/* current position in history[] */
     76   1.1       jtc static int	curpos;		/* current index in history[] */
     77   1.1       jtc static char    *hname;		/* current name of history file */
     78   1.1       jtc static int	hstarted;	/* set after hist_init() called */
     79   1.1       jtc static Source	*hist_source;
     80   1.1       jtc 
     81   1.1       jtc 
     82   1.1       jtc int
     83   1.1       jtc c_fc(wp)
     84   1.1       jtc 	char **wp;
     85   1.1       jtc {
     86   1.1       jtc 	struct shf *shf;
     87   1.1       jtc 	struct temp UNINITIALIZED(*tf);
     88   1.1       jtc 	char *p, *editor = (char *) 0;
     89   1.1       jtc 	int gflag = 0, lflag = 0, nflag = 0, sflag = 0, rflag = 0;
     90   1.1       jtc 	int optc;
     91   1.1       jtc 	char *first = (char *) 0, *last = (char *) 0;
     92   1.1       jtc 	char **hfirst, **hlast, **hp;
     93   1.1       jtc 
     94   1.8  christos 	if (hist_source == NULL) {
     95   1.8  christos 		bi_errorf("not interactive");
     96   1.8  christos 		return 1;
     97   1.8  christos 	}
     98   1.8  christos 
     99   1.1       jtc 	while ((optc = ksh_getopt(wp, &builtin_opt, "e:glnrs0,1,2,3,4,5,6,7,8,9,")) != EOF)
    100   1.1       jtc 		switch (optc) {
    101   1.1       jtc 		  case 'e':
    102   1.1       jtc 			p = builtin_opt.optarg;
    103   1.1       jtc 			if (strcmp(p, "-") == 0)
    104   1.1       jtc 				sflag++;
    105   1.1       jtc 			else {
    106   1.7   mycroft 				size_t len = strlen(p) + 4;
    107   1.7   mycroft 				editor = str_nsave(p, len, ATEMP);
    108   1.7   mycroft 				strlcat(editor, " $_", len);
    109   1.1       jtc 			}
    110   1.1       jtc 			break;
    111   1.1       jtc 		  case 'g': /* non-at&t ksh */
    112   1.1       jtc 			gflag++;
    113   1.1       jtc 			break;
    114   1.1       jtc 		  case 'l':
    115   1.1       jtc 			lflag++;
    116   1.1       jtc 			break;
    117   1.1       jtc 		  case 'n':
    118   1.1       jtc 			nflag++;
    119   1.1       jtc 			break;
    120   1.1       jtc 		  case 'r':
    121   1.1       jtc 			rflag++;
    122   1.1       jtc 			break;
    123   1.1       jtc 		  case 's':	/* posix version of -e - */
    124   1.1       jtc 			sflag++;
    125   1.1       jtc 			break;
    126   1.1       jtc 		  /* kludge city - accept -num as -- -num (kind of) */
    127   1.1       jtc 		  case '0': case '1': case '2': case '3': case '4':
    128   1.1       jtc 		  case '5': case '6': case '7': case '8': case '9':
    129   1.1       jtc 			p = shf_smprintf("-%c%s",
    130   1.1       jtc 					optc, builtin_opt.optarg);
    131   1.1       jtc 			if (!first)
    132   1.1       jtc 				first = p;
    133   1.1       jtc 			else if (!last)
    134   1.1       jtc 				last = p;
    135   1.1       jtc 			else {
    136   1.1       jtc 				bi_errorf("too many arguments");
    137   1.1       jtc 				return 1;
    138   1.1       jtc 			}
    139   1.1       jtc 			break;
    140   1.1       jtc 		  case '?':
    141   1.1       jtc 			return 1;
    142   1.1       jtc 		}
    143   1.1       jtc 	wp += builtin_opt.optind;
    144   1.1       jtc 
    145   1.1       jtc 	/* Substitute and execute command */
    146   1.1       jtc 	if (sflag) {
    147   1.1       jtc 		char *pat = (char *) 0, *rep = (char *) 0;
    148   1.1       jtc 
    149   1.1       jtc 		if (editor || lflag || nflag || rflag) {
    150   1.1       jtc 			bi_errorf("can't use -e, -l, -n, -r with -s (-e -)");
    151   1.1       jtc 			return 1;
    152   1.1       jtc 		}
    153   1.1       jtc 
    154   1.1       jtc 		/* Check for pattern replacement argument */
    155   1.1       jtc 		if (*wp && **wp && (p = strchr(*wp + 1, '='))) {
    156   1.1       jtc 			pat = str_save(*wp, ATEMP);
    157   1.1       jtc 			p = pat + (p - *wp);
    158   1.1       jtc 			*p++ = '\0';
    159   1.1       jtc 			rep = p;
    160   1.1       jtc 			wp++;
    161   1.1       jtc 		}
    162   1.1       jtc 		/* Check for search prefix */
    163   1.1       jtc 		if (!first && (first = *wp))
    164   1.1       jtc 			wp++;
    165   1.1       jtc 		if (last || *wp) {
    166   1.1       jtc 			bi_errorf("too many arguments");
    167   1.1       jtc 			return 1;
    168   1.1       jtc 		}
    169   1.1       jtc 
    170   1.1       jtc 		hp = first ? hist_get(first, FALSE, FALSE)
    171   1.1       jtc 			   : hist_get_newest(FALSE);
    172   1.1       jtc 		if (!hp)
    173   1.1       jtc 			return 1;
    174   1.1       jtc 		return hist_replace(hp, pat, rep, gflag);
    175   1.1       jtc 	}
    176   1.1       jtc 
    177   1.1       jtc 	if (editor && (lflag || nflag)) {
    178   1.1       jtc 		bi_errorf("can't use -l, -n with -e");
    179   1.1       jtc 		return 1;
    180   1.1       jtc 	}
    181   1.1       jtc 
    182   1.1       jtc 	if (!first && (first = *wp))
    183   1.1       jtc 		wp++;
    184   1.1       jtc 	if (!last && (last = *wp))
    185   1.1       jtc 		wp++;
    186   1.1       jtc 	if (*wp) {
    187   1.1       jtc 		bi_errorf("too many arguments");
    188   1.1       jtc 		return 1;
    189   1.1       jtc 	}
    190   1.1       jtc 	if (!first) {
    191   1.1       jtc 		hfirst = lflag ? hist_get("-16", TRUE, TRUE)
    192   1.1       jtc 			       : hist_get_newest(FALSE);
    193   1.1       jtc 		if (!hfirst)
    194   1.1       jtc 			return 1;
    195   1.1       jtc 		/* can't fail if hfirst didn't fail */
    196   1.1       jtc 		hlast = hist_get_newest(FALSE);
    197   1.1       jtc 	} else {
    198   1.1       jtc 		/* POSIX says not an error if first/last out of bounds
    199   1.1       jtc 		 * when range is specified; at&t ksh and pdksh allow out of
    200   1.1       jtc 		 * bounds for -l as well.
    201   1.1       jtc 		 */
    202   1.1       jtc 		hfirst = hist_get(first, (lflag || last) ? TRUE : FALSE,
    203   1.1       jtc 				lflag ? TRUE : FALSE);
    204   1.1       jtc 		if (!hfirst)
    205   1.1       jtc 			return 1;
    206   1.1       jtc 		hlast = last ? hist_get(last, TRUE, lflag ? TRUE : FALSE)
    207   1.1       jtc 			    : (lflag ? hist_get_newest(FALSE) : hfirst);
    208   1.1       jtc 		if (!hlast)
    209   1.1       jtc 			return 1;
    210   1.1       jtc 	}
    211   1.1       jtc 	if (hfirst > hlast) {
    212   1.1       jtc 		char **temp;
    213   1.1       jtc 
    214   1.1       jtc 		temp = hfirst; hfirst = hlast; hlast = temp;
    215   1.1       jtc 		rflag = !rflag; /* POSIX */
    216   1.1       jtc 	}
    217   1.1       jtc 
    218   1.1       jtc 	/* List history */
    219   1.1       jtc 	if (lflag) {
    220   1.1       jtc 		char *s, *t;
    221   1.1       jtc 		const char *nfmt = nflag ? "\t" : "%d\t";
    222   1.1       jtc 
    223   1.1       jtc 		for (hp = rflag ? hlast : hfirst;
    224   1.1       jtc 		     hp >= hfirst && hp <= hlast; hp += rflag ? -1 : 1)
    225   1.1       jtc 		{
    226   1.1       jtc 			shf_fprintf(shl_stdout, nfmt,
    227   1.1       jtc 				hist_source->line - (int) (histptr - hp));
    228   1.1       jtc 			/* print multi-line commands correctly */
    229   1.1       jtc 			for (s = *hp; (t = strchr(s, '\n')); s = t)
    230   1.1       jtc 				shf_fprintf(shl_stdout, "%.*s\t", ++t - s, s);
    231   1.1       jtc 			shf_fprintf(shl_stdout, "%s\n", s);
    232   1.1       jtc 		}
    233   1.1       jtc 		shf_flush(shl_stdout);
    234   1.1       jtc 		return 0;
    235   1.1       jtc 	}
    236   1.1       jtc 
    237   1.1       jtc 	/* Run editor on selected lines, then run resulting commands */
    238   1.1       jtc 
    239   1.4   hubertf 	tf = maketemp(ATEMP, TT_HIST_EDIT, &e->temps);
    240   1.1       jtc 	if (!(shf = tf->shf)) {
    241   1.1       jtc 		bi_errorf("cannot create temp file %s - %s",
    242   1.1       jtc 			tf->name, strerror(errno));
    243   1.1       jtc 		return 1;
    244   1.1       jtc 	}
    245   1.1       jtc 	for (hp = rflag ? hlast : hfirst;
    246   1.1       jtc 	     hp >= hfirst && hp <= hlast; hp += rflag ? -1 : 1)
    247   1.1       jtc 		shf_fprintf(shf, "%s\n", *hp);
    248   1.1       jtc 	if (shf_close(shf) == EOF) {
    249   1.1       jtc 		bi_errorf("error writing temporary file - %s", strerror(errno));
    250   1.1       jtc 		return 1;
    251   1.1       jtc 	}
    252   1.1       jtc 
    253   1.4   hubertf 	/* Ignore setstr errors here (arbitrary) */
    254   1.4   hubertf 	setstr(local("_", FALSE), tf->name, KSH_RETURN_ERROR);
    255   1.1       jtc 
    256   1.1       jtc 	/* XXX: source should not get trashed by this.. */
    257   1.1       jtc 	{
    258   1.1       jtc 		Source *sold = source;
    259   1.1       jtc 		int ret;
    260   1.1       jtc 
    261   1.1       jtc 		ret = command(editor ? editor : "${FCEDIT:-/bin/ed} $_");
    262   1.1       jtc 		source = sold;
    263   1.1       jtc 		if (ret)
    264   1.1       jtc 			return ret;
    265   1.1       jtc 	}
    266   1.1       jtc 
    267   1.1       jtc 	{
    268   1.1       jtc 		struct stat statb;
    269   1.1       jtc 		XString xs;
    270   1.1       jtc 		char *xp;
    271   1.1       jtc 		int n;
    272   1.1       jtc 
    273   1.1       jtc 		if (!(shf = shf_open(tf->name, O_RDONLY, 0, 0))) {
    274   1.1       jtc 			bi_errorf("cannot open temp file %s", tf->name);
    275   1.1       jtc 			return 1;
    276   1.1       jtc 		}
    277   1.1       jtc 
    278   1.1       jtc 		n = fstat(shf_fileno(shf), &statb) < 0 ? 128
    279   1.1       jtc 			: statb.st_size + 1;
    280   1.1       jtc 		Xinit(xs, xp, n, hist_source->areap);
    281   1.1       jtc 		while ((n = shf_read(xp, Xnleft(xs, xp), shf)) > 0) {
    282   1.1       jtc 			xp += n;
    283   1.1       jtc 			if (Xnleft(xs, xp) <= 0)
    284   1.1       jtc 				XcheckN(xs, xp, Xlength(xs, xp));
    285   1.1       jtc 		}
    286   1.1       jtc 		if (n < 0) {
    287   1.1       jtc 			bi_errorf("error reading temp file %s - %s",
    288   1.1       jtc 				tf->name, strerror(shf_errno(shf)));
    289   1.1       jtc 			shf_close(shf);
    290   1.1       jtc 			return 1;
    291   1.1       jtc 		}
    292   1.1       jtc 		shf_close(shf);
    293   1.1       jtc 		*xp = '\0';
    294   1.1       jtc 		strip_nuls(Xstring(xs, xp), Xlength(xs, xp));
    295   1.1       jtc 		return hist_execute(Xstring(xs, xp));
    296   1.1       jtc 	}
    297   1.1       jtc }
    298   1.1       jtc 
    299   1.1       jtc /* Save cmd in history, execute cmd (cmd gets trashed) */
    300   1.1       jtc static int
    301   1.1       jtc hist_execute(cmd)
    302   1.1       jtc 	char *cmd;
    303   1.1       jtc {
    304   1.1       jtc 	Source *sold;
    305   1.1       jtc 	int ret;
    306   1.1       jtc 	char *p, *q;
    307   1.1       jtc 
    308   1.1       jtc 	histbackup();
    309   1.1       jtc 
    310   1.1       jtc 	for (p = cmd; p; p = q) {
    311   1.1       jtc 		if ((q = strchr(p, '\n'))) {
    312   1.1       jtc 			*q++ = '\0'; /* kill the newline */
    313   1.1       jtc 			if (!*q) /* ignore trailing newline */
    314   1.1       jtc 				q = (char *) 0;
    315   1.1       jtc 		}
    316   1.1       jtc #ifdef EASY_HISTORY
    317   1.1       jtc 		if (p != cmd)
    318   1.1       jtc 			histappend(p, TRUE);
    319   1.1       jtc 		else
    320   1.1       jtc #endif /* EASY_HISTORY */
    321   1.1       jtc 			histsave(++(hist_source->line), p, 1);
    322   1.1       jtc 
    323   1.1       jtc 		shellf("%s\n", p); /* POSIX doesn't say this is done... */
    324   1.1       jtc 		if ((p = q)) /* restore \n (trailing \n not restored) */
    325   1.1       jtc 			q[-1] = '\n';
    326   1.1       jtc 	}
    327   1.1       jtc 
    328   1.1       jtc 	/* Commands are executed here instead of pushing them onto the
    329   1.1       jtc 	 * input 'cause posix says the redirection and variable assignments
    330   1.1       jtc 	 * in
    331   1.1       jtc 	 *	X=y fc -e - 42 2> /dev/null
    332   1.1       jtc 	 * are to effect the repeated commands environment.
    333   1.1       jtc 	 */
    334   1.1       jtc 	/* XXX: source should not get trashed by this.. */
    335   1.1       jtc 	sold = source;
    336   1.1       jtc 	ret = command(cmd);
    337   1.1       jtc 	source = sold;
    338   1.1       jtc 	return ret;
    339   1.1       jtc }
    340   1.1       jtc 
    341   1.1       jtc static int
    342   1.9  christos hist_replace(hp, pat, rep, globalv)
    343   1.1       jtc 	char **hp;
    344   1.1       jtc 	const char *pat;
    345   1.1       jtc 	const char *rep;
    346   1.9  christos 	int globalv;
    347   1.1       jtc {
    348   1.1       jtc 	char *line;
    349   1.1       jtc 
    350   1.1       jtc 	if (!pat)
    351   1.1       jtc 		line = str_save(*hp, ATEMP);
    352   1.1       jtc 	else {
    353   1.1       jtc 		char *s, *s1;
    354   1.1       jtc 		int pat_len = strlen(pat);
    355   1.1       jtc 		int rep_len = strlen(rep);
    356   1.1       jtc 		int len;
    357   1.1       jtc 		XString xs;
    358   1.1       jtc 		char *xp;
    359   1.1       jtc 		int any_subst = 0;
    360   1.1       jtc 
    361   1.1       jtc 		Xinit(xs, xp, 128, ATEMP);
    362   1.1       jtc 		for (s = *hp; (s1 = strstr(s, pat))
    363   1.9  christos 			      && (!any_subst || globalv) ; s = s1 + pat_len)
    364   1.1       jtc 		{
    365   1.1       jtc 			any_subst = 1;
    366   1.1       jtc 			len = s1 - s;
    367   1.1       jtc 			XcheckN(xs, xp, len + rep_len);
    368   1.1       jtc 			memcpy(xp, s, len);		/* first part */
    369   1.1       jtc 			xp += len;
    370   1.1       jtc 			memcpy(xp, rep, rep_len);	/* replacement */
    371   1.1       jtc 			xp += rep_len;
    372   1.1       jtc 		}
    373   1.1       jtc 		if (!any_subst) {
    374   1.1       jtc 			bi_errorf("substitution failed");
    375   1.1       jtc 			return 1;
    376   1.1       jtc 		}
    377   1.1       jtc 		len = strlen(s) + 1;
    378   1.1       jtc 		XcheckN(xs, xp, len);
    379   1.1       jtc 		memcpy(xp, s, len);
    380   1.1       jtc 		xp += len;
    381   1.1       jtc 		line = Xclose(xs, xp);
    382   1.1       jtc 	}
    383   1.1       jtc 	return hist_execute(line);
    384   1.1       jtc }
    385   1.1       jtc 
    386   1.1       jtc /*
    387   1.1       jtc  * get pointer to history given pattern
    388   1.1       jtc  * pattern is a number or string
    389   1.1       jtc  */
    390   1.1       jtc static char **
    391   1.1       jtc hist_get(str, approx, allow_cur)
    392   1.1       jtc 	const char *str;
    393   1.1       jtc 	int approx;
    394   1.1       jtc 	int allow_cur;
    395   1.1       jtc {
    396   1.1       jtc 	char **hp = (char **) 0;
    397   1.1       jtc 	int n;
    398   1.1       jtc 
    399   1.1       jtc 	if (getn(str, &n)) {
    400   1.1       jtc 		hp = histptr + (n < 0 ? n : (n - hist_source->line));
    401   1.6  jdolecek 		if (hp < histlist) {
    402   1.1       jtc 			if (approx)
    403   1.1       jtc 				hp = hist_get_oldest();
    404   1.1       jtc 			else {
    405   1.1       jtc 				bi_errorf("%s: not in history", str);
    406   1.1       jtc 				hp = (char **) 0;
    407   1.1       jtc 			}
    408   1.1       jtc 		} else if (hp > histptr) {
    409   1.1       jtc 			if (approx)
    410   1.1       jtc 				hp = hist_get_newest(allow_cur);
    411   1.1       jtc 			else {
    412   1.1       jtc 				bi_errorf("%s: not in history", str);
    413   1.1       jtc 				hp = (char **) 0;
    414   1.1       jtc 			}
    415   1.1       jtc 		} else if (!allow_cur && hp == histptr) {
    416   1.1       jtc 			bi_errorf("%s: invalid range", str);
    417   1.1       jtc 			hp = (char **) 0;
    418   1.1       jtc 		}
    419   1.1       jtc 	} else {
    420   1.1       jtc 		int anchored = *str == '?' ? (++str, 0) : 1;
    421   1.1       jtc 
    422   1.1       jtc 		/* the -1 is to avoid the current fc command */
    423   1.6  jdolecek 		n = findhist(histptr - histlist - 1, 0, str, anchored);
    424   1.1       jtc 		if (n < 0) {
    425   1.1       jtc 			bi_errorf("%s: not in history", str);
    426   1.1       jtc 			hp = (char **) 0;
    427   1.1       jtc 		} else
    428   1.6  jdolecek 			hp = &histlist[n];
    429   1.1       jtc 	}
    430   1.1       jtc 	return hp;
    431   1.1       jtc }
    432   1.1       jtc 
    433   1.1       jtc /* Return a pointer to the newest command in the history */
    434   1.1       jtc static char **
    435   1.1       jtc hist_get_newest(allow_cur)
    436   1.1       jtc 	int allow_cur;
    437   1.1       jtc {
    438   1.6  jdolecek 	if (histptr < histlist || (!allow_cur && histptr == histlist)) {
    439   1.1       jtc 		bi_errorf("no history (yet)");
    440   1.1       jtc 		return (char **) 0;
    441   1.1       jtc 	}
    442   1.1       jtc 	if (allow_cur)
    443   1.1       jtc 		return histptr;
    444   1.1       jtc 	return histptr - 1;
    445   1.1       jtc }
    446   1.1       jtc 
    447   1.1       jtc /* Return a pointer to the newest command in the history */
    448   1.1       jtc static char **
    449   1.1       jtc hist_get_oldest()
    450   1.1       jtc {
    451   1.6  jdolecek 	if (histptr <= histlist) {
    452   1.1       jtc 		bi_errorf("no history (yet)");
    453   1.1       jtc 		return (char **) 0;
    454   1.1       jtc 	}
    455   1.6  jdolecek 	return histlist;
    456   1.1       jtc }
    457   1.1       jtc 
    458   1.1       jtc /******************************/
    459   1.1       jtc /* Back up over last histsave */
    460   1.1       jtc /******************************/
    461   1.1       jtc static void
    462   1.1       jtc histbackup()
    463   1.1       jtc {
    464   1.1       jtc 	static int last_line = -1;
    465   1.1       jtc 
    466   1.6  jdolecek 	if (histptr >= histlist && last_line != hist_source->line) {
    467   1.1       jtc 		hist_source->line--;
    468   1.1       jtc 		afree((void*)*histptr, APERM);
    469   1.1       jtc 		histptr--;
    470   1.1       jtc 		last_line = hist_source->line;
    471   1.1       jtc 	}
    472   1.1       jtc }
    473   1.1       jtc 
    474   1.1       jtc /*
    475   1.1       jtc  * Return the current position.
    476   1.1       jtc  */
    477   1.1       jtc char **
    478   1.1       jtc histpos()
    479   1.1       jtc {
    480   1.1       jtc 	return current;
    481   1.1       jtc }
    482   1.1       jtc 
    483   1.1       jtc int
    484   1.1       jtc histN()
    485   1.1       jtc {
    486   1.1       jtc 	return curpos;
    487   1.1       jtc }
    488   1.1       jtc 
    489   1.1       jtc int
    490   1.1       jtc histnum(n)
    491   1.1       jtc 	int	n;
    492   1.1       jtc {
    493   1.6  jdolecek 	int	last = histptr - histlist;
    494   1.1       jtc 
    495   1.1       jtc 	if (n < 0 || n >= last) {
    496   1.1       jtc 		current = histptr;
    497   1.1       jtc 		curpos = last;
    498   1.1       jtc 		return last;
    499   1.4   hubertf 	} else {
    500   1.6  jdolecek 		current = &histlist[n];
    501   1.1       jtc 		curpos = n;
    502   1.1       jtc 		return n;
    503   1.1       jtc 	}
    504   1.1       jtc }
    505   1.1       jtc 
    506   1.1       jtc /*
    507   1.7   mycroft  * This will become unnecessary if hist_get is modified to allow
    508   1.1       jtc  * searching from positions other than the end, and in either
    509   1.1       jtc  * direction.
    510   1.1       jtc  */
    511   1.1       jtc int
    512   1.1       jtc findhist(start, fwd, str, anchored)
    513   1.1       jtc 	int	start;
    514   1.1       jtc 	int	fwd;
    515   1.1       jtc 	const char  *str;
    516   1.1       jtc 	int	anchored;
    517   1.1       jtc {
    518   1.1       jtc 	char	**hp;
    519   1.6  jdolecek 	int	maxhist = histptr - histlist;
    520   1.1       jtc 	int	incr = fwd ? 1 : -1;
    521   1.1       jtc 	int	len = strlen(str);
    522   1.1       jtc 
    523   1.1       jtc 	if (start < 0 || start >= maxhist)
    524   1.1       jtc 		start = maxhist;
    525   1.1       jtc 
    526   1.6  jdolecek 	hp = &histlist[start];
    527   1.6  jdolecek 	for (; hp >= histlist && hp <= histptr; hp += incr)
    528   1.1       jtc 		if ((anchored && strncmp(*hp, str, len) == 0)
    529   1.1       jtc 		    || (!anchored && strstr(*hp, str)))
    530   1.6  jdolecek 			return hp - histlist;
    531   1.1       jtc 
    532   1.1       jtc 	return -1;
    533   1.1       jtc }
    534   1.1       jtc 
    535   1.1       jtc /*
    536   1.1       jtc  *	set history
    537   1.1       jtc  *	this means reallocating the dataspace
    538   1.1       jtc  */
    539   1.1       jtc void
    540   1.1       jtc sethistsize(n)
    541   1.1       jtc 	int n;
    542   1.1       jtc {
    543   1.1       jtc 	if (n > 0 && n != histsize) {
    544   1.6  jdolecek 		int cursize = histptr - histlist;
    545   1.1       jtc 
    546   1.1       jtc 		/* save most recent history */
    547   1.1       jtc 		if (n < cursize) {
    548   1.6  jdolecek 			memmove(histlist, histptr - n, n * sizeof(char *));
    549   1.1       jtc 			cursize = n;
    550   1.1       jtc 		}
    551   1.1       jtc 
    552   1.6  jdolecek 		histlist = (char **)aresize(histlist, n*sizeof(char *), APERM);
    553   1.1       jtc 
    554   1.1       jtc 		histsize = n;
    555   1.6  jdolecek 		histptr = histlist + cursize;
    556   1.1       jtc 	}
    557   1.1       jtc }
    558   1.1       jtc 
    559   1.1       jtc /*
    560   1.1       jtc  *	set history file
    561   1.1       jtc  *	This can mean reloading/resetting/starting history file
    562   1.1       jtc  *	maintenance
    563   1.1       jtc  */
    564   1.1       jtc void
    565   1.1       jtc sethistfile(name)
    566   1.1       jtc 	const char *name;
    567   1.1       jtc {
    568   1.1       jtc 	/* if not started then nothing to do */
    569   1.1       jtc 	if (hstarted == 0)
    570   1.1       jtc 		return;
    571   1.1       jtc 
    572   1.1       jtc 	/* if the name is the same as the name we have */
    573   1.1       jtc 	if (hname && strcmp(hname, name) == 0)
    574   1.1       jtc 		return;
    575   1.1       jtc 
    576   1.1       jtc 	/*
    577   1.1       jtc 	 * its a new name - possibly
    578   1.1       jtc 	 */
    579   1.1       jtc # ifdef EASY_HISTORY
    580   1.1       jtc 	if (hname) {
    581   1.1       jtc 		afree(hname, APERM);
    582   1.1       jtc 		hname = NULL;
    583   1.1       jtc 	}
    584   1.1       jtc # else
    585   1.1       jtc 	if (histfd) {
    586   1.1       jtc 		/* yes the file is open */
    587   1.1       jtc 		(void) close(histfd);
    588   1.1       jtc 		histfd = 0;
    589   1.1       jtc 		hsize = 0;
    590   1.1       jtc 		afree(hname, APERM);
    591   1.1       jtc 		hname = NULL;
    592   1.1       jtc 		/* let's reset the history */
    593   1.6  jdolecek 		histptr = histlist - 1;
    594   1.1       jtc 		hist_source->line = 0;
    595   1.1       jtc 	}
    596   1.1       jtc # endif
    597   1.1       jtc 
    598   1.1       jtc 	hist_init(hist_source);
    599   1.1       jtc }
    600   1.1       jtc 
    601   1.1       jtc /*
    602   1.1       jtc  *	initialise the history vector
    603   1.1       jtc  */
    604   1.1       jtc void
    605   1.1       jtc init_histvec()
    606   1.1       jtc {
    607  1.11    plunky 	if (histlist == NULL) {
    608   1.1       jtc 		histsize = HISTORYSIZE;
    609   1.6  jdolecek 		histlist = (char **)alloc(histsize*sizeof (char *), APERM);
    610   1.6  jdolecek 		histptr = histlist - 1;
    611   1.1       jtc 	}
    612   1.1       jtc }
    613   1.1       jtc 
    614   1.1       jtc # ifdef EASY_HISTORY
    615   1.1       jtc /*
    616   1.1       jtc  * save command in history
    617   1.1       jtc  */
    618   1.1       jtc void
    619   1.1       jtc histsave(lno, cmd, dowrite)
    620   1.1       jtc 	int lno;	/* ignored (compatibility with COMPLEX_HISTORY) */
    621   1.1       jtc 	const char *cmd;
    622   1.1       jtc 	int dowrite;	/* ignored (compatibility with COMPLEX_HISTORY) */
    623   1.1       jtc {
    624   1.1       jtc 	register char **hp = histptr;
    625   1.1       jtc 	char *cp;
    626   1.1       jtc 
    627   1.6  jdolecek 	if (++hp >= histlist + histsize) { /* remove oldest command */
    628   1.6  jdolecek 		afree((void*)histlist[0], APERM);
    629   1.6  jdolecek 		memmove(histlist, histlist + 1,
    630   1.6  jdolecek 			sizeof(histlist[0]) * (histsize - 1));
    631   1.6  jdolecek 		hp = &histlist[histsize - 1];
    632   1.1       jtc 	}
    633   1.1       jtc 	*hp = str_save(cmd, APERM);
    634   1.1       jtc 	/* trash trailing newline but allow imbedded newlines */
    635   1.1       jtc 	cp = *hp + strlen(*hp);
    636   1.1       jtc 	if (cp > *hp && cp[-1] == '\n')
    637   1.1       jtc 		cp[-1] = '\0';
    638   1.1       jtc 	histptr = hp;
    639   1.1       jtc }
    640   1.1       jtc 
    641   1.1       jtc /*
    642   1.1       jtc  * Append an entry to the last saved command. Used for multiline
    643   1.1       jtc  * commands
    644   1.1       jtc  */
    645   1.1       jtc void
    646   1.4   hubertf histappend(cmd, nl_separate)
    647   1.1       jtc 	const char *cmd;
    648   1.4   hubertf 	int	nl_separate;
    649   1.1       jtc {
    650   1.1       jtc 	int	hlen, clen;
    651   1.1       jtc 	char	*p;
    652   1.1       jtc 
    653   1.1       jtc 	hlen = strlen(*histptr);
    654   1.1       jtc 	clen = strlen(cmd);
    655   1.1       jtc 	if (clen > 0 && cmd[clen-1] == '\n')
    656   1.1       jtc 		clen--;
    657   1.1       jtc 	p = *histptr = (char *) aresize(*histptr, hlen + clen + 2, APERM);
    658   1.1       jtc 	p += hlen;
    659   1.4   hubertf 	if (nl_separate)
    660   1.1       jtc 		*p++ = '\n';
    661   1.1       jtc 	memcpy(p, cmd, clen);
    662   1.1       jtc 	p[clen] = '\0';
    663   1.1       jtc }
    664   1.1       jtc 
    665   1.1       jtc /*
    666   1.1       jtc  * 92-04-25 <sjg@zen>
    667   1.1       jtc  * A simple history file implementation.
    668   1.1       jtc  * At present we only save the history when we exit.
    669   1.1       jtc  * This can cause problems when there are multiple shells are
    670   1.1       jtc  * running under the same user-id.  The last shell to exit gets
    671   1.1       jtc  * to save its history.
    672   1.1       jtc  */
    673   1.1       jtc void
    674   1.1       jtc hist_init(s)
    675   1.1       jtc 	Source *s;
    676   1.1       jtc {
    677   1.1       jtc 	char *f;
    678   1.1       jtc 	FILE *fh;
    679   1.1       jtc 
    680   1.1       jtc 	if (Flag(FTALKING) == 0)
    681   1.1       jtc 		return;
    682   1.1       jtc 
    683   1.1       jtc 	hstarted = 1;
    684   1.1       jtc 
    685   1.1       jtc 	hist_source = s;
    686   1.1       jtc 
    687   1.1       jtc 	if ((f = str_val(global("HISTFILE"))) == NULL || *f == '\0') {
    688   1.1       jtc # if 1 /* Don't use history file unless the user asks for it */
    689   1.1       jtc 		hname = NULL;
    690   1.1       jtc 		return;
    691   1.1       jtc # else
    692   1.1       jtc 		char *home = str_val(global("HOME"));
    693   1.1       jtc 		int len;
    694   1.1       jtc 
    695   1.1       jtc 		if (home == NULL)
    696   1.1       jtc 			home = null;
    697   1.1       jtc 		f = HISTFILE;
    698   1.1       jtc 		hname = alloc(len = strlen(home) + strlen(f) + 2, APERM);
    699   1.1       jtc 		shf_snprintf(hname, len, "%s/%s", home, f);
    700   1.1       jtc # endif
    701   1.1       jtc 	} else
    702   1.1       jtc 		hname = str_save(f, APERM);
    703   1.1       jtc 
    704   1.1       jtc 	if ((fh = fopen(hname, "r"))) {
    705   1.1       jtc 		int pos = 0, nread = 0;
    706   1.1       jtc 		int contin = 0;		/* continuation of previous command */
    707   1.1       jtc 		char *end;
    708   1.1       jtc 		char hline[LINE + 1];
    709   1.1       jtc 
    710   1.1       jtc 		while (1) {
    711   1.1       jtc 			if (pos >= nread) {
    712   1.1       jtc 				pos = 0;
    713   1.1       jtc 				nread = fread(hline, 1, LINE, fh);
    714   1.1       jtc 				if (nread <= 0)
    715   1.1       jtc 					break;
    716   1.1       jtc 				hline[nread] = '\0';
    717   1.1       jtc 			}
    718   1.1       jtc 			end = strchr(hline + pos, 0); /* will always succeed */
    719   1.1       jtc 			if (contin)
    720   1.1       jtc 				histappend(hline + pos, 0);
    721   1.1       jtc 			else {
    722   1.1       jtc 				hist_source->line++;
    723   1.1       jtc 				histsave(0, hline + pos, 0);
    724   1.1       jtc 			}
    725   1.1       jtc 			pos = end - hline + 1;
    726   1.1       jtc 			contin = end == &hline[nread];
    727   1.1       jtc 		}
    728   1.1       jtc 		fclose(fh);
    729   1.1       jtc 	}
    730   1.1       jtc }
    731   1.1       jtc 
    732   1.1       jtc /*
    733   1.1       jtc  * save our history.
    734   1.1       jtc  * We check that we do not have more than we are allowed.
    735   1.1       jtc  * If the history file is read-only we do nothing.
    736   1.1       jtc  * Handy for having all shells start with a useful history set.
    737   1.1       jtc  */
    738   1.1       jtc 
    739   1.1       jtc void
    740   1.1       jtc hist_finish()
    741   1.1       jtc {
    742   1.1       jtc   static int once;
    743  1.10       dsl   int fd;
    744   1.1       jtc   FILE *fh;
    745   1.1       jtc   register int i;
    746   1.1       jtc   register char **hp;
    747   1.1       jtc 
    748   1.1       jtc   if (once++)
    749   1.1       jtc     return;
    750  1.10       dsl   if (hname == NULL || hname[0] == 0)
    751  1.10       dsl     return;
    752  1.10       dsl 
    753   1.1       jtc   /* check how many we have */
    754   1.6  jdolecek   i = histptr - histlist;
    755   1.1       jtc   if (i >= histsize)
    756   1.1       jtc     hp = &histptr[-histsize];
    757   1.1       jtc   else
    758   1.6  jdolecek     hp = histlist;
    759  1.10       dsl 
    760  1.10       dsl   fd = open(hname, O_WRONLY | O_CREAT | O_TRUNC | O_EXLOCK, 0777);
    761  1.10       dsl   /* Remove anything written before we got the lock */
    762  1.10       dsl   ftruncate(fd, 0);
    763  1.10       dsl   if (fd >= 0 && (fh = fdopen(fd, "w"))) {
    764   1.1       jtc     for (i = 0; hp + i <= histptr && hp[i]; i++)
    765   1.1       jtc       fprintf(fh, "%s%c", hp[i], '\0');
    766   1.1       jtc     fclose(fh);
    767   1.1       jtc   }
    768   1.1       jtc }
    769   1.1       jtc 
    770   1.1       jtc # else /* EASY_HISTORY */
    771   1.1       jtc 
    772   1.1       jtc /*
    773   1.1       jtc  *	Routines added by Peter Collinson BSDI(Europe)/Hillside Systems to
    774   1.1       jtc  *	a) permit HISTSIZE to control number of lines of history stored
    775   1.1       jtc  *	b) maintain a physical history file
    776   1.1       jtc  *
    777   1.1       jtc  *	It turns out that there is a lot of ghastly hackery here
    778   1.1       jtc  */
    779   1.1       jtc 
    780   1.1       jtc 
    781   1.1       jtc /*
    782   1.1       jtc  * save command in history
    783   1.1       jtc  */
    784   1.1       jtc void
    785   1.1       jtc histsave(lno, cmd, dowrite)
    786   1.1       jtc 	int lno;
    787   1.1       jtc 	const char *cmd;
    788   1.1       jtc 	int dowrite;
    789   1.1       jtc {
    790   1.1       jtc 	register char **hp;
    791   1.1       jtc 	char *c, *cp;
    792   1.1       jtc 
    793   1.1       jtc 	c = str_save(cmd, APERM);
    794   1.1       jtc 	if ((cp = strchr(c, '\n')) != NULL)
    795   1.1       jtc 		*cp = '\0';
    796   1.1       jtc 
    797   1.1       jtc 	if (histfd && dowrite)
    798   1.1       jtc 		writehistfile(lno, c);
    799   1.1       jtc 
    800   1.1       jtc 	hp = histptr;
    801   1.1       jtc 
    802   1.6  jdolecek 	if (++hp >= histlist + histsize) { /* remove oldest command */
    803   1.6  jdolecek 		afree((void*)*histlist, APERM);
    804   1.6  jdolecek 		for (hp = histlist; hp < histlist + histsize - 1; hp++)
    805   1.1       jtc 			hp[0] = hp[1];
    806   1.1       jtc 	}
    807   1.1       jtc 	*hp = c;
    808   1.1       jtc 	histptr = hp;
    809   1.1       jtc }
    810   1.1       jtc 
    811   1.1       jtc /*
    812   1.1       jtc  *	Write history data to a file nominated by HISTFILE
    813   1.1       jtc  *	if HISTFILE is unset then history still happens, but
    814   1.1       jtc  *	the data is not written to a file
    815   1.1       jtc  *	All copies of ksh looking at the file will maintain the
    816   1.1       jtc  *	same history. This is ksh behaviour.
    817   1.1       jtc  *
    818   1.1       jtc  *	This stuff uses mmap()
    819   1.1       jtc  *	if your system ain't got it - then you'll have to undef HISTORYFILE
    820   1.1       jtc  */
    821   1.1       jtc 
    822   1.1       jtc /*
    823   1.1       jtc  *	Open a history file
    824   1.1       jtc  *	Format is:
    825   1.1       jtc  *	Bytes 1, 2: HMAGIC - just to check that we are dealing with
    826   1.1       jtc  *		    the correct object
    827   1.1       jtc  *	Then follows a number of stored commands
    828   1.1       jtc  *	Each command is
    829   1.1       jtc  *	<command byte><command number(4 bytes)><bytes><null>
    830   1.1       jtc  */
    831   1.1       jtc # define HMAGIC1		0xab
    832   1.1       jtc # define HMAGIC2		0xcd
    833   1.1       jtc # define COMMAND		0xff
    834   1.1       jtc 
    835   1.1       jtc void
    836   1.1       jtc hist_init(s)
    837   1.1       jtc 	Source *s;
    838   1.1       jtc {
    839   1.1       jtc 	unsigned char	*base;
    840   1.1       jtc 	int	lines;
    841   1.1       jtc 	int	fd;
    842   1.1       jtc 
    843   1.1       jtc 	if (Flag(FTALKING) == 0)
    844   1.1       jtc 		return;
    845   1.1       jtc 
    846   1.1       jtc 	hstarted = 1;
    847   1.1       jtc 
    848   1.1       jtc 	hist_source = s;
    849   1.1       jtc 
    850   1.1       jtc 	hname = str_val(global("HISTFILE"));
    851   1.1       jtc 	if (hname == NULL)
    852   1.1       jtc 		return;
    853   1.1       jtc 	hname = str_save(hname, APERM);
    854   1.1       jtc 
    855   1.1       jtc   retry:
    856   1.1       jtc 	/* we have a file and are interactive */
    857   1.1       jtc 	if ((fd = open(hname, O_RDWR|O_CREAT|O_APPEND, 0600)) < 0)
    858   1.1       jtc 		return;
    859   1.1       jtc 
    860   1.1       jtc 	histfd = savefd(fd, 0);
    861   1.1       jtc 
    862   1.1       jtc 	(void) flock(histfd, LOCK_EX);
    863   1.1       jtc 
    864   1.1       jtc 	hsize = lseek(histfd, 0L, SEEK_END);
    865   1.1       jtc 
    866   1.1       jtc 	if (hsize == 0) {
    867   1.1       jtc 		/* add magic */
    868   1.1       jtc 		if (sprinkle(histfd)) {
    869   1.1       jtc 			hist_finish();
    870   1.1       jtc 			return;
    871   1.1       jtc 		}
    872   1.1       jtc 	}
    873   1.1       jtc 	else if (hsize > 0) {
    874   1.1       jtc 		/*
    875   1.1       jtc 		 * we have some data
    876   1.1       jtc 		 */
    877   1.1       jtc 		base = (unsigned char *)mmap(0, hsize, PROT_READ, MAP_FLAGS, histfd, 0);
    878   1.1       jtc 		/*
    879   1.1       jtc 		 * check on its validity
    880   1.1       jtc 		 */
    881   1.7   mycroft 		if (base == MAP_FAILED || *base != HMAGIC1 || base[1] != HMAGIC2) {
    882   1.7   mycroft 			if (base != MAP_FAILED)
    883   1.1       jtc 				munmap((caddr_t)base, hsize);
    884   1.1       jtc 			hist_finish();
    885   1.1       jtc 			unlink(hname);
    886   1.1       jtc 			goto retry;
    887   1.1       jtc 		}
    888   1.1       jtc 		if (hsize > 2) {
    889   1.1       jtc 			lines = hist_count_lines(base+2, hsize-2);
    890   1.1       jtc 			if (lines > histsize) {
    891   1.1       jtc 				/* we need to make the file smaller */
    892   1.1       jtc 				if (hist_shrink(base, hsize))
    893   1.1       jtc 					unlink(hname);
    894   1.1       jtc 				munmap((caddr_t)base, hsize);
    895   1.1       jtc 				hist_finish();
    896   1.1       jtc 				goto retry;
    897   1.1       jtc 			}
    898   1.1       jtc 		}
    899   1.1       jtc 		histload(hist_source, base+2, hsize-2);
    900   1.1       jtc 		munmap((caddr_t)base, hsize);
    901   1.1       jtc 	}
    902   1.1       jtc 	(void) flock(histfd, LOCK_UN);
    903   1.1       jtc 	hsize = lseek(histfd, 0L, SEEK_END);
    904   1.1       jtc }
    905   1.1       jtc 
    906   1.1       jtc typedef enum state {
    907   1.1       jtc 	shdr,		/* expecting a header */
    908   1.1       jtc 	sline,		/* looking for a null byte to end the line */
    909   1.1       jtc 	sn1,		/* bytes 1 to 4 of a line no */
    910   1.7   mycroft 	sn2, sn3, sn4
    911   1.1       jtc } State;
    912   1.1       jtc 
    913   1.1       jtc static int
    914   1.1       jtc hist_count_lines(base, bytes)
    915   1.1       jtc 	register unsigned char *base;
    916   1.1       jtc 	register int bytes;
    917   1.1       jtc {
    918   1.1       jtc 	State state = shdr;
    919   1.7   mycroft 	int lines = 0;
    920   1.1       jtc 
    921   1.1       jtc 	while (bytes--) {
    922   1.1       jtc 		switch (state)
    923   1.1       jtc 		{
    924   1.1       jtc 		case shdr:
    925   1.1       jtc 			if (*base == COMMAND)
    926   1.1       jtc 				state = sn1;
    927   1.1       jtc 			break;
    928   1.1       jtc 		case sn1:
    929   1.1       jtc 			state = sn2; break;
    930   1.1       jtc 		case sn2:
    931   1.1       jtc 			state = sn3; break;
    932   1.1       jtc 		case sn3:
    933   1.1       jtc 			state = sn4; break;
    934   1.1       jtc 		case sn4:
    935   1.1       jtc 			state = sline; break;
    936   1.1       jtc 		case sline:
    937   1.1       jtc 			if (*base == '\0')
    938   1.1       jtc 				lines++, state = shdr;
    939   1.1       jtc 		}
    940   1.1       jtc 		base++;
    941   1.1       jtc 	}
    942   1.1       jtc 	return lines;
    943   1.1       jtc }
    944   1.1       jtc 
    945   1.1       jtc /*
    946   1.1       jtc  *	Shrink the history file to histsize lines
    947   1.1       jtc  */
    948   1.1       jtc static int
    949   1.1       jtc hist_shrink(oldbase, oldbytes)
    950   1.1       jtc 	unsigned char *oldbase;
    951   1.1       jtc 	int oldbytes;
    952   1.1       jtc {
    953   1.1       jtc 	int fd;
    954   1.1       jtc 	char	nfile[1024];
    955   1.1       jtc 	struct	stat statb;
    956   1.1       jtc 	unsigned char *nbase = oldbase;
    957   1.1       jtc 	int nbytes = oldbytes;
    958   1.1       jtc 
    959   1.1       jtc 	nbase = hist_skip_back(nbase, &nbytes, histsize);
    960   1.1       jtc 	if (nbase == NULL)
    961   1.1       jtc 		return 1;
    962   1.1       jtc 	if (nbase == oldbase)
    963   1.1       jtc 		return 0;
    964   1.1       jtc 
    965   1.1       jtc 	/*
    966   1.1       jtc 	 *	create temp file
    967   1.1       jtc 	 */
    968   1.1       jtc 	(void) shf_snprintf(nfile, sizeof(nfile), "%s.%d", hname, procpid);
    969   1.1       jtc 	if ((fd = creat(nfile, 0600)) < 0)
    970   1.1       jtc 		return 1;
    971   1.1       jtc 
    972   1.1       jtc 	if (sprinkle(fd)) {
    973   1.1       jtc 		close(fd);
    974   1.1       jtc 		unlink(nfile);
    975   1.1       jtc 		return 1;
    976   1.1       jtc 	}
    977   1.1       jtc 	if (write(fd, nbase, nbytes) != nbytes) {
    978   1.1       jtc 		close(fd);
    979   1.1       jtc 		unlink(nfile);
    980   1.1       jtc 		return 1;
    981   1.1       jtc 	}
    982   1.1       jtc 	/*
    983   1.1       jtc 	 *	worry about who owns this file
    984   1.1       jtc 	 */
    985   1.1       jtc 	if (fstat(histfd, &statb) >= 0)
    986   1.1       jtc 		fchown(fd, statb.st_uid, statb.st_gid);
    987   1.1       jtc 	close(fd);
    988   1.1       jtc 
    989   1.1       jtc 	/*
    990   1.1       jtc 	 *	rename
    991   1.1       jtc 	 */
    992   1.1       jtc 	if (rename(nfile, hname) < 0)
    993   1.1       jtc 		return 1;
    994   1.1       jtc 	return 0;
    995   1.1       jtc }
    996   1.1       jtc 
    997   1.1       jtc 
    998   1.1       jtc /*
    999   1.1       jtc  *	find a pointer to the data `no' back from the end of the file
   1000   1.1       jtc  *	return the pointer and the number of bytes left
   1001   1.1       jtc  */
   1002   1.1       jtc static unsigned char *
   1003   1.1       jtc hist_skip_back(base, bytes, no)
   1004   1.1       jtc 	unsigned char *base;
   1005   1.1       jtc 	int *bytes;
   1006   1.1       jtc 	int no;
   1007   1.1       jtc {
   1008   1.1       jtc 	register int lines = 0;
   1009   1.1       jtc 	register unsigned char *ep;
   1010   1.1       jtc 
   1011   1.1       jtc 	for (ep = base + *bytes; --ep > base; ) {
   1012   1.1       jtc 		/* this doesn't really work: the 4 byte line number that is
   1013   1.1       jtc 		 * encoded after the COMMAND byte can itself contain the
   1014   1.1       jtc 		 * COMMAND byte....
   1015   1.1       jtc 		 */
   1016   1.1       jtc 		for (; ep > base && *ep != COMMAND; ep--)
   1017   1.1       jtc 			;
   1018   1.1       jtc 		if (ep == base)
   1019   1.1       jtc 			break;
   1020   1.1       jtc 		if (++lines == no) {
   1021   1.1       jtc 			*bytes = *bytes - ((char *)ep - (char *)base);
   1022   1.1       jtc 			return ep;
   1023   1.1       jtc 		}
   1024   1.1       jtc 	}
   1025   1.1       jtc 	return NULL;
   1026   1.1       jtc }
   1027   1.1       jtc 
   1028   1.1       jtc /*
   1029   1.1       jtc  *	load the history structure from the stored data
   1030   1.1       jtc  */
   1031   1.1       jtc static void
   1032   1.1       jtc histload(s, base, bytes)
   1033   1.1       jtc 	Source *s;
   1034   1.1       jtc 	register unsigned char *base;
   1035   1.1       jtc 	register int bytes;
   1036   1.1       jtc {
   1037   1.1       jtc 	State state;
   1038   1.7   mycroft 	int	lno = 0;
   1039   1.7   mycroft 	unsigned char	*line = NULL;
   1040   1.1       jtc 
   1041   1.1       jtc 	for (state = shdr; bytes-- > 0; base++) {
   1042   1.1       jtc 		switch (state) {
   1043   1.1       jtc 		case shdr:
   1044   1.1       jtc 			if (*base == COMMAND)
   1045   1.1       jtc 				state = sn1;
   1046   1.1       jtc 			break;
   1047   1.1       jtc 		case sn1:
   1048   1.1       jtc 			lno = (((*base)&0xff)<<24);
   1049   1.1       jtc 			state = sn2;
   1050   1.1       jtc 			break;
   1051   1.1       jtc 		case sn2:
   1052   1.1       jtc 			lno |= (((*base)&0xff)<<16);
   1053   1.1       jtc 			state = sn3;
   1054   1.1       jtc 			break;
   1055   1.1       jtc 		case sn3:
   1056   1.1       jtc 			lno |= (((*base)&0xff)<<8);
   1057   1.1       jtc 			state = sn4;
   1058   1.1       jtc 			break;
   1059   1.1       jtc 		case sn4:
   1060   1.1       jtc 			lno |= (*base)&0xff;
   1061   1.1       jtc 			line = base+1;
   1062   1.1       jtc 			state = sline;
   1063   1.1       jtc 			break;
   1064   1.1       jtc 		case sline:
   1065   1.1       jtc 			if (*base == '\0') {
   1066   1.1       jtc 				/* worry about line numbers */
   1067   1.6  jdolecek 				if (histptr >= histlist && lno-1 != s->line) {
   1068   1.1       jtc 					/* a replacement ? */
   1069   1.1       jtc 					histinsert(s, lno, line);
   1070   1.1       jtc 				}
   1071   1.1       jtc 				else {
   1072   1.1       jtc 					s->line = lno;
   1073   1.1       jtc 					histsave(lno, (char *)line, 0);
   1074   1.1       jtc 				}
   1075   1.1       jtc 				state = shdr;
   1076   1.1       jtc 			}
   1077   1.1       jtc 		}
   1078   1.1       jtc 	}
   1079   1.1       jtc }
   1080   1.1       jtc 
   1081   1.1       jtc /*
   1082   1.1       jtc  *	Insert a line into the history at a specified number
   1083   1.1       jtc  */
   1084   1.1       jtc static void
   1085   1.1       jtc histinsert(s, lno, line)
   1086   1.1       jtc 	Source *s;
   1087   1.1       jtc 	int lno;
   1088   1.1       jtc 	unsigned char *line;
   1089   1.1       jtc {
   1090   1.1       jtc 	register char **hp;
   1091   1.1       jtc 
   1092   1.6  jdolecek 	if (lno >= s->line-(histptr-histlist) && lno <= s->line) {
   1093   1.1       jtc 		hp = &histptr[lno-s->line];
   1094   1.1       jtc 		if (*hp)
   1095   1.1       jtc 			afree((void*)*hp, APERM);
   1096   1.1       jtc 		*hp = str_save((char *)line, APERM);
   1097   1.1       jtc 	}
   1098   1.1       jtc }
   1099   1.1       jtc 
   1100   1.1       jtc /*
   1101   1.1       jtc  *	write a command to the end of the history file
   1102   1.1       jtc  *	This *MAY* seem easy but it's also necessary to check
   1103   1.1       jtc  *	that the history file has not changed in size.
   1104   1.1       jtc  *	If it has - then some other shell has written to it
   1105   1.1       jtc  *	and we should read those commands to update our history
   1106   1.1       jtc  */
   1107   1.1       jtc static void
   1108   1.1       jtc writehistfile(lno, cmd)
   1109   1.1       jtc 	int lno;
   1110   1.1       jtc 	char *cmd;
   1111   1.1       jtc {
   1112   1.1       jtc 	int	sizenow;
   1113   1.1       jtc 	unsigned char	*base;
   1114   1.1       jtc 	unsigned char	*new;
   1115   1.1       jtc 	int	bytes;
   1116   1.7   mycroft 	unsigned char	hdr[5];
   1117   1.1       jtc 
   1118   1.1       jtc 	(void) flock(histfd, LOCK_EX);
   1119   1.1       jtc 	sizenow = lseek(histfd, 0L, SEEK_END);
   1120   1.1       jtc 	if (sizenow != hsize) {
   1121   1.1       jtc 		/*
   1122   1.1       jtc 		 *	Things have changed
   1123   1.1       jtc 		 */
   1124   1.1       jtc 		if (sizenow > hsize) {
   1125   1.1       jtc 			/* someone has added some lines */
   1126   1.1       jtc 			bytes = sizenow - hsize;
   1127   1.1       jtc 			base = (unsigned char *)mmap(0, sizenow, PROT_READ, MAP_FLAGS, histfd, 0);
   1128   1.7   mycroft 			if (base == MAP_FAILED)
   1129   1.1       jtc 				goto bad;
   1130   1.1       jtc 			new = base + hsize;
   1131   1.1       jtc 			if (*new != COMMAND) {
   1132   1.1       jtc 				munmap((caddr_t)base, sizenow);
   1133   1.1       jtc 				goto bad;
   1134   1.1       jtc 			}
   1135   1.1       jtc 			hist_source->line--;
   1136   1.1       jtc 			histload(hist_source, new, bytes);
   1137   1.1       jtc 			hist_source->line++;
   1138   1.1       jtc 			lno = hist_source->line;
   1139   1.1       jtc 			munmap((caddr_t)base, sizenow);
   1140   1.1       jtc 			hsize = sizenow;
   1141   1.1       jtc 		} else {
   1142   1.1       jtc 			/* it has shrunk */
   1143   1.1       jtc 			/* but to what? */
   1144   1.1       jtc 			/* we'll give up for now */
   1145   1.1       jtc 			goto bad;
   1146   1.1       jtc 		}
   1147   1.1       jtc 	}
   1148   1.1       jtc 	/*
   1149   1.1       jtc 	 *	we can write our bit now
   1150   1.1       jtc 	 */
   1151   1.1       jtc 	hdr[0] = COMMAND;
   1152   1.1       jtc 	hdr[1] = (lno>>24)&0xff;
   1153   1.1       jtc 	hdr[2] = (lno>>16)&0xff;
   1154   1.1       jtc 	hdr[3] = (lno>>8)&0xff;
   1155   1.1       jtc 	hdr[4] = lno&0xff;
   1156   1.1       jtc 	(void) write(histfd, hdr, 5);
   1157   1.1       jtc 	(void) write(histfd, cmd, strlen(cmd)+1);
   1158   1.1       jtc 	hsize = lseek(histfd, 0L, SEEK_END);
   1159   1.1       jtc 	(void) flock(histfd, LOCK_UN);
   1160   1.1       jtc 	return;
   1161   1.1       jtc bad:
   1162   1.1       jtc 	hist_finish();
   1163   1.1       jtc }
   1164   1.1       jtc 
   1165   1.1       jtc void
   1166   1.1       jtc hist_finish()
   1167   1.1       jtc {
   1168   1.1       jtc 	(void) flock(histfd, LOCK_UN);
   1169   1.1       jtc 	(void) close(histfd);
   1170   1.1       jtc 	histfd = 0;
   1171   1.1       jtc }
   1172   1.1       jtc 
   1173   1.1       jtc /*
   1174   1.1       jtc  *	add magic to the history file
   1175   1.1       jtc  */
   1176   1.1       jtc static int
   1177   1.1       jtc sprinkle(fd)
   1178   1.1       jtc 	int fd;
   1179   1.1       jtc {
   1180   1.7   mycroft 	static unsigned char mag[] = { HMAGIC1, HMAGIC2 };
   1181   1.1       jtc 
   1182   1.1       jtc 	return(write(fd, mag, 2) != 2);
   1183   1.1       jtc }
   1184   1.1       jtc 
   1185   1.1       jtc # endif
   1186   1.1       jtc #else /* HISTORY */
   1187   1.1       jtc 
   1188   1.1       jtc /* No history to be compiled in: dummy routines to avoid lots more ifdefs */
   1189   1.1       jtc void
   1190   1.1       jtc init_histvec()
   1191   1.1       jtc {
   1192   1.1       jtc }
   1193   1.1       jtc void
   1194   1.1       jtc hist_init(s)
   1195   1.1       jtc 	Source *s;
   1196   1.1       jtc {
   1197   1.1       jtc }
   1198   1.1       jtc void
   1199   1.1       jtc hist_finish()
   1200   1.1       jtc {
   1201   1.1       jtc }
   1202   1.1       jtc void
   1203   1.1       jtc histsave(lno, cmd, dowrite)
   1204   1.1       jtc 	int lno;
   1205   1.1       jtc 	const char *cmd;
   1206   1.1       jtc 	int dowrite;
   1207   1.1       jtc {
   1208   1.1       jtc 	errorf("history not enabled");
   1209   1.1       jtc }
   1210   1.1       jtc #endif /* HISTORY */
   1211