git.oblomov.eu Git - wine/blob - dlls/winhttp/net.c

   1 /*
   2  * Copyright 2008 Hans Leidekker for CodeWeavers
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Lesser General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2.1 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Lesser General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Lesser General Public
  15  * License along with this library; if not, write to the Free Software
  16  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  17  */
  18
  19 #include "config.h"
  20 #include "wine/port.h"
  21
  22 #include <stdarg.h>
  23 #include <stdio.h>
  24 #include <errno.h>
  25
  26 #include <sys/types.h>
  27 #ifdef HAVE_SYS_SOCKET_H
  28 # include <sys/socket.h>
  29 #endif
  30 #ifdef HAVE_SYS_IOCTL_H
  31 # include <sys/ioctl.h>
  32 #endif
  33 #ifdef HAVE_SYS_FILIO_H
  34 # include <sys/filio.h>
  35 #endif
  36 #ifdef HAVE_POLL_H
  37 # include <poll.h>
  38 #endif
  39 #ifdef HAVE_OPENSSL_SSL_H
  40 # include <openssl/ssl.h>
  41 #undef FAR
  42 #undef DSA
  43 #endif
  44
  45 #include "wine/debug.h"
  46 #include "wine/library.h"
  47
  48 #include "windef.h"
  49 #include "winbase.h"
  50 #include "winhttp.h"
  51 #include "wincrypt.h"
  52
  53 #include "winhttp_private.h"
  54
  55 /* to avoid conflicts with the Unix socket headers */
  56 #define USE_WS_PREFIX
  57 #include "winsock2.h"
  58
  59 WINE_DEFAULT_DEBUG_CHANNEL(winhttp);
  60
  61 #ifndef HAVE_GETADDRINFO
  62
  63 /* critical section to protect non-reentrant gethostbyname() */
  64 static CRITICAL_SECTION cs_gethostbyname;
  65 static CRITICAL_SECTION_DEBUG critsect_debug =
  66 {
  67     0, 0, &cs_gethostbyname,
  68     { &critsect_debug.ProcessLocksList, &critsect_debug.ProcessLocksList },
  69       0, 0, { (DWORD_PTR)(__FILE__ ": cs_gethostbyname") }
  70 };
  71 static CRITICAL_SECTION cs_gethostbyname = { &critsect_debug, -1, 0, 0, 0, 0 };
  72
  73 #endif
  74
  75 #ifdef SONAME_LIBSSL
  76
  77 #include <openssl/err.h>
  78
  79 static CRITICAL_SECTION init_ssl_cs;
  80 static CRITICAL_SECTION_DEBUG init_ssl_cs_debug =
  81 {
  82     0, 0, &init_ssl_cs,
  83     { &init_ssl_cs_debug.ProcessLocksList,
  84       &init_ssl_cs_debug.ProcessLocksList },
  85     0, 0, { (DWORD_PTR)(__FILE__ ": init_ssl_cs") }
  86 };
  87 static CRITICAL_SECTION init_ssl_cs = { &init_ssl_cs_debug, -1, 0, 0, 0, 0 };
  88
  89 static void *libssl_handle;
  90 static void *libcrypto_handle;
  91
  92 static SSL_METHOD *method;
  93 static SSL_CTX *ctx;
  94
  95 #define MAKE_FUNCPTR(f) static typeof(f) * p##f
  96
  97 MAKE_FUNCPTR( SSL_library_init );
  98 MAKE_FUNCPTR( SSL_load_error_strings );
  99 MAKE_FUNCPTR( SSLv23_method );
 100 MAKE_FUNCPTR( SSL_CTX_free );
 101 MAKE_FUNCPTR( SSL_CTX_new );
 102 MAKE_FUNCPTR( SSL_new );
 103 MAKE_FUNCPTR( SSL_free );
 104 MAKE_FUNCPTR( SSL_set_fd );
 105 MAKE_FUNCPTR( SSL_connect );
 106 MAKE_FUNCPTR( SSL_shutdown );
 107 MAKE_FUNCPTR( SSL_write );
 108 MAKE_FUNCPTR( SSL_read );
 109 MAKE_FUNCPTR( SSL_get_verify_result );
 110 MAKE_FUNCPTR( SSL_get_peer_certificate );
 111 MAKE_FUNCPTR( SSL_CTX_set_default_verify_paths );
 112
 113 MAKE_FUNCPTR( BIO_new_fp );
 114 MAKE_FUNCPTR( CRYPTO_num_locks );
 115 MAKE_FUNCPTR( CRYPTO_set_id_callback );
 116 MAKE_FUNCPTR( CRYPTO_set_locking_callback );
 117 MAKE_FUNCPTR( ERR_get_error );
 118 MAKE_FUNCPTR( ERR_error_string );
 119 MAKE_FUNCPTR( i2d_X509 );
 120 #undef MAKE_FUNCPTR
 121
 122 static CRITICAL_SECTION *ssl_locks;
 123 static unsigned int num_ssl_locks;
 124
 125 static unsigned long ssl_thread_id(void)
 126 {
 127     return GetCurrentThreadId();
 128 }
 129
 130 static void ssl_lock_callback(int mode, int type, const char *file, int line)
 131 {
 132     if (mode & CRYPTO_LOCK)
 133         EnterCriticalSection( &ssl_locks[type] );
 134     else
 135         LeaveCriticalSection( &ssl_locks[type] );
 136 }
 137
 138 #endif
 139
 140 /* translate a unix error code into a winsock error code */
 141 static int sock_get_error( int err )
 142 {
 143 #if !defined(__MINGW32__) && !defined (_MSC_VER)
 144     switch (err)
 145     {
 146         case EINTR:             return WSAEINTR;
 147         case EBADF:             return WSAEBADF;
 148         case EPERM:
 149         case EACCES:            return WSAEACCES;
 150         case EFAULT:            return WSAEFAULT;
 151         case EINVAL:            return WSAEINVAL;
 152         case EMFILE:            return WSAEMFILE;
 153         case EWOULDBLOCK:       return WSAEWOULDBLOCK;
 154         case EINPROGRESS:       return WSAEINPROGRESS;
 155         case EALREADY:          return WSAEALREADY;
 156         case ENOTSOCK:          return WSAENOTSOCK;
 157         case EDESTADDRREQ:      return WSAEDESTADDRREQ;
 158         case EMSGSIZE:          return WSAEMSGSIZE;
 159         case EPROTOTYPE:        return WSAEPROTOTYPE;
 160         case ENOPROTOOPT:       return WSAENOPROTOOPT;
 161         case EPROTONOSUPPORT:   return WSAEPROTONOSUPPORT;
 162         case ESOCKTNOSUPPORT:   return WSAESOCKTNOSUPPORT;
 163         case EOPNOTSUPP:        return WSAEOPNOTSUPP;
 164         case EPFNOSUPPORT:      return WSAEPFNOSUPPORT;
 165         case EAFNOSUPPORT:      return WSAEAFNOSUPPORT;
 166         case EADDRINUSE:        return WSAEADDRINUSE;
 167         case EADDRNOTAVAIL:     return WSAEADDRNOTAVAIL;
 168         case ENETDOWN:          return WSAENETDOWN;
 169         case ENETUNREACH:       return WSAENETUNREACH;
 170         case ENETRESET:         return WSAENETRESET;
 171         case ECONNABORTED:      return WSAECONNABORTED;
 172         case EPIPE:
 173         case ECONNRESET:        return WSAECONNRESET;
 174         case ENOBUFS:           return WSAENOBUFS;
 175         case EISCONN:           return WSAEISCONN;
 176         case ENOTCONN:          return WSAENOTCONN;
 177         case ESHUTDOWN:         return WSAESHUTDOWN;
 178         case ETOOMANYREFS:      return WSAETOOMANYREFS;
 179         case ETIMEDOUT:         return WSAETIMEDOUT;
 180         case ECONNREFUSED:      return WSAECONNREFUSED;
 181         case ELOOP:             return WSAELOOP;
 182         case ENAMETOOLONG:      return WSAENAMETOOLONG;
 183         case EHOSTDOWN:         return WSAEHOSTDOWN;
 184         case EHOSTUNREACH:      return WSAEHOSTUNREACH;
 185         case ENOTEMPTY:         return WSAENOTEMPTY;
 186 #ifdef EPROCLIM
 187         case EPROCLIM:          return WSAEPROCLIM;
 188 #endif
 189 #ifdef EUSERS
 190         case EUSERS:            return WSAEUSERS;
 191 #endif
 192 #ifdef EDQUOT
 193         case EDQUOT:            return WSAEDQUOT;
 194 #endif
 195 #ifdef ESTALE
 196         case ESTALE:            return WSAESTALE;
 197 #endif
 198 #ifdef EREMOTE
 199         case EREMOTE:           return WSAEREMOTE;
 200 #endif
 201     default: errno = err; perror( "sock_set_error" ); return WSAEFAULT;
 202     }
 203 #endif
 204     return err;
 205 }
 206
 207 BOOL netconn_init( netconn_t *conn, BOOL secure )
 208 {
 209 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
 210     int i;
 211 #endif
 212
 213     conn->socket = -1;
 214     if (!secure) return TRUE;
 215
 216 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
 217     EnterCriticalSection( &init_ssl_cs );
 218     if (libssl_handle)
 219     {
 220         LeaveCriticalSection( &init_ssl_cs );
 221         return TRUE;
 222     }
 223     if (!(libssl_handle = wine_dlopen( SONAME_LIBSSL, RTLD_NOW, NULL, 0 )))
 224     {
 225         ERR("Trying to use SSL but couldn't load %s. Expect trouble.\n", SONAME_LIBSSL);
 226         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 227         LeaveCriticalSection( &init_ssl_cs );
 228         return FALSE;
 229     }
 230     if (!(libcrypto_handle = wine_dlopen( SONAME_LIBCRYPTO, RTLD_NOW, NULL, 0 )))
 231     {
 232         ERR("Trying to use SSL but couldn't load %s. Expect trouble.\n", SONAME_LIBCRYPTO);
 233         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 234         LeaveCriticalSection( &init_ssl_cs );
 235         return FALSE;
 236     }
 237 #define LOAD_FUNCPTR(x) \
 238     if (!(p##x = wine_dlsym( libssl_handle, #x, NULL, 0 ))) \
 239     { \
 240         ERR("Failed to load symbol %s\n", #x); \
 241         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR ); \
 242         LeaveCriticalSection( &init_ssl_cs ); \
 243         return FALSE; \
 244     }
 245     LOAD_FUNCPTR( SSL_library_init );
 246     LOAD_FUNCPTR( SSL_load_error_strings );
 247     LOAD_FUNCPTR( SSLv23_method );
 248     LOAD_FUNCPTR( SSL_CTX_free );
 249     LOAD_FUNCPTR( SSL_CTX_new );
 250     LOAD_FUNCPTR( SSL_new );
 251     LOAD_FUNCPTR( SSL_free );
 252     LOAD_FUNCPTR( SSL_set_fd );
 253     LOAD_FUNCPTR( SSL_connect );
 254     LOAD_FUNCPTR( SSL_shutdown );
 255     LOAD_FUNCPTR( SSL_write );
 256     LOAD_FUNCPTR( SSL_read );
 257     LOAD_FUNCPTR( SSL_get_verify_result );
 258     LOAD_FUNCPTR( SSL_get_peer_certificate );
 259     LOAD_FUNCPTR( SSL_CTX_set_default_verify_paths );
 260 #undef LOAD_FUNCPTR
 261
 262 #define LOAD_FUNCPTR(x) \
 263     if (!(p##x = wine_dlsym( libcrypto_handle, #x, NULL, 0 ))) \
 264     { \
 265         ERR("Failed to load symbol %s\n", #x); \
 266         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR ); \
 267         LeaveCriticalSection( &init_ssl_cs ); \
 268         return FALSE; \
 269     }
 270     LOAD_FUNCPTR( BIO_new_fp );
 271     LOAD_FUNCPTR( CRYPTO_num_locks );
 272     LOAD_FUNCPTR( CRYPTO_set_id_callback );
 273     LOAD_FUNCPTR( CRYPTO_set_locking_callback );
 274     LOAD_FUNCPTR( ERR_get_error );
 275     LOAD_FUNCPTR( ERR_error_string );
 276     LOAD_FUNCPTR( i2d_X509 );
 277 #undef LOAD_FUNCPTR
 278
 279     pSSL_library_init();
 280     pSSL_load_error_strings();
 281     pBIO_new_fp( stderr, BIO_NOCLOSE );
 282
 283     method = pSSLv23_method();
 284     ctx = pSSL_CTX_new( method );
 285     if (!pSSL_CTX_set_default_verify_paths( ctx ))
 286     {
 287         ERR("SSL_CTX_set_default_verify_paths failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 288         set_last_error( ERROR_OUTOFMEMORY );
 289         LeaveCriticalSection( &init_ssl_cs );
 290         return FALSE;
 291     }
 292
 293     pCRYPTO_set_id_callback(ssl_thread_id);
 294     num_ssl_locks = pCRYPTO_num_locks();
 295     ssl_locks = HeapAlloc(GetProcessHeap(), 0, num_ssl_locks * sizeof(CRITICAL_SECTION));
 296     if (!ssl_locks)
 297     {
 298         set_last_error( ERROR_OUTOFMEMORY );
 299         LeaveCriticalSection( &init_ssl_cs );
 300         return FALSE;
 301     }
 302     for (i = 0; i < num_ssl_locks; i++) InitializeCriticalSection( &ssl_locks[i] );
 303     pCRYPTO_set_locking_callback(ssl_lock_callback);
 304
 305     LeaveCriticalSection( &init_ssl_cs );
 306 #else
 307     WARN("SSL support not compiled in.\n");
 308     set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 309     return FALSE;
 310 #endif
 311     return TRUE;
 312 }
 313
 314 void netconn_unload( void )
 315 {
 316 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
 317     if (libcrypto_handle)
 318     {
 319         wine_dlclose( libcrypto_handle, NULL, 0 );
 320     }
 321     if (libssl_handle)
 322     {
 323         if (ctx)
 324             pSSL_CTX_free( ctx );
 325         wine_dlclose( libssl_handle, NULL, 0 );
 326     }
 327     if (ssl_locks)
 328     {
 329         int i;
 330         for (i = 0; i < num_ssl_locks; i++) DeleteCriticalSection( &ssl_locks[i] );
 331         HeapFree( GetProcessHeap(), 0, ssl_locks );
 332     }
 333 #endif
 334 }
 335
 336 BOOL netconn_connected( netconn_t *conn )
 337 {
 338     return (conn->socket != -1);
 339 }
 340
 341 BOOL netconn_create( netconn_t *conn, int domain, int type, int protocol )
 342 {
 343     if ((conn->socket = socket( domain, type, protocol )) == -1)
 344     {
 345         WARN("unable to create socket (%s)\n", strerror(errno));
 346         set_last_error( sock_get_error( errno ) );
 347         return FALSE;
 348     }
 349     return TRUE;
 350 }
 351
 352 BOOL netconn_close( netconn_t *conn )
 353 {
 354     int res;
 355
 356 #ifdef SONAME_LIBSSL
 357     if (conn->secure)
 358     {
 359         heap_free( conn->peek_msg_mem );
 360         conn->peek_msg_mem = NULL;
 361         conn->peek_msg = NULL;
 362         conn->peek_len = 0;
 363
 364         pSSL_shutdown( conn->ssl_conn );
 365         pSSL_free( conn->ssl_conn );
 366
 367         conn->ssl_conn = NULL;
 368         conn->secure = FALSE;
 369     }
 370 #endif
 371     res = closesocket( conn->socket );
 372     conn->socket = -1;
 373     if (res == -1)
 374     {
 375         set_last_error( sock_get_error( errno ) );
 376         return FALSE;
 377     }
 378     return TRUE;
 379 }
 380
 381 BOOL netconn_connect( netconn_t *conn, const struct sockaddr *sockaddr, unsigned int addr_len, int timeout )
 382 {
 383     BOOL ret = FALSE;
 384     int res = 0, state;
 385
 386     if (timeout > 0)
 387     {
 388         state = 1;
 389         ioctlsocket( conn->socket, FIONBIO, &state );
 390     }
 391     if (connect( conn->socket, sockaddr, addr_len ) < 0)
 392     {
 393         res = sock_get_error( errno );
 394         if (res == WSAEWOULDBLOCK || res == WSAEINPROGRESS)
 395         {
 396             struct pollfd pfd;
 397
 398             pfd.fd = conn->socket;
 399             pfd.events = POLLOUT;
 400             if (poll( &pfd, 1, timeout ) > 0)
 401                 ret = TRUE;
 402             else
 403                 res = sock_get_error( errno );
 404         }
 405     }
 406     else
 407         ret = TRUE;
 408     if (timeout > 0)
 409     {
 410         state = 0;
 411         ioctlsocket( conn->socket, FIONBIO, &state );
 412     }
 413     if (!ret)
 414     {
 415         WARN("unable to connect to host (%d)\n", res);
 416         set_last_error( res );
 417     }
 418     return ret;
 419 }
 420
 421 BOOL netconn_secure_connect( netconn_t *conn )
 422 {
 423 #ifdef SONAME_LIBSSL
 424     X509 *cert;
 425     long res;
 426
 427     if (!(conn->ssl_conn = pSSL_new( ctx )))
 428     {
 429         ERR("SSL_new failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 430         set_last_error( ERROR_OUTOFMEMORY );
 431         goto fail;
 432     }
 433     if (!pSSL_set_fd( conn->ssl_conn, conn->socket ))
 434     {
 435         ERR("SSL_set_fd failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 436         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 437         goto fail;
 438     }
 439     if (pSSL_connect( conn->ssl_conn ) <= 0)
 440     {
 441         ERR("SSL_connect failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 442         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 443         goto fail;
 444     }
 445     if (!(cert = pSSL_get_peer_certificate( conn->ssl_conn )))
 446     {
 447         ERR("No certificate for server: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 448         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 449         goto fail;
 450     }
 451     if ((res = pSSL_get_verify_result( conn->ssl_conn )) != X509_V_OK)
 452     {
 453         /* FIXME: we should set an error and return, but we only print an error at the moment */
 454         ERR("couldn't verify server certificate (%ld)\n", res);
 455     }
 456     TRACE("established SSL connection\n");
 457     conn->secure = TRUE;
 458     return TRUE;
 459
 460 fail:
 461     if (conn->ssl_conn)
 462     {
 463         pSSL_shutdown( conn->ssl_conn );
 464         pSSL_free( conn->ssl_conn );
 465         conn->ssl_conn = NULL;
 466     }
 467 #endif
 468     return FALSE;
 469 }
 470
 471 BOOL netconn_send( netconn_t *conn, const void *msg, size_t len, int flags, int *sent )
 472 {
 473     if (!netconn_connected( conn )) return FALSE;
 474     if (conn->secure)
 475     {
 476 #ifdef SONAME_LIBSSL
 477         if (flags) FIXME("SSL_write doesn't support any flags (%08x)\n", flags);
 478         *sent = pSSL_write( conn->ssl_conn, msg, len );
 479         if (*sent < 1 && len) return FALSE;
 480         return TRUE;
 481 #else
 482         return FALSE;
 483 #endif
 484     }
 485     if ((*sent = send( conn->socket, msg, len, flags )) == -1)
 486     {
 487         set_last_error( sock_get_error( errno ) );
 488         return FALSE;
 489     }
 490     return TRUE;
 491 }
 492
 493 BOOL netconn_recv( netconn_t *conn, void *buf, size_t len, int flags, int *recvd )
 494 {
 495     *recvd = 0;
 496     if (!netconn_connected( conn )) return FALSE;
 497     if (!len) return TRUE;
 498
 499     if (conn->secure)
 500     {
 501 #ifdef SONAME_LIBSSL
 502         if (flags & ~(MSG_PEEK | MSG_WAITALL))
 503             FIXME("SSL_read does not support the following flags: %08x\n", flags);
 504
 505         /* this ugly hack is all for MSG_PEEK */
 506         if (flags & MSG_PEEK && !conn->peek_msg)
 507         {
 508             if (!(conn->peek_msg = conn->peek_msg_mem = heap_alloc( len + 1 ))) return FALSE;
 509         }
 510         else if (flags & MSG_PEEK && conn->peek_msg)
 511         {
 512             if (len < conn->peek_len) FIXME("buffer isn't big enough, should we wrap?\n");
 513             *recvd = min( len, conn->peek_len );
 514             memcpy( buf, conn->peek_msg, *recvd );
 515             return TRUE;
 516         }
 517         else if (conn->peek_msg)
 518         {
 519             *recvd = min( len, conn->peek_len );
 520             memcpy( buf, conn->peek_msg, *recvd );
 521             conn->peek_len -= *recvd;
 522             conn->peek_msg += *recvd;
 523
 524             if (conn->peek_len == 0)
 525             {
 526                 heap_free( conn->peek_msg_mem );
 527                 conn->peek_msg_mem = NULL;
 528                 conn->peek_msg = NULL;
 529             }
 530             /* check if we have enough data from the peek buffer */
 531             if (!(flags & MSG_WAITALL) || (*recvd == len)) return TRUE;
 532         }
 533         *recvd += pSSL_read( conn->ssl_conn, (char *)buf + *recvd, len - *recvd );
 534         if (flags & MSG_PEEK) /* must copy into buffer */
 535         {
 536             conn->peek_len = *recvd;
 537             if (!*recvd)
 538             {
 539                 heap_free( conn->peek_msg_mem );
 540                 conn->peek_msg_mem = NULL;
 541                 conn->peek_msg = NULL;
 542             }
 543             else memcpy( conn->peek_msg, buf, *recvd );
 544         }
 545         if (*recvd < 1 && len) return FALSE;
 546         return TRUE;
 547 #else
 548         return FALSE;
 549 #endif
 550     }
 551     if ((*recvd = recv( conn->socket, buf, len, flags )) == -1)
 552     {
 553         set_last_error( sock_get_error( errno ) );
 554         return FALSE;
 555     }
 556     return TRUE;
 557 }
 558
 559 BOOL netconn_query_data_available( netconn_t *conn, DWORD *available )
 560 {
 561 #ifdef FIONREAD
 562     int ret, unread;
 563 #endif
 564     *available = 0;
 565     if (!netconn_connected( conn )) return FALSE;
 566
 567     if (conn->secure)
 568     {
 569 #ifdef SONAME_LIBSSL
 570         if (conn->peek_msg) *available = conn->peek_len;
 571 #endif
 572         return TRUE;
 573     }
 574 #ifdef FIONREAD
 575     if (!(ret = ioctlsocket( conn->socket, FIONREAD, &unread ))) *available = unread;
 576 #endif
 577     return TRUE;
 578 }
 579
 580 BOOL netconn_get_next_line( netconn_t *conn, char *buffer, DWORD *buflen )
 581 {
 582     struct pollfd pfd;
 583     BOOL ret = FALSE;
 584     DWORD recvd = 0;
 585
 586     if (!netconn_connected( conn )) return FALSE;
 587
 588     if (conn->secure)
 589     {
 590 #ifdef SONAME_LIBSSL
 591         while (recvd < *buflen)
 592         {
 593             int dummy;
 594             if (!netconn_recv( conn, &buffer[recvd], 1, 0, &dummy ))
 595             {
 596                 set_last_error( ERROR_CONNECTION_ABORTED );
 597                 break;
 598             }
 599             if (buffer[recvd] == '\n')
 600             {
 601                 ret = TRUE;
 602                 break;
 603             }
 604             if (buffer[recvd] != '\r') recvd++;
 605         }
 606         if (ret)
 607         {
 608             buffer[recvd++] = 0;
 609             *buflen = recvd;
 610             TRACE("received line %s\n", debugstr_a(buffer));
 611         }
 612         return ret;
 613 #else
 614         return FALSE;
 615 #endif
 616     }
 617
 618     pfd.fd = conn->socket;
 619     pfd.events = POLLIN;
 620     while (recvd < *buflen)
 621     {
 622         int timeout, res;
 623         struct timeval tv;
 624         socklen_t len = sizeof(tv);
 625
 626         if ((res = getsockopt( conn->socket, SOL_SOCKET, SO_RCVTIMEO, (void*)&tv, &len ) != -1))
 627             timeout = tv.tv_sec * 1000 + tv.tv_usec / 1000;
 628         else
 629             timeout = -1;
 630         if (poll( &pfd, 1, timeout ) > 0)
 631         {
 632             if ((res = recv( conn->socket, &buffer[recvd], 1, 0 )) <= 0)
 633             {
 634                 if (res == -1) set_last_error( sock_get_error( errno ) );
 635                 break;
 636             }
 637             if (buffer[recvd] == '\n')
 638             {
 639                 ret = TRUE;
 640                 break;
 641             }
 642             if (buffer[recvd] != '\r') recvd++;
 643         }
 644         else
 645         {
 646             set_last_error( ERROR_WINHTTP_TIMEOUT );
 647             break;
 648         }
 649     }
 650     if (ret)
 651     {
 652         buffer[recvd++] = 0;
 653         *buflen = recvd;
 654         TRACE("received line %s\n", debugstr_a(buffer));
 655     }
 656     return ret;
 657 }
 658
 659 DWORD netconn_set_timeout( netconn_t *netconn, BOOL send, int value )
 660 {
 661     int res;
 662     struct timeval tv;
 663
 664     /* value is in milliseconds, convert to struct timeval */
 665     tv.tv_sec = value / 1000;
 666     tv.tv_usec = (value % 1000) * 1000;
 667
 668     if ((res = setsockopt( netconn->socket, SOL_SOCKET, send ? SO_SNDTIMEO : SO_RCVTIMEO, (void*)&tv, sizeof(tv) ) == -1))
 669     {
 670         WARN("setsockopt failed (%s)\n", strerror( errno ));
 671         return sock_get_error( errno );
 672     }
 673     return ERROR_SUCCESS;
 674 }
 675
 676 BOOL netconn_resolve( WCHAR *hostnameW, INTERNET_PORT port, struct sockaddr *sa, socklen_t *sa_len )
 677 {
 678     char *hostname;
 679 #ifdef HAVE_GETADDRINFO
 680     struct addrinfo *res, hints;
 681     int ret;
 682 #else
 683     struct hostent *he;
 684     struct sockaddr_in *sin = (struct sockaddr_in *)sa;
 685 #endif
 686
 687     if (!(hostname = strdupWA( hostnameW ))) return FALSE;
 688
 689 #ifdef HAVE_GETADDRINFO
 690     memset( &hints, 0, sizeof(struct addrinfo) );
 691     /* Prefer IPv4 to IPv6 addresses, since some web servers do not listen on
 692      * their IPv6 addresses even though they have IPv6 addresses in the DNS.
 693      */
 694     hints.ai_family = AF_INET;
 695
 696     ret = getaddrinfo( hostname, NULL, &hints, &res );
 697     if (ret != 0)
 698     {
 699         TRACE("failed to get IPv4 address of %s (%s), retrying with IPv6\n", debugstr_w(hostnameW), gai_strerror(ret));
 700         hints.ai_family = AF_INET6;
 701         ret = getaddrinfo( hostname, NULL, &hints, &res );
 702         if (ret != 0)
 703         {
 704             TRACE("failed to get address of %s (%s)\n", debugstr_w(hostnameW), gai_strerror(ret));
 705             heap_free( hostname );
 706             return FALSE;
 707         }
 708     }
 709     heap_free( hostname );
 710     if (*sa_len < res->ai_addrlen)
 711     {
 712         WARN("address too small\n");
 713         freeaddrinfo( res );
 714         return FALSE;
 715     }
 716     *sa_len = res->ai_addrlen;
 717     memcpy( sa, res->ai_addr, res->ai_addrlen );
 718     /* Copy port */
 719     switch (res->ai_family)
 720     {
 721     case AF_INET:
 722         ((struct sockaddr_in *)sa)->sin_port = htons( port );
 723         break;
 724     case AF_INET6:
 725         ((struct sockaddr_in6 *)sa)->sin6_port = htons( port );
 726         break;
 727     }
 728
 729     freeaddrinfo( res );
 730     return TRUE;
 731 #else
 732     EnterCriticalSection( &cs_gethostbyname );
 733
 734     he = gethostbyname( hostname );
 735     heap_free( hostname );
 736     if (!he)
 737     {
 738         TRACE("failed to get address of %s (%d)\n", debugstr_w(hostnameW), h_errno);
 739         LeaveCriticalSection( &cs_gethostbyname );
 740         return FALSE;
 741     }
 742     if (*sa_len < sizeof(struct sockaddr_in))
 743     {
 744         WARN("address too small\n");
 745         LeaveCriticalSection( &cs_gethostbyname );
 746         return FALSE;
 747     }
 748     *sa_len = sizeof(struct sockaddr_in);
 749     memset( sa, 0, sizeof(struct sockaddr_in) );
 750     memcpy( &sin->sin_addr, he->h_addr, he->h_length );
 751     sin->sin_family = he->h_addrtype;
 752     sin->sin_port = htons( port );
 753
 754     LeaveCriticalSection( &cs_gethostbyname );
 755     return TRUE;
 756 #endif
 757 }
 758
 759 const void *netconn_get_certificate( netconn_t *conn )
 760 {
 761 #ifdef SONAME_LIBSSL
 762     X509 *cert;
 763     unsigned char *buffer, *p;
 764     int len;
 765     BOOL malloc = FALSE;
 766     const CERT_CONTEXT *ret;
 767
 768     if (!conn->secure) return NULL;
 769
 770     if (!(cert = pSSL_get_peer_certificate( conn->ssl_conn ))) return NULL;
 771     p = NULL;
 772     if ((len = pi2d_X509( cert, &p )) < 0) return NULL;
 773     /*
 774      * SSL 0.9.7 and above malloc the buffer if it is null.
 775      * however earlier version do not and so we would need to alloc the buffer.
 776      *
 777      * see the i2d_X509 man page for more details.
 778      */
 779     if (!p)
 780     {
 781         if (!(buffer = heap_alloc( len ))) return NULL;
 782         p = buffer;
 783         len = pi2d_X509( cert, &p );
 784     }
 785     else
 786     {
 787         buffer = p;
 788         malloc = TRUE;
 789     }
 790
 791     ret = CertCreateCertificateContext( X509_ASN_ENCODING, buffer, len );
 792
 793     if (malloc) free( buffer );
 794     else heap_free( buffer );
 795
 796     return ret;
 797 #else
 798     return NULL;
 799 #endif
 800 }