innfeed/main.c

   1 /*  $Id: main.c 6956 2004-06-29 22:41:35Z rra $
   2 **
   3 **  Main routines for the innfeed program.
   4 **
   5 **  Written by James Brister <brister@vix.com>
   6 */
   7
   8 #include "innfeed.h"
   9 #include "config.h"
  10 #include "clibrary.h"
  11 #include "portable/socket.h"
  12 #include "portable/time.h"
  13
  14 #include <assert.h>
  15 #include <ctype.h>
  16 #include <errno.h>
  17 #include <fcntl.h>
  18 #include <math.h>
  19 #include <netdb.h>
  20 #include <signal.h>
  21 #include <sys/stat.h>
  22 #include <syslog.h>
  23
  24 #if defined(HAVE_UNIX_DOMAIN_SOCKETS)
  25 # include <sys/un.h>
  26 #endif
  27
  28 #include "inn/innconf.h"
  29 #include "inn/messages.h"
  30 #include "libinn.h"
  31 #include "storage.h"
  32
  33 #include "article.h"
  34 #include "buffer.h"
  35 #include "configfile.h"
  36 #include "connection.h"
  37 #include "endpoint.h"
  38 #include "host.h"
  39 #include "innlistener.h"
  40 #include "misc.h"
  41 #include "tape.h"
  42
  43 #define INHERIT 1
  44 #define NO_INHERIT 0
  45
  46 /* exports */
  47 bool talkToSelf ;
  48 extern int debugWrites ;
  49 bool sigFlag = false ;
  50 const char *InputFile ;
  51 char *configFile = NULL ;
  52 bool RollInputFile = false ;
  53 char *pidFile = NULL ;
  54 bool useMMap = false ;
  55 void (*gPrintInfo) (void) ;
  56 char *dflTapeDir;
  57 /* these are used by imapfeed */
  58 char *deliver_username  = NULL;
  59 char *deliver_authname  = NULL;
  60 char *deliver_password  = NULL;
  61 char *deliver_realm     = NULL;
  62 const char *deliver_rcpt_to   = "+%s";
  63 char *deliver_to_header = NULL;
  64
  65 /* imports */
  66 extern char *versionInfo ;
  67 #if defined (sun)
  68 extern char *optarg ;           /* needed for Solaris */
  69 extern int optind;
  70 #endif
  71 extern bool genHtml ;
  72
  73 extern void openInputFile (void);
  74
  75 /* privates */
  76 static char *logFile ;
  77 static char *newsspool ;
  78
  79 static void sigemt (int sig) ;
  80 static void sigalrm (int sig) ;
  81 static void sigchld (int sig) ;
  82 static void sigint (int sig) ;
  83 static void sigquit (int sig) ;
  84 static void sighup (int sig) ;
  85 static void sigterm (int sig) ;
  86 static void sigusr (int sig) ;
  87 static void usage (int) ;
  88 static void gprintinfo (void) ;
  89 static void openLogFile (void) ;
  90 static void writePidFile (void) ;
  91 static int mainOptionsProcess (void *data) ;
  92 static int mainConfigLoadCbk (void *data) ;
  93 static void mainCleanup (void) ;
  94
  95 static char *bopt = NULL ;
  96 static char *aopt = NULL ;
  97 static char *popt = NULL ;
  98 static bool Mopt = false ;
  99 static bool Zopt = false ;
 100 static bool Dopt = false ;
 101 static int debugLevel = 0 ;
 102 static unsigned int initialSleep = 2 ;
 103 static char *sopt = NULL ;
 104 static char *lopt = NULL ;
 105 static bool eopt = false ;
 106 static int elimit = 0 ;
 107
 108 int main (int argc, char **argv)
 109 {
 110   EndPoint ep ;
 111   InnListener listener ;
 112   int optVal, fd, rval ;
 113   const char *subProgram = NULL ;
 114   bool seenV = false ;
 115   bool dynamicPeers = false ;
 116   time_t now = theTime() ;
 117   char dateString [30] ;
 118   char *copt = NULL ;
 119   char *debugFile;
 120   bool checkConfig = false ;
 121   bool val;
 122
 123   strlcpy (dateString,ctime(&now),sizeof (dateString)) ;
 124
 125   message_program_name = strrchr (argv [0],'/');
 126   if (message_program_name == NULL)
 127     message_program_name = argv [0] ;
 128   else
 129     message_program_name++;
 130
 131   gPrintInfo = gprintinfo ;
 132
 133   openlog (message_program_name,(int)(L_OPENLOG_FLAGS|LOG_PID),LOG_INN_PROG) ;
 134   if (!innconf_read(NULL)) {
 135       syslog(LOG_ERR, "cant read inn.conf\n");
 136       exit(1);
 137   }
 138
 139 #if defined (HAVE_MMAP)
 140   useMMap = true ;
 141 #else
 142   useMMap = false ;
 143 #endif
 144
 145   message_handlers_die (2, error_log_stderr_date, message_log_syslog_err) ;
 146   message_handlers_warn (1, message_log_syslog_warning);
 147   message_handlers_notice (1, message_log_syslog_notice) ;
 148
 149 #define OPT_STRING "a:b:c:Cd:e:hl:mMo:p:S:s:vxyz"
 150
 151   while ((optVal = getopt (argc,argv,OPT_STRING)) != EOF)
 152     {
 153       switch (optVal)
 154         {
 155           case 'a':
 156             aopt = optarg ;
 157             break ;
 158
 159           case 'b':
 160             if ( !isDirectory (optarg) )
 161               logAndExit (1,"Not a directory: %s\n",optarg) ;
 162             bopt = optarg ;
 163             break ;
 164
 165           case 'C':
 166             checkConfig = true ;
 167             break ;
 168
 169           case 'c':
 170             copt = optarg ;
 171             break ;
 172
 173           case 'd':
 174             loggingLevel = atoi (optarg) ;
 175             debugLevel = loggingLevel ;
 176             Dopt = true ;
 177             break ;
 178
 179           case 'e':
 180             eopt = true ;
 181             elimit = atoi (optarg) ;
 182             if (elimit <= 0)
 183               {
 184                 fprintf (stderr,"Illegal value for -e option\n") ;
 185                 usage (1) ;
 186               }
 187             break ;
 188
 189           case 'h':
 190             usage (0) ;
 191
 192           case 'l':
 193             lopt = optarg ;
 194             break ;
 195
 196           case 'M':
 197             Mopt = true ;
 198             useMMap = false ;
 199             break ;
 200
 201           case 'm':
 202             artLogMissingArticles (true) ;
 203             break ;
 204
 205           case 'o':
 206             artSetMaxBytesInUse (atoi (optarg)) ;
 207             break ;
 208
 209           case 'p':
 210             popt = optarg ;
 211             break ;
 212
 213           case 's':
 214             subProgram = optarg ;
 215             break ;
 216
 217           case 'S':
 218             sopt = optarg ;
 219             break ;
 220
 221           case 'v':
 222             seenV = true ;
 223             break ;
 224
 225           case 'x':
 226             talkToSelf = true ;
 227             break ;
 228
 229           case 'y':
 230             dynamicPeers = true ;
 231             break ;
 232
 233           case 'z':
 234             Zopt = true ;
 235             break ;
 236
 237           default:
 238             usage (1) ;
 239         }
 240     }
 241
 242   argc -= optind;
 243   argv += optind;
 244
 245   if (argc > 1)
 246     usage (1) ;
 247   else if (argc == 1)
 248     InputFile = *argv;
 249
 250   if (seenV)
 251     {
 252       warn ("%s version: %s\n",message_program_name, versionInfo) ;
 253       exit (0) ;
 254     }
 255
 256   /* make sure we have valid fds 0, 1 & 2 so it is not taken by
 257     something else, probably openlog().  fd 0 will be freopen()ed on the
 258     inputFile, the subProgram, or ourself.  fd 1 and fd 2 will
 259     be freopen()ed on the log file (or will stay pointed at /dev/null).
 260
 261     without doing this, if the descriptors were closed then the
 262     freopen calls on some systems (like BSDI 2.1) will really close
 263     whatever has aquired the stdio descriptors, such as the socket
 264     to syslogd.
 265
 266     XXX possible problems:  what if fd 0 is closed but no inputFile,
 267     XXX subProgram or talkToSelf is true?  it will not be freopen()ed, so
 268     XXX innfeed won't have any fresh data (besides, fd 0 is only writable
 269     XXX here).  perhaps a warning should be issued.
 270     */
 271   do
 272     {
 273       fd = open("/dev/null", O_WRONLY);
 274       switch (fd)
 275         {
 276           case -1:
 277             logAndExit (1,"open(\"/dev/null\", O_WRONLY): %s",
 278                         strerror (errno));
 279             break;
 280           case 0:
 281           case 1:
 282           case 2:
 283             /* good, we saved an fd from being trounced */
 284             break;
 285           default:
 286             close(fd);
 287         }
 288     } while (fd < 2);
 289
 290   if ( !checkConfig )
 291     {
 292       notice ("ME starting %s at %s", versionInfo, dateString) ;
 293     }
 294
 295   val = true;
 296   if (!SMsetup(SM_PREOPEN, (void *)&val)) {
 297       syslog(LOG_ERR, "cant setup the storage subsystem\n");
 298       exit(1);
 299   }
 300   if (!SMinit()) {
 301       d_printf(0, "Storage manager initialization failed\n");
 302       syslog(LOG_ERR, "Storage manager initialization failed\n");
 303       exit(1);
 304   }
 305
 306   if (subProgram == NULL && talkToSelf == false)
 307     {
 308       struct stat buf ;
 309
 310       if (fstat (0,&buf) < 0)
 311         logAndExit (1,"ME oserr fstat stdin: %s", strerror (errno)) ;
 312       else if (S_ISREG (buf.st_mode))
 313         InputFile = "";
 314     }
 315
 316   /*
 317    * set up the config file name and then read the file in. Order is important.
 318    */
 319   configAddLoadCallback (mainOptionsProcess,(checkConfig ? stderr : NULL)) ;
 320   configAddLoadCallback (tapeConfigLoadCbk,(checkConfig ? stderr : NULL)) ;
 321
 322   configAddLoadCallback (endpointConfigLoadCbk,(checkConfig ? stderr : NULL));
 323   configAddLoadCallback (hostConfigLoadCbk,(checkConfig ? stderr : NULL)) ;
 324   configAddLoadCallback (cxnConfigLoadCbk,(checkConfig ? stderr : NULL)) ;
 325   configAddLoadCallback (mainConfigLoadCbk,(checkConfig ? stderr : NULL)) ;
 326   configAddLoadCallback (listenerConfigLoadCbk,(checkConfig ? stderr : NULL));
 327
 328   if (copt != NULL && *copt == '\0')
 329     {
 330       logOrPrint (LOG_CRIT,(checkConfig ? stderr : NULL),
 331                   "Empty pathname for ``-c'' option") ;
 332       exit (1) ;
 333     }
 334   configFile = buildFilename(innconf->pathetc, copt ? copt : CONFIG_FILE);
 335   dflTapeDir = buildFilename(innconf->pathspool, TAPE_DIRECTORY);
 336
 337   rval = readConfig (configFile,(checkConfig ? stderr : NULL),
 338                      checkConfig,loggingLevel > 0);
 339
 340   if (subProgram != NULL && (talkToSelf == true || InputFile))
 341     {
 342       d_printf (0,"Cannot specify '-s' with '-x' or an input file\n") ;
 343       syslog (LOG_ERR,"Incorrect arguments: '-s' with '-x' or an input file\n");
 344       usage (1) ;
 345     }
 346
 347   if (checkConfig)
 348     {
 349       if (!rval)
 350         {
 351           fprintf (stderr,"config loading failed.\n") ;
 352           exit (1) ;
 353         }
 354       else
 355         {
 356           fprintf (stderr,"config loading succeeded.\n") ;
 357           exit (0) ;
 358         }
 359     }
 360   else if (!rval)
 361     exit (1) ;
 362
 363   debugFile = buildFilename (innconf->pathlog, DEBUG_FILE);
 364   if (loggingLevel == 0 && fileExistsP (debugFile))
 365     loggingLevel = 1 ;
 366
 367   if (logFile == NULL && ! isatty (fileno (stderr)))
 368     logFile = buildFilename (innconf->pathlog, LOG_FILE) ;
 369
 370   if (logFile)
 371     openLogFile () ;
 372
 373   openfds = 4 ;                 /* stdin, stdout, stderr and syslog */
 374
 375   writePidFile ();
 376
 377   if (subProgram != NULL)
 378     {
 379       int fds [2] ;
 380       int pid ;
 381
 382       if (pipe (fds) < 0)
 383         sysdie ("ME fatal pipe") ;
 384
 385       if ((pid = fork ()) < 0)
 386         {
 387           sysdie ("ME fatal fork") ;
 388         }
 389       else if (pid == 0)
 390         {                       /* child */
 391           close (fds[0]) ;
 392           close (0) ;
 393           close (1) ;
 394           close (2) ;
 395           dup2 (fds[1],1) ;
 396           dup2 (fds[1],2) ;
 397           execlp ("sh", "sh", "-c", subProgram, (char *) 0) ;
 398           perror ("execlp") ;
 399           exit (1) ;
 400         }
 401       else
 402         {                       /* parent */
 403           close (0) ;
 404           dup2 (fds[0],0) ;
 405           close (fds[1]) ;
 406           xsignal(SIGCHLD,sigchld) ;
 407           openfds++ ;
 408         }
 409     }
 410   else  if (talkToSelf)
 411     {
 412         /* We're not really getting information from innd or a subprogram,
 413            but are just processing backlog files. We set up a pipe to ourself
 414            that we never write to, to simulate an idle innd. */
 415       int pipefds [2] ;
 416
 417       if (pipe (pipefds) != 0)
 418         sysdie ("ME fatal pipe") ;
 419
 420       close (0) ;
 421       dup2 (pipefds [0], 0) ;
 422
 423       openfds++ ;
 424       openfds++ ;
 425     }
 426
 427   if (chdir (newsspool) != 0)
 428     sysdie ("ME fatal chdir %s", newsspool) ;
 429
 430     /* hook up the endpoint to the source of new article information (usually
 431        innd). */
 432   ep = newEndPoint (0) ;        /* fd 0, i.e. stdin */
 433
 434     /* now arrange for this endpoint to always be the first one checked for
 435        possible activity. */
 436   setMainEndPoint (ep) ;
 437
 438   listener = newListener (ep, talkToSelf,dynamicPeers) ;
 439   mainListener = listener ;
 440
 441   sleep (initialSleep) ;
 442
 443   if (innconf->rlimitnofile >= 0)
 444     if (setfdlimit (innconf->rlimitnofile) < 0)
 445       syswarn ("ME oserr setrlimit(RLIM_NOFILE,%ld)", innconf->rlimitnofile) ;
 446
 447   if (innconf->timer > 0)
 448     TMRinit (TMR_MAX) ;
 449
 450   configHosts (talkToSelf) ;
 451
 452   if (InputFile && *InputFile) {
 453     openInputFile () ;
 454   }
 455
 456   /* handle signal to shutdown */
 457   setSigHandler (SIGTERM,sigterm) ;
 458   setSigHandler (SIGQUIT,sigquit) ;
 459
 460   /* handle signal to reload config */
 461   setSigHandler (SIGHUP,sighup) ;
 462
 463   /* handle signal to print snapshot. */
 464   setSigHandler (SIGINT,sigint) ;
 465
 466   /* handle signal to roll input file */
 467   setSigHandler (SIGALRM,sigalrm) ;
 468
 469   /* handle signal to flush all the backlog files */
 470   setSigHandler (SIGCHLD,sigemt) ;
 471
 472   /* we can increment and decrement logging levels by sending SIGUSR{1,2} */
 473   setSigHandler (SIGUSR1,sigusr) ;
 474   setSigHandler (SIGUSR2,sigusr) ;
 475
 476   atexit (mainCleanup) ;
 477
 478   Run () ;
 479
 480   exit (0) ;
 481 }
 482
 483 static void usage (int val)
 484 {
 485   fprintf (stderr,"usage: %s [ options ] [ file ]\n\n",
 486            message_program_name) ;
 487   fprintf (stderr,"Version: %s\n\n",versionInfo) ;
 488   fprintf (stderr,"Config file: %s\n",CONFIG_FILE) ;
 489   fprintf (stderr,"Backlog directory: %s/%s\n", innconf->pathspool, TAPE_DIRECTORY) ;
 490   fprintf (stderr,"\nLegal options are:\n") ;
 491   fprintf (stderr,"\t-a dir      Use the given directory as the top of the article spool\n") ;
 492
 493   fprintf (stderr,"\t-b dir      Use the given directory as the the storage\n");
 494   fprintf (stderr,"\t            place for backlog files and lock files.\n");
 495
 496   fprintf (stderr,"\t-c file     Use the given file as the config file instead of the\n");
 497   fprintf (stderr,"\t            default of %s\n",CONFIG_FILE);
 498
 499   fprintf (stderr,"\t-C          Check the config file and then exit.\n") ;
 500   fprintf (stderr,"\t-d num      set the logging level to num (an integer).\n");
 501   fprintf (stderr,"\t            Larger value means more logging. 0 means no\n");
 502   fprintf (stderr,"\t            logging. The default is 0\n");
 503
 504   fprintf (stderr,"\t-e bytes    Keep the output backlog files to no bigger\n");
 505   fprintf (stderr,"\t            than %.2f times this number\n",LIMIT_FUDGE);
 506
 507   fprintf (stderr,"\t-h          print this message\n");
 508
 509   fprintf (stderr,"\t-l file     redirect stderr and stdout to the given file.\n");
 510   fprintf (stderr,"\t            When run under INN they normally are redirected to\n");
 511   fprintf (stderr,"\t            /dev/null. This is needed if using '-d'.\n");
 512
 513   fprintf (stderr,"\t-m          Log information on all missing articles\n");
 514
 515   fprintf (stderr,"\t-M          Turn *off* use of mmap\n") ;
 516 #if ! defined (HAVE_MMAP)
 517   fprintf (stderr,"\t            (a no-op as this excutable has been built without mmap support\n") ;
 518 #endif
 519
 520   fprintf (stderr,"\t-p file     Write the process id to the given file\n") ;
 521   fprintf (stderr,"\t            instead of the default of %s\n",PID_FILE);
 522   fprintf (stderr,"\t            A relative path is relative to %s\n", innconf->pathrun) ;
 523
 524   fprintf (stderr,"\t-s command  run the given command in a subprocess and use\n");
 525   fprintf (stderr,"\t            its output as article information instead of\n");
 526   fprintf (stderr,"\t            running under innd\n");
 527
 528   fprintf (stderr,"\t-S file     Use the give filename instead of innfeed.status\n") ;
 529   fprintf (stderr,"\t            relative pathnames start from %s\n", innconf->pathlog) ;
 530
 531   fprintf (stderr,"\t-v          print version information\n");
 532
 533   fprintf (stderr,"\t-x          Do not read any article information off stdin,\n");
 534   fprintf (stderr,"\t            but simply process backlog files and then exit\n");
 535   fprintf (stderr,"\t            when done\n");
 536
 537   fprintf (stderr,"\t-y          Add peers dynamically. If an unrecognized peername\n");
 538   fprintf (stderr,"\t            is received from innd, then it is presumed to also\n");
 539   fprintf (stderr,"\t            be the ip name and a new peer binding is set up\n");
 540
 541   fprintf (stderr,"\t-z          have each of the connections issue their own stats\n");
 542   fprintf (stderr,"\t            whenever they close, or whenever their controller\n");
 543   fprintf (stderr,"\t            issues its own stats\n");
 544
 545   exit (val) ;
 546 }
 547
 548 static void sigterm (int sig UNUSED)
 549 {
 550   notice ("ME received shutdown signal") ;
 551   shutDown (mainListener) ;
 552 }
 553
 554 static void sigquit (int sig UNUSED)
 555 {
 556   sigterm (0) ;
 557 }
 558
 559 static void sigint (int sig UNUSED)
 560 {
 561   gprintinfo () ;
 562 }
 563
 564 static void sighup (int sig UNUSED)
 565 {
 566   notice ("ME reloading config file %s", configFile) ;
 567
 568   if (!readConfig (configFile,NULL,false,loggingLevel > 0))
 569     {
 570       die ("ME config aborting, error parsing config file") ;
 571     }
 572
 573   configHosts (talkToSelf) ;
 574 }
 575
 576 static void sigemt (int sig UNUSED)
 577 {
 578   gFlushTapes () ;
 579 }
 580
 581 static void sigalrm (int sig UNUSED)
 582 {
 583   if (InputFile == NULL)
 584     warn ("ME signal SIGALRM in non-funnel-file mode ignored") ;
 585   else
 586     {
 587       RollInputFile = true;
 588       syslog(LOG_NOTICE, "ME preparing to roll %s", InputFile);
 589     }
 590 }
 591
 592 static void sigchld (int sig UNUSED)
 593 {
 594 #if 0
 595   wait (&status) ;              /* we don't care */
 596 #endif
 597
 598   xsignal (sig,sigchld) ;
 599 }
 600
 601   /* SIGUSR1 increments logging level. SIGUSR2 decrements. */
 602 static void sigusr (int sig)
 603 {
 604   if (sig == SIGUSR1) {
 605     loggingLevel++ ;
 606     notice ("ME increasing logging level to %d", loggingLevel) ;
 607   } else if (sig == SIGUSR2 && loggingLevel > 0) {
 608     loggingLevel-- ;
 609     notice ("ME decreasing logging level to %d", loggingLevel) ;
 610   }
 611 }
 612
 613 static void openLogFile (void)
 614 {
 615   FILE *fpr ;
 616
 617   if (logFile)
 618     {
 619       fpr = freopen (logFile,"a",stdout) ;
 620       if (fpr != stdout)
 621         logAndExit (1,"freopen (%s, \"a\", stdout): %s",
 622                     logFile, strerror (errno)) ;
 623
 624       fpr = freopen (logFile,"a",stderr) ;
 625       if (fpr != stderr)
 626         logAndExit (1,"freopen (%s, \"a\", stderr): %s",
 627                     logFile, strerror (errno)) ;
 628
 629 #if defined (HAVE_SETBUFFER)
 630       setbuffer (stdout, NULL, 0) ;
 631       setbuffer (stderr, NULL, 0) ;
 632 #else
 633       setbuf (stdout, NULL) ;
 634       setbuf (stderr, NULL) ;
 635 #endif
 636     }
 637 }
 638
 639 static void writePidFile (void)
 640 {
 641   FILE *F;
 642   int pid;
 643
 644   if (pidFile == NULL)
 645     logAndExit (1,"NULL pidFile\n") ;
 646
 647   /* Record our PID. */
 648   pid = getpid();
 649   if ((F = fopen(pidFile, "w")) == NULL)
 650     {
 651       syslog(LOG_ERR, "ME cant fopen %s %m", pidFile);
 652     }
 653   else
 654     {
 655       if (fprintf(F, "%ld\n", (long)pid) == EOF || ferror(F))
 656         {
 657           syslog(LOG_ERR, "ME cant fprintf %s %m", pidFile);
 658         }
 659       if (fclose(F) == EOF)
 660         {
 661           syslog(LOG_ERR, "ME cant fclose %s %m", pidFile);
 662         }
 663       if (chmod(pidFile, 0664) < 0)
 664         {
 665           syslog(LOG_ERR, "ME cant chmod %s %m", pidFile);
 666         }
 667     }
 668 }
 669
 670 static void gprintinfo (void)
 671 {
 672   char *snapshotFile;
 673   FILE *fp;
 674   time_t now = theTime() ;
 675
 676   snapshotFile = buildFilename(innconf->pathlog, SNAPSHOT_FILE);
 677   fp = fopen (snapshotFile,"a") ;
 678   if (fp == NULL)
 679     {
 680       syswarn ("ME fopen %s", snapshotFile) ;
 681       free(snapshotFile);
 682       return ;
 683     }
 684   free(snapshotFile);
 685
 686 #if defined (HAVE_SETBUFFER)
 687   setbuffer (fp, NULL, 0) ;
 688 #else
 689   setbuf (fp, NULL) ;
 690 #endif
 691
 692   fprintf (fp,"----------------------------System snaphot taken at: %s\n",
 693            ctime (&now)) ;
 694   gPrintListenerInfo (fp,0) ;
 695   fprintf (fp,"\n\n\n\n") ;
 696   gPrintHostInfo (fp,0) ;
 697   fprintf (fp,"\n\n\n\n") ;
 698   gPrintCxnInfo (fp,0) ;
 699   fprintf (fp,"\n\n\n\n") ;
 700   gPrintArticleInfo (fp,0) ;
 701   fprintf (fp,"\n\n\n\n") ;
 702   gPrintBufferInfo (fp,0) ;
 703   fprintf (fp,"\n\n\n\n") ;
 704   fclose (fp) ;
 705 }
 706
 707 /* called after the config file is loaded and after the config data has
 708   been updated with command line options. */
 709 static int mainConfigLoadCbk (void *data)
 710 {
 711   FILE *fp = (FILE *) data ;
 712   char *p ;
 713   long ival ;
 714   int bval ;
 715
 716   if (getString (topScope,"news-spool", &p,NO_INHERIT))
 717     {
 718       if ( !isDirectory (p) && isDirectory (innconf->patharticles) )
 719         {
 720           logOrPrint (LOG_WARNING,fp,
 721                       "ME config: definition of news-spool (%s) is a"
 722                       " non-existant directory. Using %s",p,
 723                       innconf->patharticles) ;
 724           p = xstrdup (innconf->patharticles) ;
 725         }
 726       else if (!isDirectory (p))
 727         logAndExit (1,"Bad spool directories: %s, %s\n",p,innconf->patharticles) ;
 728     }
 729   else if (!isDirectory (innconf->patharticles))
 730     logAndExit (1,"ME config: no definition of news-spool, and %s is no good",
 731                 innconf->patharticles);
 732   else
 733     p = xstrdup (innconf->patharticles) ;
 734   newsspool = p ;
 735
 736   /***************************************************/
 737
 738   if (getString (topScope,"input-file",&p,NO_INHERIT))
 739     {
 740       if (*p != '\0')
 741         InputFile = buildFilename (getTapeDirectory(),p) ;
 742       else
 743         InputFile = "" ;
 744       free (p) ;
 745     }
 746
 747   if (getString (topScope,"pid-file",&p,NO_INHERIT))
 748     {
 749       pidFile = buildFilename (innconf->pathrun,p) ;
 750       free (p) ;
 751     }
 752   else
 753     pidFile = buildFilename (innconf->pathrun,PID_FILE) ;
 754
 755   if (getInteger (topScope,"debug-level",&ival,NO_INHERIT))
 756     loggingLevel = (unsigned int) ival ;
 757
 758
 759   if (getInteger (topScope,"initial-sleep",&ival,NO_INHERIT))
 760     initialSleep = (unsigned int) ival ;
 761
 762
 763   if (getBool (topScope,"use-mmap",&bval,NO_INHERIT))
 764     useMMap = (bval ? true : false) ;
 765
 766
 767   if (getString (topScope,"log-file",&p,NO_INHERIT))
 768     {
 769       logFile = buildFilename (innconf->pathlog,p) ;
 770       free (p) ;
 771     }
 772
 773    /* For imap/lmtp delivering */
 774   if (getString (topScope,"deliver-username",&p, NO_INHERIT))
 775     {
 776         deliver_username = p;
 777       /* don't need to free */
 778     }
 779
 780   if (getString (topScope,"deliver-authname",&p, NO_INHERIT))
 781     {
 782       deliver_authname = p;
 783       /* don't need to free */
 784     }
 785
 786   if (getString (topScope,"deliver-password",&p, NO_INHERIT))
 787     {
 788       deliver_password = p;
 789       /* don't need to free */
 790     }
 791
 792   if (getString (topScope,"deliver-realm",&p, NO_INHERIT))
 793     {
 794       deliver_realm = p;
 795       /* don't need to free */
 796     }
 797
 798   if (getString (topScope,"deliver-rcpt-to",&p, NO_INHERIT))
 799     {
 800       deliver_rcpt_to = p;
 801       /* don't need to free */
 802     }
 803
 804   if (getString (topScope,"deliver-to-header",&p, NO_INHERIT))
 805     {
 806       deliver_to_header = p;
 807       /* don't need to free */
 808     }
 809
 810
 811
 812   return 1 ;
 813 }
 814
 815 /*
 816  * called after config file is loaded but before other callbacks, so we
 817  * can adjust config file values from options. They will be validated in the
 818  * second callback.
 819  */
 820 static int mainOptionsProcess (void *data UNUSED)
 821 {
 822   value *v ;
 823
 824   if (bopt != NULL)
 825     {
 826       if ((v = findValue (topScope,"backlog-directory",NO_INHERIT)) != NULL)
 827         {
 828           free (v->v.charp_val) ;
 829           v->v.charp_val = xstrdup (bopt) ;
 830         }
 831       else
 832         addString (topScope,"backlog-directory",xstrdup (bopt)) ;
 833     }
 834
 835   if (aopt != NULL)
 836     {
 837       if ((v = findValue (topScope,"news-spool",NO_INHERIT)) != NULL)
 838         {
 839           free (v->v.charp_val) ;
 840           v->v.charp_val = xstrdup (aopt) ;
 841         }
 842       else
 843         addString (topScope,"news-spool",xstrdup (aopt)) ;
 844     }
 845
 846   if (sopt != NULL)
 847     {
 848       if ((v = findValue (topScope,"status-file",NO_INHERIT)) != NULL)
 849         {
 850           free (v->v.charp_val) ;
 851           v->v.charp_val = xstrdup (sopt) ;
 852         }
 853       else
 854         addString (topScope,"status-file",xstrdup (sopt)) ;
 855     }
 856
 857
 858   if (Dopt)
 859     {
 860       if ((v = findValue (topScope,"debug-level",NO_INHERIT)) != NULL)
 861         v->v.int_val = debugLevel ;
 862       else
 863         addInteger (topScope,"debug-level",debugLevel) ;
 864     }
 865
 866
 867   if (eopt || talkToSelf)
 868     {
 869       if (talkToSelf)
 870         elimit = 0 ;
 871
 872       if ((v = findValue (topScope,"backlog-limit",NO_INHERIT)) != NULL)
 873         v->v.int_val = elimit ;
 874       else
 875         addInteger (topScope,"backlog-limit",elimit) ;
 876     }
 877
 878
 879   if (Mopt)
 880     {
 881       if ((v = findValue (topScope,"use-mmap",NO_INHERIT)) != NULL)
 882         v->v.bool_val = 0 ;
 883       else
 884         addBoolean (topScope,"use-mmap",0) ;
 885     }
 886
 887
 888   if (popt != NULL)
 889     {
 890       if ((v = findValue (topScope,"pid-file",NO_INHERIT)) != NULL)
 891         {
 892           free (v->v.charp_val) ;
 893           v->v.charp_val = xstrdup (popt) ;
 894         }
 895       else
 896         addString (topScope,"pid-file",xstrdup (popt)) ;
 897     }
 898
 899   if (Zopt)
 900     {
 901       if ((v = findValue (topScope,"connection-stats",NO_INHERIT)) != NULL)
 902         v->v.bool_val = 1 ;
 903       else
 904         addBoolean (topScope,"connection-stats",1) ;
 905     }
 906
 907   if (lopt != NULL)
 908     {
 909       if ((v = findValue (topScope,"log-file",NO_INHERIT)) != NULL)
 910         {
 911           free (v->v.charp_val) ;
 912           v->v.charp_val = xstrdup (lopt) ;
 913         }
 914       else
 915         addString (topScope,"log-file",xstrdup (lopt)) ;
 916     }
 917
 918   if (InputFile != NULL)
 919     {
 920       if ((v = findValue (topScope,"input-file",NO_INHERIT)) != NULL)
 921         {
 922           free (v->v.charp_val) ;
 923           v->v.charp_val = xstrdup (InputFile) ;
 924         }
 925       else
 926         addString (topScope,"input-file",xstrdup (InputFile)) ;
 927     }
 928
 929   return 1 ;
 930 }
 931
 932
 933
 934 static void mainCleanup (void)
 935 {
 936   free ((void *)configFile) ;
 937   free ((void *)pidFile) ;
 938   free (logFile) ;
 939   free (newsspool) ;
 940   configFile = NULL ;
 941   pidFile = NULL ;
 942   logFile = NULL ;
 943   newsspool = NULL ;
 944 }
 945
 946
 947 void mainLogStatus (FILE *fp)
 948 {
 949   fprintf (fp,"%sGlobal configuration parameters:%s\n",
 950            genHtml ? "<B>" : "", genHtml ? "</B>" : "") ;
 951   fprintf (fp,"          Mode: ") ;
 952   if (InputFile != NULL)
 953     fprintf (fp,"Funnel file") ;
 954   else if (talkToSelf)
 955     fprintf (fp,"Batch") ;
 956   else
 957     fprintf (fp,"Channel") ;
 958   if (InputFile != NULL)
 959     fprintf (fp,"   (%s)",(*InputFile == '\0' ? "stdin" : InputFile)) ;
 960   fprintf (fp,"\n") ;
 961   fprintf (fp,"    News spool: %s\n",newsspool) ;
 962   fprintf (fp,"      Pid file: %s\n",pidFile) ;
 963   fprintf (fp,"      Log file: %s\n",(logFile == NULL ? "(none)" : logFile));
 964   fprintf (fp,"   Debug level: %2ld                Mmap: %s\n",
 965            (long)loggingLevel,boolToString(useMMap)) ;
 966   fprintf (fp,"\n") ;
 967 }