process.c revision 1.7 1 1.7 ragge /* $NetBSD: process.c,v 1.7 2000/06/27 18:57:41 ragge Exp $ */
2 1.2 thorpej
3 1.1 cjs /*
4 1.1 cjs * Copyright (c) 1993-95 Mats O Jansson. All rights reserved.
5 1.1 cjs *
6 1.1 cjs * Redistribution and use in source and binary forms, with or without
7 1.1 cjs * modification, are permitted provided that the following conditions
8 1.1 cjs * are met:
9 1.1 cjs * 1. Redistributions of source code must retain the above copyright
10 1.1 cjs * notice, this list of conditions and the following disclaimer.
11 1.1 cjs * 2. Redistributions in binary form must reproduce the above copyright
12 1.1 cjs * notice, this list of conditions and the following disclaimer in the
13 1.1 cjs * documentation and/or other materials provided with the distribution.
14 1.1 cjs * 3. All advertising materials mentioning features or use of this software
15 1.1 cjs * must display the following acknowledgement:
16 1.1 cjs * This product includes software developed by Mats O Jansson.
17 1.1 cjs * 4. The name of the author may not be used to endorse or promote products
18 1.1 cjs * derived from this software without specific prior written permission.
19 1.1 cjs *
20 1.1 cjs * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
21 1.1 cjs * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
22 1.1 cjs * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
23 1.1 cjs * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
24 1.1 cjs * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
25 1.1 cjs * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
26 1.1 cjs * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
27 1.1 cjs * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
28 1.1 cjs * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
29 1.1 cjs * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
30 1.1 cjs */
31 1.1 cjs
32 1.5 lukem #include <sys/cdefs.h>
33 1.5 lukem #ifndef lint
34 1.7 ragge __RCSID("$NetBSD: process.c,v 1.7 2000/06/27 18:57:41 ragge Exp $");
35 1.1 cjs #endif
36 1.1 cjs
37 1.4 christos #include "os.h"
38 1.5 lukem #include "cmp.h"
39 1.5 lukem #include "common.h"
40 1.5 lukem #include "dl.h"
41 1.5 lukem #include "file.h"
42 1.5 lukem #include "get.h"
43 1.5 lukem #include "mopdef.h"
44 1.5 lukem #include "nmadef.h"
45 1.5 lukem #include "pf.h"
46 1.5 lukem #include "print.h"
47 1.5 lukem #include "put.h"
48 1.5 lukem #include "rc.h"
49 1.1 cjs
50 1.1 cjs extern u_char buf[];
51 1.1 cjs extern int DebugFlag;
52 1.1 cjs
53 1.1 cjs struct dllist dllist[MAXDL]; /* dump/load list */
54 1.1 cjs extern char dl_mcst[]; /* Dump/Load Multicast */
55 1.1 cjs extern char rc_mcst[]; /* Remote Console Multicast */
56 1.1 cjs
57 1.5 lukem void mopNextLoad __P((u_char *, u_char *, u_char, int));
58 1.5 lukem void mopProcessDL __P((FILE *, struct if_info *, u_char *, int *,
59 1.5 lukem u_char *, u_char *, int, u_short));
60 1.5 lukem void mopProcessRC __P((FILE *, struct if_info *, u_char *, int *,
61 1.5 lukem u_char *, u_char *, int, u_short));
62 1.5 lukem void mopProcessInfo __P((u_char *, int *, u_short, struct dllist *, int));
63 1.5 lukem void mopSendASV __P((u_char *, u_char *, struct if_info *, int));
64 1.5 lukem void mopStartLoad __P((u_char *, u_char *, struct dllist *, int));
65 1.5 lukem
66 1.1 cjs void
67 1.5 lukem mopProcessInfo(pkt, index, moplen, dl_rpr, trans)
68 1.1 cjs u_char *pkt;
69 1.5 lukem int *index;
70 1.1 cjs u_short moplen;
71 1.1 cjs struct dllist *dl_rpr;
72 1.5 lukem int trans;
73 1.1 cjs {
74 1.1 cjs u_short itype,tmps;
75 1.1 cjs u_char ilen ,tmpc,device;
76 1.1 cjs u_char uc1,uc2,uc3,*ucp;
77 1.1 cjs
78 1.1 cjs device = 0;
79 1.1 cjs
80 1.1 cjs switch(trans) {
81 1.1 cjs case TRANS_ETHER:
82 1.1 cjs moplen = moplen + 16;
83 1.1 cjs break;
84 1.1 cjs case TRANS_8023:
85 1.1 cjs moplen = moplen + 14;
86 1.1 cjs break;
87 1.1 cjs }
88 1.1 cjs
89 1.1 cjs itype = mopGetShort(pkt,index);
90 1.1 cjs
91 1.1 cjs while (*index < (int)(moplen)) {
92 1.1 cjs ilen = mopGetChar(pkt,index);
93 1.1 cjs switch (itype) {
94 1.1 cjs case 0:
95 1.1 cjs tmpc = mopGetChar(pkt,index);
96 1.1 cjs *index = *index + tmpc;
97 1.1 cjs break;
98 1.1 cjs case MOP_K_INFO_VER:
99 1.1 cjs uc1 = mopGetChar(pkt,index);
100 1.1 cjs uc2 = mopGetChar(pkt,index);
101 1.1 cjs uc3 = mopGetChar(pkt,index);
102 1.1 cjs break;
103 1.1 cjs case MOP_K_INFO_MFCT:
104 1.1 cjs tmps = mopGetShort(pkt,index);
105 1.1 cjs break;
106 1.1 cjs case MOP_K_INFO_CNU:
107 1.1 cjs ucp = pkt + *index; *index = *index + 6;
108 1.1 cjs break;
109 1.1 cjs case MOP_K_INFO_RTM:
110 1.1 cjs tmps = mopGetShort(pkt,index);
111 1.1 cjs break;
112 1.1 cjs case MOP_K_INFO_CSZ:
113 1.1 cjs tmps = mopGetShort(pkt,index);
114 1.1 cjs break;
115 1.1 cjs case MOP_K_INFO_RSZ:
116 1.1 cjs tmps = mopGetShort(pkt,index);
117 1.1 cjs break;
118 1.1 cjs case MOP_K_INFO_HWA:
119 1.1 cjs ucp = pkt + *index; *index = *index + 6;
120 1.1 cjs break;
121 1.1 cjs case MOP_K_INFO_TIME:
122 1.1 cjs ucp = pkt + *index; *index = *index + 10;
123 1.1 cjs break;
124 1.1 cjs case MOP_K_INFO_SOFD:
125 1.1 cjs device = mopGetChar(pkt,index);
126 1.1 cjs break;
127 1.1 cjs case MOP_K_INFO_SFID:
128 1.1 cjs tmpc = mopGetChar(pkt,index);
129 1.1 cjs ucp = pkt + *index; *index = *index + tmpc;
130 1.1 cjs break;
131 1.1 cjs case MOP_K_INFO_PRTY:
132 1.1 cjs tmpc = mopGetChar(pkt,index);
133 1.1 cjs break;
134 1.1 cjs case MOP_K_INFO_DLTY:
135 1.1 cjs tmpc = mopGetChar(pkt,index);
136 1.1 cjs break;
137 1.1 cjs case MOP_K_INFO_DLBSZ:
138 1.1 cjs tmps = mopGetShort(pkt,index);
139 1.1 cjs dl_rpr->dl_bsz = tmps;
140 1.1 cjs break;
141 1.1 cjs default:
142 1.1 cjs if (((device = NMA_C_SOFD_LCS) || /* DECserver 100 */
143 1.1 cjs (device = NMA_C_SOFD_DS2) || /* DECserver 200 */
144 1.1 cjs (device = NMA_C_SOFD_DP2) || /* DECserver 250 */
145 1.1 cjs (device = NMA_C_SOFD_DS3)) && /* DECserver 300 */
146 1.1 cjs ((itype > 101) && (itype < 107)))
147 1.1 cjs {
148 1.1 cjs switch (itype) {
149 1.1 cjs case 102:
150 1.1 cjs ucp = pkt + *index;
151 1.1 cjs *index = *index + ilen;
152 1.1 cjs break;
153 1.1 cjs case 103:
154 1.1 cjs ucp = pkt + *index;
155 1.1 cjs *index = *index + ilen;
156 1.1 cjs break;
157 1.1 cjs case 104:
158 1.1 cjs tmps = mopGetShort(pkt,index);
159 1.1 cjs break;
160 1.1 cjs case 105:
161 1.1 cjs ucp = pkt + *index;
162 1.1 cjs *index = *index + ilen;
163 1.1 cjs break;
164 1.1 cjs case 106:
165 1.1 cjs ucp = pkt + *index;
166 1.1 cjs *index = *index + ilen;
167 1.1 cjs break;
168 1.1 cjs };
169 1.1 cjs } else {
170 1.1 cjs ucp = pkt + *index; *index = *index + ilen;
171 1.1 cjs };
172 1.1 cjs }
173 1.1 cjs itype = mopGetShort(pkt,index);
174 1.1 cjs }
175 1.1 cjs }
176 1.1 cjs
177 1.1 cjs void
178 1.1 cjs mopSendASV(dst, src, ii, trans)
179 1.1 cjs u_char *dst,*src;
180 1.1 cjs struct if_info *ii;
181 1.1 cjs int trans;
182 1.1 cjs {
183 1.1 cjs u_char pkt[200], *p;
184 1.1 cjs int index;
185 1.1 cjs u_char mopcode = MOP_K_CODE_ASV;
186 1.1 cjs u_short newlen = 0,ptype = MOP_K_PROTO_DL;
187 1.1 cjs
188 1.1 cjs index = 0;
189 1.1 cjs mopPutHeader(pkt, &index, dst, src, ptype, trans);
190 1.1 cjs
191 1.1 cjs p = &pkt[index];
192 1.1 cjs mopPutChar(pkt,&index,mopcode);
193 1.1 cjs
194 1.1 cjs mopPutLength(pkt, trans, index);
195 1.1 cjs newlen = mopGetLength(pkt, trans);
196 1.1 cjs
197 1.1 cjs if ((DebugFlag == DEBUG_ONELINE)) {
198 1.1 cjs mopPrintOneline(stdout, pkt, trans);
199 1.1 cjs }
200 1.1 cjs
201 1.1 cjs if ((DebugFlag >= DEBUG_HEADER)) {
202 1.1 cjs mopPrintHeader(stdout, pkt, trans);
203 1.1 cjs mopPrintMopHeader(stdout, pkt, trans);
204 1.1 cjs }
205 1.1 cjs
206 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
207 1.1 cjs mopDumpDL(stdout, pkt, trans);
208 1.1 cjs }
209 1.1 cjs
210 1.1 cjs if (pfWrite(ii->fd, pkt, index, trans) != index) {
211 1.1 cjs if (DebugFlag) {
212 1.1 cjs (void)fprintf(stderr, "error pfWrite()\n");
213 1.1 cjs }
214 1.1 cjs }
215 1.1 cjs }
216 1.1 cjs
217 1.1 cjs void
218 1.1 cjs mopStartLoad(dst, src, dl_rpr, trans)
219 1.1 cjs u_char *dst,*src;
220 1.1 cjs struct dllist *dl_rpr;
221 1.1 cjs int trans;
222 1.1 cjs {
223 1.1 cjs int len;
224 1.1 cjs int i, slot;
225 1.1 cjs u_char pkt[BUFSIZE], *p;
226 1.1 cjs int index;
227 1.1 cjs u_char mopcode = MOP_K_CODE_MLD;
228 1.1 cjs u_short newlen,ptype = MOP_K_PROTO_DL;
229 1.1 cjs
230 1.1 cjs slot = -1;
231 1.1 cjs
232 1.1 cjs /* Look if we have a non terminated load, if so, use it's slot */
233 1.1 cjs
234 1.1 cjs for (i = 0; i < MAXDL; i++) {
235 1.1 cjs if (dllist[i].status != DL_STATUS_FREE) {
236 1.1 cjs if (mopCmpEAddr(dllist[i].eaddr,dst) == 0) {
237 1.1 cjs slot = i;
238 1.1 cjs }
239 1.1 cjs }
240 1.1 cjs }
241 1.1 cjs
242 1.1 cjs /* If no slot yet, then find first free */
243 1.1 cjs
244 1.1 cjs if (slot == -1) {
245 1.1 cjs for (i = 0; i < MAXDL; i++) {
246 1.1 cjs if (dllist[i].status == DL_STATUS_FREE) {
247 1.1 cjs if (slot == -1) {
248 1.1 cjs slot = i;
249 1.6 abs memmove((char *)dllist[i].eaddr,
250 1.6 abs (char *)dst, 6);
251 1.1 cjs }
252 1.1 cjs }
253 1.1 cjs }
254 1.1 cjs }
255 1.1 cjs
256 1.1 cjs /* If no slot yet, then return. No slot is free */
257 1.1 cjs
258 1.1 cjs if (slot == -1)
259 1.1 cjs return;
260 1.1 cjs
261 1.1 cjs /* Ok, save info from RPR */
262 1.1 cjs
263 1.1 cjs dllist[slot] = *dl_rpr;
264 1.1 cjs dllist[slot].status = DL_STATUS_READ_IMGHDR;
265 1.1 cjs
266 1.1 cjs /* Get Load and Transfer Address. */
267 1.1 cjs
268 1.1 cjs GetFileInfo(dllist[slot].ldfd,
269 1.1 cjs &dllist[slot].loadaddr,
270 1.1 cjs &dllist[slot].xferaddr,
271 1.1 cjs &dllist[slot].aout,
272 1.1 cjs &dllist[slot].a_text, &dllist[slot].a_text_fill,
273 1.1 cjs &dllist[slot].a_data, &dllist[slot].a_data_fill,
274 1.1 cjs &dllist[slot].a_bss, &dllist[slot].a_bss_fill);
275 1.1 cjs
276 1.1 cjs dllist[slot].nloadaddr = dllist[slot].loadaddr;
277 1.1 cjs dllist[slot].lseek = lseek(dllist[slot].ldfd,0L,SEEK_CUR);
278 1.1 cjs dllist[slot].a_lseek = 0;
279 1.1 cjs
280 1.1 cjs dllist[slot].count = 0;
281 1.1 cjs if (dllist[slot].dl_bsz >= 1492)
282 1.1 cjs dllist[slot].dl_bsz = 1492;
283 1.1 cjs if (dllist[slot].dl_bsz == 1030) /* VS/uVAX 2000 needs this */
284 1.1 cjs dllist[slot].dl_bsz = 1000;
285 1.7 ragge if (dllist[slot].dl_bsz == 0) /* Needed by "big" VAXen */
286 1.7 ragge dllist[slot].dl_bsz = 1492;
287 1.1 cjs if (trans == TRANS_8023)
288 1.1 cjs dllist[slot].dl_bsz = dllist[slot].dl_bsz - 8;
289 1.1 cjs
290 1.1 cjs index = 0;
291 1.1 cjs mopPutHeader(pkt, &index, dst, src, ptype, trans);
292 1.1 cjs p = &pkt[index];
293 1.1 cjs mopPutChar (pkt,&index,mopcode);
294 1.1 cjs
295 1.1 cjs mopPutChar (pkt,&index,dllist[slot].count);
296 1.1 cjs mopPutLong (pkt,&index,dllist[slot].loadaddr);
297 1.1 cjs
298 1.1 cjs len = mopFileRead(&dllist[slot],&pkt[index]);
299 1.1 cjs
300 1.1 cjs dllist[slot].nloadaddr = dllist[slot].loadaddr + len;
301 1.1 cjs index = index + len;
302 1.1 cjs
303 1.1 cjs mopPutLength(pkt, trans, index);
304 1.1 cjs newlen = mopGetLength(pkt, trans);
305 1.1 cjs
306 1.1 cjs if ((DebugFlag == DEBUG_ONELINE)) {
307 1.1 cjs mopPrintOneline(stdout, pkt, trans);
308 1.1 cjs }
309 1.1 cjs
310 1.1 cjs if ((DebugFlag >= DEBUG_HEADER)) {
311 1.1 cjs mopPrintHeader(stdout, pkt, trans);
312 1.1 cjs mopPrintMopHeader(stdout, pkt, trans);
313 1.1 cjs }
314 1.1 cjs
315 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
316 1.1 cjs mopDumpDL(stdout, pkt, trans);
317 1.1 cjs }
318 1.1 cjs
319 1.1 cjs if (pfWrite(dllist[slot].ii->fd, pkt, index, trans) != index) {
320 1.1 cjs if (DebugFlag) {
321 1.1 cjs (void)fprintf(stderr, "error pfWrite()\n");
322 1.1 cjs }
323 1.1 cjs }
324 1.1 cjs
325 1.1 cjs dllist[slot].status = DL_STATUS_SENT_MLD;
326 1.1 cjs }
327 1.1 cjs
328 1.1 cjs void
329 1.1 cjs mopNextLoad(dst, src, new_count, trans)
330 1.1 cjs u_char *dst,*src,new_count;
331 1.1 cjs int trans;
332 1.1 cjs {
333 1.1 cjs int len;
334 1.1 cjs int i, slot;
335 1.1 cjs u_char pkt[BUFSIZE], *p;
336 1.1 cjs int index, pindex;
337 1.1 cjs char line[100];
338 1.1 cjs u_short newlen = 0,ptype = MOP_K_PROTO_DL;
339 1.1 cjs u_char mopcode;
340 1.1 cjs
341 1.1 cjs slot = -1;
342 1.1 cjs
343 1.1 cjs for (i = 0; i < MAXDL; i++) {
344 1.1 cjs if (dllist[i].status != DL_STATUS_FREE) {
345 1.1 cjs if (mopCmpEAddr(dst,dllist[i].eaddr) == 0)
346 1.1 cjs slot = i;
347 1.1 cjs }
348 1.1 cjs }
349 1.1 cjs
350 1.1 cjs /* If no slot yet, then return. No slot is free */
351 1.1 cjs
352 1.1 cjs if (slot == -1)
353 1.1 cjs return;
354 1.1 cjs
355 1.1 cjs if ((new_count == ((dllist[slot].count+1) % 256))) {
356 1.1 cjs dllist[slot].loadaddr = dllist[slot].nloadaddr;
357 1.1 cjs dllist[slot].count = new_count;
358 1.1 cjs } else {
359 1.1 cjs return;
360 1.1 cjs }
361 1.1 cjs
362 1.1 cjs if (dllist[slot].status == DL_STATUS_SENT_PLT) {
363 1.1 cjs close(dllist[slot].ldfd);
364 1.1 cjs dllist[slot].ldfd = 0;
365 1.1 cjs dllist[slot].status = DL_STATUS_FREE;
366 1.1 cjs sprintf(line,
367 1.1 cjs "%x:%x:%x:%x:%x:%x Load completed",
368 1.1 cjs dst[0],dst[1],dst[2],dst[3],dst[4],dst[5]);
369 1.1 cjs syslog(LOG_INFO, line);
370 1.1 cjs return;
371 1.1 cjs }
372 1.1 cjs
373 1.1 cjs dllist[slot].lseek = lseek(dllist[slot].ldfd,0L,SEEK_CUR);
374 1.1 cjs
375 1.1 cjs if (dllist[slot].dl_bsz >= 1492)
376 1.1 cjs dllist[slot].dl_bsz = 1492;
377 1.1 cjs
378 1.1 cjs index = 0;
379 1.1 cjs mopPutHeader(pkt, &index, dst, src, ptype, trans);
380 1.1 cjs p = &pkt[index];
381 1.1 cjs mopcode = MOP_K_CODE_MLD;
382 1.1 cjs pindex = index;
383 1.1 cjs mopPutChar (pkt,&index,mopcode);
384 1.1 cjs mopPutChar (pkt,&index,dllist[slot].count);
385 1.1 cjs mopPutLong (pkt,&index,dllist[slot].loadaddr);
386 1.1 cjs
387 1.1 cjs len = mopFileRead(&dllist[slot],&pkt[index]);
388 1.1 cjs
389 1.1 cjs if (len > 0 ) {
390 1.1 cjs
391 1.1 cjs dllist[slot].nloadaddr = dllist[slot].loadaddr + len;
392 1.1 cjs index = index + len;
393 1.1 cjs
394 1.1 cjs mopPutLength(pkt, trans, index);
395 1.1 cjs newlen = mopGetLength(pkt, trans);
396 1.1 cjs
397 1.1 cjs } else {
398 1.1 cjs if (len == 0) {
399 1.1 cjs index = pindex;
400 1.1 cjs mopcode = MOP_K_CODE_PLT;
401 1.1 cjs mopPutChar (pkt,&index,mopcode);
402 1.1 cjs mopPutChar (pkt,&index,dllist[slot].count);
403 1.1 cjs mopPutChar (pkt,&index,MOP_K_PLTP_HSN);
404 1.1 cjs mopPutChar (pkt,&index,3);
405 1.1 cjs mopPutMulti(pkt,&index,"ipc",3);
406 1.1 cjs mopPutChar (pkt,&index,MOP_K_PLTP_HSA);
407 1.1 cjs mopPutChar (pkt,&index,6);
408 1.1 cjs mopPutMulti(pkt,&index,src,6);
409 1.1 cjs mopPutChar (pkt,&index,MOP_K_PLTP_HST);
410 1.1 cjs mopPutTime (pkt,&index, 0);
411 1.1 cjs mopPutChar (pkt,&index,0);
412 1.1 cjs mopPutLong (pkt,&index,dllist[slot].xferaddr);
413 1.1 cjs
414 1.1 cjs mopPutLength(pkt, trans, index);
415 1.1 cjs newlen = mopGetLength(pkt, trans);
416 1.1 cjs
417 1.1 cjs dllist[slot].status = DL_STATUS_SENT_PLT;
418 1.1 cjs } else {
419 1.1 cjs dllist[slot].status = DL_STATUS_FREE;
420 1.1 cjs return;
421 1.1 cjs }
422 1.1 cjs }
423 1.1 cjs
424 1.1 cjs if ((DebugFlag == DEBUG_ONELINE)) {
425 1.1 cjs mopPrintOneline(stdout, pkt, trans);
426 1.1 cjs }
427 1.1 cjs
428 1.1 cjs if ((DebugFlag >= DEBUG_HEADER)) {
429 1.1 cjs mopPrintHeader(stdout, pkt, trans);
430 1.1 cjs mopPrintMopHeader(stdout, pkt, trans);
431 1.1 cjs }
432 1.1 cjs
433 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
434 1.1 cjs mopDumpDL(stdout, pkt, trans);
435 1.1 cjs }
436 1.1 cjs
437 1.1 cjs if (pfWrite(dllist[slot].ii->fd, pkt, index, trans) != index) {
438 1.1 cjs if (DebugFlag) {
439 1.1 cjs (void)fprintf(stderr, "error pfWrite()\n");
440 1.1 cjs }
441 1.1 cjs }
442 1.1 cjs }
443 1.1 cjs
444 1.1 cjs void
445 1.1 cjs mopProcessDL(fd, ii, pkt, index, dst, src, trans, len)
446 1.1 cjs FILE *fd;
447 1.1 cjs struct if_info *ii;
448 1.5 lukem u_char *pkt;
449 1.5 lukem int *index;
450 1.5 lukem u_char *dst, *src;
451 1.5 lukem int trans;
452 1.1 cjs u_short len;
453 1.1 cjs {
454 1.1 cjs u_char tmpc;
455 1.1 cjs u_short moplen;
456 1.1 cjs u_char pfile[17], mopcode;
457 1.1 cjs char filename[FILENAME_MAX];
458 1.1 cjs char line[100];
459 1.1 cjs int i,nfd,iindex;
460 1.1 cjs struct dllist dl,*dl_rpr;
461 1.1 cjs u_char rpr_pgty,load;
462 1.1 cjs
463 1.1 cjs if ((DebugFlag == DEBUG_ONELINE)) {
464 1.1 cjs mopPrintOneline(stdout, pkt, trans);
465 1.1 cjs }
466 1.1 cjs
467 1.1 cjs if ((DebugFlag >= DEBUG_HEADER)) {
468 1.1 cjs mopPrintHeader(stdout, pkt, trans);
469 1.1 cjs mopPrintMopHeader(stdout, pkt, trans);
470 1.1 cjs }
471 1.1 cjs
472 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
473 1.1 cjs mopDumpDL(stdout, pkt, trans);
474 1.1 cjs }
475 1.1 cjs
476 1.1 cjs moplen = mopGetLength(pkt, trans);
477 1.1 cjs mopcode = mopGetChar(pkt,index);
478 1.1 cjs
479 1.1 cjs switch (mopcode) {
480 1.1 cjs case MOP_K_CODE_MLT:
481 1.1 cjs break;
482 1.1 cjs case MOP_K_CODE_DCM:
483 1.1 cjs break;
484 1.1 cjs case MOP_K_CODE_MLD:
485 1.1 cjs break;
486 1.1 cjs case MOP_K_CODE_ASV:
487 1.1 cjs break;
488 1.1 cjs case MOP_K_CODE_RMD:
489 1.1 cjs break;
490 1.1 cjs case MOP_K_CODE_RPR:
491 1.1 cjs
492 1.1 cjs tmpc = mopGetChar(pkt,index); /* Device Type */
493 1.1 cjs
494 1.1 cjs tmpc = mopGetChar(pkt,index); /* Format Version */
495 1.1 cjs if ((tmpc != MOP_K_RPR_FORMAT) &&
496 1.1 cjs (tmpc != MOP_K_RPR_FORMAT_V3)) {
497 1.1 cjs (void)fprintf(stderr,"mopd: Unknown RPR Format (%d) from ",tmpc);
498 1.1 cjs mopPrintHWA(stderr,src);
499 1.1 cjs (void)fprintf(stderr,"\n");
500 1.1 cjs }
501 1.1 cjs
502 1.1 cjs rpr_pgty = mopGetChar(pkt,index); /* Program Type */
503 1.1 cjs
504 1.1 cjs tmpc = mopGetChar(pkt,index); /* Software ID Len */
505 1.1 cjs for (i = 0; i < tmpc; i++) {
506 1.1 cjs pfile[i] = mopGetChar(pkt,index);
507 1.1 cjs pfile[i+1] = '\0';
508 1.1 cjs }
509 1.1 cjs
510 1.1 cjs if (tmpc == 0) {
511 1.1 cjs /* In a normal implementation of a MOP Loader this */
512 1.1 cjs /* would cause a question to NML (DECnet) if this */
513 1.1 cjs /* node is known and if so what image to load. But */
514 1.1 cjs /* we don't have DECnet so we don't have anybody */
515 1.1 cjs /* to ask. My solution is to use the ethernet addr */
516 1.1 cjs /* as filename. Implementing a database would be */
517 1.1 cjs /* overkill. */
518 1.1 cjs sprintf(pfile,"%02x%02x%02x%02x%02x%02x%c",
519 1.1 cjs src[0],src[1],src[2],src[3],src[4],src[5],0);
520 1.1 cjs }
521 1.1 cjs
522 1.1 cjs tmpc = mopGetChar(pkt,index); /* Processor */
523 1.1 cjs
524 1.1 cjs iindex = *index;
525 1.1 cjs dl_rpr = &dl;
526 1.5 lukem memset(dl_rpr, 0, sizeof(*dl_rpr));
527 1.1 cjs dl_rpr->ii = ii;
528 1.5 lukem memmove((char *)(dl_rpr->eaddr), (char *)src, 6);
529 1.1 cjs mopProcessInfo(pkt,index,moplen,dl_rpr,trans);
530 1.1 cjs
531 1.1 cjs sprintf(filename,"%s/%s.SYS", MOP_FILE_PATH, pfile);
532 1.1 cjs if ((mopCmpEAddr(dst,dl_mcst) == 0)) {
533 1.1 cjs if ((nfd = open(filename, O_RDONLY, 0)) != -1) {
534 1.1 cjs close(nfd);
535 1.1 cjs mopSendASV(src, ii->eaddr, ii, trans);
536 1.1 cjs sprintf(line,
537 1.1 cjs "%x:%x:%x:%x:%x:%x (%d) Do you have %s? (Yes)",
538 1.1 cjs src[0],src[1],src[2],
539 1.1 cjs src[3],src[4],src[5],trans,pfile);
540 1.1 cjs } else {
541 1.1 cjs sprintf(line,
542 1.1 cjs "%x:%x:%x:%x:%x:%x (%d) Do you have %s? (No)",
543 1.1 cjs src[0],src[1],src[2],
544 1.1 cjs src[3],src[4],src[5],trans,pfile);
545 1.1 cjs }
546 1.1 cjs syslog(LOG_INFO, line);
547 1.1 cjs } else {
548 1.1 cjs if ((mopCmpEAddr(dst,ii->eaddr) == 0)) {
549 1.1 cjs dl_rpr->ldfd = open(filename, O_RDONLY, 0);
550 1.1 cjs mopStartLoad(src, ii->eaddr, dl_rpr, trans);
551 1.1 cjs sprintf(line,
552 1.1 cjs "%x:%x:%x:%x:%x:%x Send me %s",
553 1.1 cjs src[0],src[1],src[2],
554 1.1 cjs src[3],src[4],src[5],pfile);
555 1.1 cjs syslog(LOG_INFO, line);
556 1.1 cjs }
557 1.1 cjs }
558 1.1 cjs
559 1.1 cjs break;
560 1.1 cjs case MOP_K_CODE_RML:
561 1.1 cjs
562 1.1 cjs load = mopGetChar(pkt,index); /* Load Number */
563 1.1 cjs
564 1.1 cjs tmpc = mopGetChar(pkt,index); /* Error */
565 1.1 cjs
566 1.1 cjs if ((mopCmpEAddr(dst,ii->eaddr) == 0)) {
567 1.1 cjs mopNextLoad(src, ii->eaddr, load, trans);
568 1.1 cjs }
569 1.1 cjs
570 1.1 cjs break;
571 1.1 cjs case MOP_K_CODE_RDS:
572 1.1 cjs break;
573 1.1 cjs case MOP_K_CODE_MDD:
574 1.1 cjs break;
575 1.1 cjs case MOP_K_CODE_CCP:
576 1.1 cjs break;
577 1.1 cjs case MOP_K_CODE_PLT:
578 1.1 cjs break;
579 1.1 cjs default:
580 1.1 cjs break;
581 1.1 cjs }
582 1.1 cjs }
583 1.1 cjs
584 1.1 cjs void
585 1.1 cjs mopProcessRC(fd, ii, pkt, index, dst, src, trans, len)
586 1.1 cjs FILE *fd;
587 1.1 cjs struct if_info *ii;
588 1.5 lukem u_char *pkt;
589 1.5 lukem int *index;
590 1.5 lukem u_char *dst, *src;
591 1.5 lukem int trans;
592 1.1 cjs u_short len;
593 1.1 cjs {
594 1.1 cjs u_char tmpc;
595 1.1 cjs u_short tmps, moplen = 0;
596 1.1 cjs u_char mopcode;
597 1.1 cjs struct dllist dl,*dl_rpr;
598 1.1 cjs
599 1.1 cjs if ((DebugFlag == DEBUG_ONELINE)) {
600 1.1 cjs mopPrintOneline(stdout, pkt, trans);
601 1.1 cjs }
602 1.1 cjs
603 1.1 cjs if ((DebugFlag >= DEBUG_HEADER)) {
604 1.1 cjs mopPrintHeader(stdout, pkt, trans);
605 1.1 cjs mopPrintMopHeader(stdout, pkt, trans);
606 1.1 cjs }
607 1.1 cjs
608 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
609 1.1 cjs mopDumpRC(stdout, pkt, trans);
610 1.1 cjs }
611 1.1 cjs
612 1.1 cjs moplen = mopGetLength(pkt, trans);
613 1.1 cjs mopcode = mopGetChar(pkt,index);
614 1.1 cjs
615 1.1 cjs switch (mopcode) {
616 1.1 cjs case MOP_K_CODE_RID:
617 1.1 cjs break;
618 1.1 cjs case MOP_K_CODE_BOT:
619 1.1 cjs break;
620 1.1 cjs case MOP_K_CODE_SID:
621 1.1 cjs
622 1.1 cjs tmpc = mopGetChar(pkt,index); /* Reserved */
623 1.1 cjs
624 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
625 1.1 cjs (void)fprintf(stderr, "Reserved : %02x\n",tmpc);
626 1.1 cjs }
627 1.1 cjs
628 1.1 cjs tmps = mopGetShort(pkt,index); /* Receipt # */
629 1.1 cjs if ((DebugFlag >= DEBUG_INFO)) {
630 1.1 cjs (void)fprintf(stderr, "Receipt Nbr : %04x\n",tmpc);
631 1.1 cjs }
632 1.1 cjs
633 1.1 cjs dl_rpr = &dl;
634 1.5 lukem memset(dl_rpr, 0, sizeof(*dl_rpr));
635 1.1 cjs dl_rpr->ii = ii;
636 1.5 lukem memmove((char *)(dl_rpr->eaddr), (char *)src, 6);
637 1.1 cjs mopProcessInfo(pkt,index,moplen,dl_rpr,trans);
638 1.1 cjs
639 1.1 cjs break;
640 1.1 cjs case MOP_K_CODE_RQC:
641 1.1 cjs break;
642 1.1 cjs case MOP_K_CODE_CNT:
643 1.1 cjs break;
644 1.1 cjs case MOP_K_CODE_RVC:
645 1.1 cjs break;
646 1.1 cjs case MOP_K_CODE_RLC:
647 1.1 cjs break;
648 1.1 cjs case MOP_K_CODE_CCP:
649 1.1 cjs break;
650 1.1 cjs case MOP_K_CODE_CRA:
651 1.1 cjs break;
652 1.1 cjs default:
653 1.1 cjs break;
654 1.1 cjs }
655 1.1 cjs }
656 1.1 cjs
657