xref: /freebsd/libexec/rbootd/rmpproto.c (revision a6fe717c2a876105123214c05176cd74106fb94b)
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