/*
 * Log Replayer Daemon
 *
 * This replays question logs
 * Copyright (C) 1991 by the Massachusetts Institute of Technology.
 * For copying and distribution information, see the file "mit-copyright.h".
 */

#ifndef lint
#ifndef SABER
static char *RCSid = "$Header: /afs/sipb.mit.edu/project/sipb-athena/repository/src/olc/server/rpd/rpd.c,v 1.2 1996/06/02 03:15:32 svalente Exp $";
#endif
#endif

#include <mit-copyright.h>
#include "rpd.h"

#ifndef SOMAXCONN
#define SOMAXCONN 5
#endif

int sock;	/* the listening socket */
int fd;		/* the accepting socket */

#ifdef __STDC__
# define        P(s) s
#else
# define P(s) ()
#endif


#ifdef PROFILE
static int dump_profile P((int sig ));
static int start_profile P((int sig ));
#endif /* PROFILE */

#ifdef VOID_SIGRET
static void clean_up P((int sig));
#else
static int clean_up P((int sig));
#endif
#undef P

main(argc, argv)
     int argc;
     char **argv;
{
  int len,max_fd;
  struct sockaddr_in sin,from;
  struct servent *sent;
  int onoff;
  int nofork=0;
  int arg;

#ifdef PROFILE
    /* Turn off profiling on startup; that way, we collect "steady state" */
    /* statistics, not the initial flurry of startup activity */
    moncontrol(0);
#endif

  for (arg=1;arg< argc; arg++) {
    if (!strcmp(argv[arg],"-nofork")) {
      nofork = 1;
      continue;
    }
    else {
      fprintf (stderr,"rpd: Unknown argument: %s\n",argv[arg]);
      exit(1);
    }
  }


  signal(SIGHUP,clean_up);
  signal(SIGINT,clean_up);
  signal(SIGTERM,clean_up);
  signal(SIGPIPE,SIG_IGN);
#ifdef PROFILE
  signal(SIGUSR1, dump_profile); /* Dump profiling information and stop */
  				 /* profiling */
  signal(SIGUSR2, start_profile); /* Start profiling */
#endif /* PROFILE */

#if defined(ultrix)
#ifdef LOG_CONS
	openlog ("rpd", LOG_CONS | LOG_PID);
#else
	openlog ("rpd", LOG_PID);
#endif /* LOG_CONS */
#else
#ifdef LOG_CONS
	openlog ("rpd", LOG_CONS | LOG_PID,SYSLOG_FACILITY);
#else
	openlog ("rpd", LOG_PID, SYSLOG_FACILITY);
#endif /* LOG_CONS */
#endif /* ultrix */

#ifndef SABER
  if (!nofork) {
    /* Fork off */
    switch (fork()) {
    case 0:		/* Child */
      break;
    case 1:
      syslog(LOG_ERR,"Can't fork: %m");
      exit(1);
    default:
      exit(0);		/* Parent */
    }
#endif
    max_fd = getdtablesize();
    
    for(fd = 0;fd<max_fd;fd++)
      close(fd);
    fd = open("/",O_RDONLY,0);
    if (fd < 0) {
      syslog(LOG_ERR,"Can't open /: %m");
      exit(1);
    }
    if (fd != 0)
      dup2 (fd, 0);
    if (fd != 1)
      dup2 (fd, 1);
    if (fd != 2)
      dup2 (fd, 2);
    if (fd > 2)
      close (fd);
    
    fd = open("/dev/tty",O_RDWR,0);
    if (fd>=0) {
      ioctl(fd, TIOCNOTTY, (char *) NULL);
      close(fd);
    }
  }

  init_cache();

  if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
    syslog(LOG_ERR,"socket: %m");
    exit(1);
  }

  if ((sent = getservbyname("ols","tcp")) == NULL) {
    syslog(LOG_ERR,"ols/tcp unknown service");
    exit(1);
  }

  bzero(&sin,sizeof(sin));
  sin.sin_family = AF_INET;
  sin.sin_addr.s_addr = INADDR_ANY;
  sin.sin_port = sent->s_port;

  onoff = 1;
  if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &onoff, sizeof(int)) < 0) {
    syslog(LOG_ERR,"setsockopt: %m");
    exit(1);
  }

  if (bind(sock, (struct sockaddr *)&sin, sizeof(sin)) == -1) {
    syslog(LOG_ERR,"bind: %m");
    exit(1);
  }

  if (listen(sock,SOMAXCONN) == -1) {
    syslog(LOG_ERR,"bind: %m");
    exit(1);
  }

  syslog(LOG_INFO,"Ready to accept connections..");

  /* Main loop... */

  while (1) {
    len = sizeof(from);
    if ((fd = accept(sock,(struct sockaddr *) &from, &len)) == -1) {
      if (errno == EINTR) {
	syslog(LOG_WARNING,"Interrupted by signal in accept; continuing");
	continue;
      }
      syslog(LOG_ERR,"accept: %m");
      exit(1);
    }
    handle_request(fd,from);
    close(fd);
  }
}

#ifdef PROFILE
static int
dump_profile(sig)
     int sig;
{
  syslog(LOG_INFO,"Dumping profile..");
  monitor(0);
  moncontrol(0);
  return 0;
}

static int
start_profile(sig)
     int sig;
{
  syslog(LOG_INFO,"Starting profile..");
  moncontrol(1);
  return 0;
}
#endif /* PROFILE */

static
#ifdef VOID_SIGRET
void
#else
int
#endif
clean_up(signal)
     int signal;
{
  close(fd);
  close(sock);
  syslog(LOG_NOTICE,"rpd shutting down on signal %d",signal);
  exit(0);
#ifdef VOID_SIGRET
  return;
#else
  return 0;
#endif
}