b8ba871bd9
files, curses, db, regex etc that we already have). The other glue will follow shortly. Obtained from: Keith Bostic <bostic@bostic.com>
308 lines
6.1 KiB
C
308 lines
6.1 KiB
C
/*-
|
|
* Copyright (c) 1996
|
|
* Keith Bostic. All rights reserved.
|
|
*
|
|
* See the LICENSE file for redistribution information.
|
|
*/
|
|
|
|
#include "config.h"
|
|
|
|
#ifndef lint
|
|
static const char sccsid[] = "@(#)ip_read.c 8.3 (Berkeley) 9/24/96";
|
|
#endif /* not lint */
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/queue.h>
|
|
|
|
#include <bitstring.h>
|
|
#include <stdio.h>
|
|
#include <termios.h>
|
|
#include <time.h>
|
|
|
|
#include "../common/common.h"
|
|
#include "../ex/script.h"
|
|
#include "ip.h"
|
|
|
|
extern GS *__global_list;
|
|
|
|
typedef enum { INP_OK=0, INP_EOF, INP_ERR, INP_TIMEOUT } input_t;
|
|
|
|
static input_t ip_read __P((SCR *, IP_PRIVATE *, struct timeval *));
|
|
static int ip_resize __P((SCR *, size_t, size_t));
|
|
static int ip_trans __P((SCR *, IP_PRIVATE *, EVENT *));
|
|
|
|
/*
|
|
* ip_event --
|
|
* Return a single event.
|
|
*
|
|
* PUBLIC: int ip_event __P((SCR *, EVENT *, u_int32_t, int));
|
|
*/
|
|
int
|
|
ip_event(sp, evp, flags, ms)
|
|
SCR *sp;
|
|
EVENT *evp;
|
|
u_int32_t flags;
|
|
int ms;
|
|
{
|
|
IP_PRIVATE *ipp;
|
|
struct timeval t, *tp;
|
|
|
|
if (LF_ISSET(EC_INTERRUPT)) { /* XXX */
|
|
evp->e_event = E_TIMEOUT;
|
|
return (0);
|
|
}
|
|
|
|
ipp = sp == NULL ? GIPP(__global_list) : IPP(sp);
|
|
|
|
/* Discard the last command. */
|
|
if (ipp->iskip != 0) {
|
|
ipp->iblen -= ipp->iskip;
|
|
memmove(ipp->ibuf, ipp->ibuf + ipp->iskip, ipp->iblen);
|
|
ipp->iskip = 0;
|
|
}
|
|
|
|
/* Set timer. */
|
|
if (ms == 0)
|
|
tp = NULL;
|
|
else {
|
|
t.tv_sec = ms / 1000;
|
|
t.tv_usec = (ms % 1000) * 1000;
|
|
tp = &t;
|
|
}
|
|
|
|
/* Read input events. */
|
|
for (;;) {
|
|
switch (ip_read(sp, ipp, tp)) {
|
|
case INP_OK:
|
|
if (!ip_trans(sp, ipp, evp))
|
|
continue;
|
|
break;
|
|
case INP_EOF:
|
|
evp->e_event = E_EOF;
|
|
break;
|
|
case INP_ERR:
|
|
evp->e_event = E_ERR;
|
|
break;
|
|
case INP_TIMEOUT:
|
|
evp->e_event = E_TIMEOUT;
|
|
break;
|
|
default:
|
|
abort();
|
|
}
|
|
break;
|
|
}
|
|
return (0);
|
|
}
|
|
|
|
/*
|
|
* ip_read --
|
|
* Read characters from the input.
|
|
*/
|
|
static input_t
|
|
ip_read(sp, ipp, tp)
|
|
SCR *sp;
|
|
IP_PRIVATE *ipp;
|
|
struct timeval *tp;
|
|
{
|
|
struct timeval poll;
|
|
GS *gp;
|
|
SCR *tsp;
|
|
fd_set rdfd;
|
|
input_t rval;
|
|
size_t blen;
|
|
int maxfd, nr;
|
|
char *bp;
|
|
|
|
gp = sp == NULL ? __global_list : sp->gp;
|
|
bp = ipp->ibuf + ipp->iblen;
|
|
blen = sizeof(ipp->ibuf) - ipp->iblen;
|
|
|
|
/*
|
|
* 1: A read with an associated timeout, e.g., trying to complete
|
|
* a map sequence. If input exists, we fall into #2.
|
|
*/
|
|
FD_ZERO(&rdfd);
|
|
poll.tv_sec = 0;
|
|
poll.tv_usec = 0;
|
|
if (tp != NULL) {
|
|
FD_SET(ipp->i_fd, &rdfd);
|
|
switch (select(ipp->i_fd + 1,
|
|
&rdfd, NULL, NULL, tp == NULL ? &poll : tp)) {
|
|
case 0:
|
|
return (INP_TIMEOUT);
|
|
case -1:
|
|
goto err;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* 2: Wait for input.
|
|
*
|
|
* Select on the command input and scripting window file descriptors.
|
|
* It's ugly that we wait on scripting file descriptors here, but it's
|
|
* the only way to keep from locking out scripting windows.
|
|
*/
|
|
if (sp != NULL && F_ISSET(gp, G_SCRWIN)) {
|
|
loop: FD_ZERO(&rdfd);
|
|
FD_SET(ipp->i_fd, &rdfd);
|
|
maxfd = ipp->i_fd;
|
|
for (tsp = gp->dq.cqh_first;
|
|
tsp != (void *)&gp->dq; tsp = tsp->q.cqe_next)
|
|
if (F_ISSET(sp, SC_SCRIPT)) {
|
|
FD_SET(sp->script->sh_master, &rdfd);
|
|
if (sp->script->sh_master > maxfd)
|
|
maxfd = sp->script->sh_master;
|
|
}
|
|
switch (select(maxfd + 1, &rdfd, NULL, NULL, NULL)) {
|
|
case 0:
|
|
abort();
|
|
case -1:
|
|
goto err;
|
|
default:
|
|
break;
|
|
}
|
|
if (!FD_ISSET(ipp->i_fd, &rdfd)) {
|
|
if (sscr_input(sp))
|
|
return (INP_ERR);
|
|
goto loop;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* 3: Read the input.
|
|
*/
|
|
switch (nr = read(ipp->i_fd, bp, blen)) {
|
|
case 0: /* EOF. */
|
|
rval = INP_EOF;
|
|
break;
|
|
case -1: /* Error or interrupt. */
|
|
err: rval = INP_ERR;
|
|
msgq(sp, M_SYSERR, "input");
|
|
break;
|
|
default: /* Input characters. */
|
|
ipp->iblen += nr;
|
|
rval = INP_OK;
|
|
break;
|
|
}
|
|
return (rval);
|
|
}
|
|
|
|
/*
|
|
* ip_trans --
|
|
* Translate messages into events.
|
|
*/
|
|
static int
|
|
ip_trans(sp, ipp, evp)
|
|
SCR *sp;
|
|
IP_PRIVATE *ipp;
|
|
EVENT *evp;
|
|
{
|
|
u_int32_t val1, val2;
|
|
|
|
switch (ipp->ibuf[0]) {
|
|
case IPO_EOF:
|
|
evp->e_event = E_EOF;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
case IPO_ERR:
|
|
evp->e_event = E_ERR;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
case IPO_INTERRUPT:
|
|
evp->e_event = E_INTERRUPT;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
case IPO_QUIT:
|
|
evp->e_event = E_QUIT;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
case IPO_RESIZE:
|
|
if (ipp->iblen < IPO_CODE_LEN + IPO_INT_LEN * 2)
|
|
return (0);
|
|
evp->e_event = E_WRESIZE;
|
|
memcpy(&val1, ipp->ibuf + IPO_CODE_LEN, IPO_INT_LEN);
|
|
val1 = ntohl(val1);
|
|
memcpy(&val2,
|
|
ipp->ibuf + IPO_CODE_LEN + IPO_INT_LEN, IPO_INT_LEN);
|
|
val2 = ntohl(val2);
|
|
ip_resize(sp, val1, val2);
|
|
ipp->iskip = IPO_CODE_LEN + IPO_INT_LEN * 2;
|
|
return (1);
|
|
case IPO_SIGHUP:
|
|
evp->e_event = E_SIGHUP;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
case IPO_SIGTERM:
|
|
evp->e_event = E_SIGTERM;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
case IPO_STRING:
|
|
evp->e_event = E_STRING;
|
|
string: if (ipp->iblen < IPO_CODE_LEN + IPO_INT_LEN)
|
|
return (0);
|
|
memcpy(&val1, ipp->ibuf + IPO_CODE_LEN, IPO_INT_LEN);
|
|
val1 = ntohl(val1);
|
|
if (ipp->iblen < IPO_CODE_LEN + IPO_INT_LEN + val1)
|
|
return (0);
|
|
ipp->iskip = IPO_CODE_LEN + IPO_INT_LEN + val1;
|
|
evp->e_csp = ipp->ibuf + IPO_CODE_LEN + IPO_INT_LEN;
|
|
evp->e_len = val1;
|
|
return (1);
|
|
case IPO_WRITE:
|
|
evp->e_event = E_WRITE;
|
|
ipp->iskip = IPO_CODE_LEN;
|
|
return (1);
|
|
default:
|
|
/*
|
|
* XXX: Protocol is out of sync?
|
|
*/
|
|
abort();
|
|
}
|
|
/* NOTREACHED */
|
|
}
|
|
|
|
/*
|
|
* ip_resize --
|
|
* Reset the options for a resize event.
|
|
*/
|
|
static int
|
|
ip_resize(sp, lines, columns)
|
|
SCR *sp;
|
|
size_t lines, columns;
|
|
{
|
|
GS *gp;
|
|
ARGS *argv[2], a, b;
|
|
char b1[1024];
|
|
|
|
/*
|
|
* XXX
|
|
* The IP screen has to know the lines and columns before anything
|
|
* else happens. So, we may not have a valid SCR pointer, and we
|
|
* have to deal with that.
|
|
*/
|
|
if (sp == NULL) {
|
|
gp = __global_list;
|
|
OG_VAL(gp, GO_LINES) = OG_D_VAL(gp, GO_LINES) = lines;
|
|
OG_VAL(gp, GO_COLUMNS) = OG_D_VAL(gp, GO_COLUMNS) = columns;
|
|
return (0);
|
|
}
|
|
|
|
a.bp = b1;
|
|
b.bp = NULL;
|
|
a.len = b.len = 0;
|
|
argv[0] = &a;
|
|
argv[1] = &b;
|
|
|
|
(void)snprintf(b1, sizeof(b1), "lines=%lu", (u_long)lines);
|
|
a.len = strlen(b1);
|
|
if (opts_set(sp, argv, NULL))
|
|
return (1);
|
|
(void)snprintf(b1, sizeof(b1), "columns=%lu", (u_long)columns);
|
|
a.len = strlen(b1);
|
|
if (opts_set(sp, argv, NULL))
|
|
return (1);
|
|
return (0);
|
|
}
|