diff options
Diffstat (limited to 'package/mopd/src/mopd')
| -rw-r--r-- | package/mopd/src/mopd/Makefile | 24 | ||||
| -rw-r--r-- | package/mopd/src/mopd/TODO | 1 | ||||
| -rw-r--r-- | package/mopd/src/mopd/mopd.8 | 109 | ||||
| -rw-r--r-- | package/mopd/src/mopd/mopd.c | 216 | ||||
| -rw-r--r-- | package/mopd/src/mopd/process.c | 684 | ||||
| -rw-r--r-- | package/mopd/src/mopd/process.h | 45 |
6 files changed, 1079 insertions, 0 deletions
diff --git a/package/mopd/src/mopd/Makefile b/package/mopd/src/mopd/Makefile new file mode 100644 index 000000000..1f88c946e --- /dev/null +++ b/package/mopd/src/mopd/Makefile @@ -0,0 +1,24 @@ +CC?= +OBJS=mopd.o process.o +INCL=-I../ -I../common +LIBS=../common/libcommon.a + +all: mopd + +mopd: ${OBJS} version.o $(LIBS) + $(CC) -o mopd version.o ${OBJS} ${LIBS} + +.c.o: .c + $(CC) -c $(CFLAGS) ${INCL} $< + +clean: + rm -f *.o *~ mopd VERSION version.* + +version.o: version.c +version.c version.h: + ln -sf ../common/VERSION VERSION + rm -f version.c ; sed 's/.*/char version[] = "&";/' VERSION > version.c + set `sed 's/\([0-9]*\)\.\([0-9]*\).*/\1 \2/' VERSION` ; \ + { echo '#define VERSION_MAJOR' $$1 ; \ + echo '#define VERSION_MINOR' $$2 ; } > version.h + diff --git a/package/mopd/src/mopd/TODO b/package/mopd/src/mopd/TODO new file mode 100644 index 000000000..720b58d75 --- /dev/null +++ b/package/mopd/src/mopd/TODO @@ -0,0 +1 @@ +Change code to send hostname instead of 'ipc'. diff --git a/package/mopd/src/mopd/mopd.8 b/package/mopd/src/mopd/mopd.8 new file mode 100644 index 000000000..41163ed60 --- /dev/null +++ b/package/mopd/src/mopd/mopd.8 @@ -0,0 +1,109 @@ +.\" $NetBSD: mopd.8,v 1.2 1997/03/25 03:07:48 thorpej Exp $ +.\" +.\" Copyright (c) 1993-96 Mats O Jansson. All rights reserved. +.\" +.\" Redistribution and use in source and binary forms, with or without +.\" modification, are permitted provided that the following conditions +.\" are met: +.\" 1. Redistributions of source code must retain the above copyright +.\" notice, this list of conditions and the following disclaimer. +.\" 2. Redistributions in binary form must reproduce the above copyright +.\" notice, this list of conditions and the following disclaimer in the +.\" documentation and/or other materials provided with the distribution. +.\" 3. All advertising materials mentioning features or use of this software +.\" must display the following acknowledgement: +.\" This product includes software developed by Mats O Jansson. +.\" 4. The name of the author may not be used to endorse or promote products +.\" derived from this software without specific prior written permission. +.\" +.\" THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR +.\" IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES +.\" OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. +.\" IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, +.\" INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT +.\" NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +.\" DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +.\" THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +.\" (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF +.\" THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. +.\" +.Dd September 24, 1995 +.Dt MOPD 8 +.Sh NAME +.Nm mopd +.Nd MOP Loader Daemon +.Sh SYNOPSIS +.Nm +.Op Fl adf +.Op Ar interface +.Sh DESCRIPTION +.Nm +services MOP Load requests on the Ethernet connected to +.Ar interface +or all interfaces if +.Sq Fl a +is given. +In a load request received by +.Nm +a filename can be given. This is the normal case for e.g. terminal servers. +If a filename isn't given +.Nm +must know what image to load. +.Pp +Upon receiving a request, +.Nm +checks if the requested file exists in +.Pa /tftpboot/mop , +the filename is normaly uppercase and with an extension of +.Pa .SYS . +If the filename isn't given, the ethernet address of the target is used as +filename, e.g. +.Pa 08002b09f4de.SYS +and it might be a soft link to another file. +.Pp +.Nm +supports two kinds of files. The first type that is check is if the file is +in +.Xr a.out 5 +format. If not, a couple of Digital's formats are checked. +.Pp +In normal operation, +.Nm +forks a copy of itself and runs in +the background. Anomalies and errors are reported via +.Xr syslog 3 . +.Sh OPTIONS +.Bl -tag -width indent +.It Fl a +Listen on all the Ethernets attached to the system. +If +.Sq Fl a +is omitted, an interface must be specified. +.It Fl d +Run in debug mode, with all the output to stdout. The process will run in +the foreground. +.It Fl f +Run in the foreground. +.El +.Sh FILES +.Bl -tag -width Pa -compact +.It Pa /tftpboot/mop +.El +.Sh SEE ALSO +.Xr bpf 4 , +.Xr mopa.out 1 , +.Xr mopchk 1 , +.Xr mopprobe 1 , +.Xr moptrace 1 +.Rs +DECnet Digital Network Architecture Phase IV, +.%R Maintenance Operations Functional Specification V3.0.0 +.%N AA-X436A-TK +.Re +.Rs +DECnet Digital Network Architecture, +.%R Maintenance Operations Protocol Functional Specification V4.0.0 +.%N EK-DNA11-FS-001 +.Re +.Sh AUTHORS +Mats O Jansson (moj@stacken.kth.se). diff --git a/package/mopd/src/mopd/mopd.c b/package/mopd/src/mopd/mopd.c new file mode 100644 index 000000000..2de83d0f0 --- /dev/null +++ b/package/mopd/src/mopd/mopd.c @@ -0,0 +1,216 @@ +/* $NetBSD: mopd.c,v 1.5 1997/10/16 23:25:17 lukem Exp $ */ + +/* + * Copyright (c) 1993-96 Mats O Jansson. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by Mats O Jansson. + * 4. The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include <sys/cdefs.h> +#ifndef lint +/*__RCSID("$NetBSD: mopd.c,v 1.5 1997/10/16 23:25:17 lukem Exp $");*/ +#endif + +/* + * mopd - MOP Dump/Load Daemon + * + * Usage: mopd -a [ -d -f -v ] [ -3 | -4 ] + * mopd [ -d -f -v ] [ -3 | -4 ] interface + */ + +#include "common/os.h" +#include "common/cmp.h" +#include "common/common.h" +#include "common/device.h" +#include "common/dl.h" +#include "common/get.h" +#include "common/mopdef.h" +#include "common/pf.h" +#include "common/print.h" +#include "process.h" +#include "common/rc.h" + +#ifndef __linux__ +#include <util.h> +#else +#define pidfile(x) x; +#endif + +/* + * The list of all interfaces that are being listened to. + * "selects" on the descriptors in this list. + */ +struct if_info *iflist; + +void Usage __P((void)); +int main __P((int, char **)); +void mopProcess __P((struct if_info *, u_char *)); + +int AllFlag = 0; /* listen on "all" interfaces */ +int DebugFlag = 0; /* print debugging messages */ +int ForegroundFlag = 0; /* run in foreground */ +int VersionFlag = 0; /* print version */ +int Not3Flag = 0; /* Not MOP V3 messages. */ +int Not4Flag = 0; /* Not MOP V4 messages. */ +int promisc = 1; /* Need promisc mode */ + +extern char *__progname; /* from crt0.o */ + +int +main(argc, argv) + int argc; + char **argv; +{ + int c, pid; + char *interface; + + extern char version[]; + + while ((c = getopt(argc, argv, "34adfv")) != -1) + switch (c) { + case '3': + Not3Flag++; + break; + case '4': + Not4Flag++; + break; + case 'a': + AllFlag++; + break; + case 'd': + DebugFlag++; + break; + case 'f': + ForegroundFlag++; + break; + case 'v': + VersionFlag++; + break; + default: + Usage(); + /* NOTREACHED */ + } + + if (VersionFlag) { + fprintf(stdout,"%s: version %s\n", __progname, version); + exit(0); + } + + interface = argv[optind++]; + + if ((AllFlag && interface) || + (!AllFlag && interface == 0) || + (argc > optind) || + (Not3Flag && Not4Flag)) + Usage(); + + /* All error reporting is done through syslogs. */ + openlog(__progname, LOG_PID | LOG_CONS, LOG_DAEMON); + + if ((!ForegroundFlag) && DebugFlag) + fprintf(stdout, + "%s: not running as daemon, -d given.\n", __progname); + + if ((!ForegroundFlag) && (!DebugFlag)) { + pid = fork(); + if (pid > 0) + /* Parent exits, leaving child in background. */ + exit(0); + else + if (pid == -1) { + syslog(LOG_ERR, "cannot fork"); + exit(0); + } + + /* Fade into the background */ + daemon(0, 0); + pidfile(NULL); + } + + syslog(LOG_INFO, "%s %s started.", __progname, version); + + if (AllFlag) + deviceInitAll(); + else + deviceInitOne(interface); + + Loop(); + /* NOTREACHED */ + return (0); +} + +void +Usage() +{ + (void) fprintf(stderr, "usage: %s -a [ -d -f -v ] [ -3 | -4 ]\n", + __progname); + (void) fprintf(stderr, " %s [ -d -f -v ] [ -3 | -4 ] interface\n", + __progname); + exit(1); +} + +/* + * Process incomming packages. + */ +void +mopProcess(ii, pkt) + struct if_info *ii; + u_char *pkt; +{ + u_char *dst, *src; + u_short ptype; + int index, trans, len; + + /* We don't known with transport, Guess! */ + + trans = mopGetTrans(pkt, 0); + + /* Ok, return if we don't wan't this message */ + + if ((trans == TRANS_ETHER) && Not3Flag) return; + if ((trans == TRANS_8023) && Not4Flag) return; + + index = 0; + mopGetHeader(pkt, &index, &dst, &src, &ptype, &len, trans); + + /* + * Ignore our own transmissions + * + */ + if (mopCmpEAddr(ii->eaddr,src) == 0) + return; + + switch(ptype) { + case MOP_K_PROTO_DL: + mopProcessDL(stdout, ii, pkt, &index, dst, src, trans, len); + break; + case MOP_K_PROTO_RC: + mopProcessRC(stdout, ii, pkt, &index, dst, src, trans, len); + break; + default: + break; + } +} diff --git a/package/mopd/src/mopd/process.c b/package/mopd/src/mopd/process.c new file mode 100644 index 000000000..4656e027a --- /dev/null +++ b/package/mopd/src/mopd/process.c @@ -0,0 +1,684 @@ +/* $NetBSD: process.c,v 1.7 2000/06/27 18:57:41 ragge Exp $ */ + +/* + * Copyright (c) 1993-95 Mats O Jansson. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by Mats O Jansson. + * 4. The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include <sys/cdefs.h> +#ifndef lint +static char rcsid[]="$NetBSD: process.c,v 1.7 2000/06/27 18:57:41 ragge Exp $"; +#endif + +#include "os.h" +#include "cmp.h" +#include "common.h" +#include "dl.h" +#include "file.h" +#include "get.h" +#include "mopdef.h" +#include "nmadef.h" +#include "pf.h" +#include "print.h" +#include "put.h" +#include "rc.h" + +#ifdef SEND_REAL_HOSTNAME +#include <sys/utsname.h> /* for getting the hostname */ +#endif +#include <sys/param.h> /* for getting MAXHOSTNAMELEN */ + +extern u_char buf[]; +extern int DebugFlag; + +struct dllist dllist[MAXDL]; /* dump/load list */ +extern char dl_mcst[]; /* Dump/Load Multicast */ +extern char rc_mcst[]; /* Remote Console Multicast */ + +void mopNextLoad __P((u_char *, u_char *, u_char, int)); +void mopProcessDL __P((FILE *, struct if_info *, u_char *, int *, + u_char *, u_char *, int, u_short)); +void mopProcessRC __P((FILE *, struct if_info *, u_char *, int *, + u_char *, u_char *, int, u_short)); +void mopProcessInfo __P((u_char *, int *, u_short, struct dllist *, int)); +void mopSendASV __P((u_char *, u_char *, struct if_info *, int)); +void mopStartLoad __P((u_char *, u_char *, struct dllist *, int)); + +void +mopProcessInfo(pkt, index, moplen, dl_rpr, trans) + u_char *pkt; + int *index; + u_short moplen; + struct dllist *dl_rpr; + int trans; +{ + u_short itype,tmps; + u_char ilen ,tmpc,device; + u_char uc1,uc2,uc3,*ucp; + + device = 0; + + switch(trans) { + case TRANS_ETHER: + moplen = moplen + 16; + break; + case TRANS_8023: + moplen = moplen + 14; + break; + } + + itype = mopGetShort(pkt,index); + + while (*index < (int)(moplen)) { + ilen = mopGetChar(pkt,index); + switch (itype) { + case 0: + tmpc = mopGetChar(pkt,index); + *index = *index + tmpc; + break; + case MOP_K_INFO_VER: + uc1 = mopGetChar(pkt,index); + uc2 = mopGetChar(pkt,index); + uc3 = mopGetChar(pkt,index); + break; + case MOP_K_INFO_MFCT: + tmps = mopGetShort(pkt,index); + break; + case MOP_K_INFO_CNU: + ucp = pkt + *index; *index = *index + 6; + break; + case MOP_K_INFO_RTM: + tmps = mopGetShort(pkt,index); + break; + case MOP_K_INFO_CSZ: + tmps = mopGetShort(pkt,index); + break; + case MOP_K_INFO_RSZ: + tmps = mopGetShort(pkt,index); + break; + case MOP_K_INFO_HWA: + ucp = pkt + *index; *index = *index + 6; + break; + case MOP_K_INFO_TIME: + ucp = pkt + *index; *index = *index + 10; + break; + case MOP_K_INFO_SOFD: + device = mopGetChar(pkt,index); + break; + case MOP_K_INFO_SFID: + tmpc = mopGetChar(pkt,index); + ucp = pkt + *index; *index = *index + tmpc; + break; + case MOP_K_INFO_PRTY: + tmpc = mopGetChar(pkt,index); + break; + case MOP_K_INFO_DLTY: + tmpc = mopGetChar(pkt,index); + break; + case MOP_K_INFO_DLBSZ: + tmps = mopGetShort(pkt,index); + dl_rpr->dl_bsz = tmps; + break; + default: + if (((device = NMA_C_SOFD_LCS) || /* DECserver 100 */ + (device = NMA_C_SOFD_DS2) || /* DECserver 200 */ + (device = NMA_C_SOFD_DP2) || /* DECserver 250 */ + (device = NMA_C_SOFD_DS3)) && /* DECserver 300 */ + ((itype > 101) && (itype < 107))) + { + switch (itype) { + case 102: + ucp = pkt + *index; + *index = *index + ilen; + break; + case 103: + ucp = pkt + *index; + *index = *index + ilen; + break; + case 104: + tmps = mopGetShort(pkt,index); + break; + case 105: + ucp = pkt + *index; + *index = *index + ilen; + break; + case 106: + ucp = pkt + *index; + *index = *index + ilen; + break; + }; + } else { + ucp = pkt + *index; *index = *index + ilen; + }; + } + itype = mopGetShort(pkt,index); + } +} + +void +mopSendASV(dst, src, ii, trans) + u_char *dst,*src; + struct if_info *ii; + int trans; +{ + u_char pkt[200], *p; + int index; + u_char mopcode = MOP_K_CODE_ASV; + u_short newlen = 0,ptype = MOP_K_PROTO_DL; + + index = 0; + mopPutHeader(pkt, &index, dst, src, ptype, trans); + + p = &pkt[index]; + mopPutChar(pkt,&index,mopcode); + + mopPutLength(pkt, trans, index); + newlen = mopGetLength(pkt, trans); + + if ((DebugFlag == DEBUG_ONELINE)) { + mopPrintOneline(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_HEADER)) { + mopPrintHeader(stdout, pkt, trans); + mopPrintMopHeader(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_INFO)) { + mopDumpDL(stdout, pkt, trans); + } + + if (pfWrite(ii->fd, pkt, index, trans) != index) { + if (DebugFlag) { + (void)fprintf(stderr, "error pfWrite()\n"); + } + } +} + +#define MAX_ETH_PAYLOAD 1492 + +void +mopStartLoad(dst, src, dl_rpr, trans) + u_char *dst,*src; + struct dllist *dl_rpr; + int trans; +{ + int len; + int i, slot; + u_char pkt[BUFSIZE], *p; + int index; + u_char mopcode = MOP_K_CODE_MLD; + u_short newlen,ptype = MOP_K_PROTO_DL; + + slot = -1; + + /* Look if we have a non terminated load, if so, use it's slot */ + + for (i = 0; i < MAXDL; i++) { + if (dllist[i].status != DL_STATUS_FREE) { + if (mopCmpEAddr(dllist[i].eaddr,dst) == 0) { + slot = i; + } + } + } + + /* If no slot yet, then find first free */ + + if (slot == -1) { + for (i = 0; i < MAXDL; i++) { + if (dllist[i].status == DL_STATUS_FREE) { + if (slot == -1) { + slot = i; + memmove((char *)dllist[i].eaddr, + (char *)dst, 6); + } + } + } + } + + /* If no slot yet, then return. No slot is free */ + + if (slot == -1) + return; + + /* Ok, save info from RPR */ + + dllist[slot] = *dl_rpr; + dllist[slot].status = DL_STATUS_READ_IMGHDR; + + /* Get Load and Transfer Address. */ + + GetFileInfo(dllist[slot].ldfd, + &dllist[slot].loadaddr, + &dllist[slot].xferaddr, + &dllist[slot].aout, + &dllist[slot].a_text, &dllist[slot].a_text_fill, + &dllist[slot].a_data, &dllist[slot].a_data_fill, + &dllist[slot].a_bss, &dllist[slot].a_bss_fill); + + dllist[slot].nloadaddr = dllist[slot].loadaddr; + dllist[slot].lseek = lseek(dllist[slot].ldfd,0L,SEEK_CUR); + dllist[slot].a_lseek = 0; + + dllist[slot].count = 0; + if (dllist[slot].dl_bsz >= MAX_ETH_PAYLOAD || dllist[slot].dl_bsz == 0) + dllist[slot].dl_bsz = MAX_ETH_PAYLOAD; + if (dllist[slot].dl_bsz == 1030) /* VS/uVAX 2000 needs this */ + dllist[slot].dl_bsz = 1000; + if (dllist[slot].dl_bsz == 0) /* Needed by "big" VAXen */ + dllist[slot].dl_bsz = MAX_ETH_PAYLOAD; + if (trans == TRANS_8023) + dllist[slot].dl_bsz = dllist[slot].dl_bsz - 8; + + index = 0; + mopPutHeader(pkt, &index, dst, src, ptype, trans); + p = &pkt[index]; + mopPutChar (pkt,&index,mopcode); + + mopPutChar (pkt,&index,dllist[slot].count); + mopPutLong (pkt,&index,dllist[slot].loadaddr); + + len = mopFileRead(&dllist[slot],&pkt[index]); + + dllist[slot].nloadaddr = dllist[slot].loadaddr + len; + index = index + len; + + mopPutLength(pkt, trans, index); + newlen = mopGetLength(pkt, trans); + + if ((DebugFlag == DEBUG_ONELINE)) { + mopPrintOneline(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_HEADER)) { + mopPrintHeader(stdout, pkt, trans); + mopPrintMopHeader(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_INFO)) { + mopDumpDL(stdout, pkt, trans); + } + + if (pfWrite(dllist[slot].ii->fd, pkt, index, trans) != index) { + if (DebugFlag) { + (void)fprintf(stderr, "error pfWrite()\n"); + } + } + + dllist[slot].status = DL_STATUS_SENT_MLD; +} + +void +mopNextLoad(dst, src, new_count, trans) + u_char *dst,*src,new_count; + int trans; +{ + int len; + int i, slot; + u_char pkt[BUFSIZE], *p; + int index, pindex; + char line[100]; + u_short newlen = 0,ptype = MOP_K_PROTO_DL; + u_char mopcode; + +#ifdef SEND_REAL_HOSTNAME + struct utsname uts_name; +#endif + char hostname[MAXHOSTNAMELEN]; + + slot = -1; + + for (i = 0; i < MAXDL; i++) { + if (dllist[i].status != DL_STATUS_FREE) { + if (mopCmpEAddr(dst,dllist[i].eaddr) == 0) + slot = i; + } + } + + /* If no slot yet, then return. No slot is free */ + + if (slot == -1) + return; + + if ((new_count == ((dllist[slot].count+1) % 256))) { + dllist[slot].loadaddr = dllist[slot].nloadaddr; + dllist[slot].count = new_count; + } else { + return; + } + + if (dllist[slot].status == DL_STATUS_SENT_PLT) { + close(dllist[slot].ldfd); + dllist[slot].ldfd = 0; + dllist[slot].status = DL_STATUS_FREE; + sprintf(line, + "%x:%x:%x:%x:%x:%x Load completed", + dst[0],dst[1],dst[2],dst[3],dst[4],dst[5]); + syslog(LOG_INFO, "%s", line); + return; + } + + dllist[slot].lseek = lseek(dllist[slot].ldfd,0L,SEEK_CUR); + + if (dllist[slot].dl_bsz >= MAX_ETH_PAYLOAD) + dllist[slot].dl_bsz = MAX_ETH_PAYLOAD; + + index = 0; + mopPutHeader(pkt, &index, dst, src, ptype, trans); + p = &pkt[index]; + mopcode = MOP_K_CODE_MLD; + pindex = index; + mopPutChar (pkt,&index,mopcode); + mopPutChar (pkt,&index,dllist[slot].count); + mopPutLong (pkt,&index,dllist[slot].loadaddr); + + len = mopFileRead(&dllist[slot],&pkt[index]); + + if (len > 0 ) { + + dllist[slot].nloadaddr = dllist[slot].loadaddr + len; + index = index + len; + + mopPutLength(pkt, trans, index); + newlen = mopGetLength(pkt, trans); + + } else { + if (len == 0) { + +#ifdef SEND_REAL_HOSTNAME + /* get the proper hostname. use 'DEFAULT_HOSTNAME' on failure */ + if(uname(&uts_name) < 0){ + syslog(LOG_ERR,"uname() failed with errno: %d. using '%s' as hostname\n",errno,DEFAULT_HOSTNAME); + sprintf(hostname, "%s", DEFAULT_HOSTNAME); + } + else{ + sprintf(hostname, "%s", uts_name.nodename); + } +#else + sprintf(hostname,"%s",DEFAULT_HOSTNAME); +#endif + syslog(LOG_INFO,"hostname: [%s] len: %d\n",hostname,strlen(hostname)); + index = pindex; + mopcode = MOP_K_CODE_PLT; + mopPutChar (pkt,&index,mopcode); + mopPutChar (pkt,&index,dllist[slot].count); + mopPutChar (pkt,&index,MOP_K_PLTP_HSN); + mopPutChar (pkt,&index,strlen(hostname)); + mopPutMulti(pkt,&index,hostname,strlen(hostname)); + mopPutChar (pkt,&index,MOP_K_PLTP_HSA); + mopPutChar (pkt,&index,6); + mopPutMulti(pkt,&index,src,6); + mopPutChar (pkt,&index,MOP_K_PLTP_HST); + mopPutTime (pkt,&index, 0); + mopPutChar (pkt,&index,0); + mopPutLong (pkt,&index,dllist[slot].xferaddr); + + mopPutLength(pkt, trans, index); + newlen = mopGetLength(pkt, trans); + + dllist[slot].status = DL_STATUS_SENT_PLT; + } else { + dllist[slot].status = DL_STATUS_FREE; + return; + } + } + + if ((DebugFlag == DEBUG_ONELINE)) { + mopPrintOneline(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_HEADER)) { + mopPrintHeader(stdout, pkt, trans); + mopPrintMopHeader(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_INFO)) { + mopDumpDL(stdout, pkt, trans); + } + + if (pfWrite(dllist[slot].ii->fd, pkt, index, trans) != index) { + if (DebugFlag) { + (void)fprintf(stderr, "error pfWrite()\n"); + } + } +} + +void +mopProcessDL(fd, ii, pkt, index, dst, src, trans, len) + FILE *fd; + struct if_info *ii; + u_char *pkt; + int *index; + u_char *dst, *src; + int trans; + u_short len; +{ + u_char tmpc; + u_short moplen; + u_char pfile[129], mopcode; + char filename[FILENAME_MAX]; + char line[100]; + int i,nfd,iindex; + struct dllist dl,*dl_rpr; + u_char rpr_pgty,load; + + if ((DebugFlag == DEBUG_ONELINE)) { + mopPrintOneline(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_HEADER)) { + mopPrintHeader(stdout, pkt, trans); + mopPrintMopHeader(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_INFO)) { + mopDumpDL(stdout, pkt, trans); + } + + moplen = mopGetLength(pkt, trans); + mopcode = mopGetChar(pkt,index); + + switch (mopcode) { + case MOP_K_CODE_MLT: + break; + case MOP_K_CODE_DCM: + break; + case MOP_K_CODE_MLD: + break; + case MOP_K_CODE_ASV: + break; + case MOP_K_CODE_RMD: + break; + case MOP_K_CODE_RPR: + + tmpc = mopGetChar(pkt,index); /* Device Type */ + + tmpc = mopGetChar(pkt,index); /* Format Version */ + if ((tmpc != MOP_K_RPR_FORMAT) && + (tmpc != MOP_K_RPR_FORMAT_V3)) { + (void)fprintf(stderr,"mopd: Unknown RPR Format (%d) from ",tmpc); + mopPrintHWA(stderr,src); + (void)fprintf(stderr,"\n"); + } + + rpr_pgty = mopGetChar(pkt,index); /* Program Type */ + + tmpc = mopGetChar(pkt,index); /* Software ID Len */ + if (tmpc > sizeof(pfile) - 1) + return; + for (i = 0; i < tmpc; i++) { + pfile[i] = mopGetChar(pkt,index); + pfile[i+1] = '\0'; + } + + if (tmpc == 0) { + /* In a normal implementation of a MOP Loader this */ + /* would cause a question to NML (DECnet) if this */ + /* node is known and if so what image to load. But */ + /* we don't have DECnet so we don't have anybody */ + /* to ask. My solution is to use the ethernet addr */ + /* as filename. Implementing a database would be */ + /* overkill. */ + sprintf(pfile,"%02x%02x%02x%02x%02x%02x%c", + src[0],src[1],src[2],src[3],src[4],src[5],0); + } + + tmpc = mopGetChar(pkt,index); /* Processor */ + + iindex = *index; + dl_rpr = &dl; + memset(dl_rpr, 0, sizeof(*dl_rpr)); + dl_rpr->ii = ii; + memmove((char *)(dl_rpr->eaddr), (char *)src, 6); + mopProcessInfo(pkt,index,moplen,dl_rpr,trans); + + sprintf(filename,"%s/%s.SYS", MOP_FILE_PATH, pfile); + if ((mopCmpEAddr(dst,dl_mcst) == 0)) { + if ((nfd = open(filename, O_RDONLY, 0)) != -1) { + close(nfd); + mopSendASV(src, ii->eaddr, ii, trans); + sprintf(line, + "%x:%x:%x:%x:%x:%x (%d) Do you have %s? (Yes)", + src[0],src[1],src[2], + src[3],src[4],src[5],trans,pfile); + } else { + sprintf(line, + "%x:%x:%x:%x:%x:%x (%d) Do you have %s? (No)", + src[0],src[1],src[2], + src[3],src[4],src[5],trans,pfile); + } + syslog(LOG_INFO, "%s", line); + } else { + if ((mopCmpEAddr(dst,ii->eaddr) == 0)) { + dl_rpr->ldfd = open(filename, O_RDONLY, 0); + mopStartLoad(src, ii->eaddr, dl_rpr, trans); + sprintf(line, + "%x:%x:%x:%x:%x:%x Send me %s", + src[0],src[1],src[2], + src[3],src[4],src[5],pfile); + syslog(LOG_INFO, "%s", line); + } + } + + break; + case MOP_K_CODE_RML: + + load = mopGetChar(pkt,index); /* Load Number */ + + tmpc = mopGetChar(pkt,index); /* Error */ + + if ((mopCmpEAddr(dst,ii->eaddr) == 0)) { + mopNextLoad(src, ii->eaddr, load, trans); + } + + break; + case MOP_K_CODE_RDS: + break; + case MOP_K_CODE_MDD: + break; + case MOP_K_CODE_CCP: + break; + case MOP_K_CODE_PLT: + break; + default: + break; + } +} + +void +mopProcessRC(fd, ii, pkt, index, dst, src, trans, len) + FILE *fd; + struct if_info *ii; + u_char *pkt; + int *index; + u_char *dst, *src; + int trans; + u_short len; +{ + u_char tmpc; + u_short tmps, moplen = 0; + u_char mopcode; + struct dllist dl,*dl_rpr; + + if ((DebugFlag == DEBUG_ONELINE)) { + mopPrintOneline(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_HEADER)) { + mopPrintHeader(stdout, pkt, trans); + mopPrintMopHeader(stdout, pkt, trans); + } + + if ((DebugFlag >= DEBUG_INFO)) { + mopDumpRC(stdout, pkt, trans); + } + + moplen = mopGetLength(pkt, trans); + mopcode = mopGetChar(pkt,index); + + switch (mopcode) { + case MOP_K_CODE_RID: + break; + case MOP_K_CODE_BOT: + break; + case MOP_K_CODE_SID: + + tmpc = mopGetChar(pkt,index); /* Reserved */ + + if ((DebugFlag >= DEBUG_INFO)) { + (void)fprintf(stderr, "Reserved : %02x\n",tmpc); + } + + tmps = mopGetShort(pkt,index); /* Receipt # */ + if ((DebugFlag >= DEBUG_INFO)) { + (void)fprintf(stderr, "Receipt Nbr : %04x\n",tmpc); + } + + dl_rpr = &dl; + memset(dl_rpr, 0, sizeof(*dl_rpr)); + dl_rpr->ii = ii; + memmove((char *)(dl_rpr->eaddr), (char *)src, 6); + mopProcessInfo(pkt,index,moplen,dl_rpr,trans); + + break; + case MOP_K_CODE_RQC: + break; + case MOP_K_CODE_CNT: + break; + case MOP_K_CODE_RVC: + break; + case MOP_K_CODE_RLC: + break; + case MOP_K_CODE_CCP: + break; + case MOP_K_CODE_CRA: + break; + default: + break; + } +} + diff --git a/package/mopd/src/mopd/process.h b/package/mopd/src/mopd/process.h new file mode 100644 index 000000000..12bb94419 --- /dev/null +++ b/package/mopd/src/mopd/process.h @@ -0,0 +1,45 @@ +/* $NetBSD: process.h,v 1.2 1997/03/25 03:07:52 thorpej Exp $ */ + +/* + * Copyright (c) 1993-95 Mats O Jansson. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by Mats O Jansson. + * 4. The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + * + * $NetBSD: process.h,v 1.2 1997/03/25 03:07:52 thorpej Exp $ + * + */ + +#ifndef _PROCESS_H_ +#define _PROCESS_H_ + +__BEGIN_DECLS +void mopProcessDL __P((FILE *, struct if_info *, u_char *, int *, + u_char *, u_char *, int, u_short)); +void mopProcessRC __P((FILE *, struct if_info *, u_char *, int *, + u_char *, u_char *, int, u_short)); +__END_DECLS + +#endif _PROCESS_H_ |