/* * Copyright (c) 1985 Regents of the University of California. * All rights reserved. * * Redistribution and use in source and binary forms are permitted * provided that the above copyright notice and this paragraph are * duplicated in all such forms and that any documentation, * advertising materials, and other materials related to such * distribution and use acknowledge that the software was developed * by the University of California, Berkeley. The name of the * University may not be used to endorse or promote products derived * from this software without specific prior written permission. * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE. */ #ifndef lint char copyright[] = "@(#) Copyright (c) 1985 Regents of the University of California.\n\ All rights reserved.\n"; #endif /* not lint */ #ifndef lint static char sccsid[] = "@(#)driver.c 5.3 (Berkeley) 6/27/88"; #endif /* not lint */ /* * Hunt * Copyright (c) 1985 Conrad C. Huang, Gregory S. Couch, Kenneth C.R.C. Arnold * San Francisco, California */ # include "hunt.h" # include <signal.h> # include <errno.h> # include <sys/ioctl.h> # include <sys/time.h> # ifndef pdp11 # define RN (((Seed = Seed * 11109 + 13849) >> 16) & 0xffff) # else pdp11 # define RN ((Seed = Seed * 11109 + 13849) & 0x7fff) # endif pdp11 int Seed = 0; # ifdef CONSTANT_MOVE static struct itimerval Timing; # endif CONSTANT_MOVE SOCKET Daemon; # ifdef INTERNET int Test_socket; /* test socket to answer datagrams */ # define DAEMON_SIZE (sizeof Daemon) # else INTERNET # define DAEMON_SIZE (sizeof Daemon - 1) # endif INTERNET /* * main: * The main program. */ main() { register PLAYER *pp; register int had_char; # ifdef INTERNET register long test_mask; int msg; int namelen; SOCKET test; # endif INTERNET # ifdef CONSTANT_MOVE register int enable_alarm, disable_alarm; # endif CONSTANT_MOVE static long read_fds; init(); Sock_mask = (1 << Socket); # ifdef INTERNET test_mask = (1 << Test_socket); # endif INTERNET # ifdef CONSTANT_MOVE enable_alarm = sigblock(0); disable_alarm = enable_alarm | (1 << (SIGALRM - 1)); (void) sigsetmask(disable_alarm); (void) signal(SIGALRM, moveshots); # endif CONSTANT_MOVE while (Nplayer > 0) { # ifdef CONSTANT_MOVE (void) sigsetmask(enable_alarm); # endif CONSTANT_MOVE read_fds = Fds_mask; errno = 0; # ifndef OLDIPC while (select(Num_fds, &read_fds, (int *) NULL, (int *) NULL, (struct timeval *) NULL) < 0) # else OLDIPC while (select(20, &read_fds, NULL, 32767) < 0) # endif OLDIPC { if (errno != EINTR) perror("select"); if (Nplayer == 0) goto out; errno = 0; } Have_inp = read_fds; # ifdef CONSTANT_MOVE (void) sigsetmask(disable_alarm); # endif CONSTANT_MOVE # ifdef INTERNET if (read_fds & test_mask) { namelen = DAEMON_SIZE; # ifndef OLDIPC (void) recvfrom(Test_socket, (char *) &msg, sizeof msg, 0, (struct sockaddr *) &test, &namelen); (void) sendto(Test_socket, (char *) &msg, sizeof msg, 0, (struct sockaddr *) &test, DAEMON_SIZE); # else OLDIPC (void) receive(Test_socket, (struct sockaddr *) &test, (char *) &msg, sizeof msg); (void) send(Test_socket, (struct sockaddr *) &test, (char *) &msg, sizeof msg); # endif OLDIPC } # endif INTERNET for (;;) { had_char = FALSE; for (pp = Player; pp < End_player; pp++) if (havechar(pp)) { execute(pp); pp->p_nexec++; had_char++; } # ifdef MONITOR for (pp = Monitor; pp < End_monitor; pp++) if (havechar(pp)) { mon_execute(pp); pp->p_nexec++; had_char++; } # endif MONITOR if (!had_char) break; # ifdef CONSTANT_MOVE for (pp = Player; pp < End_player; pp++) { look(pp); sendcom(pp, REFRESH); } # ifdef MONITOR for (pp = Monitor; pp < End_monitor; pp++) sendcom(pp, REFRESH); # endif MONITOR # else CONSTANT_MOVE moveshots(); # endif CONSTANT_MOVE for (pp = Player; pp < End_player; ) if (pp->p_death[0] != '\0') zap(pp, TRUE); else pp++; # ifdef MONITOR for (pp = Monitor; pp < End_monitor; ) if (pp->p_death[0] != '\0') zap(pp, FALSE); else pp++; # endif MONITOR } if (read_fds & Sock_mask) answer(); for (pp = Player; pp < End_player; pp++) { if (read_fds & pp->p_mask) sendcom(pp, READY, pp->p_nexec); pp->p_nexec = 0; (void) fflush(pp->p_output); } # ifdef MONITOR for (pp = Monitor; pp < End_monitor; pp++) { if (read_fds & pp->p_mask) sendcom(pp, READY, pp->p_nexec); pp->p_nexec = 0; (void) fflush(pp->p_output); } # endif MONITOR } out: # ifdef CONSTANT_MOVE bul_alarm(0); # endif CONSTANT_MOVE # ifdef MONITOR for (pp = Monitor; pp < End_monitor; ) zap(pp, FALSE); # endif MONITOR cleanup(0); } /* * init: * Initialize the global parameters. */ init() { register int i; # ifdef INTERNET SOCKET test_port; auto int msg; # endif INTERNET int cleanup(); # ifndef DEBUG (void) ioctl(fileno(stdout), TIOCNOTTY, NULL); (void) setpgrp(getpid(), getpid()); (void) signal(SIGHUP, SIG_IGN); (void) signal(SIGINT, SIG_IGN); (void) signal(SIGQUIT, SIG_IGN); (void) signal(SIGTERM, cleanup); # endif DEBUG (void) chdir("/usr/tmp"); /* just in case it core dumps */ (void) signal(SIGPIPE, SIG_IGN); # ifdef INTERNET Daemon.sin_family = SOCK_FAMILY; # ifdef OLD if (gethostname(local_name, sizeof local_name) < 0) { perror("gethostname"); exit(1); } if ((hp = gethostbyname(local_name)) == NULL) { fprintf(stderr, "Unknown host %s\n", local_name); exit(1); } bcopy(hp->h_addr, &(Daemon.sin_addr.s_addr), hp->h_length); # else Daemon.sin_addr.s_addr = INADDR_ANY; # endif OLD Daemon.sin_port = htons(Sock_port); # else INTERNET Daemon.sun_family = SOCK_FAMILY; (void) strcpy(Daemon.sun_path, Sock_name); # endif INTERNET # ifndef OLDIPC Socket = socket(SOCK_FAMILY, SOCK_STREAM, 0); # else OLDIPC Socket = socket(SOCK_STREAM, 0, (struct sockaddr *) &Daemon, SO_ACCEPTCONN); # endif OLDIPC # if defined(INTERNET) && !defined(OLDIPC) if (setsockopt(Socket, SOL_SOCKET, SO_USELOOPBACK, &msg, sizeof msg)<0) perror("setsockopt loopback"); # endif INTERNET # ifndef OLDIPC if (bind(Socket, (struct sockaddr *) &Daemon, DAEMON_SIZE) < 0) { if (errno == EADDRINUSE) exit(0); else { perror("bind"); cleanup(1); } } (void) listen(Socket, 5); # endif OLDIPC Fds_mask = (1 << Socket); Num_fds = Socket + 1; # ifdef INTERNET test_port = Daemon; test_port.sin_port = htons(Test_port); # ifndef OLDIPC Test_socket = socket(SOCK_FAMILY, SOCK_DGRAM, 0); if (bind(Test_socket, (struct sockaddr *) &test_port, DAEMON_SIZE) < 0) { perror("bind"); exit(1); } (void) listen(Test_socket, 5); # else OLDIPC Test_socket = socket(SOCK_DGRAM, 0, (struct sockaddr *) &test_port, 0); # endif OLDIPC Fds_mask |= (1 << Test_socket); if (Test_socket > Socket) Num_fds = Test_socket + 1; # endif INTERNET Seed = getpid() + time((time_t *) NULL); makemaze(); for (i = 0; i < NASCII; i++) See_over[i] = TRUE; See_over[DOOR] = FALSE; See_over[WALL1] = FALSE; See_over[WALL2] = FALSE; See_over[WALL3] = FALSE; # ifdef REFLECT See_over[WALL4] = FALSE; See_over[WALL5] = FALSE; # endif REFLECT # ifdef CONSTANT_MOVE getitimer(ITIMER_REAL, &Timing); Timing.it_interval.tv_sec = 0; Timing.it_interval.tv_usec = 500; Timing.it_value.tv_sec = 0; Timing.it_value.tv_usec = 0; setitimer(ITIMER_REAL, &Timing, NULL); # endif CONSTANT_MOVE answer(); } # ifdef CONSTANT_MOVE /* * bul_alarm: * Set up the alarm for the bullets */ bul_alarm(val) int val; { Timing.it_value.tv_usec = val * Timing.it_interval.tv_usec; setitimer(ITIMER_REAL, &Timing, NULL); } # endif CONSTANT_MOVE /* * checkdam: * Check the damage to the given player, and see if s/he is killed */ checkdam(ouch, gotcha, credit, amt, shot_type) register PLAYER *ouch, *gotcha; register IDENT *credit; int amt; char shot_type; { register char *cp; if (ouch->p_death[0] != '\0') return; if (rand_num(100) < 5) { message(ouch, "Missed you by a hair"); if (gotcha != NULL) message(gotcha, "Missed him"); return; } ouch->p_damage += amt; if (ouch->p_damage <= ouch->p_damcap) { (void) sprintf(Buf, "%2d", ouch->p_damage); cgoto(ouch, STAT_DAM_ROW, STAT_VALUE_COL); outstr(ouch, Buf, 2); return; } /* Someone DIED */ switch (shot_type) { default: cp = "Killed"; break; # ifdef FLY case FALL: cp = "Killed on impact"; break; # endif FLY case KNIFE: cp = "Stabbed to death"; break; case SHOT: cp = "Shot to death"; break; case GRENADE: case SATCHEL: case BOMB: cp = "Bombed"; break; case MINE: case GMINE: cp = "Blown apart"; break; # ifdef OOZE case SLIME: cp = "Slimed"; break; # endif OOZE # ifdef VOLCANO case LAVA: cp = "Baked"; break; # endif VOLCANO } if (credit == NULL) { (void) sprintf(ouch->p_death, "| %s by %s |", cp, (shot_type == MINE || shot_type == GMINE) ? "a mine" : "act of God"); return; } (void) sprintf(ouch->p_death, "| %s by %s |", cp, credit->i_name); credit->i_kills++; credit->i_score = credit->i_kills / (double) credit->i_entries; if (gotcha == NULL) return; gotcha->p_damcap += STABDAM; gotcha->p_damage -= STABDAM; if (gotcha->p_damage < 0) gotcha->p_damage = 0; (void) sprintf(Buf, "%2d/%2d", gotcha->p_damage, gotcha->p_damcap); cgoto(gotcha, STAT_DAM_ROW, STAT_VALUE_COL); outstr(gotcha, Buf, 5); (void) sprintf(Buf, "%3d", (gotcha->p_damcap - MAXDAM) / 2); cgoto(gotcha, STAT_KILL_ROW, STAT_VALUE_COL); outstr(gotcha, Buf, 3); (void) sprintf(Buf, "%5.2f", gotcha->p_ident->i_score); for (ouch = Player; ouch < End_player; ouch++) { cgoto(ouch, STAT_PLAY_ROW + 1 + (gotcha - Player), STAT_NAME_COL); outstr(ouch, Buf, 5); } } /* * zap: * Kill off a player and take him out of the game. */ zap(pp, was_player) register PLAYER *pp; FLAG was_player; { register int i, len; register BULLET *bp; register PLAYER *np; register int x, y; int savefd, savemask; if (was_player) { drawplayer(pp, FALSE); Nplayer--; } len = strlen(pp->p_death); /* Display the cause of death */ x = (WIDTH - len) / 2; cgoto(pp, HEIGHT / 2, x); outstr(pp, pp->p_death, len); for (i = 1; i < len; i++) pp->p_death[i] = '-'; pp->p_death[0] = '+'; pp->p_death[len - 1] = '+'; cgoto(pp, HEIGHT / 2 - 1, x); outstr(pp, pp->p_death, len); cgoto(pp, HEIGHT / 2 + 1, x); outstr(pp, pp->p_death, len); cgoto(pp, HEIGHT, 0); if (Nplayer == 0) { # ifdef CONSTANT_MOVE bul_alarm(0); # endif CONSTANT_MOVE cleanup(0); /* NOTREACHED */ } savefd = pp->p_fd; savemask = pp->p_mask; # ifdef MONITOR if (was_player) { # endif MONITOR for (bp = Bullets; bp != NULL; bp = bp->b_next) { if (bp->b_owner == pp) bp->b_owner = NULL; if (bp->b_x == pp->p_x && bp->b_y == pp->p_y) bp->b_over = SPACE; } i = rand_num(pp->p_ammo); if (i == pp->p_ammo - 1) { x = pp->p_ammo; len = SLIME; } else if (i >= BOMBREQ) { x = BOMBREQ; len = BOMB; } else if (i >= SSLIMEREQ) { x = SSLIMEREQ; len = SLIME; } else if (i >= SATREQ) { x = SATREQ; len = SATCHEL; } else if (i >= SLIMEREQ) { x = SLIMEREQ; len = SLIME; } else if (i >= GRENREQ) { x = GRENREQ; len = GRENADE; } else x = 0; if (x > 0) { add_shot(len, pp->p_y, pp->p_x, pp->p_face, x, (PLAYER *) NULL, TRUE, SPACE); (void) sprintf(Buf, "%s detonated.", pp->p_ident->i_name); for (np = Player; np < End_player; np++) message(np, Buf); # ifdef MONITOR for (np = Monitor; np < End_monitor; np++) message(np, Buf); # endif MONITOR } # ifdef VOLCANO volcano += pp->p_ammo - x; if (rand_num(100) < volcano / 50) { do { x = rand_num(WIDTH / 2) + WIDTH / 4; y = rand_num(HEIGHT / 2) + HEIGHT / 4; } while (Maze[y][x] != SPACE); add_shot(LAVA, y, x, LEFTS, volcano, (PLAYER *) NULL, TRUE, SPACE); for (np = Player; np < End_player; np++) message(np, "Volcano eruption."); volcano = 0; } # endif VOLCANO sendcom(pp, ENDWIN); (void) fclose(pp->p_output); End_player--; if (pp != End_player) { bcopy((char *) End_player, (char *) pp, sizeof (PLAYER)); (void) sprintf(Buf, "%5.2f%c%-10.10s", pp->p_ident->i_score, stat_char(pp), pp->p_ident->i_name); i = STAT_PLAY_ROW + 1 + (pp - Player); for (np = Player; np < End_player; np++) { cgoto(np, i, STAT_NAME_COL); outstr(np, Buf, STAT_NAME_LEN); } # ifdef MONITOR for (np = Monitor; np < End_monitor; np++) { cgoto(np, i, STAT_NAME_COL); outstr(np, Buf, STAT_NAME_LEN); } # endif MONITOR } /* Erase the last player */ i = STAT_PLAY_ROW + 1 + Nplayer; for (np = Player; np < End_player; np++) { cgoto(np, i, STAT_NAME_COL); ce(np); } # ifdef MONITOR for (np = Monitor; np < End_monitor; np++) { cgoto(np, i, STAT_NAME_COL); ce(np); } } else { sendcom(pp, ENDWIN); (void) putc(LAST_PLAYER, pp->p_output); (void) fclose(pp->p_output); End_monitor--; if (pp != End_monitor) { bcopy((char *) End_monitor, (char *) pp, sizeof (PLAYER)); (void) sprintf(Buf, "%5.5s %-10.10s", " ", pp->p_ident->i_name); i = STAT_MON_ROW + 1 + (pp - Player); for (np = Player; np < End_player; np++) { cgoto(np, i, STAT_NAME_COL); outstr(np, Buf, STAT_NAME_LEN); } for (np = Monitor; np < End_monitor; np++) { cgoto(np, i, STAT_NAME_COL); outstr(np, Buf, STAT_NAME_LEN); } } /* Erase the last monitor */ i = STAT_MON_ROW + 1 + (End_monitor - Monitor); for (np = Player; np < End_player; np++) { cgoto(np, i, STAT_NAME_COL); ce(np); } for (np = Monitor; np < End_monitor; np++) { cgoto(np, i, STAT_NAME_COL); ce(np); } } # endif MONITOR Fds_mask &= ~savemask; if (Num_fds == savefd + 1) { Num_fds = Socket; # ifdef INTERNET if (Test_socket > Socket) Num_fds = Test_socket; # endif INTERNET for (np = Player; np < End_player; np++) if (np->p_fd > Num_fds) Num_fds = np->p_fd; # ifdef MONITOR for (np = Monitor; np < End_monitor; np++) if (np->p_fd > Num_fds) Num_fds = np->p_fd; # endif MONITOR Num_fds++; } } /* * rand_num: * Return a random number in a given range. */ rand_num(range) int range; { return (range == 0 ? 0 : RN % range); } /* * havechar: * Check to see if we have any characters in the input queue; if * we do, read them, stash them away, and return TRUE; else return * FALSE. */ havechar(pp) register PLAYER *pp; { extern int errno; if (pp->p_ncount < pp->p_nchar) return TRUE; if (!(Have_inp & pp->p_mask)) return FALSE; Have_inp &= ~pp->p_mask; check_again: errno = 0; if ((pp->p_nchar = read(pp->p_fd, pp->p_cbuf, sizeof pp->p_cbuf)) <= 0) { if (errno == EINTR) goto check_again; pp->p_cbuf[0] = 'q'; } pp->p_ncount = 0; return TRUE; } /* * cleanup: * Exit with the given value, cleaning up any droppings lying around */ cleanup(eval) int eval; { register PLAYER *pp; for (pp = Player; pp < End_player; pp++) { cgoto(pp, HEIGHT, 0); sendcom(pp, ENDWIN); (void) putc(LAST_PLAYER, pp->p_output); (void) fclose(pp->p_output); } # ifdef MONITOR for (pp = Monitor; pp < End_monitor; pp++) { cgoto(pp, HEIGHT, 0); sendcom(pp, ENDWIN); (void) putc(LAST_PLAYER, pp->p_output); (void) fclose(pp->p_output); } # endif MONITOR (void) close(Socket); # ifdef AF_UNIX_HACK (void) unlink(Sock_name); # endif AF_UNIX_HACK exit(eval); }