2.11BSD/src/games/hunt/driver.c
/*
* Hunt
* Copyright (c) 1985 Conrad C. Huang, Gregory S. Couch, Kenneth C.R.C. Arnold
* San Francisco, California
*
* Copyright (c) 1985 Regents of the University of California.
* All rights reserved. The Berkeley software License Agreement
* specifies the terms and conditions for redistribution.
*
* 1997/9/9 - updated to use sigprocmask (and compute the alarm mask correctly)
*/
# 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
sigset_t alarm_sigset;
# endif CONSTANT_MOVE
static long read_fds;
init();
Sock_mask = (1 << Socket);
# ifdef INTERNET
test_mask = (1 << Test_socket);
# endif INTERNET
# ifdef CONSTANT_MOVE
sigemptyset(&alarm_sigset);
sigaddset(&alarm_sigset, SIGALRM);
(void) sigprocmask(SIG_BLOCK, &alarm_sigset, NULL);
(void) signal(SIGALRM, moveshots);
# endif CONSTANT_MOVE
while (Nplayer > 0) {
# ifdef CONSTANT_MOVE
(void) sigprocmask(SIG_UNBLOCK, &alarm_sigset, NULL);
# 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) sigprocmask(SIG_BLOCK, &alarm_sigset, NULL);
# 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);
}