- Added AC_CHECK_FUNC tests for the availability of
[privoxy.git] / jcc.c
diff --git a/jcc.c b/jcc.c
index 0a06e62..2d37bec 100644 (file)
--- a/jcc.c
+++ b/jcc.c
@@ -1,4 +1,4 @@
-const char jcc_rcs[] = "$Id: jcc.c,v 1.52 2001/10/26 20:11:20 jongfoster Exp $";
+const char jcc_rcs[] = "$Id: jcc.c,v 1.59 2001/12/13 14:07:18 oes Exp $";
 /*********************************************************************
  *
  * File        :  $Source: /cvsroot/ijbswa/current/jcc.c,v $
@@ -33,6 +33,35 @@ const char jcc_rcs[] = "$Id: jcc.c,v 1.52 2001/10/26 20:11:20 jongfoster Exp $";
  *
  * Revisions   :
  *    $Log: jcc.c,v $
+ *    Revision 1.59  2001/12/13 14:07:18  oes
+ *    Fixed Bug: 503 error page now sent OK
+ *
+ *    Revision 1.58  2001/11/30 23:37:24  jongfoster
+ *    Renaming the Win32 config file to config.txt - this is almost the
+ *    same as the corresponding UNIX name "config"
+ *
+ *    Revision 1.57  2001/11/16 00:47:43  jongfoster
+ *    Changing the tty-disconnection code to use setsid().
+ *
+ *    Revision 1.56  2001/11/13 20:20:54  jongfoster
+ *    Tabs->spaces, fixing a bug with missing {} around an if()
+ *
+ *    Revision 1.55  2001/11/13 20:14:53  jongfoster
+ *    Patch for FreeBSD setpgrp() as suggested by Alexander Lazic
+ *
+ *    Revision 1.54  2001/11/07 00:03:14  steudten
+ *    Give reliable return value if an error
+ *    occurs not just 0 with new daemon mode.
+ *
+ *    Revision 1.53  2001/11/05 21:41:43  steudten
+ *    Add changes to be a real daemon just for unix os.
+ *    (change cwd to /, detach from controlling tty, set
+ *    process group and session leader to the own process.
+ *    Add DBG() Macro.
+ *    Add some fatal-error log message for failed malloc().
+ *    Add '-d' if compiled with 'configure --with-debug' to
+ *    enable debug output.
+ *
  *    Revision 1.52  2001/10/26 20:11:20  jongfoster
  *    Fixing type mismatch
  *
@@ -435,6 +464,8 @@ const char project_h_rcs[] = PROJECT_H_VERSION;
 struct client_state  clients[1];
 struct file_list     files[1];
 
+short int MustReload = 0;
+
 #ifdef FEATURE_STATISTICS
 int urls_read     = 0;     /* total nr of urls read inc rejected */
 int urls_rejected = 0;     /* total nr of urls rejected */
@@ -476,6 +507,44 @@ static const char VANILLA_WAFER[] =
    "(copyright_or_otherwise)_applying_to_any_cookie._";
 
 
+#if !defined(_WIN32) && !defined(__OS2__)
+/*********************************************************************
+ *
+ * Function    :  SIG_handler 
+ *
+ * Description :  Signal handler for different signals.
+ *                see man kill, signal .. 
+ *
+ * Parameters  :
+ *          1  : signal - the signal cause this function to call 
+ *
+ * Returns     :  - 
+ *
+ *********************************************************************/
+static void SIG_handler( int signal )
+{
+   switch( signal )
+   {
+      case SIGHUP:
+         MustReload = 1;
+         break;
+      case SIGTERM:
+         log_error(LOG_LEVEL_INFO, "exiting by signal %d .. bye", signal);
+         
+#if defined(unix)
+         deletePidFile();
+#endif /* unix */
+
+         exit( signal );
+         break;
+
+      default:
+         /* want to exit jb so use FATAL */
+         log_error(LOG_LEVEL_FATAL, "SIG_handler: receive signal %d without handler.", signal);
+   }
+   return;
+}
+#endif
 /*********************************************************************
  *
  * Function    :  chat
@@ -767,13 +836,13 @@ static void chat(struct client_state *csp)
 
    if (
        /* a CGI call was detected and answered */
