18a16b7a1SPedro F. Giffuni /*-
28a16b7a1SPedro F. Giffuni * SPDX-License-Identifier: BSD-3-Clause
38a16b7a1SPedro F. Giffuni *
40559b331SSteve Price * Copyright (c) 1988, 1992 The University of Utah and the Center
50559b331SSteve Price * for Software Science (CSS).
60559b331SSteve Price * Copyright (c) 1992, 1993
70559b331SSteve Price * The Regents of the University of California. All rights reserved.
80559b331SSteve Price *
90559b331SSteve Price * This code is derived from software contributed to Berkeley by
100559b331SSteve Price * the Center for Software Science of the University of Utah Computer
110559b331SSteve Price * Science Department. CSS requests users of this software to return
120559b331SSteve Price * to css-dist@cs.utah.edu any improvements that they make and grant
130559b331SSteve Price * CSS redistribution rights.
140559b331SSteve Price *
150559b331SSteve Price * Redistribution and use in source and binary forms, with or without
160559b331SSteve Price * modification, are permitted provided that the following conditions
170559b331SSteve Price * are met:
180559b331SSteve Price * 1. Redistributions of source code must retain the above copyright
190559b331SSteve Price * notice, this list of conditions and the following disclaimer.
200559b331SSteve Price * 2. Redistributions in binary form must reproduce the above copyright
210559b331SSteve Price * notice, this list of conditions and the following disclaimer in the
220559b331SSteve Price * documentation and/or other materials provided with the distribution.
235efaea4cSChristian Brueffer * 3. Neither the name of the University nor the names of its contributors
240559b331SSteve Price * may be used to endorse or promote products derived from this software
250559b331SSteve Price * without specific prior written permission.
260559b331SSteve Price *
270559b331SSteve Price * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
280559b331SSteve Price * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
290559b331SSteve Price * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
300559b331SSteve Price * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
310559b331SSteve Price * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
320559b331SSteve Price * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
330559b331SSteve Price * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
340559b331SSteve Price * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
350559b331SSteve Price * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
360559b331SSteve Price * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
370559b331SSteve Price * SUCH DAMAGE.
380559b331SSteve Price *
390559b331SSteve Price * From: Utah Hdr: rmpproto.c 3.1 92/07/06
400559b331SSteve Price * Author: Jeff Forys, University of Utah CSS
410559b331SSteve Price */
420559b331SSteve Price
430559b331SSteve Price #include <sys/param.h>
440559b331SSteve Price #include <sys/time.h>
4540905e90SStefan Farfeleder #include <netinet/in.h>
460559b331SSteve Price
470559b331SSteve Price #include <errno.h>
480559b331SSteve Price #include <fcntl.h>
490559b331SSteve Price #include <stdio.h>
500559b331SSteve Price #include <string.h>
510559b331SSteve Price #include <syslog.h>
520559b331SSteve Price #include <unistd.h>
530559b331SSteve Price #include "defs.h"
540559b331SSteve Price
550559b331SSteve Price /*
560559b331SSteve Price ** ProcessPacket -- determine packet type and do what's required.
570559b331SSteve Price **
580559b331SSteve Price ** An RMP BOOT packet has been received. Look at the type field
590559b331SSteve Price ** and process Boot Requests, Read Requests, and Boot Complete
600559b331SSteve Price ** packets. Any other type will be dropped with a warning msg.
610559b331SSteve Price **
620559b331SSteve Price ** Parameters:
630559b331SSteve Price ** rconn - the new connection
640559b331SSteve Price ** client - list of files available to this host
650559b331SSteve Price **
660559b331SSteve Price ** Returns:
670559b331SSteve Price ** Nothing.
680559b331SSteve Price **
690559b331SSteve Price ** Side Effects:
700559b331SSteve Price ** - If this is a valid boot request, it will be added to
710559b331SSteve Price ** the linked list of outstanding requests (RmpConns).
720559b331SSteve Price ** - If this is a valid boot complete, its associated
730559b331SSteve Price ** entry in RmpConns will be deleted.
740559b331SSteve Price ** - Also, unless we run out of memory, a reply will be
750559b331SSteve Price ** sent to the host that sent the packet.
760559b331SSteve Price */
770559b331SSteve Price void
ProcessPacket(RMPCONN * rconn,CLIENT * client)78266ebcd3SWarner Losh ProcessPacket(RMPCONN *rconn, CLIENT *client)
790559b331SSteve Price {
800559b331SSteve Price struct rmp_packet *rmp;
810559b331SSteve Price RMPCONN *rconnout;
820559b331SSteve Price
830559b331SSteve Price rmp = &rconn->rmp; /* cache pointer to RMP packet */
840559b331SSteve Price
850559b331SSteve Price switch(rmp->r_type) { /* do what we came here to do */
860559b331SSteve Price case RMP_BOOT_REQ: /* boot request */
870559b331SSteve Price if ((rconnout = NewConn(rconn)) == NULL)
880559b331SSteve Price return;
890559b331SSteve Price
900559b331SSteve Price /*
910559b331SSteve Price * If the Session ID is 0xffff, this is a "probe"
920559b331SSteve Price * packet and we do not want to add the connection
930559b331SSteve Price * to the linked list of active connections. There
940559b331SSteve Price * are two types of probe packets, if the Sequence
950559b331SSteve Price * Number is 0 they want to know our host name, o/w
960559b331SSteve Price * they want the name of the file associated with
970559b331SSteve Price * the number spec'd by the Sequence Number.
980559b331SSteve Price *
990559b331SSteve Price * If this is an actual boot request, open the file
1000559b331SSteve Price * and send a reply. If SendBootRepl() does not
1010559b331SSteve Price * return 0, add the connection to the linked list
1020559b331SSteve Price * of active connections, otherwise delete it since
1030559b331SSteve Price * an error was encountered.
1040559b331SSteve Price */
1050559b331SSteve Price if (ntohs(rmp->r_brq.rmp_session) == RMP_PROBESID) {
1060559b331SSteve Price if (WORDZE(rmp->r_brq.rmp_seqno))
1070559b331SSteve Price (void) SendServerID(rconnout);
1080559b331SSteve Price else
1090559b331SSteve Price (void) SendFileNo(rmp, rconnout,
1100559b331SSteve Price client? client->files:
1110559b331SSteve Price BootFiles);
1120559b331SSteve Price FreeConn(rconnout);
1130559b331SSteve Price } else {
1140559b331SSteve Price if (SendBootRepl(rmp, rconnout,
1150559b331SSteve Price client? client->files: BootFiles))
1160559b331SSteve Price AddConn(rconnout);
1170559b331SSteve Price else
1180559b331SSteve Price FreeConn(rconnout);
1190559b331SSteve Price }
1200559b331SSteve Price break;
1210559b331SSteve Price
1220559b331SSteve Price case RMP_BOOT_REPL: /* boot reply (not valid) */
1230559b331SSteve Price syslog(LOG_WARNING, "%s: sent a boot reply",
1240559b331SSteve Price EnetStr(rconn));
1250559b331SSteve Price break;
1260559b331SSteve Price
1270559b331SSteve Price case RMP_READ_REQ: /* read request */
1280559b331SSteve Price /*
1290559b331SSteve Price * Send a portion of the boot file.
1300559b331SSteve Price */
1310559b331SSteve Price (void) SendReadRepl(rconn);
1320559b331SSteve Price break;
1330559b331SSteve Price
1340559b331SSteve Price case RMP_READ_REPL: /* read reply (not valid) */
1350559b331SSteve Price syslog(LOG_WARNING, "%s: sent a read reply",
1360559b331SSteve Price EnetStr(rconn));
1370559b331SSteve Price break;
1380559b331SSteve Price
1390559b331SSteve Price case RMP_BOOT_DONE: /* boot complete */
1400559b331SSteve Price /*
1410559b331SSteve Price * Remove the entry from the linked list of active
1420559b331SSteve Price * connections.
1430559b331SSteve Price */
1440559b331SSteve Price (void) BootDone(rconn);
1450559b331SSteve Price break;
1460559b331SSteve Price
1470559b331SSteve Price default: /* unknown RMP packet type */
1480559b331SSteve Price syslog(LOG_WARNING, "%s: unknown packet type (%u)",
1490559b331SSteve Price EnetStr(rconn), rmp->r_type);
1500559b331SSteve Price }
1510559b331SSteve Price }
1520559b331SSteve Price
1530559b331SSteve Price /*
1540559b331SSteve Price ** SendServerID -- send our host name to who ever requested it.
1550559b331SSteve Price **
1560559b331SSteve Price ** Parameters:
1570559b331SSteve Price ** rconn - the reply packet to be formatted.
1580559b331SSteve Price **
1590559b331SSteve Price ** Returns:
1600559b331SSteve Price ** 1 on success, 0 on failure.
1610559b331SSteve Price **
1620559b331SSteve Price ** Side Effects:
1630559b331SSteve Price ** none.
1640559b331SSteve Price */
1650559b331SSteve Price int
SendServerID(RMPCONN * rconn)166266ebcd3SWarner Losh SendServerID(RMPCONN *rconn)
1670559b331SSteve Price {
16811fe7d5eSSteve Price struct rmp_packet *rpl;
16911fe7d5eSSteve Price char *src, *dst;
17011fe7d5eSSteve Price u_int8_t *size;
1710559b331SSteve Price
1720559b331SSteve Price rpl = &rconn->rmp; /* cache ptr to RMP packet */
1730559b331SSteve Price
1740559b331SSteve Price /*
1750559b331SSteve Price * Set up assorted fields in reply packet.
1760559b331SSteve Price */
1770559b331SSteve Price rpl->r_brpl.rmp_type = RMP_BOOT_REPL;
1780559b331SSteve Price rpl->r_brpl.rmp_retcode = RMP_E_OKAY;
1790559b331SSteve Price ZEROWORD(rpl->r_brpl.rmp_seqno);
1800559b331SSteve Price rpl->r_brpl.rmp_session = 0;
1810559b331SSteve Price rpl->r_brpl.rmp_version = htons(RMP_VERSION);
1820559b331SSteve Price
1830559b331SSteve Price size = &rpl->r_brpl.rmp_flnmsize; /* ptr to length of host name */
1840559b331SSteve Price
1850559b331SSteve Price /*
1860559b331SSteve Price * Copy our host name into the reply packet incrementing the
1870559b331SSteve Price * length as we go. Stop at RMP_HOSTLEN or the first dot.
1880559b331SSteve Price */
1890559b331SSteve Price src = MyHost;
1900559b331SSteve Price dst = (char *) &rpl->r_brpl.rmp_flnm;
1910559b331SSteve Price for (*size = 0; *size < RMP_HOSTLEN; (*size)++) {
1920559b331SSteve Price if (*src == '.' || *src == '\0')
1930559b331SSteve Price break;
1940559b331SSteve Price *dst++ = *src++;
1950559b331SSteve Price }
1960559b331SSteve Price
1970559b331SSteve Price rconn->rmplen = RMPBOOTSIZE(*size); /* set packet length */
1980559b331SSteve Price
1990559b331SSteve Price return(SendPacket(rconn)); /* send packet */
2000559b331SSteve Price }
2010559b331SSteve Price
2020559b331SSteve Price /*
2030559b331SSteve Price ** SendFileNo -- send the name of a bootable file to the requester.
2040559b331SSteve Price **
2050559b331SSteve Price ** Parameters:
2060559b331SSteve Price ** req - RMP BOOT packet containing the request.
2070559b331SSteve Price ** rconn - the reply packet to be formatted.
2080559b331SSteve Price ** filelist - list of files available to the requester.
2090559b331SSteve Price **
2100559b331SSteve Price ** Returns:
2110559b331SSteve Price ** 1 on success, 0 on failure.
2120559b331SSteve Price **
2130559b331SSteve Price ** Side Effects:
2140559b331SSteve Price ** none.
2150559b331SSteve Price */
2160559b331SSteve Price int
SendFileNo(struct rmp_packet * req,RMPCONN * rconn,char * filelist[])217266ebcd3SWarner Losh SendFileNo(struct rmp_packet *req, RMPCONN *rconn, char *filelist[])
2180559b331SSteve Price {
21911fe7d5eSSteve Price struct rmp_packet *rpl;
22011fe7d5eSSteve Price char *src, *dst;
22111fe7d5eSSteve Price u_int8_t *size;
22211fe7d5eSSteve Price int i;
2230559b331SSteve Price
2240559b331SSteve Price GETWORD(req->r_brpl.rmp_seqno, i); /* SeqNo is really FileNo */
2250559b331SSteve Price rpl = &rconn->rmp; /* cache ptr to RMP packet */
2260559b331SSteve Price
2270559b331SSteve Price /*
2280559b331SSteve Price * Set up assorted fields in reply packet.
2290559b331SSteve Price */
2300559b331SSteve Price rpl->r_brpl.rmp_type = RMP_BOOT_REPL;
2310559b331SSteve Price PUTWORD(i, rpl->r_brpl.rmp_seqno);
2320559b331SSteve Price i--;
2330559b331SSteve Price rpl->r_brpl.rmp_session = 0;
2340559b331SSteve Price rpl->r_brpl.rmp_version = htons(RMP_VERSION);
2350559b331SSteve Price
2360559b331SSteve Price size = &rpl->r_brpl.rmp_flnmsize; /* ptr to length of filename */
2370559b331SSteve Price *size = 0; /* init length to zero */
2380559b331SSteve Price
2390559b331SSteve Price /*
2400559b331SSteve Price * Copy the file name into the reply packet incrementing the
2410559b331SSteve Price * length as we go. Stop at end of string or when RMPBOOTDATA
2420559b331SSteve Price * characters have been copied. Also, set return code to
2430559b331SSteve Price * indicate success or "no more files".
2440559b331SSteve Price */
2450559b331SSteve Price if (i < C_MAXFILE && filelist[i] != NULL) {
2460559b331SSteve Price src = filelist[i];
2470559b331SSteve Price dst = (char *)&rpl->r_brpl.rmp_flnm;
2480559b331SSteve Price for (; *src && *size < RMPBOOTDATA; (*size)++) {
2490559b331SSteve Price if (*src == '\0')
2500559b331SSteve Price break;
2510559b331SSteve Price *dst++ = *src++;
2520559b331SSteve Price }
2530559b331SSteve Price rpl->r_brpl.rmp_retcode = RMP_E_OKAY;
2540559b331SSteve Price } else
2550559b331SSteve Price rpl->r_brpl.rmp_retcode = RMP_E_NODFLT;
2560559b331SSteve Price
2570559b331SSteve Price rconn->rmplen = RMPBOOTSIZE(*size); /* set packet length */
2580559b331SSteve Price
2590559b331SSteve Price return(SendPacket(rconn)); /* send packet */
2600559b331SSteve Price }
2610559b331SSteve Price
2620559b331SSteve Price /*
2630559b331SSteve Price ** SendBootRepl -- open boot file and respond to boot request.
2640559b331SSteve Price **
2650559b331SSteve Price ** Parameters:
2660559b331SSteve Price ** req - RMP BOOT packet containing the request.
2670559b331SSteve Price ** rconn - the reply packet to be formatted.
2680559b331SSteve Price ** filelist - list of files available to the requester.
2690559b331SSteve Price **
2700559b331SSteve Price ** Returns:
2710559b331SSteve Price ** 1 on success, 0 on failure.
2720559b331SSteve Price **
2730559b331SSteve Price ** Side Effects:
2740559b331SSteve Price ** none.
2750559b331SSteve Price */
2760559b331SSteve Price int
SendBootRepl(struct rmp_packet * req,RMPCONN * rconn,char * filelist[])277266ebcd3SWarner Losh SendBootRepl(struct rmp_packet *req, RMPCONN *rconn, char *filelist[])
2780559b331SSteve Price {
2790559b331SSteve Price int retval;
2800559b331SSteve Price char *filename, filepath[RMPBOOTDATA+1];
2810559b331SSteve Price RMPCONN *oldconn;
28211fe7d5eSSteve Price struct rmp_packet *rpl;
28311fe7d5eSSteve Price char *src, *dst1, *dst2;
28411fe7d5eSSteve Price u_int8_t i;
2850559b331SSteve Price
2860559b331SSteve Price /*
2870559b331SSteve Price * If another connection already exists, delete it since we
2880559b331SSteve Price * are obviously starting again.
2890559b331SSteve Price */
2900559b331SSteve Price if ((oldconn = FindConn(rconn)) != NULL) {
2910559b331SSteve Price syslog(LOG_WARNING, "%s: dropping existing connection",
2920559b331SSteve Price EnetStr(oldconn));
2930559b331SSteve Price RemoveConn(oldconn);
2940559b331SSteve Price }
2950559b331SSteve Price
2960559b331SSteve Price rpl = &rconn->rmp; /* cache ptr to RMP packet */
2970559b331SSteve Price
2980559b331SSteve Price /*
2990559b331SSteve Price * Set up assorted fields in reply packet.
3000559b331SSteve Price */
3010559b331SSteve Price rpl->r_brpl.rmp_type = RMP_BOOT_REPL;
3020559b331SSteve Price COPYWORD(req->r_brq.rmp_seqno, rpl->r_brpl.rmp_seqno);
3030559b331SSteve Price rpl->r_brpl.rmp_session = htons(GenSessID());
3040559b331SSteve Price rpl->r_brpl.rmp_version = htons(RMP_VERSION);
3050559b331SSteve Price rpl->r_brpl.rmp_flnmsize = req->r_brq.rmp_flnmsize;
3060559b331SSteve Price
3070559b331SSteve Price /*
3080559b331SSteve Price * Copy file name to `filepath' string, and into reply packet.
3090559b331SSteve Price */
3100559b331SSteve Price src = &req->r_brq.rmp_flnm;
3110559b331SSteve Price dst1 = filepath;
3120559b331SSteve Price dst2 = &rpl->r_brpl.rmp_flnm;
3130559b331SSteve Price for (i = 0; i < req->r_brq.rmp_flnmsize; i++)
3140559b331SSteve Price *dst1++ = *dst2++ = *src++;
3150559b331SSteve Price *dst1 = '\0';
3160559b331SSteve Price
3170559b331SSteve Price /*
3180559b331SSteve Price * If we are booting HP-UX machines, their secondary loader will
3190559b331SSteve Price * ask for files like "/hp-ux". As a security measure, we do not
3200559b331SSteve Price * allow boot files to lay outside the boot directory (unless they
3210559b331SSteve Price * are purposely link'd out. So, make `filename' become the path-
3220559b331SSteve Price * stripped file name and spoof the client into thinking that it
3230559b331SSteve Price * really got what it wanted.
3240559b331SSteve Price */
325*fe1b3370SDimitry Andric filename = strrchr(filepath,'/');
326*fe1b3370SDimitry Andric filename = filename? filename + 1: filepath;
3270559b331SSteve Price
3280559b331SSteve Price /*
3290559b331SSteve Price * Check that this is a valid boot file name.
3300559b331SSteve Price */
3310559b331SSteve Price for (i = 0; i < C_MAXFILE && filelist[i] != NULL; i++)
3320559b331SSteve Price if (STREQN(filename, filelist[i]))
3330559b331SSteve Price goto match;
3340559b331SSteve Price
3350559b331SSteve Price /*
3360559b331SSteve Price * Invalid boot file name, set error and send reply packet.
3370559b331SSteve Price */
3380559b331SSteve Price rpl->r_brpl.rmp_retcode = RMP_E_NOFILE;
3390559b331SSteve Price retval = 0;
3400559b331SSteve Price goto sendpkt;
3410559b331SSteve Price
3420559b331SSteve Price match:
3430559b331SSteve Price /*
3440559b331SSteve Price * This is a valid boot file. Open the file and save the file
3450559b331SSteve Price * descriptor associated with this connection and set success
3460559b331SSteve Price * indication. If the file couldnt be opened, set error:
3470559b331SSteve Price * "no such file or dir" - RMP_E_NOFILE
3480559b331SSteve Price * "file table overflow" - RMP_E_BUSY
3490559b331SSteve Price * "too many open files" - RMP_E_BUSY
3500559b331SSteve Price * anything else - RMP_E_OPENFILE
3510559b331SSteve Price */
3520559b331SSteve Price if ((rconn->bootfd = open(filename, O_RDONLY, 0600)) < 0) {
3530559b331SSteve Price rpl->r_brpl.rmp_retcode = (errno == ENOENT)? RMP_E_NOFILE:
3540559b331SSteve Price (errno == EMFILE || errno == ENFILE)? RMP_E_BUSY:
3550559b331SSteve Price RMP_E_OPENFILE;
3560559b331SSteve Price retval = 0;
3570559b331SSteve Price } else {
3580559b331SSteve Price rpl->r_brpl.rmp_retcode = RMP_E_OKAY;
3590559b331SSteve Price retval = 1;
3600559b331SSteve Price }
3610559b331SSteve Price
3620559b331SSteve Price sendpkt:
3630559b331SSteve Price syslog(LOG_INFO, "%s: request to boot %s (%s)",
3640559b331SSteve Price EnetStr(rconn), filename, retval? "granted": "denied");
3650559b331SSteve Price
3660559b331SSteve Price rconn->rmplen = RMPBOOTSIZE(rpl->r_brpl.rmp_flnmsize);
3670559b331SSteve Price
3680559b331SSteve Price return (retval & SendPacket(rconn));
3690559b331SSteve Price }
3700559b331SSteve Price
3710559b331SSteve Price /*
3720559b331SSteve Price ** SendReadRepl -- send a portion of the boot file to the requester.
3730559b331SSteve Price **
3740559b331SSteve Price ** Parameters:
3750559b331SSteve Price ** rconn - the reply packet to be formatted.
3760559b331SSteve Price **
3770559b331SSteve Price ** Returns:
3780559b331SSteve Price ** 1 on success, 0 on failure.
3790559b331SSteve Price **
3800559b331SSteve Price ** Side Effects:
3810559b331SSteve Price ** none.
3820559b331SSteve Price */
3830559b331SSteve Price int
SendReadRepl(RMPCONN * rconn)384266ebcd3SWarner Losh SendReadRepl(RMPCONN *rconn)
3850559b331SSteve Price {
3860559b331SSteve Price int retval = 0;
3870559b331SSteve Price RMPCONN *oldconn;
38811fe7d5eSSteve Price struct rmp_packet *rpl, *req;
38911fe7d5eSSteve Price int size = 0;
3900559b331SSteve Price int madeconn = 0;
3910559b331SSteve Price
3920559b331SSteve Price /*
3931acf0dbaSUlrich Spörlein * Find the old connection. If one doesn't exist, create one only
3940559b331SSteve Price * to return the error code.
3950559b331SSteve Price */
3960559b331SSteve Price if ((oldconn = FindConn(rconn)) == NULL) {
3970559b331SSteve Price if ((oldconn = NewConn(rconn)) == NULL)
3980559b331SSteve Price return(0);
3990559b331SSteve Price syslog(LOG_ERR, "SendReadRepl: no active connection (%s)",
4000559b331SSteve Price EnetStr(rconn));
4010559b331SSteve Price madeconn++;
4020559b331SSteve Price }
4030559b331SSteve Price
4040559b331SSteve Price req = &rconn->rmp; /* cache ptr to request packet */
4050559b331SSteve Price rpl = &oldconn->rmp; /* cache ptr to reply packet */
4060559b331SSteve Price
4070559b331SSteve Price if (madeconn) { /* no active connection above; abort */
4080559b331SSteve Price rpl->r_rrpl.rmp_retcode = RMP_E_ABORT;
4090559b331SSteve Price retval = 1;
4100559b331SSteve Price goto sendpkt;
4110559b331SSteve Price }
4120559b331SSteve Price
4130559b331SSteve Price /*
4140559b331SSteve Price * Make sure Session ID's match.
4150559b331SSteve Price */
4160559b331SSteve Price if (ntohs(req->r_rrq.rmp_session) !=
4170559b331SSteve Price ((rpl->r_type == RMP_BOOT_REPL)? ntohs(rpl->r_brpl.rmp_session):
4180559b331SSteve Price ntohs(rpl->r_rrpl.rmp_session))) {
4190559b331SSteve Price syslog(LOG_ERR, "SendReadRepl: bad session id (%s)",
4200559b331SSteve Price EnetStr(rconn));
4210559b331SSteve Price rpl->r_rrpl.rmp_retcode = RMP_E_BADSID;
4220559b331SSteve Price retval = 1;
4230559b331SSteve Price goto sendpkt;
4240559b331SSteve Price }
4250559b331SSteve Price
4260559b331SSteve Price /*
4270559b331SSteve Price * If the requester asks for more data than we can fit,
4280559b331SSteve Price * silently clamp the request size down to RMPREADDATA.
4290559b331SSteve Price *
4300559b331SSteve Price * N.B. I do not know if this is "legal", however it seems
4310559b331SSteve Price * to work. This is necessary for bpfwrite() on machines
4320559b331SSteve Price * with MCLBYTES less than 1514.
4330559b331SSteve Price */
4340559b331SSteve Price if (ntohs(req->r_rrq.rmp_size) > RMPREADDATA)
4350559b331SSteve Price req->r_rrq.rmp_size = htons(RMPREADDATA);
4360559b331SSteve Price
4370559b331SSteve Price /*
4380559b331SSteve Price * Position read head on file according to info in request packet.
4390559b331SSteve Price */
4400559b331SSteve Price GETWORD(req->r_rrq.rmp_offset, size);
441e10471bbSKris Kennaway if (lseek(oldconn->bootfd, (off_t)size, SEEK_SET) < 0) {
4420559b331SSteve Price syslog(LOG_ERR, "SendReadRepl: lseek: %m (%s)",
4430559b331SSteve Price EnetStr(rconn));
4440559b331SSteve Price rpl->r_rrpl.rmp_retcode = RMP_E_ABORT;
4450559b331SSteve Price retval = 1;
4460559b331SSteve Price goto sendpkt;
4470559b331SSteve Price }
4480559b331SSteve Price
4490559b331SSteve Price /*
4500559b331SSteve Price * Read data directly into reply packet.
4510559b331SSteve Price */
4520559b331SSteve Price if ((size = read(oldconn->bootfd, &rpl->r_rrpl.rmp_data,
4530559b331SSteve Price (int) ntohs(req->r_rrq.rmp_size))) <= 0) {
4540559b331SSteve Price if (size < 0) {
4550559b331SSteve Price syslog(LOG_ERR, "SendReadRepl: read: %m (%s)",
4560559b331SSteve Price EnetStr(rconn));
4570559b331SSteve Price rpl->r_rrpl.rmp_retcode = RMP_E_ABORT;
4580559b331SSteve Price } else {
4590559b331SSteve Price rpl->r_rrpl.rmp_retcode = RMP_E_EOF;
4600559b331SSteve Price }
4610559b331SSteve Price retval = 1;
4620559b331SSteve Price goto sendpkt;
4630559b331SSteve Price }
4640559b331SSteve Price
4650559b331SSteve Price /*
4660559b331SSteve Price * Set success indication.
4670559b331SSteve Price */
4680559b331SSteve Price rpl->r_rrpl.rmp_retcode = RMP_E_OKAY;
4690559b331SSteve Price
4700559b331SSteve Price sendpkt:
4710559b331SSteve Price /*
4720559b331SSteve Price * Set up assorted fields in reply packet.
4730559b331SSteve Price */
4740559b331SSteve Price rpl->r_rrpl.rmp_type = RMP_READ_REPL;
4750559b331SSteve Price COPYWORD(req->r_rrq.rmp_offset, rpl->r_rrpl.rmp_offset);
4760559b331SSteve Price rpl->r_rrpl.rmp_session = req->r_rrq.rmp_session;
4770559b331SSteve Price
4780559b331SSteve Price oldconn->rmplen = RMPREADSIZE(size); /* set size of packet */
4790559b331SSteve Price
4800559b331SSteve Price retval &= SendPacket(oldconn); /* send packet */
4810559b331SSteve Price
4820559b331SSteve Price if (madeconn) /* clean up after ourself */
4830559b331SSteve Price FreeConn(oldconn);
4840559b331SSteve Price
4850559b331SSteve Price return (retval);
4860559b331SSteve Price }
4870559b331SSteve Price
4880559b331SSteve Price /*
4890559b331SSteve Price ** BootDone -- free up memory allocated for a connection.
4900559b331SSteve Price **
4910559b331SSteve Price ** Parameters:
4920559b331SSteve Price ** rconn - incoming boot complete packet.
4930559b331SSteve Price **
4940559b331SSteve Price ** Returns:
4950559b331SSteve Price ** 1 on success, 0 on failure.
4960559b331SSteve Price **
4970559b331SSteve Price ** Side Effects:
4980559b331SSteve Price ** none.
4990559b331SSteve Price */
5000559b331SSteve Price int
BootDone(RMPCONN * rconn)501266ebcd3SWarner Losh BootDone(RMPCONN *rconn)
5020559b331SSteve Price {
5030559b331SSteve Price RMPCONN *oldconn;
5040559b331SSteve Price struct rmp_packet *rpl;
5050559b331SSteve Price
5060559b331SSteve Price /*
5071acf0dbaSUlrich Spörlein * If we can't find the connection, ignore the request.
5080559b331SSteve Price */
5090559b331SSteve Price if ((oldconn = FindConn(rconn)) == NULL) {
5100559b331SSteve Price syslog(LOG_ERR, "BootDone: no existing connection (%s)",
5110559b331SSteve Price EnetStr(rconn));
5120559b331SSteve Price return(0);
5130559b331SSteve Price }
5140559b331SSteve Price
5150559b331SSteve Price rpl = &oldconn->rmp; /* cache ptr to RMP packet */
5160559b331SSteve Price
5170559b331SSteve Price /*
5180559b331SSteve Price * Make sure Session ID's match.
5190559b331SSteve Price */
5200559b331SSteve Price if (ntohs(rconn->rmp.r_rrq.rmp_session) !=
5210559b331SSteve Price ((rpl->r_type == RMP_BOOT_REPL)? ntohs(rpl->r_brpl.rmp_session):
5220559b331SSteve Price ntohs(rpl->r_rrpl.rmp_session))) {
5230559b331SSteve Price syslog(LOG_ERR, "BootDone: bad session id (%s)",
5240559b331SSteve Price EnetStr(rconn));
5250559b331SSteve Price return(0);
5260559b331SSteve Price }
5270559b331SSteve Price
5280559b331SSteve Price RemoveConn(oldconn); /* remove connection */
5290559b331SSteve Price
5300559b331SSteve Price syslog(LOG_INFO, "%s: boot complete", EnetStr(rconn));
5310559b331SSteve Price
5320559b331SSteve Price return(1);
5330559b331SSteve Price }
5340559b331SSteve Price
5350559b331SSteve Price /*
5360559b331SSteve Price ** SendPacket -- send an RMP packet to a remote host.
5370559b331SSteve Price **
5380559b331SSteve Price ** Parameters:
5390559b331SSteve Price ** rconn - packet to be sent.
5400559b331SSteve Price **
5410559b331SSteve Price ** Returns:
5420559b331SSteve Price ** 1 on success, 0 on failure.
5430559b331SSteve Price **
5440559b331SSteve Price ** Side Effects:
5450559b331SSteve Price ** none.
5460559b331SSteve Price */
5470559b331SSteve Price int
SendPacket(RMPCONN * rconn)548266ebcd3SWarner Losh SendPacket(RMPCONN *rconn)
5490559b331SSteve Price {
5500559b331SSteve Price /*
5510559b331SSteve Price * Set Ethernet Destination address to Source (BPF and the enet
5520559b331SSteve Price * driver will take care of getting our source address set).
5530559b331SSteve Price */
55411fe7d5eSSteve Price memmove((char *)&rconn->rmp.hp_hdr.daddr[0],
55511fe7d5eSSteve Price (char *)&rconn->rmp.hp_hdr.saddr[0], RMP_ADDRLEN);
5560559b331SSteve Price rconn->rmp.hp_hdr.len = htons(rconn->rmplen - sizeof(struct hp_hdr));
5570559b331SSteve Price
5580559b331SSteve Price /*
5590559b331SSteve Price * Reverse 802.2/HP Extended Source & Destination Access Pts.
5600559b331SSteve Price */
5610559b331SSteve Price rconn->rmp.hp_llc.dxsap = htons(HPEXT_SXSAP);
5620559b331SSteve Price rconn->rmp.hp_llc.sxsap = htons(HPEXT_DXSAP);
5630559b331SSteve Price
5640559b331SSteve Price /*
5650559b331SSteve Price * Last time this connection was active.
5660559b331SSteve Price */
567902d9eafSEd Schouten (void)gettimeofday(&rconn->tstamp, NULL);
5680559b331SSteve Price
5690559b331SSteve Price if (DbgFp != NULL) /* display packet */
5700559b331SSteve Price DispPkt(rconn,DIR_SENT);
5710559b331SSteve Price
5720559b331SSteve Price /*
5730559b331SSteve Price * Send RMP packet to remote host.
5740559b331SSteve Price */
5750559b331SSteve Price return(BpfWrite(rconn));
5760559b331SSteve Price }
577