- Fix for possible unset uid/gid in toproto - Fix for default mtree style - Update libelf - Importing libexecinfo - Resynchronize GCC, mpc, gmp, mpfr - build.sh: Replace params with show-params. This has been done as the make target has been renamed in the same way, while a new target named params has been added. This new target generates a file containing all the parameters, instead of printing it on the console. - Update test48 with new etc/services (Fix by Ben Gras <ben@minix3.org) get getservbyport() out of the inner loop Change-Id: Ie6ad5226fa2621ff9f0dee8782ea48f9443d2091
210 lines
4.2 KiB
C
210 lines
4.2 KiB
C
/* $NetBSD: ip_trans.c,v 1.3 2013/11/27 17:53:00 christos Exp $ */
|
|
/*-
|
|
* Copyright (c) 1996
|
|
* Keith Bostic. All rights reserved.
|
|
*
|
|
* See the LICENSE file for redistribution information.
|
|
*/
|
|
|
|
#include "config.h"
|
|
|
|
#ifndef lint
|
|
static const char sccsid[] = "Id: ip_trans.c,v 8.18 2001/06/25 15:19:25 skimo Exp (Berkeley) Date: 2001/06/25 15:19:25 ";
|
|
#endif /* not lint */
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/queue.h>
|
|
#ifdef HAVE_SYS_SELECT_H
|
|
#include <sys/select.h>
|
|
#endif
|
|
|
|
#include <bitstring.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
#include <netinet/in.h>
|
|
|
|
#ifdef __STDC__
|
|
#include <stdarg.h>
|
|
#else
|
|
#include <varargs.h>
|
|
#endif
|
|
|
|
#include "../common/common.h"
|
|
#include "ip.h"
|
|
#include "ipc_def.h"
|
|
|
|
static char ibuf[2048]; /* Input buffer. */
|
|
static size_t ibuf_len; /* Length of current input. */
|
|
|
|
extern IPFUNLIST const ipfuns[];
|
|
|
|
/*
|
|
* vi_input --
|
|
* Read from the vi message queue.
|
|
*
|
|
* PUBLIC: int vi_input __P((IPVIWIN *, int));
|
|
*/
|
|
int
|
|
vi_input(IPVIWIN *ipviwin, int fd)
|
|
{
|
|
ssize_t nr;
|
|
|
|
/* Read waiting vi messages and translate to X calls. */
|
|
switch (nr = read(fd, ibuf + ibuf_len, sizeof(ibuf) - ibuf_len)) {
|
|
case 0:
|
|
return (0);
|
|
case -1:
|
|
return (-1);
|
|
default:
|
|
break;
|
|
}
|
|
ibuf_len += nr;
|
|
|
|
/* Parse to data end or partial message. */
|
|
(void)vi_translate(ipviwin, ibuf, &ibuf_len, NULL);
|
|
|
|
return (ibuf_len > 0);
|
|
}
|
|
|
|
/*
|
|
* vi_wsend --
|
|
* Construct and send an IP buffer, and wait for an answer.
|
|
*
|
|
* PUBLIC: int vi_wsend __P((IPVIWIN*, char *, IP_BUF *));
|
|
*/
|
|
int
|
|
vi_wsend(IPVIWIN *ipviwin, char *fmt, IP_BUF *ipbp)
|
|
{
|
|
fd_set rdfd;
|
|
ssize_t nr;
|
|
|
|
if (vi_send(ipviwin->ofd, fmt, ipbp))
|
|
return (1);
|
|
|
|
FD_ZERO(&rdfd);
|
|
ipbp->code = CODE_OOB;
|
|
|
|
for (;;) {
|
|
FD_SET(ipviwin->ifd, &rdfd);
|
|
if (select(ipviwin->ifd + 1, &rdfd, NULL, NULL, NULL) != 0)
|
|
return (-1);
|
|
|
|
/* Read waiting vi messages and translate to X calls. */
|
|
switch (nr =
|
|
read(ipviwin->ifd, ibuf + ibuf_len, sizeof(ibuf) - ibuf_len)) {
|
|
case 0:
|
|
return (0);
|
|
case -1:
|
|
return (-1);
|
|
default:
|
|
break;
|
|
}
|
|
ibuf_len += nr;
|
|
|
|
/* Parse to data end or partial message. */
|
|
(void)vi_translate(ipviwin, ibuf, &ibuf_len, ipbp);
|
|
|
|
if (ipbp->code != CODE_OOB)
|
|
break;
|
|
}
|
|
return (0);
|
|
}
|
|
|
|
/*
|
|
* vi_translate --
|
|
* Translate vi messages into function calls.
|
|
*
|
|
* PUBLIC: int vi_translate __P((IPVIWIN *, char *, size_t *, IP_BUF *));
|
|
*/
|
|
int
|
|
vi_translate(IPVIWIN *ipviwin, char *bp, size_t *lenp, IP_BUF *ipbp)
|
|
{
|
|
IP_BUF ipb;
|
|
size_t len, needlen;
|
|
u_int32_t *vp;
|
|
const char *fmt;
|
|
char *p, *s_bp;
|
|
const char **vsp;
|
|
IPFunc fun;
|
|
|
|
memset(&ipb, 0, sizeof(ipb));
|
|
for (s_bp = bp, len = *lenp; len > 0;) {
|
|
fmt = ipfuns[(ipb.code = bp[0])-1].format;
|
|
|
|
p = bp + IPO_CODE_LEN;
|
|
needlen = IPO_CODE_LEN;
|
|
for (; *fmt != '\0'; ++fmt)
|
|
switch (*fmt) {
|
|
case '1': /* Value #1. */
|
|
vp = &ipb.val1;
|
|
goto value;
|
|
case '2': /* Value #2. */
|
|
vp = &ipb.val2;
|
|
goto value;
|
|
case '3': /* Value #3. */
|
|
vp = &ipb.val3;
|
|
value: needlen += IPO_INT_LEN;
|
|
if (len < needlen)
|
|
goto partial;
|
|
memcpy(vp, p, IPO_INT_LEN);
|
|
*vp = ntohl(*vp);
|
|
p += IPO_INT_LEN;
|
|
break;
|
|
case 'a': /* String #1. */
|
|
vp = &ipb.len1;
|
|
vsp = &ipb.str1;
|
|
goto string;
|
|
case 'b': /* String #2. */
|
|
vp = &ipb.len2;
|
|
vsp = &ipb.str2;
|
|
string: needlen += IPO_INT_LEN;
|
|
if (len < needlen)
|
|
goto partial;
|
|
memcpy(vp, p, IPO_INT_LEN);
|
|
*vp = ntohl(*vp);
|
|
p += IPO_INT_LEN;
|
|
needlen += *vp;
|
|
if (len < needlen)
|
|
goto partial;
|
|
*vsp = p;
|
|
p += *vp;
|
|
break;
|
|
}
|
|
bp += needlen;
|
|
len -= needlen;
|
|
|
|
/*
|
|
* XXX
|
|
* Protocol error!?!?
|
|
*/
|
|
if (ipb.code >= SI_EVENT_SUP) {
|
|
len = 0;
|
|
break;
|
|
}
|
|
|
|
/*
|
|
* If we're waiting for a reply and we got it, return it, and
|
|
* leave any unprocessed data in the buffer. If we got a reply
|
|
* and we're not waiting for one, discard it -- callers wait
|
|
* for responses.
|
|
*/
|
|
if (ipb.code == SI_REPLY) {
|
|
if (ipbp == NULL)
|
|
continue;
|
|
*ipbp = ipb;
|
|
break;
|
|
}
|
|
|
|
/* Call the underlying routine. */
|
|
fun = *(IPFunc *)
|
|
(((char *)ipviwin->si_ops)+ipfuns[ipb.code - 1].offset);
|
|
if (fun != NULL &&
|
|
ipfuns[ipb.code - 1].unmarshall(ipviwin, &ipb, fun))
|
|
break;
|
|
}
|
|
partial:
|
|
if ((*lenp = len) != 0)
|
|
memmove(s_bp, bp, len);
|
|
return (0);
|
|
}
|