X-Git-Url: http://www.privoxy.org/gitweb/?p=privoxy.git;a=blobdiff_plain;f=jbsockets.c;h=63548620e141bc89af57e8537df126b1218776a5;hp=19bd879f8be02e076c30fac367e280e8b3db180a;hb=3a6abc8e86f6788cce99cb5d402a7fd5d7d6fe25;hpb=1ef0d7f460d552b714536ca35758b4ff7f039ef5

diff --git a/jbsockets.c b/jbsockets.c
index 19bd879f..63548620 100644
--- a/jbsockets.c
+++ b/jbsockets.c
@@ -1,4 +1,4 @@
-const char jbsockets_rcs[] = "$Id: jbsockets.c,v 1.20 2001/11/16 00:48:48 jongfoster Exp $";
+const char jbsockets_rcs[] = "$Id: jbsockets.c,v 1.23 2002/03/05 00:36:01 jongfoster Exp $";
 /*********************************************************************
  *
  * File        :  $Source: /cvsroot/ijbswa/current/jbsockets.c,v $
@@ -35,6 +35,15 @@ const char jbsockets_rcs[] = "$Id: jbsockets.c,v 1.20 2001/11/16 00:48:48 jongfo
  *
  * Revisions   :
  *    $Log: jbsockets.c,v $
+ *    Revision 1.23  2002/03/05 00:36:01  jongfoster
+ *    Fixing bug 514988 - unable to restart JunkBuster
+ *
+ *    Revision 1.22  2002/03/04 02:08:02  david__schmidt
+ *    Enable web editing of actions file on OS/2 (it had been broken all this time!)
+ *
+ *    Revision 1.21  2002/01/09 14:32:33  oes
+ *    Added support for gethostbyname_r and gethostbyaddr_r.
+ *
  *    Revision 1.20  2001/11/16 00:48:48  jongfoster
  *    Enabling duplicate-socket detection for all platforms, not
  *    just Win32.
@@ -192,14 +201,14 @@ int connect_to(const char *host, int portnum, struct client_state *csp)
 
    memset((char *)&inaddr, 0, sizeof inaddr);
 
-   if ((addr = resolve_hostname_to_ip(host)) == -1)
+   if ((addr = resolve_hostname_to_ip(host)) == INADDR_NONE)
    {
       csp->http->host_ip_addr_str = strdup("unknown");
       return(-1);
    }
 
 #ifdef FEATURE_ACL
-   dst->addr = ntohl(addr);
+   dst->addr = ntohl((unsigned long) addr);
    dst->port = portnum;
 
    if (block_acl(dst, csp))
@@ -221,12 +230,12 @@ int connect_to(const char *host, int portnum, struct client_state *csp)
    if (sizeof(inaddr.sin_port) == sizeof(short))
 #endif /* ndef _WIN32 */
    {
-      inaddr.sin_port = htons((short)portnum);
+      inaddr.sin_port = htons((unsigned short) portnum);
    }
 #ifndef _WIN32
    else
    {
-      inaddr.sin_port = htonl(portnum);
+      inaddr.sin_port = htonl((unsigned long)portnum);
    }
 #endif /* ndef _WIN32 */
 
@@ -315,7 +324,7 @@ int connect_to(const char *host, int portnum, struct client_state *csp)
  *                indicated by len. Otherwise, returns (-1).
  *
  *********************************************************************/
-int write_socket(int fd, const char *buf, int len)
+size_t write_socket(int fd, const char *buf, size_t len)
 {
    if (len <= 0)
    {
@@ -324,10 +333,31 @@ int write_socket(int fd, const char *buf, int len)
 
    log_error(LOG_LEVEL_LOG, "%N", len, buf);
 
-#if defined(_WIN32) || defined(__BEOS__) || defined(AMIGA) || defined(__OS2__)
-   return( send(fd, buf, len, 0));
+#if defined(_WIN32) || defined(__BEOS__) || defined(AMIGA)
+   return(send(fd, buf, len, 0));
+#elif defined(__OS2__)
+   /*
+    * Break the data up into SOCKET_SEND_MAX chunks for sending...
+    * OS/2 seemed to complain when the chunks were too large.
+    */
+#define SOCKET_SEND_MAX 65000
+   {
+      int write_len = 0, send_len, send_rc = 0, i = 0;
+      while ((i < len) && (send_rc != -1))
+      {
+         if ((i + SOCKET_SEND_MAX) > len)
+            send_len = len - i;
+         else
+            send_len = SOCKET_SEND_MAX;
+         send_rc = send(fd,(char*)buf + i, send_len, 0);
+         if (send_rc == -1)
+            return(0);
+         i = i + send_len;
+   }
+   return len;
+   }
 #else
-   return( write(fd, buf, len));
+   return(write(fd, buf, len));
 #endif
 
 }
@@ -358,7 +388,7 @@ int write_socket(int fd, const char *buf, int len)
  *                any) changes.
  *
  *********************************************************************/
