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