syncer.c

/*
 * Syncs the major BBS files and maintains the idle file.
 * Need to fix the 61036*4096 kludge...
 */
#include "defs.h"
#include "ext.h"

int bbssync(int init) {
  int32_t oldcputime[9];
  time_t t;
  int flags;
  int32_t curpos;
  FILE *fp;
  struct tm *tm;
  uint8_t i;
  int32_t trim;

  if (fork()) {
    _exit(0);
  }
  close(0);
  close(1);
  close(2);
  setsid();
#ifdef __hpux
  signal(SIGCLD, SIG_IGN);
#endif

  if (!(fp = fopen(ROOT "/var/idle", "a"))) {
    _exit(0);
  }
  flags = fcntl(fileno(fp), F_GETFL);
  flags |= O_SYNC;
  fcntl(fileno(fp), F_SETFL, flags);

  if (init) {
    bzero((void *)bigbtmp, sizeof(struct bigbtmp));
    for (i = 0; i < 7; i++) msem_init(&msg->sem[i], -1);

    if (!fork()) {
      setsid();
#if 1
      execl(BBSEXEC, BBSEXEC, "-f", NULL);
#endif
      return (FINGER);
    }

    if (!fork()) {
      setsid();
      bbs_sleep(60);
#if 1
      execl(BBSEXEC, BBSEXEC, "-q", NULL);
#endif
      return (QUEUE);
    }
  }

  nice(-20);
  nice(-20);
#ifdef __hpux
  rtprio(0, 64);
#endif

  for (oldcputime[0] = 0;;) {
    t = msg->t = time(0);
    tm = localtime(&t);
    bbs_sleep(60 - tm->tm_sec);

    t = msg->t = time(0);
    tm = localtime(&t);
    /* pstat_getdynamic(pst, sizeof pst_data, 0, 0); */

    if (oldcputime[0]) {
      //      fprintf(fp, "%02d/%02d %02d:%02d  %4d/%3d  user %02d%%/%02d%%  sys
      //      %02d%%  idle %02d%%/%02d%%  %5.2f/%5.2f/%5.2f\n", tm->tm_mon + 1,
      //      tm->tm_mday, tm->tm_hour, tm->tm_min, bigbtmp->users,
      //      bigbtmp->queued, (pst->psd_cpu_time[0] - oldcputime[0]) / 60,
      //      (pst->psd_cpu_time[1] - oldcputime[1]) / 60, (pst->psd_cpu_time[2]
      //      - oldcputime[2]) / 60, (pst->psd_cpu_time[3] - oldcputime[3]) /
      //      60, (pst->psd_cpu_time[4] - oldcputime[4]) / 60,
      //      pst->psd_avg_1_min, pst->psd_avg_5_min, pst->psd_avg_15_min);
      fflush(fp);
    }
    //    for (f = 0; f < 5; f++)
    //     oldcputime[f] = pst->psd_cpu_time[f];

    /* Busy rates are 120K/min X messages, 8K/min messages */
    /* This is 32 msgs/sec, ??? xmsgs/sec */
    /* Sync with INVALID the unused sections of the xmsg file somewhere? */

#if 0
    if (tm->tm_min % 3 == 0)
      sync();
#endif

    /* Here, should only sync in the area of curpos! */
    if (tm->tm_min % 15 == 5) {
      msync((caddr_t)msgstart, 61036 * 4096, MS_ASYNC);
    }

    /* Break this one up and save in pieces?  Need to maintain it in a
     * consistent state.  If make sure forums are on page boundaries, it will
     * work -- save the first few pages of crud one minute, then x forums each
     * minute after that, saving all over y minutes */
    if (tm->tm_min % 15 == 10) {
      msync((caddr_t)msg, sizeof(struct msg), MS_ASYNC);
    }

    trim = 4;
    curpos = msg->xcurpos & ~4095;
    if (curpos - trim * 1024 * 1024 >= 0) {
      if (curpos + 256 * 1024 >= msg->xmsgsize) {
        msync(
            (caddr_t)xmsg + (curpos + 256 * 1024 - msg->xmsgsize),
            curpos - trim * 1024 * 1024 - (curpos + 256 * 1024 - msg->xmsgsize),
            MS_INVALIDATE);
      } else {
        msync((caddr_t)xmsg, curpos - trim * 1024 * 1024, MS_INVALIDATE);
      }
    }
    if (curpos + 256 * 1024 < msg->xmsgsize) {
      if (trim * 1024 * 1024 - curpos >= 0) {
        msync(
            (caddr_t)xmsg + curpos + 256 * 1024,
            msg->xmsgsize - curpos - 256 * 1024 - (trim * 1024 * 1024 - curpos),
            MS_INVALIDATE);
      } else {
        msync((caddr_t)xmsg + curpos + 256 * 1024,
              msg->xmsgsize - curpos - 256 * 1024, MS_INVALIDATE);
      }
    }

    if (tm->tm_min % 15 == 0) {
      trim = 8;
    } else {
      trim = 16;
    }

    curpos = msg->curpos & ~4095;
    if (curpos - trim * 1024 * 1024 >= 0) {
      if (curpos + 256 * 1024 >= 61036 * 4096) {
        msync(
            (caddr_t)msgstart + (curpos + 256 * 1024 - 61036 * 4096),
            curpos - trim * 1024 * 1024 - (curpos + 256 * 1024 - 61036 * 4096),
            MS_INVALIDATE);
      } else {
        msync((caddr_t)msgstart, curpos - trim * 1024 * 1024, MS_INVALIDATE);
      }
    }

    if (curpos + 256 * 1024 < 61036 * 4096) {
      if (trim * 1024 * 1024 - curpos >= 0) {
        msync(
            (caddr_t)msgstart + curpos + 256 * 1024,
            61036 * 4096 - curpos - 256 * 1024 - (trim * 1024 * 1024 - curpos),
            MS_INVALIDATE);
      } else {
        msync((caddr_t)msgstart + curpos + 256 * 1024,
              61036 * 4096 - curpos - 256 * 1024, MS_INVALIDATE);
      }
    }

    {
      char *corepath =
          my_sprintf(NULL, ROOT "/core/bbs/core-%02d%02d%02d%02d",
                     tm->tm_mon + 1, tm->tm_mday, tm->tm_hour, tm->tm_min);
      rename("/bbs/core/bbs/bbs.core", corepath);
      free(corepath);
    }

    {
      char *corepath =
          my_sprintf(NULL, ROOT "/core/bbsqueued/core-%02d%02d%02d%02d",
                     tm->tm_mon + 1, tm->tm_mday, tm->tm_hour, tm->tm_min);
      rename("/bbs/core/bbsqueued/bbs.core", corepath);
      free(corepath);
    }
  }
}