driver.c revision 1.5 1 1.5 lukem /* $NetBSD: driver.c,v 1.5 1997/10/20 00:37:16 lukem Exp $ */
2 1.1 mrg /*
3 1.1 mrg * Hunt
4 1.1 mrg * Copyright (c) 1985 Conrad C. Huang, Gregory S. Couch, Kenneth C.R.C. Arnold
5 1.1 mrg * San Francisco, California
6 1.1 mrg */
7 1.1 mrg
8 1.2 lukem #include <sys/cdefs.h>
9 1.2 lukem #ifndef lint
10 1.5 lukem __RCSID("$NetBSD: driver.c,v 1.5 1997/10/20 00:37:16 lukem Exp $");
11 1.2 lukem #endif /* not lint */
12 1.2 lukem
13 1.1 mrg # include <sys/ioctl.h>
14 1.2 lukem # include <sys/stat.h>
15 1.1 mrg # include <sys/time.h>
16 1.2 lukem # include <err.h>
17 1.2 lukem # include <errno.h>
18 1.2 lukem # include <signal.h>
19 1.2 lukem # include <stdlib.h>
20 1.2 lukem # include <unistd.h>
21 1.2 lukem # include "hunt.h"
22 1.1 mrg
23 1.1 mrg # ifndef pdp11
24 1.1 mrg # define RN (((Seed = Seed * 11109 + 13849) >> 16) & 0xffff)
25 1.1 mrg # else
26 1.1 mrg # define RN ((Seed = Seed * 11109 + 13849) & 0x7fff)
27 1.1 mrg # endif
28 1.1 mrg
29 1.1 mrg int Seed = 0;
30 1.1 mrg
31 1.1 mrg
32 1.1 mrg SOCKET Daemon;
33 1.1 mrg char *First_arg; /* pointer to argv[0] */
34 1.1 mrg char *Last_arg; /* pointer to end of argv/environ */
35 1.1 mrg # ifdef INTERNET
36 1.1 mrg int Test_socket; /* test socket to answer datagrams */
37 1.1 mrg FLAG inetd_spawned; /* invoked via inetd */
38 1.1 mrg FLAG standard_port = TRUE; /* true if listening on standard port */
39 1.1 mrg u_short sock_port; /* port # of tcp listen socket */
40 1.1 mrg u_short stat_port; /* port # of statistics tcp socket */
41 1.1 mrg # define DAEMON_SIZE (sizeof Daemon)
42 1.1 mrg # else
43 1.1 mrg # define DAEMON_SIZE (sizeof Daemon - 1)
44 1.1 mrg # endif
45 1.1 mrg
46 1.2 lukem static void clear_scores __P((void));
47 1.2 lukem static int havechar __P((PLAYER *));
48 1.2 lukem static void init __P((void));
49 1.2 lukem int main __P((int, char *[], char *[]));
50 1.2 lukem static void makeboots __P((void));
51 1.2 lukem static void send_stats __P((void));
52 1.2 lukem static void zap __P((PLAYER *, FLAG));
53 1.2 lukem
54 1.1 mrg
55 1.1 mrg /*
56 1.1 mrg * main:
57 1.1 mrg * The main program.
58 1.1 mrg */
59 1.2 lukem int
60 1.1 mrg main(ac, av, ep)
61 1.2 lukem int ac;
62 1.2 lukem char **av, **ep;
63 1.1 mrg {
64 1.2 lukem PLAYER *pp;
65 1.2 lukem int had_char;
66 1.1 mrg # ifdef INTERNET
67 1.2 lukem u_short msg;
68 1.2 lukem short port_num, reply;
69 1.2 lukem int namelen;
70 1.2 lukem SOCKET test;
71 1.1 mrg # endif
72 1.2 lukem static fd_set read_fds;
73 1.1 mrg static FLAG first = TRUE;
74 1.1 mrg static FLAG server = FALSE;
75 1.1 mrg extern int optind;
76 1.1 mrg extern char *optarg;
77 1.1 mrg int c;
78 1.1 mrg static struct timeval linger = { 90, 0 };
79 1.1 mrg
80 1.1 mrg First_arg = av[0];
81 1.1 mrg if (ep == NULL || *ep == NULL)
82 1.1 mrg ep = av + ac;
83 1.1 mrg while (*ep)
84 1.1 mrg ep++;
85 1.1 mrg Last_arg = ep[-1] + strlen(ep[-1]);
86 1.1 mrg
87 1.2 lukem while ((c = getopt(ac, av, "sp:")) != -1) {
88 1.1 mrg switch (c) {
89 1.1 mrg case 's':
90 1.1 mrg server = TRUE;
91 1.1 mrg break;
92 1.1 mrg # ifdef INTERNET
93 1.1 mrg case 'p':
94 1.1 mrg standard_port = FALSE;
95 1.1 mrg Test_port = atoi(optarg);
96 1.1 mrg break;
97 1.1 mrg # endif
98 1.1 mrg default:
99 1.1 mrg erred:
100 1.1 mrg fprintf(stderr, "Usage: %s [-s] [-p port]\n", av[0]);
101 1.1 mrg exit(1);
102 1.1 mrg }
103 1.1 mrg }
104 1.1 mrg if (optind < ac)
105 1.1 mrg goto erred;
106 1.1 mrg
107 1.1 mrg init();
108 1.1 mrg
109 1.1 mrg
110 1.1 mrg again:
111 1.1 mrg do {
112 1.1 mrg read_fds = Fds_mask;
113 1.1 mrg errno = 0;
114 1.2 lukem while (select(Num_fds, &read_fds, NULL, NULL, NULL) < 0)
115 1.1 mrg {
116 1.1 mrg if (errno != EINTR)
117 1.1 mrg # ifdef LOG
118 1.1 mrg syslog(LOG_WARNING, "select: %m");
119 1.1 mrg # else
120 1.3 lukem warn("select");
121 1.1 mrg # endif
122 1.1 mrg errno = 0;
123 1.1 mrg }
124 1.1 mrg Have_inp = read_fds;
125 1.1 mrg # ifdef INTERNET
126 1.2 lukem if (FD_ISSET(Test_socket, &read_fds)) {
127 1.1 mrg namelen = DAEMON_SIZE;
128 1.1 mrg port_num = htons(sock_port);
129 1.1 mrg (void) recvfrom(Test_socket, (char *) &msg, sizeof msg,
130 1.1 mrg 0, (struct sockaddr *) &test, &namelen);
131 1.1 mrg switch (ntohs(msg)) {
132 1.1 mrg case C_MESSAGE:
133 1.1 mrg if (Nplayer <= 0)
134 1.1 mrg break;
135 1.1 mrg reply = htons((u_short) Nplayer);
136 1.1 mrg (void) sendto(Test_socket, (char *) &reply,
137 1.1 mrg sizeof reply, 0,
138 1.1 mrg (struct sockaddr *) &test, DAEMON_SIZE);
139 1.1 mrg break;
140 1.1 mrg case C_SCORES:
141 1.1 mrg reply = htons(stat_port);
142 1.1 mrg (void) sendto(Test_socket, (char *) &reply,
143 1.1 mrg sizeof reply, 0,
144 1.1 mrg (struct sockaddr *) &test, DAEMON_SIZE);
145 1.1 mrg break;
146 1.1 mrg case C_PLAYER:
147 1.1 mrg case C_MONITOR:
148 1.1 mrg if (msg == C_MONITOR && Nplayer <= 0)
149 1.1 mrg break;
150 1.1 mrg reply = htons(sock_port);
151 1.1 mrg (void) sendto(Test_socket, (char *) &reply,
152 1.1 mrg sizeof reply, 0,
153 1.1 mrg (struct sockaddr *) &test, DAEMON_SIZE);
154 1.1 mrg break;
155 1.1 mrg }
156 1.1 mrg }
157 1.1 mrg # endif
158 1.1 mrg for (;;) {
159 1.1 mrg had_char = FALSE;
160 1.1 mrg for (pp = Player; pp < End_player; pp++)
161 1.1 mrg if (havechar(pp)) {
162 1.1 mrg execute(pp);
163 1.1 mrg pp->p_nexec++;
164 1.1 mrg had_char++;
165 1.1 mrg }
166 1.1 mrg # ifdef MONITOR
167 1.1 mrg for (pp = Monitor; pp < End_monitor; pp++)
168 1.1 mrg if (havechar(pp)) {
169 1.1 mrg mon_execute(pp);
170 1.1 mrg pp->p_nexec++;
171 1.1 mrg had_char++;
172 1.1 mrg }
173 1.1 mrg # endif
174 1.1 mrg if (!had_char)
175 1.1 mrg break;
176 1.1 mrg moveshots();
177 1.1 mrg for (pp = Player; pp < End_player; )
178 1.1 mrg if (pp->p_death[0] != '\0')
179 1.1 mrg zap(pp, TRUE);
180 1.1 mrg else
181 1.1 mrg pp++;
182 1.1 mrg # ifdef MONITOR
183 1.1 mrg for (pp = Monitor; pp < End_monitor; )
184 1.1 mrg if (pp->p_death[0] != '\0')
185 1.1 mrg zap(pp, FALSE);
186 1.1 mrg else
187 1.1 mrg pp++;
188 1.1 mrg # endif
189 1.1 mrg }
190 1.2 lukem if (FD_ISSET(Socket, &read_fds))
191 1.1 mrg if (answer()) {
192 1.1 mrg # ifdef INTERNET
193 1.1 mrg if (first && standard_port)
194 1.1 mrg faketalk();
195 1.1 mrg # endif
196 1.1 mrg first = FALSE;
197 1.1 mrg }
198 1.2 lukem if (FD_ISSET(Status, &read_fds))
199 1.1 mrg send_stats();
200 1.1 mrg for (pp = Player; pp < End_player; pp++) {
201 1.2 lukem if (FD_ISSET(pp->p_fd, &read_fds))
202 1.1 mrg sendcom(pp, READY, pp->p_nexec);
203 1.1 mrg pp->p_nexec = 0;
204 1.1 mrg (void) fflush(pp->p_output);
205 1.1 mrg }
206 1.1 mrg # ifdef MONITOR
207 1.1 mrg for (pp = Monitor; pp < End_monitor; pp++) {
208 1.2 lukem if (FD_ISSET(pp->p_fd, &read_fds))
209 1.1 mrg sendcom(pp, READY, pp->p_nexec);
210 1.1 mrg pp->p_nexec = 0;
211 1.1 mrg (void) fflush(pp->p_output);
212 1.1 mrg }
213 1.1 mrg # endif
214 1.1 mrg } while (Nplayer > 0);
215 1.1 mrg
216 1.1 mrg read_fds = Fds_mask;
217 1.2 lukem if (select(Num_fds, &read_fds, NULL, NULL, &linger) > 0) {
218 1.1 mrg goto again;
219 1.1 mrg }
220 1.1 mrg if (server) {
221 1.1 mrg clear_scores();
222 1.1 mrg makemaze();
223 1.1 mrg clearwalls();
224 1.1 mrg # ifdef BOOTS
225 1.1 mrg makeboots();
226 1.1 mrg # endif
227 1.1 mrg first = TRUE;
228 1.1 mrg goto again;
229 1.1 mrg }
230 1.1 mrg
231 1.1 mrg # ifdef MONITOR
232 1.1 mrg for (pp = Monitor; pp < End_monitor; )
233 1.1 mrg zap(pp, FALSE);
234 1.1 mrg # endif
235 1.1 mrg cleanup(0);
236 1.2 lukem /* NOTREACHED */
237 1.2 lukem return(0);
238 1.1 mrg }
239 1.1 mrg
240 1.1 mrg /*
241 1.1 mrg * init:
242 1.1 mrg * Initialize the global parameters.
243 1.1 mrg */
244 1.2 lukem static void
245 1.1 mrg init()
246 1.1 mrg {
247 1.2 lukem int i;
248 1.1 mrg # ifdef INTERNET
249 1.2 lukem SOCKET test_port;
250 1.2 lukem int msg;
251 1.2 lukem int len;
252 1.1 mrg # endif
253 1.1 mrg
254 1.1 mrg # ifndef DEBUG
255 1.1 mrg # ifdef TIOCNOTTY
256 1.1 mrg (void) ioctl(fileno(stdout), TIOCNOTTY, NULL);
257 1.1 mrg # endif
258 1.1 mrg (void) setpgrp(getpid(), getpid());
259 1.1 mrg (void) signal(SIGHUP, SIG_IGN);
260 1.1 mrg (void) signal(SIGINT, SIG_IGN);
261 1.1 mrg (void) signal(SIGQUIT, SIG_IGN);
262 1.1 mrg (void) signal(SIGTERM, cleanup);
263 1.1 mrg # endif
264 1.1 mrg
265 1.4 mrg (void) chdir("/var/tmp"); /* just in case it core dumps */
266 1.1 mrg (void) umask(0); /* No privacy at all! */
267 1.1 mrg (void) signal(SIGPIPE, SIG_IGN);
268 1.1 mrg
269 1.1 mrg # ifdef LOG
270 1.1 mrg # ifdef SYSLOG_43
271 1.1 mrg openlog("HUNT", LOG_PID, LOG_DAEMON);
272 1.1 mrg # endif
273 1.1 mrg # ifdef SYSLOG_42
274 1.1 mrg openlog("HUNT", LOG_PID);
275 1.1 mrg # endif
276 1.1 mrg # endif
277 1.1 mrg
278 1.1 mrg /*
279 1.1 mrg * Initialize statistics socket
280 1.1 mrg */
281 1.1 mrg # ifdef INTERNET
282 1.1 mrg Daemon.sin_family = SOCK_FAMILY;
283 1.1 mrg Daemon.sin_addr.s_addr = INADDR_ANY;
284 1.1 mrg Daemon.sin_port = 0;
285 1.1 mrg # else
286 1.1 mrg Daemon.sun_family = SOCK_FAMILY;
287 1.1 mrg (void) strcpy(Daemon.sun_path, Stat_name);
288 1.1 mrg # endif
289 1.1 mrg
290 1.1 mrg Status = socket(SOCK_FAMILY, SOCK_STREAM, 0);
291 1.1 mrg if (bind(Status, (struct sockaddr *) &Daemon, DAEMON_SIZE) < 0) {
292 1.1 mrg if (errno == EADDRINUSE)
293 1.1 mrg exit(0);
294 1.1 mrg else {
295 1.1 mrg # ifdef LOG
296 1.1 mrg syslog(LOG_ERR, "bind: %m");
297 1.1 mrg # else
298 1.3 lukem warn("bind");
299 1.1 mrg # endif
300 1.1 mrg cleanup(1);
301 1.1 mrg }
302 1.1 mrg }
303 1.1 mrg (void) listen(Status, 5);
304 1.1 mrg
305 1.1 mrg # ifdef INTERNET
306 1.1 mrg len = sizeof (SOCKET);
307 1.1 mrg if (getsockname(Status, (struct sockaddr *) &Daemon, &len) < 0) {
308 1.1 mrg # ifdef LOG
309 1.1 mrg syslog(LOG_ERR, "getsockname: %m");
310 1.1 mrg # else
311 1.3 lukem warn("getsockname");
312 1.1 mrg # endif
313 1.1 mrg exit(1);
314 1.1 mrg }
315 1.1 mrg stat_port = ntohs(Daemon.sin_port);
316 1.1 mrg # endif
317 1.1 mrg
318 1.1 mrg /*
319 1.1 mrg * Initialize main socket
320 1.1 mrg */
321 1.1 mrg # ifdef INTERNET
322 1.1 mrg Daemon.sin_family = SOCK_FAMILY;
323 1.1 mrg Daemon.sin_addr.s_addr = INADDR_ANY;
324 1.1 mrg Daemon.sin_port = 0;
325 1.1 mrg # else
326 1.1 mrg Daemon.sun_family = SOCK_FAMILY;
327 1.1 mrg (void) strcpy(Daemon.sun_path, Sock_name);
328 1.1 mrg # endif
329 1.1 mrg
330 1.1 mrg Socket = socket(SOCK_FAMILY, SOCK_STREAM, 0);
331 1.1 mrg # if defined(INTERNET)
332 1.1 mrg msg = 1;
333 1.1 mrg if (setsockopt(Socket, SOL_SOCKET, SO_USELOOPBACK, &msg, sizeof msg)<0)
334 1.1 mrg # ifdef LOG
335 1.1 mrg syslog(LOG_WARNING, "setsockopt loopback %m");
336 1.1 mrg # else
337 1.3 lukem warn("setsockopt loopback");
338 1.1 mrg # endif
339 1.1 mrg # endif
340 1.1 mrg if (bind(Socket, (struct sockaddr *) &Daemon, DAEMON_SIZE) < 0) {
341 1.1 mrg if (errno == EADDRINUSE)
342 1.1 mrg exit(0);
343 1.1 mrg else {
344 1.1 mrg # ifdef LOG
345 1.1 mrg syslog(LOG_ERR, "bind: %m");
346 1.1 mrg # else
347 1.3 lukem warn("bind");
348 1.1 mrg # endif
349 1.1 mrg cleanup(1);
350 1.1 mrg }
351 1.1 mrg }
352 1.1 mrg (void) listen(Socket, 5);
353 1.1 mrg
354 1.1 mrg # ifdef INTERNET
355 1.1 mrg len = sizeof (SOCKET);
356 1.1 mrg if (getsockname(Socket, (struct sockaddr *) &Daemon, &len) < 0) {
357 1.1 mrg # ifdef LOG
358 1.1 mrg syslog(LOG_ERR, "getsockname: %m");
359 1.1 mrg # else
360 1.3 lukem warn("getsockname");
361 1.1 mrg # endif
362 1.1 mrg exit(1);
363 1.1 mrg }
364 1.1 mrg sock_port = ntohs(Daemon.sin_port);
365 1.1 mrg # endif
366 1.1 mrg
367 1.1 mrg /*
368 1.1 mrg * Initialize minimal select mask
369 1.1 mrg */
370 1.5 lukem FD_ZERO(&Fds_mask);
371 1.2 lukem FD_SET(Socket, &Fds_mask);
372 1.2 lukem FD_SET(Status, &Fds_mask);
373 1.1 mrg Num_fds = ((Socket > Status) ? Socket : Status) + 1;
374 1.1 mrg
375 1.1 mrg # ifdef INTERNET
376 1.1 mrg len = sizeof (SOCKET);
377 1.1 mrg if (getsockname(0, (struct sockaddr *) &test_port, &len) >= 0
378 1.1 mrg && test_port.sin_family == AF_INET) {
379 1.1 mrg inetd_spawned = TRUE;
380 1.1 mrg Test_socket = 0;
381 1.1 mrg if (test_port.sin_port != htons((u_short) Test_port)) {
382 1.1 mrg standard_port = FALSE;
383 1.1 mrg Test_port = ntohs(test_port.sin_port);
384 1.1 mrg }
385 1.1 mrg } else {
386 1.1 mrg test_port = Daemon;
387 1.1 mrg test_port.sin_port = htons((u_short) Test_port);
388 1.1 mrg
389 1.1 mrg Test_socket = socket(SOCK_FAMILY, SOCK_DGRAM, 0);
390 1.1 mrg if (bind(Test_socket, (struct sockaddr *) &test_port,
391 1.1 mrg DAEMON_SIZE) < 0) {
392 1.1 mrg # ifdef LOG
393 1.1 mrg syslog(LOG_ERR, "bind: %m");
394 1.1 mrg # else
395 1.3 lukem warn("bind");
396 1.1 mrg # endif
397 1.1 mrg exit(1);
398 1.1 mrg }
399 1.1 mrg (void) listen(Test_socket, 5);
400 1.1 mrg }
401 1.1 mrg
402 1.2 lukem FD_SET(Test_socket, &Fds_mask);
403 1.1 mrg if (Test_socket + 1 > Num_fds)
404 1.1 mrg Num_fds = Test_socket + 1;
405 1.1 mrg # endif
406 1.1 mrg
407 1.1 mrg Seed = getpid() + time((time_t *) NULL);
408 1.1 mrg makemaze();
409 1.1 mrg # ifdef BOOTS
410 1.1 mrg makeboots();
411 1.1 mrg # endif
412 1.1 mrg
413 1.1 mrg for (i = 0; i < NASCII; i++)
414 1.1 mrg See_over[i] = TRUE;
415 1.1 mrg See_over[DOOR] = FALSE;
416 1.1 mrg See_over[WALL1] = FALSE;
417 1.1 mrg See_over[WALL2] = FALSE;
418 1.1 mrg See_over[WALL3] = FALSE;
419 1.1 mrg # ifdef REFLECT
420 1.1 mrg See_over[WALL4] = FALSE;
421 1.1 mrg See_over[WALL5] = FALSE;
422 1.1 mrg # endif
423 1.1 mrg
424 1.1 mrg }
425 1.1 mrg
426 1.1 mrg # ifdef BOOTS
427 1.1 mrg /*
428 1.1 mrg * makeboots:
429 1.1 mrg * Put the boots in the maze
430 1.1 mrg */
431 1.2 lukem static void
432 1.1 mrg makeboots()
433 1.1 mrg {
434 1.2 lukem int x, y;
435 1.2 lukem PLAYER *pp;
436 1.1 mrg
437 1.1 mrg do {
438 1.1 mrg x = rand_num(WIDTH - 1) + 1;
439 1.1 mrg y = rand_num(HEIGHT - 1) + 1;
440 1.1 mrg } while (Maze[y][x] != SPACE);
441 1.1 mrg Maze[y][x] = BOOT_PAIR;
442 1.1 mrg for (pp = Boot; pp < &Boot[NBOOTS]; pp++)
443 1.1 mrg pp->p_flying = -1;
444 1.1 mrg }
445 1.1 mrg # endif
446 1.1 mrg
447 1.1 mrg
448 1.1 mrg /*
449 1.1 mrg * checkdam:
450 1.1 mrg * Check the damage to the given player, and see if s/he is killed
451 1.1 mrg */
452 1.2 lukem void
453 1.1 mrg checkdam(ouch, gotcha, credit, amt, shot_type)
454 1.2 lukem PLAYER *ouch, *gotcha;
455 1.2 lukem IDENT *credit;
456 1.2 lukem int amt;
457 1.2 lukem char shot_type;
458 1.1 mrg {
459 1.2 lukem char *cp;
460 1.1 mrg
461 1.1 mrg if (ouch->p_death[0] != '\0')
462 1.1 mrg return;
463 1.1 mrg # ifdef BOOTS
464 1.1 mrg if (shot_type == SLIME)
465 1.1 mrg switch (ouch->p_nboots) {
466 1.1 mrg default:
467 1.1 mrg break;
468 1.1 mrg case 1:
469 1.1 mrg amt = (amt + 1) / 2;
470 1.1 mrg break;
471 1.1 mrg case 2:
472 1.1 mrg if (gotcha != NULL)
473 1.1 mrg message(gotcha, "He has boots on!");
474 1.1 mrg return;
475 1.1 mrg }
476 1.1 mrg # endif
477 1.1 mrg ouch->p_damage += amt;
478 1.1 mrg if (ouch->p_damage <= ouch->p_damcap) {
479 1.1 mrg (void) sprintf(Buf, "%2d", ouch->p_damage);
480 1.1 mrg cgoto(ouch, STAT_DAM_ROW, STAT_VALUE_COL);
481 1.1 mrg outstr(ouch, Buf, 2);
482 1.1 mrg return;
483 1.1 mrg }
484 1.1 mrg
485 1.1 mrg /* Someone DIED */
486 1.1 mrg switch (shot_type) {
487 1.1 mrg default:
488 1.1 mrg cp = "Killed";
489 1.1 mrg break;
490 1.1 mrg # ifdef FLY
491 1.1 mrg case FALL:
492 1.1 mrg cp = "Killed on impact";
493 1.1 mrg break;
494 1.1 mrg # endif
495 1.1 mrg case KNIFE:
496 1.1 mrg cp = "Stabbed to death";
497 1.1 mrg ouch->p_ammo = 0; /* No exploding */
498 1.1 mrg break;
499 1.1 mrg case SHOT:
500 1.1 mrg cp = "Shot to death";
501 1.1 mrg break;
502 1.1 mrg case GRENADE:
503 1.1 mrg case SATCHEL:
504 1.1 mrg case BOMB:
505 1.1 mrg cp = "Bombed";
506 1.1 mrg break;
507 1.1 mrg case MINE:
508 1.1 mrg case GMINE:
509 1.1 mrg cp = "Blown apart";
510 1.1 mrg break;
511 1.1 mrg # ifdef OOZE
512 1.1 mrg case SLIME:
513 1.1 mrg cp = "Slimed";
514 1.1 mrg if (credit != NULL)
515 1.1 mrg credit->i_slime++;
516 1.1 mrg break;
517 1.1 mrg # endif
518 1.1 mrg # ifdef VOLCANO
519 1.1 mrg case LAVA:
520 1.1 mrg cp = "Baked";
521 1.1 mrg break;
522 1.1 mrg # endif
523 1.1 mrg # ifdef DRONE
524 1.1 mrg case DSHOT:
525 1.1 mrg cp = "Eliminated";
526 1.1 mrg break;
527 1.1 mrg # endif
528 1.1 mrg }
529 1.1 mrg if (credit == NULL) {
530 1.1 mrg (void) sprintf(ouch->p_death, "| %s by %s |", cp,
531 1.1 mrg (shot_type == MINE || shot_type == GMINE) ?
532 1.1 mrg "a mine" : "act of God");
533 1.1 mrg return;
534 1.1 mrg }
535 1.1 mrg
536 1.1 mrg (void) sprintf(ouch->p_death, "| %s by %s |", cp, credit->i_name);
537 1.1 mrg
538 1.1 mrg if (ouch == gotcha) { /* No use killing yourself */
539 1.1 mrg credit->i_kills--;
540 1.1 mrg credit->i_bkills++;
541 1.1 mrg }
542 1.1 mrg else if (ouch->p_ident->i_team == ' '
543 1.1 mrg || ouch->p_ident->i_team != credit->i_team) {
544 1.1 mrg credit->i_kills++;
545 1.1 mrg credit->i_gkills++;
546 1.1 mrg }
547 1.1 mrg else {
548 1.1 mrg credit->i_kills--;
549 1.1 mrg credit->i_bkills++;
550 1.1 mrg }
551 1.1 mrg credit->i_score = credit->i_kills / (double) credit->i_entries;
552 1.1 mrg ouch->p_ident->i_deaths++;
553 1.1 mrg if (ouch->p_nchar == 0)
554 1.1 mrg ouch->p_ident->i_stillb++;
555 1.1 mrg if (gotcha == NULL)
556 1.1 mrg return;
557 1.1 mrg gotcha->p_damcap += STABDAM;
558 1.1 mrg gotcha->p_damage -= STABDAM;
559 1.1 mrg if (gotcha->p_damage < 0)
560 1.1 mrg gotcha->p_damage = 0;
561 1.1 mrg (void) sprintf(Buf, "%2d/%2d", gotcha->p_damage, gotcha->p_damcap);
562 1.1 mrg cgoto(gotcha, STAT_DAM_ROW, STAT_VALUE_COL);
563 1.1 mrg outstr(gotcha, Buf, 5);
564 1.1 mrg (void) sprintf(Buf, "%3d", (gotcha->p_damcap - MAXDAM) / 2);
565 1.1 mrg cgoto(gotcha, STAT_KILL_ROW, STAT_VALUE_COL);
566 1.1 mrg outstr(gotcha, Buf, 3);
567 1.1 mrg (void) sprintf(Buf, "%5.2f", gotcha->p_ident->i_score);
568 1.1 mrg for (ouch = Player; ouch < End_player; ouch++) {
569 1.1 mrg cgoto(ouch, STAT_PLAY_ROW + 1 + (gotcha - Player),
570 1.1 mrg STAT_NAME_COL);
571 1.1 mrg outstr(ouch, Buf, 5);
572 1.1 mrg }
573 1.1 mrg # ifdef MONITOR
574 1.1 mrg for (ouch = Monitor; ouch < End_monitor; ouch++) {
575 1.1 mrg cgoto(ouch, STAT_PLAY_ROW + 1 + (gotcha - Player),
576 1.1 mrg STAT_NAME_COL);
577 1.1 mrg outstr(ouch, Buf, 5);
578 1.1 mrg }
579 1.1 mrg # endif
580 1.1 mrg }
581 1.1 mrg
582 1.1 mrg /*
583 1.1 mrg * zap:
584 1.1 mrg * Kill off a player and take him out of the game.
585 1.1 mrg */
586 1.2 lukem static void
587 1.1 mrg zap(pp, was_player)
588 1.2 lukem PLAYER *pp;
589 1.2 lukem FLAG was_player;
590 1.1 mrg {
591 1.2 lukem int i, len;
592 1.2 lukem BULLET *bp;
593 1.2 lukem PLAYER *np;
594 1.2 lukem int x, y;
595 1.2 lukem int savefd;
596 1.1 mrg
597 1.1 mrg if (was_player) {
598 1.1 mrg if (pp->p_undershot)
599 1.1 mrg fixshots(pp->p_y, pp->p_x, pp->p_over);
600 1.1 mrg drawplayer(pp, FALSE);
601 1.1 mrg Nplayer--;
602 1.1 mrg }
603 1.1 mrg
604 1.1 mrg len = strlen(pp->p_death); /* Display the cause of death */
605 1.1 mrg x = (WIDTH - len) / 2;
606 1.1 mrg cgoto(pp, HEIGHT / 2, x);
607 1.1 mrg outstr(pp, pp->p_death, len);
608 1.1 mrg for (i = 1; i < len; i++)
609 1.1 mrg pp->p_death[i] = '-';
610 1.1 mrg pp->p_death[0] = '+';
611 1.1 mrg pp->p_death[len - 1] = '+';
612 1.1 mrg cgoto(pp, HEIGHT / 2 - 1, x);
613 1.1 mrg outstr(pp, pp->p_death, len);
614 1.1 mrg cgoto(pp, HEIGHT / 2 + 1, x);
615 1.1 mrg outstr(pp, pp->p_death, len);
616 1.1 mrg cgoto(pp, HEIGHT, 0);
617 1.1 mrg
618 1.1 mrg savefd = pp->p_fd;
619 1.1 mrg
620 1.1 mrg # ifdef MONITOR
621 1.1 mrg if (was_player) {
622 1.1 mrg # endif
623 1.1 mrg for (bp = Bullets; bp != NULL; bp = bp->b_next) {
624 1.1 mrg if (bp->b_owner == pp)
625 1.1 mrg bp->b_owner = NULL;
626 1.1 mrg if (bp->b_x == pp->p_x && bp->b_y == pp->p_y)
627 1.1 mrg bp->b_over = SPACE;
628 1.1 mrg }
629 1.1 mrg
630 1.1 mrg i = rand_num(pp->p_ammo);
631 1.1 mrg x = rand_num(pp->p_ammo);
632 1.1 mrg if (x > i)
633 1.1 mrg i = x;
634 1.1 mrg if (pp->p_ammo == 0)
635 1.1 mrg x = 0;
636 1.1 mrg else if (i == pp->p_ammo - 1) {
637 1.1 mrg x = pp->p_ammo;
638 1.1 mrg len = SLIME;
639 1.1 mrg }
640 1.1 mrg else {
641 1.1 mrg for (x = MAXBOMB - 1; x > 0; x--)
642 1.1 mrg if (i >= shot_req[x])
643 1.1 mrg break;
644 1.1 mrg for (y = MAXSLIME - 1; y > 0; y--)
645 1.1 mrg if (i >= slime_req[y])
646 1.1 mrg break;
647 1.1 mrg if (y >= 0 && slime_req[y] > shot_req[x]) {
648 1.1 mrg x = slime_req[y];
649 1.1 mrg len = SLIME;
650 1.1 mrg }
651 1.1 mrg else if (x != 0) {
652 1.1 mrg len = shot_type[x];
653 1.1 mrg x = shot_req[x];
654 1.1 mrg }
655 1.1 mrg }
656 1.1 mrg if (x > 0) {
657 1.1 mrg (void) add_shot(len, pp->p_y, pp->p_x, pp->p_face, x,
658 1.1 mrg (PLAYER *) NULL, TRUE, SPACE);
659 1.1 mrg (void) sprintf(Buf, "%s detonated.",
660 1.1 mrg pp->p_ident->i_name);
661 1.1 mrg for (np = Player; np < End_player; np++)
662 1.1 mrg message(np, Buf);
663 1.1 mrg # ifdef MONITOR
664 1.1 mrg for (np = Monitor; np < End_monitor; np++)
665 1.1 mrg message(np, Buf);
666 1.1 mrg # endif
667 1.1 mrg # ifdef BOOTS
668 1.1 mrg while (pp->p_nboots-- > 0) {
669 1.1 mrg for (np = Boot; np < &Boot[NBOOTS]; np++)
670 1.1 mrg if (np->p_flying < 0)
671 1.1 mrg break;
672 1.1 mrg if (np >= &Boot[NBOOTS])
673 1.2 lukem err(1, "Too many boots");
674 1.1 mrg np->p_undershot = FALSE;
675 1.1 mrg np->p_x = pp->p_x;
676 1.1 mrg np->p_y = pp->p_y;
677 1.1 mrg np->p_flying = rand_num(20);
678 1.1 mrg np->p_flyx = 2 * rand_num(6) - 5;
679 1.1 mrg np->p_flyy = 2 * rand_num(6) - 5;
680 1.1 mrg np->p_over = SPACE;
681 1.1 mrg np->p_face = BOOT;
682 1.1 mrg showexpl(np->p_y, np->p_x, BOOT);
683 1.1 mrg }
684 1.1 mrg # endif
685 1.1 mrg }
686 1.1 mrg # ifdef BOOTS
687 1.1 mrg else if (pp->p_nboots > 0) {
688 1.1 mrg if (pp->p_nboots == 2)
689 1.1 mrg Maze[pp->p_y][pp->p_x] = BOOT_PAIR;
690 1.1 mrg else
691 1.1 mrg Maze[pp->p_y][pp->p_x] = BOOT;
692 1.1 mrg if (pp->p_undershot)
693 1.1 mrg fixshots(pp->p_y, pp->p_x,
694 1.1 mrg Maze[pp->p_y][pp->p_x]);
695 1.1 mrg }
696 1.1 mrg # endif
697 1.1 mrg
698 1.1 mrg # ifdef VOLCANO
699 1.1 mrg volcano += pp->p_ammo - x;
700 1.1 mrg if (rand_num(100) < volcano / 50) {
701 1.1 mrg do {
702 1.1 mrg x = rand_num(WIDTH / 2) + WIDTH / 4;
703 1.1 mrg y = rand_num(HEIGHT / 2) + HEIGHT / 4;
704 1.1 mrg } while (Maze[y][x] != SPACE);
705 1.1 mrg (void) add_shot(LAVA, y, x, LEFTS, volcano,
706 1.1 mrg (PLAYER *) NULL, TRUE, SPACE);
707 1.1 mrg for (np = Player; np < End_player; np++)
708 1.1 mrg message(np, "Volcano eruption.");
709 1.1 mrg volcano = 0;
710 1.1 mrg }
711 1.1 mrg # endif
712 1.1 mrg
713 1.1 mrg # ifdef DRONE
714 1.1 mrg if (rand_num(100) < 2) {
715 1.1 mrg do {
716 1.1 mrg x = rand_num(WIDTH / 2) + WIDTH / 4;
717 1.1 mrg y = rand_num(HEIGHT / 2) + HEIGHT / 4;
718 1.1 mrg } while (Maze[y][x] != SPACE);
719 1.1 mrg add_shot(DSHOT, y, x, rand_dir(),
720 1.1 mrg shot_req[MINDSHOT +
721 1.1 mrg rand_num(MAXBOMB - MINDSHOT)],
722 1.1 mrg (PLAYER *) NULL, FALSE, SPACE);
723 1.1 mrg }
724 1.1 mrg # endif
725 1.1 mrg
726 1.1 mrg sendcom(pp, ENDWIN);
727 1.1 mrg (void) putc(' ', pp->p_output);
728 1.1 mrg (void) fclose(pp->p_output);
729 1.1 mrg
730 1.1 mrg End_player--;
731 1.1 mrg if (pp != End_player) {
732 1.1 mrg memcpy(pp, End_player, sizeof (PLAYER));
733 1.1 mrg (void) sprintf(Buf, "%5.2f%c%-10.10s %c",
734 1.1 mrg pp->p_ident->i_score, stat_char(pp),
735 1.1 mrg pp->p_ident->i_name, pp->p_ident->i_team);
736 1.1 mrg i = STAT_PLAY_ROW + 1 + (pp - Player);
737 1.1 mrg for (np = Player; np < End_player; np++) {
738 1.1 mrg cgoto(np, i, STAT_NAME_COL);
739 1.1 mrg outstr(np, Buf, STAT_NAME_LEN);
740 1.1 mrg }
741 1.1 mrg # ifdef MONITOR
742 1.1 mrg for (np = Monitor; np < End_monitor; np++) {
743 1.1 mrg cgoto(np, i, STAT_NAME_COL);
744 1.1 mrg outstr(np, Buf, STAT_NAME_LEN);
745 1.1 mrg }
746 1.1 mrg # endif
747 1.1 mrg }
748 1.1 mrg
749 1.1 mrg /* Erase the last player */
750 1.1 mrg i = STAT_PLAY_ROW + 1 + Nplayer;
751 1.1 mrg for (np = Player; np < End_player; np++) {
752 1.1 mrg cgoto(np, i, STAT_NAME_COL);
753 1.1 mrg ce(np);
754 1.1 mrg }
755 1.1 mrg # ifdef MONITOR
756 1.1 mrg for (np = Monitor; np < End_monitor; np++) {
757 1.1 mrg cgoto(np, i, STAT_NAME_COL);
758 1.1 mrg ce(np);
759 1.1 mrg }
760 1.1 mrg }
761 1.1 mrg else {
762 1.1 mrg sendcom(pp, ENDWIN);
763 1.1 mrg (void) putc(LAST_PLAYER, pp->p_output);
764 1.1 mrg (void) fclose(pp->p_output);
765 1.1 mrg
766 1.1 mrg End_monitor--;
767 1.1 mrg if (pp != End_monitor) {
768 1.1 mrg memcpy(pp, End_monitor, sizeof (PLAYER));
769 1.1 mrg (void) sprintf(Buf, "%5.5s %-10.10s %c", " ",
770 1.1 mrg pp->p_ident->i_name, pp->p_ident->i_team);
771 1.1 mrg i = STAT_MON_ROW + 1 + (pp - Player);
772 1.1 mrg for (np = Player; np < End_player; np++) {
773 1.1 mrg cgoto(np, i, STAT_NAME_COL);
774 1.1 mrg outstr(np, Buf, STAT_NAME_LEN);
775 1.1 mrg }
776 1.1 mrg for (np = Monitor; np < End_monitor; np++) {
777 1.1 mrg cgoto(np, i, STAT_NAME_COL);
778 1.1 mrg outstr(np, Buf, STAT_NAME_LEN);
779 1.1 mrg }
780 1.1 mrg }
781 1.1 mrg
782 1.1 mrg /* Erase the last monitor */
783 1.1 mrg i = STAT_MON_ROW + 1 + (End_monitor - Monitor);
784 1.1 mrg for (np = Player; np < End_player; np++) {
785 1.1 mrg cgoto(np, i, STAT_NAME_COL);
786 1.1 mrg ce(np);
787 1.1 mrg }
788 1.1 mrg for (np = Monitor; np < End_monitor; np++) {
789 1.1 mrg cgoto(np, i, STAT_NAME_COL);
790 1.1 mrg ce(np);
791 1.1 mrg }
792 1.1 mrg
793 1.1 mrg }
794 1.1 mrg # endif
795 1.1 mrg
796 1.2 lukem FD_CLR(savefd, &Fds_mask);
797 1.1 mrg if (Num_fds == savefd + 1) {
798 1.1 mrg Num_fds = Socket;
799 1.1 mrg # ifdef INTERNET
800 1.1 mrg if (Test_socket > Socket)
801 1.1 mrg Num_fds = Test_socket;
802 1.1 mrg # endif
803 1.1 mrg for (np = Player; np < End_player; np++)
804 1.1 mrg if (np->p_fd > Num_fds)
805 1.1 mrg Num_fds = np->p_fd;
806 1.1 mrg # ifdef MONITOR
807 1.1 mrg for (np = Monitor; np < End_monitor; np++)
808 1.1 mrg if (np->p_fd > Num_fds)
809 1.1 mrg Num_fds = np->p_fd;
810 1.1 mrg # endif
811 1.1 mrg Num_fds++;
812 1.1 mrg }
813 1.1 mrg }
814 1.1 mrg
815 1.1 mrg /*
816 1.1 mrg * rand_num:
817 1.1 mrg * Return a random number in a given range.
818 1.1 mrg */
819 1.2 lukem int
820 1.1 mrg rand_num(range)
821 1.2 lukem int range;
822 1.1 mrg {
823 1.1 mrg return (range == 0 ? 0 : RN % range);
824 1.1 mrg }
825 1.1 mrg
826 1.1 mrg /*
827 1.1 mrg * havechar:
828 1.1 mrg * Check to see if we have any characters in the input queue; if
829 1.1 mrg * we do, read them, stash them away, and return TRUE; else return
830 1.1 mrg * FALSE.
831 1.1 mrg */
832 1.2 lukem static int
833 1.1 mrg havechar(pp)
834 1.2 lukem PLAYER *pp;
835 1.1 mrg {
836 1.1 mrg
837 1.1 mrg if (pp->p_ncount < pp->p_nchar)
838 1.1 mrg return TRUE;
839 1.2 lukem if (!FD_ISSET(pp->p_fd, &Have_inp))
840 1.1 mrg return FALSE;
841 1.2 lukem FD_CLR(pp->p_fd, &Have_inp);
842 1.1 mrg check_again:
843 1.1 mrg errno = 0;
844 1.1 mrg if ((pp->p_nchar = read(pp->p_fd, pp->p_cbuf, sizeof pp->p_cbuf)) <= 0)
845 1.1 mrg {
846 1.1 mrg if (errno == EINTR)
847 1.1 mrg goto check_again;
848 1.1 mrg pp->p_cbuf[0] = 'q';
849 1.1 mrg }
850 1.1 mrg pp->p_ncount = 0;
851 1.1 mrg return TRUE;
852 1.1 mrg }
853 1.1 mrg
854 1.1 mrg /*
855 1.1 mrg * cleanup:
856 1.1 mrg * Exit with the given value, cleaning up any droppings lying around
857 1.1 mrg */
858 1.1 mrg SIGNAL_TYPE
859 1.1 mrg cleanup(eval)
860 1.2 lukem int eval;
861 1.1 mrg {
862 1.2 lukem PLAYER *pp;
863 1.1 mrg
864 1.1 mrg for (pp = Player; pp < End_player; pp++) {
865 1.1 mrg cgoto(pp, HEIGHT, 0);
866 1.1 mrg sendcom(pp, ENDWIN);
867 1.1 mrg (void) putc(LAST_PLAYER, pp->p_output);
868 1.1 mrg (void) fclose(pp->p_output);
869 1.1 mrg }
870 1.1 mrg # ifdef MONITOR
871 1.1 mrg for (pp = Monitor; pp < End_monitor; pp++) {
872 1.1 mrg cgoto(pp, HEIGHT, 0);
873 1.1 mrg sendcom(pp, ENDWIN);
874 1.1 mrg (void) putc(LAST_PLAYER, pp->p_output);
875 1.1 mrg (void) fclose(pp->p_output);
876 1.1 mrg }
877 1.1 mrg # endif
878 1.1 mrg (void) close(Socket);
879 1.1 mrg # ifdef AF_UNIX_HACK
880 1.1 mrg (void) unlink(Sock_name);
881 1.1 mrg # endif
882 1.1 mrg
883 1.1 mrg exit(eval);
884 1.1 mrg }
885 1.1 mrg
886 1.1 mrg /*
887 1.1 mrg * send_stats:
888 1.1 mrg * Print stats to requestor
889 1.1 mrg */
890 1.2 lukem static void
891 1.1 mrg send_stats()
892 1.1 mrg {
893 1.2 lukem IDENT *ip;
894 1.2 lukem FILE *fp;
895 1.2 lukem int s;
896 1.2 lukem SOCKET sockstruct;
897 1.2 lukem int socklen;
898 1.1 mrg
899 1.1 mrg /*
900 1.1 mrg * Get the output stream ready
901 1.1 mrg */
902 1.1 mrg # ifdef INTERNET
903 1.1 mrg socklen = sizeof sockstruct;
904 1.1 mrg # else
905 1.1 mrg socklen = sizeof sockstruct - 1;
906 1.1 mrg # endif
907 1.1 mrg s = accept(Status, (struct sockaddr *) &sockstruct, &socklen);
908 1.1 mrg if (s < 0) {
909 1.1 mrg if (errno == EINTR)
910 1.1 mrg return;
911 1.1 mrg # ifdef LOG
912 1.1 mrg syslog(LOG_ERR, "accept: %m");
913 1.1 mrg # else
914 1.3 lukem warn("accept");
915 1.1 mrg # endif
916 1.1 mrg return;
917 1.1 mrg }
918 1.1 mrg fp = fdopen(s, "w");
919 1.1 mrg if (fp == NULL) {
920 1.1 mrg # ifdef LOG
921 1.1 mrg syslog(LOG_ERR, "fdopen: %m");
922 1.1 mrg # else
923 1.3 lukem warn("fdopen");
924 1.1 mrg # endif
925 1.1 mrg (void) close(s);
926 1.1 mrg return;
927 1.1 mrg }
928 1.1 mrg
929 1.1 mrg /*
930 1.1 mrg * Send output to requestor
931 1.1 mrg */
932 1.1 mrg fputs("Name\t\tScore\tDucked\tAbsorb\tFaced\tShot\tRobbed\tMissed\tSlimeK\n", fp);
933 1.1 mrg for (ip = Scores; ip != NULL; ip = ip->i_next) {
934 1.1 mrg fprintf(fp, "%s\t", ip->i_name);
935 1.1 mrg if (strlen(ip->i_name) < 8)
936 1.1 mrg putc('\t', fp);
937 1.1 mrg fprintf(fp, "%.2f\t%d\t%d\t%d\t%d\t%d\t%d\t%d\n",
938 1.1 mrg ip->i_score, ip->i_ducked, ip->i_absorbed,
939 1.1 mrg ip->i_faced, ip->i_shot, ip->i_robbed,
940 1.1 mrg ip->i_missed, ip->i_slime);
941 1.1 mrg }
942 1.1 mrg fputs("\n\nName\t\tEnemy\tFriend\tDeaths\tStill\tSaved\n", fp);
943 1.1 mrg for (ip = Scores; ip != NULL; ip = ip->i_next) {
944 1.1 mrg if (ip->i_team == ' ') {
945 1.1 mrg fprintf(fp, "%s\t", ip->i_name);
946 1.1 mrg if (strlen(ip->i_name) < 8)
947 1.1 mrg putc('\t', fp);
948 1.1 mrg }
949 1.1 mrg else {
950 1.1 mrg fprintf(fp, "%s[%c]\t", ip->i_name, ip->i_team);
951 1.1 mrg if (strlen(ip->i_name) + 3 < 8)
952 1.1 mrg putc('\t', fp);
953 1.1 mrg }
954 1.1 mrg fprintf(fp, "%d\t%d\t%d\t%d\t%d\n",
955 1.1 mrg ip->i_gkills, ip->i_bkills, ip->i_deaths,
956 1.1 mrg ip->i_stillb, ip->i_saved);
957 1.1 mrg }
958 1.1 mrg
959 1.1 mrg (void) fclose(fp);
960 1.1 mrg }
961 1.1 mrg
962 1.1 mrg /*
963 1.1 mrg * clear_scores:
964 1.1 mrg * Clear out the scores so the next session start clean
965 1.1 mrg */
966 1.2 lukem static void
967 1.1 mrg clear_scores()
968 1.1 mrg {
969 1.2 lukem IDENT *ip, *nextip;
970 1.1 mrg
971 1.1 mrg for (ip = Scores; ip != NULL; ip = nextip) {
972 1.1 mrg nextip = ip->i_next;
973 1.1 mrg (void) free((char *) ip);
974 1.1 mrg }
975 1.1 mrg Scores = NULL;
976 1.1 mrg }
977