-int read_socket(int fd, char *buf, int len)
+size_t read_socket(int fd, char *buf, size_t len)
 {
    if (len <= 0)
    {
@@ -366,9 +396,9 @@ int read_socket(int fd, char *buf, int len)
    }
 
 #if defined(_WIN32) || defined(__BEOS__) || defined(AMIGA) || defined(__OS2__)
-   return( recv(fd, buf, len, 0));
+   return(recv(fd, buf, len, 0));
 #else
-   return( read(fd, buf, len));
+   return(read(fd, buf, len));
 #endif
 }
 
@@ -412,34 +442,39 @@ void close_socket(int fd)
  *          2  :  portnum = port to listen on
  *
  * Returns     :  if success, return file descriptor
- *                if failure, returns -2 if address is in use, otherwise -1
+ *                if failure, returns -3 if address is in use,
+ *                                    -2 if address unresolvable,
+ *                                    -1 otherwise
  *
  *********************************************************************/
 int bind_port(const char *hostnam, int portnum)
 {
    struct sockaddr_in inaddr;
    int fd;
-#if 0
 #ifndef _WIN32
    int one = 1;
 #endif /* ndef _WIN32 */
-#endif
 
    memset((char *)&inaddr, '\0', sizeof inaddr);
 
    inaddr.sin_family      = AF_INET;
    inaddr.sin_addr.s_addr = resolve_hostname_to_ip(hostnam);
 
+   if (inaddr.sin_addr.s_addr == INADDR_NONE)
+   {
+      return(-2);
+   }
+
 #ifndef _WIN32
    if (sizeof(inaddr.sin_port) == sizeof(short))
 #endif /* ndef _WIN32 */
    {
-      inaddr.sin_port = htons((short)portnum);
+      inaddr.sin_port = htons((unsigned short) portnum);
    }
 #ifndef _WIN32
    else
    {
-      inaddr.sin_port = htonl(portnum);
+      inaddr.sin_port = htonl((unsigned long) portnum);
    }
 #endif /* ndef _WIN32 */
 
@@ -450,17 +485,21 @@ int bind_port(const char *hostnam, int portnum)
       return(-1);
    }
 
-#if 0
 #ifndef _WIN32
    /*
-    * FIXME: This is not needed for Win32 - in fact, it stops
+    * This is not needed for Win32 - in fact, it stops
     * duplicate instances of JunkBuster from being caught.
-    * Is this really needed under UNIX, or should it be taked out?
-    * -- Jon
+    *
+    * On UNIX, we assume the user is sensible enough not
+    * to start JunkBuster multiple times on the same IP.
+    * Without this, stopping and restarting JunkBuster
+    * from a script fails.
+    * Note: SO_REUSEADDR is meant to only take over
+    * sockets which are *not* in listen state in Linux,
+    * e.g. sockets in TIME_WAIT. YMMV.
     */
    setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, (char *)&one, sizeof(one));
 #endif /* ndef _WIN32 */
-#endif
 
    if (bind (fd, (struct sockaddr *)&inaddr, sizeof(inaddr)) < 0)
    {
@@ -471,7 +510,7 @@ int bind_port(const char *hostnam, int portnum)
       if (errno == EADDRINUSE)
 #endif
       {
-         return(-2);
+         return(-3);
       }
       else
       {
@@ -512,7 +551,8 @@ int accept_connection(struct client_state * csp, int fd)
 {
    struct sockaddr_in client, server;
    struct hostent *host = NULL;
-   int afd, c_length, s_length;
+   int afd;
+   size_t c_length, s_length;
 #if defined(HAVE_GETHOSTBYADDR_R_8_ARGS) ||  defined(HAVE_GETHOSTBYADDR_R_7_ARGS) || defined(HAVE_GETHOSTBYADDR_R_5_ARGS)
    struct hostent result;
 #if defined(HAVE_GETHOSTBYADDR_R_5_ARGS)
@@ -595,10 +635,10 @@ int accept_connection(struct client_state * csp, int fd)
  * Parameters  :
  *          1  :  host = hostname to resolve
  *
- * Returns     :  -1 => failure, INADDR_ANY or tcp/ip address if succesful.
+ * Returns     :  INADDR_NONE => failure, INADDR_ANY or tcp/ip address if succesful.
  *
  *********************************************************************/
-int resolve_hostname_to_ip(const char *host)
+unsigned long resolve_hostname_to_ip(const char *host)
 {
    struct sockaddr_in inaddr;
    struct hostent *hostp;
@@ -642,7 +682,8 @@ int resolve_hostname_to_ip(const char *host)
       if (hostp == NULL)
       {
          errno = EINVAL;
-         return(-1);
+         log_error(LOG_LEVEL_ERROR, "could not resolve hostname %s", host);
+         return(INADDR_NONE);
       }
       if (hostp->h_addrtype != AF_INET)
       {
@@ -651,7 +692,8 @@ int resolve_hostname_to_ip(const char *host)
 #else
          errno = EPROTOTYPE;
 #endif 
-         return(-1);
+         log_error(LOG_LEVEL_ERROR, "hostname %s resolves to unknown address type.", host);
+         return(INADDR_NONE);
       }
       memcpy(
          (char *) &inaddr.sin_addr,