-        (NULL != (rsp = dispatch_cgi(csp)))
+       (NULL != (rsp = dispatch_cgi(csp)))
 
        /* or we are enabled and... */
        || (IS_ENABLED_AND (
 
             /* ..the request was blocked */
-           ( NULL != (rsp = block_url(csp)))
+          ( NULL != (rsp = block_url(csp)))
 
           /* ..or untrusted */
 #ifdef FEATURE_TRUST
@@ -783,14 +852,14 @@ static void chat(struct client_state *csp)
           /* ..or a fast redirect kicked in */
 #ifdef FEATURE_FAST_REDIRECTS
           || (((csp->action->flags & ACTION_FAST_REDIRECTS) != 0) &&
-                    (NULL != (rsp = redirect_url(csp))))
+                (NULL != (rsp = redirect_url(csp))))
 #endif /* def FEATURE_FAST_REDIRECTS */
-                ))
-       )
+          ))
+      )
    {
       /* Write the answer to the client */
       if ((write_socket(csp->cfd, rsp->head, rsp->head_length) != rsp->head_length)
-            || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
+           || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
       {
          log_error(LOG_LEVEL_ERROR, "write to: %s failed: %E", http->host);
       }
@@ -832,24 +901,25 @@ static void chat(struct client_state *csp)
 
       if (errno == EINVAL)
       {
-          rsp = error_response(csp, "no-such-domain", errno);
+         rsp = error_response(csp, "no-such-domain", errno);
 
          log_error(LOG_LEVEL_CLF, "%s - - [%T] \"%s\" 404 0",
                    csp->ip_addr_str, http->cmd);
       }
       else
       {
-          rsp = error_response(csp, "connect-failed", errno);
+         rsp = error_response(csp, "connect-failed", errno);
 
          log_error(LOG_LEVEL_CLF, "%s - - [%T] \"%s\" 503 0",
                    csp->ip_addr_str, http->cmd);
       }
 
+
       /* Write the answer to the client */
       if(rsp)
-       {
+      {
          if ((write_socket(csp->cfd, rsp->head, rsp->head_length) != rsp->head_length)
-               || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
+          || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
          {
             log_error(LOG_LEVEL_ERROR, "write to: %s failed: %E", http->host);
          }
@@ -885,8 +955,8 @@ static void chat(struct client_state *csp)
 
          if(rsp)
          {
-            if ((write_socket(csp->cfd, rsp->head, n) != n)
-               || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
+            if ((write_socket(csp->cfd, rsp->head, rsp->head_length) != rsp->head_length)
+             || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
             {
                log_error(LOG_LEVEL_ERROR, "write to: %s failed: %E", http->host);
             }
@@ -986,11 +1056,11 @@ static void chat(struct client_state *csp)
             if(rsp)
             {
                if ((write_socket(csp->cfd, rsp->head, rsp->head_length) != rsp->head_length)
-                   || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
+                || (write_socket(csp->cfd, rsp->body, rsp->content_length) != rsp->content_length))
                {
                   log_error(LOG_LEVEL_ERROR, "write to: %s failed: %E", http->host);
-                          }
-                       }
+               }
+            }
 
             free_http_response(rsp);
             return;
@@ -1362,7 +1432,7 @@ int real_main(int argc, const char *argv[])
 int main(int argc, const char *argv[])
 #endif
 {
-   int         argc_pos = 1;
+   int argc_pos = 1;
 
    configfile =
 #ifdef AMIGA
@@ -1370,7 +1440,7 @@ int main(int argc, const char *argv[])
 #elif !defined(_WIN32)
    "config"
 #else
-   "junkbstr.txt"
+   "config.txt"
 #endif
       ;
 
@@ -1392,9 +1462,9 @@ int main(int argc, const char *argv[])
 #ifdef _DEBUG
    if ((argc >= 2) && (strcmp(argv[1], "-d")==0))
    {
-       ldebug++;
-       argc_pos++;
-       fprintf(stderr,"debugging enabled..\n");
+      ldebug++;
+      argc_pos++;
+      fprintf(stderr,"debugging enabled..\n");
    }
 #endif /* _DEBUG */
 #endif /* !defined(_WIN32) || defined(_WIN_CONSOLE) */
@@ -1408,29 +1478,30 @@ int main(int argc, const char *argv[])
    }
 
 #if defined(unix)
-       if ( *configfile != '/' )
-       {
-               char    *abs_file;
-
-               DBG(1, ("configfile before '%s'\n",configfile) );
-
-               /* make config-filename absolute here */        
-               if ( !(basedir = getcwd( NULL, 1024 )))
-               {
-                       perror("get working dir");
-               }
-               DBG(1, ("working dir '%s'\n",basedir) );
-               if ( !(abs_file = malloc( strlen( basedir ) + strlen( configfile ) + 5 )))
-               {
-                       perror("malloc failed");
-                       exit( 1 );
-               }
-               strcpy( abs_file, basedir );
-               strcat( abs_file, "/" );
-               strcat( abs_file, configfile );
-               configfile = abs_file;
-               DBG(1, ("configfile after '%s'\n",configfile) );
-       }
+   if ( *configfile != '/' )
+   {
+      char *abs_file;
+
+      DBG(1, ("configfile before '%s'\n",configfile) );
+
+      /* make config-filename absolute here */
+      if ( !(basedir = getcwd( NULL, 1024 )))
+      {
+         perror("get working dir failed");
+         exit( 1 );
+      }
+      DBG(1, ("working dir '%s'\n",basedir) );
+      if ( !(abs_file = malloc( strlen( basedir ) + strlen( configfile ) + 5 )))
+      {
+         perror("malloc failed");
+         exit( 1 );
+      }
+      strcpy( abs_file, basedir );
+      strcat( abs_file, "/" );
+      strcat( abs_file, configfile );
+      configfile = abs_file;
+      DBG(1, ("configfile after '%s'\n",configfile) );
+   }
 #endif /* defined unix */
 
 
@@ -1444,8 +1515,44 @@ int main(int argc, const char *argv[])
 
 
 #if !defined(_WIN32) && !defined(__OS2__)
-   signal(SIGPIPE, SIG_IGN);
-   signal(SIGCHLD, SIG_IGN);
+{
+   int sig;
+   struct sigaction action;
+
+   for ( sig = 1; sig < 16; sig++ )
+   {
+      switch( sig )
+      {
+         case 9:
+         case SIGPIPE:
+         case SIGCHLD:
+         case SIGHUP:
+                 continue;
+      }
+      if ( signal(sig, SIG_handler)  == SIG_ERR )
+         log_error(LOG_LEVEL_FATAL, "Can't set signal-handler for signal %d: %E", sig);
+   }
+   /* SIG_IGN */
+   if ( signal(SIGPIPE, SIG_IGN) == SIG_ERR )
+      log_error(LOG_LEVEL_FATAL, "Can't set SIG_IGN to SIGPIPE: %E");
+   if ( signal(SIGCHLD, SIG_IGN) == SIG_ERR )
+      log_error(LOG_LEVEL_FATAL, "Can't set SIG_IGN to SIGCHLD: %E");
+   /* log file reload */
+   if (!sigaction(SIGHUP,NULL,&action))
+   {
+      action.sa_handler = &SIG_handler;
+      action.sa_flags   = SA_RESTART;
+
+      if ( sigaction(SIGHUP,&action,NULL))
+         log_error(LOG_LEVEL_FATAL, "Can't set signal-handler for signal SIGHUP: %E");
+   } 
+   else
+   {
+      perror("sigaction");
+      log_error(LOG_LEVEL_FATAL, "Can't get sigaction data for signal SIGHUP");
+   }
+      
+}
 
 #else /* ifdef _WIN32 */
 # ifdef _WIN_CONSOLE
@@ -1463,46 +1570,74 @@ int main(int argc, const char *argv[])
 
 #if defined(unix)
 {
-       pid_t   pid = 0;
-       int     fd;
+   pid_t pid = 0;
+#if 0
+   int   fd;
+#endif
 
-       /*
-       ** we make us a real daemon
-       */
+   /*
+    * we make us a real daemon
+    */
 #ifdef _DEBUG
-       if ( !ldebug) 
+   if ( !ldebug)
 #endif
-               pid  = fork();
-       if ( pid < 0 )  /* error */
-       {
-               perror("fork");
-               exit( 3 );
-       } 
-       else if ( pid != 0 ) /* parent */
-       {
-               exit( 0 );
-       }
-       /* child */
-       setpgrp();
-       fd = open("/dev/tty", O_RDONLY);
-       if ( fd ) 
-       {
-               /* no error check here */
-               ioctl( fd, TIOCNOTTY,0 );
-               close ( fd );
-       }
-       /* should close stderr (fd 2) here too, but the test for existence
-       ** and load config file is done in listen_loop() and puts
-       ** some messages on stderr there.
-       */
+   pid  = fork();
+   if ( pid < 0 ) /* error */
+   {
+      perror("fork");
+      exit( 3 );
+   }
+   else if ( pid != 0 ) /* parent */
+   {
+      int status;
+      pid_t wpid;
+      /*
+       * must check for errors
+       * child died due to missing files aso
+       */
+      sleep( 1 );
+      wpid = waitpid( pid, &status, WNOHANG );
+      if ( wpid != 0 )
+      {
+         exit( 1 );
+      }
+      exit( 0 );
+   }
+   /* child */
+#if 1
+   /* Should be more portable, but not as well tested */
+   setsid();
+#else /* !1 */
+#ifdef __FreeBSD__
+   setpgrp(0,0);
+#else /* ndef __FreeBSD__ */
+   setpgrp();
+#endif /* ndef __FreeBSD__ */
+   fd = open("/dev/tty", O_RDONLY);
+   if ( fd )
+   {
+      /* no error check here */
+      ioctl( fd, TIOCNOTTY,0 );
+      close ( fd );
+   }
+#endif /* !1 */
+   /* should close stderr (fd 2) here too, but the test for existence
+   ** and load config file is done in listen_loop() and puts
+   ** some messages on stderr there.
+   */
 #ifdef _DEBUG
-       if ( !ldebug ) 
-               close( 0 ); close( 1 ); 
+   if ( !ldebug )
+   {
+      close( 0 );
+      close( 1 );
+   }
 #else
-       close( 0 ); close( 1 ); 
+   close( 0 );
+   close( 1 );
 #endif /* _DEBUG */
-       chdir("/");
+   chdir("/");
 
+   writePidFile();
 }
 #endif /* defined unix */
 
@@ -1553,7 +1688,6 @@ static void listen_loop(void)
 
    config->need_bind = 0;
 
-
    while (FOREVER)
    {
 #if !defined(FEATURE_PTHREAD) && !defined(_WIN32) && !defined(__BEOS__) && !defined(AMIGA) && !defined(__OS2__)