home *** CD-ROM | disk | FTP | other *** search
/ InfoMagic Source Code 1993 July / THE_SOURCE_CODE_CD_ROM.iso / bsd_srcs / games / sail / sync.c < prev    next >
Encoding:
C/C++ Source or Header  |  1991-04-08  |  9.0 KB  |  422 lines
  1. /*
  2.  * Copyright (c) 1983 Regents of the University of California.
  3.  * All rights reserved.
  4.  *
  5.  * Redistribution and use in source and binary forms, with or without
  6.  * modification, are permitted provided that the following conditions
  7.  * are met:
  8.  * 1. Redistributions of source code must retain the above copyright
  9.  *    notice, this list of conditions and the following disclaimer.
  10.  * 2. Redistributions in binary form must reproduce the above copyright
  11.  *    notice, this list of conditions and the following disclaimer in the
  12.  *    documentation and/or other materials provided with the distribution.
  13.  * 3. All advertising materials mentioning features or use of this software
  14.  *    must display the following acknowledgement:
  15.  *    This product includes software developed by the University of
  16.  *    California, Berkeley and its contributors.
  17.  * 4. Neither the name of the University nor the names of its contributors
  18.  *    may be used to endorse or promote products derived from this software
  19.  *    without specific prior written permission.
  20.  *
  21.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  22.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  23.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  24.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  25.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  26.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  27.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  28.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  29.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  30.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  31.  * SUCH DAMAGE.
  32.  */
  33.  
  34. #ifndef lint
  35. static char sccsid[] = "@(#)sync.c    5.6 (Berkeley) 6/1/90";
  36. #endif /* not lint */
  37.  
  38. #include "externs.h"
  39. #include <sys/file.h>
  40. #include <sys/errno.h>
  41.  
  42. #define BUFSIZE 4096
  43.  
  44. static char sync_buf[BUFSIZE];
  45. static char *sync_bp = sync_buf;
  46. static char sync_lock[25];
  47. static char sync_file[25];
  48. static long sync_seek;
  49. static FILE *sync_fp;
  50. #define SF "/tmp/#sailsink.%d"
  51. #define LF "/tmp/#saillock.%d"
  52.  
  53. /*VARARGS3*/
  54. makesignal(from, fmt, ship, a, b, c)
  55.     struct ship *from;
  56.     char *fmt;
  57.     register struct ship *ship;
  58. {
  59.     char message[80];
  60.  
  61.     if (ship == 0)
  62.         (void) sprintf(message, fmt, a, b, c);
  63.     else
  64.         (void) sprintf(message, fmt,
  65.             ship->shipname, colours(ship),
  66.             sterncolour(ship), a, b, c);
  67.     Write(W_SIGNAL, from, 1, (int)message, 0, 0, 0);
  68. }
  69.  
  70. #include <sys/types.h>
  71. #include <sys/stat.h>
  72. sync_exists(game)
  73. {
  74.     char buf[sizeof sync_file];
  75.     struct stat s;
  76.     time_t t;
  77.  
  78.     (void) sprintf(buf, SF, game);
  79.     (void) time(&t);
  80.     if (stat(buf, &s) < 0)
  81.         return 0;
  82.     if (s.st_mtime < t - 60*60*2) {        /* 2 hours */
  83.         (void) unlink(buf);
  84.         (void) sprintf(buf, LF, game);
  85.         (void) unlink(buf);
  86.         return 0;
  87.     } else
  88.         return 1;
  89. }
  90.  
  91. sync_open()
  92. {
  93.     if (sync_fp != NULL)
  94.         (void) fclose(sync_fp);
  95.     (void) sprintf(sync_lock, LF, game);
  96.     (void) sprintf(sync_file, SF, game);
  97.     if (access(sync_file, 0) < 0) {
  98.         int omask = umask(issetuid ? 077 : 011);
  99.         sync_fp = fopen(sync_file, "w+");
  100.         (void) umask(omask);
  101.     } else
  102.         sync_fp = fopen(sync_file, "r+");
  103.     if (sync_fp == NULL)
  104.         return -1;
  105.     sync_seek = 0;
  106.     return 0;
  107. }
  108.  
  109. sync_close(remove)
  110.     char remove;
  111. {
  112.     if (sync_fp != 0)
  113.         (void) fclose(sync_fp);
  114.     if (remove)
  115.         (void) unlink(sync_file);
  116. }
  117.  
  118. Write(type, ship, isstr, a, b, c, d)
  119.     int type;
  120.     struct ship *ship;
  121.     char isstr;
  122.     int a, b, c, d;
  123. {
  124.     if (isstr)
  125.         (void) sprintf(sync_bp, "%d %d %d %s\n",
  126.             type, ship->file->index, isstr, a);
  127.     else
  128.         (void) sprintf(sync_bp, "%d %d %d %d %d %d %d\n",
  129.             type, ship->file->index, isstr, a, b, c, d);
  130.     while (*sync_bp++)
  131.         ;
  132.     sync_bp--;
  133.     if (sync_bp >= &sync_buf[sizeof sync_buf])
  134.         abort();
  135.     (void) sync_update(type, ship, a, b, c, d);
  136. }
  137.  
  138. Sync()
  139. {
  140.     sig_t sighup, sigint;
  141.     register n;
  142.     int type, shipnum, isstr, a, b, c, d;
  143.     char buf[80];
  144.     char erred = 0;
  145.     extern errno;
  146.  
  147.     sighup = signal(SIGHUP, SIG_IGN);
  148.     sigint = signal(SIGINT, SIG_IGN);
  149.     for (n = TIMEOUT; --n >= 0;) {
  150. #ifdef LOCK_EX
  151.         if (flock(fileno(sync_fp), LOCK_EX|LOCK_NB) >= 0)
  152.             break;
  153.         if (errno != EWOULDBLOCK)
  154.             return -1;
  155. #else
  156.         if (link(sync_file, sync_lock) >= 0)
  157.             break;
  158.         if (errno != EEXIST)
  159.             return -1;
  160. #endif
  161.         sleep(1);
  162.     }
  163.     if (n <= 0)
  164.         return -1;
  165.     (void) fseek(sync_fp, sync_seek, 0);
  166.     for (;;) {
  167.         switch (fscanf(sync_fp, "%d%d%d", &type, &shipnum, &isstr)) {
  168.         case 3:
  169.             break;
  170.         case EOF:
  171.             goto out;
  172.         default:
  173.             goto bad;
  174.         }
  175.         if (shipnum < 0 || shipnum >= cc->vessels)
  176.             goto bad;
  177.         if (isstr != 0 && isstr != 1)
  178.             goto bad;
  179.         if (isstr) {
  180.             register char *p;
  181.             for (p = buf;;) {
  182.                 switch (*p++ = getc(sync_fp)) {
  183.                 case '\n':
  184.                     p--;
  185.                 case EOF:
  186.                     break;
  187.                 default:
  188.                     if (p >= buf + sizeof buf)
  189.                         p--;
  190.                     continue;
  191.                 }
  192.                 break;
  193.             }
  194.             *p = 0;
  195.             for (p = buf; *p == ' '; p++)
  196.                 ;
  197.             a = (int)p;
  198.             b = c = d = 0;
  199.         } else
  200.             if (fscanf(sync_fp, "%d%d%d%d", &a, &b, &c, &d) != 4)
  201.                 goto bad;
  202.         if (sync_update(type, SHIP(shipnum), a, b, c, d) < 0)
  203.             goto bad;
  204.     }
  205. bad:
  206.     erred++;
  207. out:
  208.     if (!erred && sync_bp != sync_buf) {
  209.         (void) fseek(sync_fp, 0L, 2);
  210.         (void) fwrite(sync_buf, sizeof *sync_buf, sync_bp - sync_buf,
  211.             sync_fp);
  212.         (void) fflush(sync_fp);
  213.         sync_bp = sync_buf;
  214.     }
  215.     sync_seek = ftell(sync_fp);
  216. #ifdef LOCK_EX
  217.     (void) flock(fileno(sync_fp), LOCK_UN);
  218. #else
  219.     (void) unlink(sync_lock);
  220. #endif
  221.     (void) signal(SIGHUP, sighup);
  222.     (void) signal(SIGINT, sigint);
  223.     return erred ? -1 : 0;
  224. }
  225.  
  226. sync_update(type, ship, a, b, c, d)
  227.     int type;
  228.     register struct ship *ship;
  229.     int a, b, c, d;
  230. {
  231.     switch (type) {
  232.     case W_DBP: {
  233.         register struct BP *p = &ship->file->DBP[a];
  234.         p->turnsent = b;
  235.         p->toship = SHIP(c);
  236.         p->mensent = d;
  237.         break;
  238.         }
  239.     case W_OBP: {
  240.         register struct BP *p = &ship->file->OBP[a];
  241.         p->turnsent = b;
  242.         p->toship = SHIP(c);
  243.         p->mensent = d;
  244.         break;
  245.         }
  246.     case W_FOUL: {
  247.         register struct snag *p = &ship->file->foul[a];
  248.         if (SHIP(a)->file->dir == 0)
  249.             break;
  250.         if (p->sn_count++ == 0)
  251.             p->sn_turn = turn;
  252.         ship->file->nfoul++;
  253.         break;
  254.         }
  255.     case W_GRAP: {
  256.         register struct snag *p = &ship->file->grap[a];
  257.         if (SHIP(a)->file->dir == 0)
  258.             break;
  259.         if (p->sn_count++ == 0)
  260.             p->sn_turn = turn;
  261.         ship->file->ngrap++;
  262.         break;
  263.         }
  264.     case W_UNFOUL: {
  265.         register struct snag *p = &ship->file->foul[a];
  266.         if (p->sn_count > 0)
  267.             if (b) {
  268.                 ship->file->nfoul -= p->sn_count;
  269.                 p->sn_count = 0;
  270.             } else {
  271.                 ship->file->nfoul--;
  272.                 p->sn_count--;
  273.             }
  274.         break;
  275.         }
  276.     case W_UNGRAP: {
  277.         register struct snag *p = &ship->file->grap[a];
  278.         if (p->sn_count > 0)
  279.             if (b) {
  280.                 ship->file->ngrap -= p->sn_count;
  281.                 p->sn_count = 0;
  282.             } else {
  283.                 ship->file->ngrap--;
  284.                 p->sn_count--;
  285.             }
  286.         break;
  287.         }
  288.     case W_SIGNAL:
  289.         if (mode == MODE_PLAYER)
  290.             if (nobells)
  291.                 Signal("%s (%c%c): %s", ship, a);
  292.             else
  293.                 Signal("\7%s (%c%c): %s", ship, a);
  294.         break;
  295.     case W_CREW: {
  296.         register struct shipspecs *s = ship->specs;
  297.         s->crew1 = a;
  298.         s->crew2 = b;
  299.         s->crew3 = c;
  300.         break;
  301.         }
  302.     case W_CAPTAIN:
  303.         (void) strncpy(ship->file->captain, (char *)a,
  304.             sizeof ship->file->captain - 1);
  305.         ship->file->captain[sizeof ship->file->captain - 1] = 0;
  306.         break;
  307.     case W_CAPTURED:
  308.         if (a < 0)
  309.             ship->file->captured = 0;
  310.         else
  311.             ship->file->captured = SHIP(a);
  312.         break;
  313.     case W_CLASS:
  314.         ship->specs->class = a;
  315.         break;
  316.     case W_DRIFT:
  317.         ship->file->drift = a;
  318.         break;
  319.     case W_EXPLODE:
  320.         if ((ship->file->explode = a) == 2)
  321.             ship->file->dir = 0;
  322.         break;
  323.     case W_FS:
  324.         ship->file->FS = a;
  325.         break;
  326.     case W_GUNL: {
  327.         register struct shipspecs *s = ship->specs;
  328.         s->gunL = a;
  329.         s->carL = b;
  330.         break;
  331.         }
  332.     case W_GUNR: {
  333.         register struct shipspecs *s = ship->specs;
  334.         s->gunR = a;
  335.         s->carR = b;
  336.         break;
  337.         }
  338.     case W_HULL:
  339.         ship->specs->hull = a;
  340.         break;
  341.     case W_MOVE:
  342.         (void) strncpy(ship->file->movebuf, (char *)a,
  343.             sizeof ship->file->movebuf - 1);
  344.         ship->file->movebuf[sizeof ship->file->movebuf - 1] = 0;
  345.         break;
  346.     case W_PCREW:
  347.         ship->file->pcrew = a;
  348.         break;
  349.     case W_POINTS:
  350.         ship->file->points = a;
  351.         break;
  352.     case W_QUAL:
  353.         ship->specs->qual = a;
  354.         break;
  355.     case W_RIGG: {
  356.         register struct shipspecs *s = ship->specs;
  357.         s->rig1 = a;
  358.         s->rig2 = b;
  359.         s->rig3 = c;
  360.         s->rig4 = d;
  361.         break;
  362.         }
  363.     case W_RIG1:
  364.         ship->specs->rig1 = a;
  365.         break;
  366.     case W_RIG2:
  367.         ship->specs->rig2 = a;
  368.         break;
  369.     case W_RIG3:
  370.         ship->specs->rig3 = a;
  371.         break;
  372.     case W_RIG4:
  373.         ship->specs->rig4 = a;
  374.         break;
  375.     case W_COL:
  376.         ship->file->col = a;
  377.         break;
  378.     case W_DIR:
  379.         ship->file->dir = a;
  380.         break;
  381.     case W_ROW:
  382.         ship->file->row = a;
  383.         break;
  384.     case W_SINK:
  385.         if ((ship->file->sink = a) == 2)
  386.             ship->file->dir = 0;
  387.         break;
  388.     case W_STRUCK:
  389.         ship->file->struck = a;
  390.         break;
  391.     case W_TA:
  392.         ship->specs->ta = a;
  393.         break;
  394.     case W_ALIVE:
  395.         alive = 1;
  396.         break;
  397.     case W_TURN:
  398.         turn = a;
  399.         break;
  400.     case W_WIND:
  401.         winddir = a;
  402.         windspeed = b;
  403.         break;
  404.     case W_BEGIN:
  405.         (void) strcpy(ship->file->captain, "begin");
  406.         people++;
  407.         break;
  408.     case W_END:
  409.         *ship->file->captain = 0;
  410.         ship->file->points = 0;
  411.         people--;
  412.         break;
  413.     case W_DDEAD:
  414.         hasdriver = 0;
  415.         break;
  416.     default:
  417.         fprintf(stderr, "sync_update: unknown type %d\r\n", type);
  418.         return -1;
  419.     }
  420.     return 0;
  421. }
  422.