![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to driver.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDTahoe / games / hunt|
Return to driver.c CVS log | Up to [CSRG BSD Unix] / 43BSDTahoe / games / hunt |
1.1 root 1: /*
2: * Copyright (c) 1985 Regents of the University of California.
3: * All rights reserved.
4: *
5: * Redistribution and use in source and binary forms are permitted
6: * provided that the above copyright notice and this paragraph are
7: * duplicated in all such forms and that any documentation,
8: * advertising materials, and other materials related to such
9: * distribution and use acknowledge that the software was developed
10: * by the University of California, Berkeley. The name of the
11: * University may not be used to endorse or promote products derived
12: * from this software without specific prior written permission.
13: * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
14: * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
15: * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
16: */
17:
18: #ifndef lint
19: char copyright[] =
20: "@(#) Copyright (c) 1985 Regents of the University of California.\n\
21: All rights reserved.\n";
22: #endif /* not lint */
23:
24: #ifndef lint
25: static char sccsid[] = "@(#)driver.c 5.3 (Berkeley) 6/27/88";
26: #endif /* not lint */
27:
28: /*
29: * Hunt
30: * Copyright (c) 1985 Conrad C. Huang, Gregory S. Couch, Kenneth C.R.C. Arnold
31: * San Francisco, California
32: */
33:
34: # include "hunt.h"
35: # include <signal.h>
36: # include <errno.h>
37: # include <sys/ioctl.h>
38: # include <sys/time.h>
39:
40: # ifndef pdp11
41: # define RN (((Seed = Seed * 11109 + 13849) >> 16) & 0xffff)
42: # else pdp11
43: # define RN ((Seed = Seed * 11109 + 13849) & 0x7fff)
44: # endif pdp11
45:
46: int Seed = 0;
47:
48: # ifdef CONSTANT_MOVE
49: static struct itimerval Timing;
50: # endif CONSTANT_MOVE
51:
52: SOCKET Daemon;
53: # ifdef INTERNET
54: int Test_socket; /* test socket to answer datagrams */
55: # define DAEMON_SIZE (sizeof Daemon)
56: # else INTERNET
57: # define DAEMON_SIZE (sizeof Daemon - 1)
58: # endif INTERNET
59:
60: /*
61: * main:
62: * The main program.
63: */
64: main()
65: {
66: register PLAYER *pp;
67: register int had_char;
68: # ifdef INTERNET
69: register long test_mask;
70: int msg;
71: int namelen;
72: SOCKET test;
73: # endif INTERNET
74: # ifdef CONSTANT_MOVE
75: register int enable_alarm, disable_alarm;
76: # endif CONSTANT_MOVE
77: static long read_fds;
78:
79: init();
80: Sock_mask = (1 << Socket);
81: # ifdef INTERNET
82: test_mask = (1 << Test_socket);
83: # endif INTERNET
84:
85: # ifdef CONSTANT_MOVE
86: enable_alarm = sigblock(0);
87: disable_alarm = enable_alarm | (1 << (SIGALRM - 1));
88: (void) sigsetmask(disable_alarm);
89: (void) signal(SIGALRM, moveshots);
90: # endif CONSTANT_MOVE
91:
92: while (Nplayer > 0) {
93: # ifdef CONSTANT_MOVE
94: (void) sigsetmask(enable_alarm);
95: # endif CONSTANT_MOVE
96: read_fds = Fds_mask;
97: errno = 0;
98: # ifndef OLDIPC
99: while (select(Num_fds, &read_fds, (int *) NULL,
100: (int *) NULL, (struct timeval *) NULL) < 0)
101: # else OLDIPC
102: while (select(20, &read_fds, NULL, 32767) < 0)
103: # endif OLDIPC
104: {
105: if (errno != EINTR)
106: perror("select");
107: if (Nplayer == 0)
108: goto out;
109: errno = 0;
110: }
111: Have_inp = read_fds;
112: # ifdef CONSTANT_MOVE
113: (void) sigsetmask(disable_alarm);
114: # endif CONSTANT_MOVE
115: # ifdef INTERNET
116: if (read_fds & test_mask) {
117: namelen = DAEMON_SIZE;
118: # ifndef OLDIPC
119: (void) recvfrom(Test_socket, (char *) &msg, sizeof msg,
120: 0, (struct sockaddr *) &test, &namelen);
121: (void) sendto(Test_socket, (char *) &msg, sizeof msg,
122: 0, (struct sockaddr *) &test, DAEMON_SIZE);
123: # else OLDIPC
124: (void) receive(Test_socket, (struct sockaddr *) &test,
125: (char *) &msg, sizeof msg);
126: (void) send(Test_socket, (struct sockaddr *) &test,
127: (char *) &msg, sizeof msg);
128: # endif OLDIPC
129: }
130: # endif INTERNET
131: for (;;) {
132: had_char = FALSE;
133: for (pp = Player; pp < End_player; pp++)
134: if (havechar(pp)) {
135: execute(pp);
136: pp->p_nexec++;
137: had_char++;
138: }
139: # ifdef MONITOR
140: for (pp = Monitor; pp < End_monitor; pp++)
141: if (havechar(pp)) {
142: mon_execute(pp);
143: pp->p_nexec++;
144: had_char++;
145: }
146: # endif MONITOR
147: if (!had_char)
148: break;
149: # ifdef CONSTANT_MOVE
150: for (pp = Player; pp < End_player; pp++) {
151: look(pp);
152: sendcom(pp, REFRESH);
153: }
154: # ifdef MONITOR
155: for (pp = Monitor; pp < End_monitor; pp++)
156: sendcom(pp, REFRESH);
157: # endif MONITOR
158: # else CONSTANT_MOVE
159: moveshots();
160: # endif CONSTANT_MOVE
161: for (pp = Player; pp < End_player; )
162: if (pp->p_death[0] != '\0')
163: zap(pp, TRUE);
164: else
165: pp++;
166: # ifdef MONITOR
167: for (pp = Monitor; pp < End_monitor; )
168: if (pp->p_death[0] != '\0')
169: zap(pp, FALSE);
170: else
171: pp++;
172: # endif MONITOR
173: }
174: if (read_fds & Sock_mask)
175: answer();
176: for (pp = Player; pp < End_player; pp++) {
177: if (read_fds & pp->p_mask)
178: sendcom(pp, READY, pp->p_nexec);
179: pp->p_nexec = 0;
180: (void) fflush(pp->p_output);
181: }
182: # ifdef MONITOR
183: for (pp = Monitor; pp < End_monitor; pp++) {
184: if (read_fds & pp->p_mask)
185: sendcom(pp, READY, pp->p_nexec);
186: pp->p_nexec = 0;
187: (void) fflush(pp->p_output);
188: }
189: # endif MONITOR
190: }
191: out:
192: # ifdef CONSTANT_MOVE
193: bul_alarm(0);
194: # endif CONSTANT_MOVE
195:
196: # ifdef MONITOR
197: for (pp = Monitor; pp < End_monitor; )
198: zap(pp, FALSE);
199: # endif MONITOR
200: cleanup(0);
201: }
202:
203: /*
204: * init:
205: * Initialize the global parameters.
206: */
207: init()
208: {
209: register int i;
210: # ifdef INTERNET
211: SOCKET test_port;
212: auto int msg;
213: # endif INTERNET
214: int cleanup();
215:
216: # ifndef DEBUG
217: (void) ioctl(fileno(stdout), TIOCNOTTY, NULL);
218: (void) setpgrp(getpid(), getpid());
219: (void) signal(SIGHUP, SIG_IGN);
220: (void) signal(SIGINT, SIG_IGN);
221: (void) signal(SIGQUIT, SIG_IGN);
222: (void) signal(SIGTERM, cleanup);
223: # endif DEBUG
224:
225: (void) chdir("/usr/tmp"); /* just in case it core dumps */
226: (void) signal(SIGPIPE, SIG_IGN);
227:
228: # ifdef INTERNET
229: Daemon.sin_family = SOCK_FAMILY;
230: # ifdef OLD
231: if (gethostname(local_name, sizeof local_name) < 0) {
232: perror("gethostname");
233: exit(1);
234: }
235: if ((hp = gethostbyname(local_name)) == NULL) {
236: fprintf(stderr, "Unknown host %s\n", local_name);
237: exit(1);
238: }
239: bcopy(hp->h_addr, &(Daemon.sin_addr.s_addr), hp->h_length);
240: # else
241: Daemon.sin_addr.s_addr = INADDR_ANY;
242: # endif OLD
243: Daemon.sin_port = htons(Sock_port);
244: # else INTERNET
245: Daemon.sun_family = SOCK_FAMILY;
246: (void) strcpy(Daemon.sun_path, Sock_name);
247: # endif INTERNET
248:
249: # ifndef OLDIPC
250: Socket = socket(SOCK_FAMILY, SOCK_STREAM, 0);
251: # else OLDIPC
252: Socket = socket(SOCK_STREAM, 0, (struct sockaddr *) &Daemon,
253: SO_ACCEPTCONN);
254: # endif OLDIPC
255: # if defined(INTERNET) && !defined(OLDIPC)
256: if (setsockopt(Socket, SOL_SOCKET, SO_USELOOPBACK, &msg, sizeof msg)<0)
257: perror("setsockopt loopback");
258: # endif INTERNET
259: # ifndef OLDIPC
260: if (bind(Socket, (struct sockaddr *) &Daemon, DAEMON_SIZE) < 0) {
261: if (errno == EADDRINUSE)
262: exit(0);
263: else {
264: perror("bind");
265: cleanup(1);
266: }
267: }
268: (void) listen(Socket, 5);
269: # endif OLDIPC
270: Fds_mask = (1 << Socket);
271: Num_fds = Socket + 1;
272:
273: # ifdef INTERNET
274: test_port = Daemon;
275: test_port.sin_port = htons(Test_port);
276:
277: # ifndef OLDIPC
278: Test_socket = socket(SOCK_FAMILY, SOCK_DGRAM, 0);
279: if (bind(Test_socket, (struct sockaddr *) &test_port,
280: DAEMON_SIZE) < 0) {
281: perror("bind");
282: exit(1);
283: }
284: (void) listen(Test_socket, 5);
285: # else OLDIPC
286: Test_socket = socket(SOCK_DGRAM, 0, (struct sockaddr *) &test_port, 0);
287: # endif OLDIPC
288: Fds_mask |= (1 << Test_socket);
289: if (Test_socket > Socket)
290: Num_fds = Test_socket + 1;
291: # endif INTERNET
292:
293: Seed = getpid() + time((time_t *) NULL);
294: makemaze();
295:
296: for (i = 0; i < NASCII; i++)
297: See_over[i] = TRUE;
298: See_over[DOOR] = FALSE;
299: See_over[WALL1] = FALSE;
300: See_over[WALL2] = FALSE;
301: See_over[WALL3] = FALSE;
302: # ifdef REFLECT
303: See_over[WALL4] = FALSE;
304: See_over[WALL5] = FALSE;
305: # endif REFLECT
306:
307: # ifdef CONSTANT_MOVE
308: getitimer(ITIMER_REAL, &Timing);
309: Timing.it_interval.tv_sec = 0;
310: Timing.it_interval.tv_usec = 500;
311: Timing.it_value.tv_sec = 0;
312: Timing.it_value.tv_usec = 0;
313: setitimer(ITIMER_REAL, &Timing, NULL);
314: # endif CONSTANT_MOVE
315:
316: answer();
317: }
318:
319: # ifdef CONSTANT_MOVE
320: /*
321: * bul_alarm:
322: * Set up the alarm for the bullets
323: */
324: bul_alarm(val)
325: int val;
326: {
327: Timing.it_value.tv_usec = val * Timing.it_interval.tv_usec;
328: setitimer(ITIMER_REAL, &Timing, NULL);
329: }
330: # endif CONSTANT_MOVE
331:
332: /*
333: * checkdam:
334: * Check the damage to the given player, and see if s/he is killed
335: */
336: checkdam(ouch, gotcha, credit, amt, shot_type)
337: register PLAYER *ouch, *gotcha;
338: register IDENT *credit;
339: int amt;
340: char shot_type;
341: {
342: register char *cp;
343:
344: if (ouch->p_death[0] != '\0')
345: return;
346: if (rand_num(100) < 5) {
347: message(ouch, "Missed you by a hair");
348: if (gotcha != NULL)
349: message(gotcha, "Missed him");
350: return;
351: }
352: ouch->p_damage += amt;
353: if (ouch->p_damage <= ouch->p_damcap) {
354: (void) sprintf(Buf, "%2d", ouch->p_damage);
355: cgoto(ouch, STAT_DAM_ROW, STAT_VALUE_COL);
356: outstr(ouch, Buf, 2);
357: return;
358: }
359:
360: /* Someone DIED */
361: switch (shot_type) {
362: default:
363: cp = "Killed";
364: break;
365: # ifdef FLY
366: case FALL:
367: cp = "Killed on impact";
368: break;
369: # endif FLY
370: case KNIFE:
371: cp = "Stabbed to death";
372: break;
373: case SHOT:
374: cp = "Shot to death";
375: break;
376: case GRENADE:
377: case SATCHEL:
378: case BOMB:
379: cp = "Bombed";
380: break;
381: case MINE:
382: case GMINE:
383: cp = "Blown apart";
384: break;
385: # ifdef OOZE
386: case SLIME:
387: cp = "Slimed";
388: break;
389: # endif OOZE
390: # ifdef VOLCANO
391: case LAVA:
392: cp = "Baked";
393: break;
394: # endif VOLCANO
395: }
396: if (credit == NULL) {
397: (void) sprintf(ouch->p_death, "| %s by %s |", cp,
398: (shot_type == MINE || shot_type == GMINE) ?
399: "a mine" : "act of God");
400: return;
401: }
402:
403: (void) sprintf(ouch->p_death, "| %s by %s |", cp, credit->i_name);
404:
405: credit->i_kills++;
406: credit->i_score = credit->i_kills / (double) credit->i_entries;
407: if (gotcha == NULL)
408: return;
409: gotcha->p_damcap += STABDAM;
410: gotcha->p_damage -= STABDAM;
411: if (gotcha->p_damage < 0)
412: gotcha->p_damage = 0;
413: (void) sprintf(Buf, "%2d/%2d", gotcha->p_damage, gotcha->p_damcap);
414: cgoto(gotcha, STAT_DAM_ROW, STAT_VALUE_COL);
415: outstr(gotcha, Buf, 5);
416: (void) sprintf(Buf, "%3d", (gotcha->p_damcap - MAXDAM) / 2);
417: cgoto(gotcha, STAT_KILL_ROW, STAT_VALUE_COL);
418: outstr(gotcha, Buf, 3);
419: (void) sprintf(Buf, "%5.2f", gotcha->p_ident->i_score);
420: for (ouch = Player; ouch < End_player; ouch++) {
421: cgoto(ouch, STAT_PLAY_ROW + 1 + (gotcha - Player),
422: STAT_NAME_COL);
423: outstr(ouch, Buf, 5);
424: }
425: }
426:
427: /*
428: * zap:
429: * Kill off a player and take him out of the game.
430: */
431: zap(pp, was_player)
432: register PLAYER *pp;
433: FLAG was_player;
434: {
435: register int i, len;
436: register BULLET *bp;
437: register PLAYER *np;
438: register int x, y;
439: int savefd, savemask;
440:
441: if (was_player) {
442: drawplayer(pp, FALSE);
443: Nplayer--;
444: }
445:
446: len = strlen(pp->p_death); /* Display the cause of death */
447: x = (WIDTH - len) / 2;
448: cgoto(pp, HEIGHT / 2, x);
449: outstr(pp, pp->p_death, len);
450: for (i = 1; i < len; i++)
451: pp->p_death[i] = '-';
452: pp->p_death[0] = '+';
453: pp->p_death[len - 1] = '+';
454: cgoto(pp, HEIGHT / 2 - 1, x);
455: outstr(pp, pp->p_death, len);
456: cgoto(pp, HEIGHT / 2 + 1, x);
457: outstr(pp, pp->p_death, len);
458: cgoto(pp, HEIGHT, 0);
459:
460: if (Nplayer == 0) {
461: # ifdef CONSTANT_MOVE
462: bul_alarm(0);
463: # endif CONSTANT_MOVE
464: cleanup(0);
465: /* NOTREACHED */
466: }
467:
468: savefd = pp->p_fd;
469: savemask = pp->p_mask;
470:
471: # ifdef MONITOR
472: if (was_player) {
473: # endif MONITOR
474: for (bp = Bullets; bp != NULL; bp = bp->b_next) {
475: if (bp->b_owner == pp)
476: bp->b_owner = NULL;
477: if (bp->b_x == pp->p_x && bp->b_y == pp->p_y)
478: bp->b_over = SPACE;
479: }
480:
481: i = rand_num(pp->p_ammo);
482: if (i == pp->p_ammo - 1) {
483: x = pp->p_ammo;
484: len = SLIME;
485: }
486: else if (i >= BOMBREQ) {
487: x = BOMBREQ;
488: len = BOMB;
489: }
490: else if (i >= SSLIMEREQ) {
491: x = SSLIMEREQ;
492: len = SLIME;
493: }
494: else if (i >= SATREQ) {
495: x = SATREQ;
496: len = SATCHEL;
497: }
498: else if (i >= SLIMEREQ) {
499: x = SLIMEREQ;
500: len = SLIME;
501: }
502: else if (i >= GRENREQ) {
503: x = GRENREQ;
504: len = GRENADE;
505: }
506: else
507: x = 0;
508: if (x > 0) {
509: add_shot(len, pp->p_y, pp->p_x, pp->p_face, x,
510: (PLAYER *) NULL, TRUE, SPACE);
511: (void) sprintf(Buf, "%s detonated.",
512: pp->p_ident->i_name);
513: for (np = Player; np < End_player; np++)
514: message(np, Buf);
515: # ifdef MONITOR
516: for (np = Monitor; np < End_monitor; np++)
517: message(np, Buf);
518: # endif MONITOR
519: }
520:
521: # ifdef VOLCANO
522: volcano += pp->p_ammo - x;
523: if (rand_num(100) < volcano / 50) {
524: do {
525: x = rand_num(WIDTH / 2) + WIDTH / 4;
526: y = rand_num(HEIGHT / 2) + HEIGHT / 4;
527: } while (Maze[y][x] != SPACE);
528: add_shot(LAVA, y, x, LEFTS, volcano,
529: (PLAYER *) NULL, TRUE, SPACE);
530: for (np = Player; np < End_player; np++)
531: message(np, "Volcano eruption.");
532: volcano = 0;
533: }
534: # endif VOLCANO
535:
536: sendcom(pp, ENDWIN);
537: (void) fclose(pp->p_output);
538:
539: End_player--;
540: if (pp != End_player) {
541: bcopy((char *) End_player, (char *) pp,
542: sizeof (PLAYER));
543: (void) sprintf(Buf, "%5.2f%c%-10.10s",
544: pp->p_ident->i_score, stat_char(pp),
545: pp->p_ident->i_name);
546: i = STAT_PLAY_ROW + 1 + (pp - Player);
547: for (np = Player; np < End_player; np++) {
548: cgoto(np, i, STAT_NAME_COL);
549: outstr(np, Buf, STAT_NAME_LEN);
550: }
551: # ifdef MONITOR
552: for (np = Monitor; np < End_monitor; np++) {
553: cgoto(np, i, STAT_NAME_COL);
554: outstr(np, Buf, STAT_NAME_LEN);
555: }
556: # endif MONITOR
557: }
558:
559: /* Erase the last player */
560: i = STAT_PLAY_ROW + 1 + Nplayer;
561: for (np = Player; np < End_player; np++) {
562: cgoto(np, i, STAT_NAME_COL);
563: ce(np);
564: }
565: # ifdef MONITOR
566: for (np = Monitor; np < End_monitor; np++) {
567: cgoto(np, i, STAT_NAME_COL);
568: ce(np);
569: }
570: }
571: else {
572: sendcom(pp, ENDWIN);
573: (void) putc(LAST_PLAYER, pp->p_output);
574: (void) fclose(pp->p_output);
575:
576: End_monitor--;
577: if (pp != End_monitor) {
578: bcopy((char *) End_monitor, (char *) pp,
579: sizeof (PLAYER));
580: (void) sprintf(Buf, "%5.5s %-10.10s", " ",
581: pp->p_ident->i_name);
582: i = STAT_MON_ROW + 1 + (pp - Player);
583: for (np = Player; np < End_player; np++) {
584: cgoto(np, i, STAT_NAME_COL);
585: outstr(np, Buf, STAT_NAME_LEN);
586: }
587: for (np = Monitor; np < End_monitor; np++) {
588: cgoto(np, i, STAT_NAME_COL);
589: outstr(np, Buf, STAT_NAME_LEN);
590: }
591: }
592:
593: /* Erase the last monitor */
594: i = STAT_MON_ROW + 1 + (End_monitor - Monitor);
595: for (np = Player; np < End_player; np++) {
596: cgoto(np, i, STAT_NAME_COL);
597: ce(np);
598: }
599: for (np = Monitor; np < End_monitor; np++) {
600: cgoto(np, i, STAT_NAME_COL);
601: ce(np);
602: }
603:
604: }
605: # endif MONITOR
606:
607: Fds_mask &= ~savemask;
608: if (Num_fds == savefd + 1) {
609: Num_fds = Socket;
610: # ifdef INTERNET
611: if (Test_socket > Socket)
612: Num_fds = Test_socket;
613: # endif INTERNET
614: for (np = Player; np < End_player; np++)
615: if (np->p_fd > Num_fds)
616: Num_fds = np->p_fd;
617: # ifdef MONITOR
618: for (np = Monitor; np < End_monitor; np++)
619: if (np->p_fd > Num_fds)
620: Num_fds = np->p_fd;
621: # endif MONITOR
622: Num_fds++;
623: }
624: }
625:
626: /*
627: * rand_num:
628: * Return a random number in a given range.
629: */
630: rand_num(range)
631: int range;
632: {
633: return (range == 0 ? 0 : RN % range);
634: }
635:
636: /*
637: * havechar:
638: * Check to see if we have any characters in the input queue; if
639: * we do, read them, stash them away, and return TRUE; else return
640: * FALSE.
641: */
642: havechar(pp)
643: register PLAYER *pp;
644: {
645: extern int errno;
646:
647: if (pp->p_ncount < pp->p_nchar)
648: return TRUE;
649: if (!(Have_inp & pp->p_mask))
650: return FALSE;
651: Have_inp &= ~pp->p_mask;
652: check_again:
653: errno = 0;
654: if ((pp->p_nchar = read(pp->p_fd, pp->p_cbuf, sizeof pp->p_cbuf)) <= 0)
655: {
656: if (errno == EINTR)
657: goto check_again;
658: pp->p_cbuf[0] = 'q';
659: }
660: pp->p_ncount = 0;
661: return TRUE;
662: }
663:
664: /*
665: * cleanup:
666: * Exit with the given value, cleaning up any droppings lying around
667: */
668: cleanup(eval)
669: int eval;
670: {
671: register PLAYER *pp;
672:
673: for (pp = Player; pp < End_player; pp++) {
674: cgoto(pp, HEIGHT, 0);
675: sendcom(pp, ENDWIN);
676: (void) putc(LAST_PLAYER, pp->p_output);
677: (void) fclose(pp->p_output);
678: }
679: # ifdef MONITOR
680: for (pp = Monitor; pp < End_monitor; pp++) {
681: cgoto(pp, HEIGHT, 0);
682: sendcom(pp, ENDWIN);
683: (void) putc(LAST_PLAYER, pp->p_output);
684: (void) fclose(pp->p_output);
685: }
686: # endif MONITOR
687: (void) close(Socket);
688: # ifdef AF_UNIX_HACK
689: (void) unlink(Sock_name);
690: # endif AF_UNIX_HACK
691: exit(eval);
692: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.