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