]> sjero.net Git - wget/blobdiff - src/http.c
[svn] Renamed xread/xwrite/xclose to fd_read/fd_write/fd_close. The "x" prefix is
[wget] / src / http.c
index 71006d122d74901da82daa0a9825454477cdcd4c..ea4ccf2477afe8ec832c52df39f19b8112a04659 100644 (file)
@@ -211,7 +211,7 @@ post_file (int sock, const char *file_name, long promised_size)
       if (length == 0)
        break;
       towrite = WMIN (promised_size - written, length);
-      write_error = xwrite (sock, chunk, towrite, -1);
+      write_error = fd_write (sock, chunk, towrite, -1);
       if (write_error < 0)
        {
          fclose (fp);
@@ -370,7 +370,7 @@ invalidate_persistent (void)
 {
   DEBUGP (("Disabling further reuse of socket %d.\n", pconn.socket));
   pconn_active = 0;
-  xclose (pconn.socket);
+  fd_close (pconn.socket);
   xfree (pconn.host);
   xzero (pconn);
 }
@@ -460,7 +460,7 @@ persistent_available_p (const char *host, int port, int ssl,
         resolves to, pconn.socket is for all intents and purposes
         already talking to HOST.  */
 
-      if (!socket_ip_address (pconn.socket, &ip, 0))
+      if (!socket_ip_address (pconn.socket, &ip, ENDPOINT_PEER))
        {
          /* Can't get the peer's address -- something must be very
             wrong with the connection.  */
@@ -474,7 +474,7 @@ persistent_available_p (const char *host, int port, int ssl,
          return 0;
        }
 
-      found = address_list_find (al, &ip);
+      found = address_list_contains (al, &ip);
       address_list_release (al);
 
       if (!found)
@@ -525,7 +525,7 @@ persistent_available_p (const char *host, int port, int ssl,
       if (pconn_active && (fd) == pconn.socket)        \
        invalidate_persistent ();               \
       else                                     \
-       xclose (fd);                            \
+       fd_close (fd);                          \
     }                                          \
 } while (0)
 
@@ -533,7 +533,7 @@ persistent_available_p (const char *host, int port, int ssl,
   if (pconn_active && (fd) == pconn.socket)    \
     invalidate_persistent ();                  \
   else                                         \
-    xclose (fd);                               \
+    fd_close (fd);                             \
 } while (0)
 \f
 struct http_stat
@@ -586,9 +586,7 @@ time_t http_atotm PARAMS ((const char *));
    will print it if there is enough information to do so (almost
    always), returning the error to the caller (i.e. http_loop).
 
-   Various HTTP parameters are stored to hs.  Although it parses the
-   response code correctly, it is not used in a sane way.  The caller
-   can do that, though.
+   Various HTTP parameters are stored to hs.
 
    If PROXY is non-NULL, the connection will be made to the proxy
    server, and u->url will be requested.  */
@@ -730,7 +728,7 @@ gethttp (struct url *u, struct http_stat *hs, int *dt, struct url *proxy)
             logputs (LOG_VERBOSE, "\n");
             logprintf (LOG_NOTQUIET,
                        _("Unable to establish SSL connection.\n"));
-            xclose (sock);
+            fd_close (sock);
             return CONSSLERR;
           }
         using_ssl = 1;
@@ -739,10 +737,8 @@ gethttp (struct url *u, struct http_stat *hs, int *dt, struct url *proxy)
     }
   else
     {
-      logprintf (LOG_VERBOSE, _("Reusing connection to %s:%hu.\n"),
-                conn->host, conn->port);
-      /* #### pc_last_fd should be accessed through an accessor
-         function.  */
+      logprintf (LOG_VERBOSE, _("Reusing existing connection to %s:%d.\n"),
+                pconn.host, pconn.port);
       sock = pconn.socket;
       using_ssl = pconn.ssl;
       DEBUGP (("Reusing fd %d.\n", sock));
@@ -965,14 +961,14 @@ Accept: %s\r\n\
   xfree (full_path);
 
   /* Send the request to server.  */
-  write_error = xwrite (sock, request, strlen (request), -1);
+  write_error = fd_write (sock, request, strlen (request), -1);
 
   if (write_error >= 0)
     {
       if (opt.post_data)
        {
          DEBUGP (("[POST data: %s]\n", opt.post_data));
-         write_error = xwrite (sock, opt.post_data, post_data_size, -1);
+         write_error = fd_write (sock, opt.post_data, post_data_size, -1);
        }
       else if (opt.post_file_name && post_data_size != 0)
        write_error = post_file (sock, opt.post_file_name, post_data_size);