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 # include <openssl/opensslv.h>
  42 #undef FAR
  43 #undef DSA
  44 #endif
  45
  46 #define NONAMELESSUNION
  47
  48 #include "wine/debug.h"
  49 #include "wine/library.h"
  50
  51 #include "windef.h"
  52 #include "winbase.h"
  53 #include "winhttp.h"
  54 #include "wincrypt.h"
  55
  56 #include "winhttp_private.h"
  57
  58 /* to avoid conflicts with the Unix socket headers */
  59 #define USE_WS_PREFIX
  60 #include "winsock2.h"
  61
  62 WINE_DEFAULT_DEBUG_CHANNEL(winhttp);
  63
  64 #ifndef HAVE_GETADDRINFO
  65
  66 /* critical section to protect non-reentrant gethostbyname() */
  67 static CRITICAL_SECTION cs_gethostbyname;
  68 static CRITICAL_SECTION_DEBUG critsect_debug =
  69 {
  70     0, 0, &cs_gethostbyname,
  71     { &critsect_debug.ProcessLocksList, &critsect_debug.ProcessLocksList },
  72       0, 0, { (DWORD_PTR)(__FILE__ ": cs_gethostbyname") }
  73 };
  74 static CRITICAL_SECTION cs_gethostbyname = { &critsect_debug, -1, 0, 0, 0, 0 };
  75
  76 #endif
  77
  78 #ifdef SONAME_LIBSSL
  79
  80 #include <openssl/err.h>
  81
  82 static CRITICAL_SECTION init_ssl_cs;
  83 static CRITICAL_SECTION_DEBUG init_ssl_cs_debug =
  84 {
  85     0, 0, &init_ssl_cs,
  86     { &init_ssl_cs_debug.ProcessLocksList,
  87       &init_ssl_cs_debug.ProcessLocksList },
  88     0, 0, { (DWORD_PTR)(__FILE__ ": init_ssl_cs") }
  89 };
  90 static CRITICAL_SECTION init_ssl_cs = { &init_ssl_cs_debug, -1, 0, 0, 0, 0 };
  91
  92 static void *libssl_handle;
  93 static void *libcrypto_handle;
  94
  95 #if defined(OPENSSL_VERSION_NUMBER) && (OPENSSL_VERSION_NUMBER > 0x10000000)
  96 static const SSL_METHOD *method;
  97 #else
  98 static SSL_METHOD *method;
  99 #endif
 100 static SSL_CTX *ctx;
 101 static int hostname_idx;
 102 static int error_idx;
 103 static int conn_idx;
 104
 105 #define MAKE_FUNCPTR(f) static typeof(f) * p##f
 106
 107 MAKE_FUNCPTR( SSL_library_init );
 108 MAKE_FUNCPTR( SSL_load_error_strings );
 109 MAKE_FUNCPTR( SSLv23_method );
 110 MAKE_FUNCPTR( SSL_CTX_free );
 111 MAKE_FUNCPTR( SSL_CTX_new );
 112 MAKE_FUNCPTR( SSL_new );
 113 MAKE_FUNCPTR( SSL_free );
 114 MAKE_FUNCPTR( SSL_set_fd );
 115 MAKE_FUNCPTR( SSL_connect );
 116 MAKE_FUNCPTR( SSL_shutdown );
 117 MAKE_FUNCPTR( SSL_write );
 118 MAKE_FUNCPTR( SSL_read );
 119 MAKE_FUNCPTR( SSL_get_error );
 120 MAKE_FUNCPTR( SSL_get_ex_new_index );
 121 MAKE_FUNCPTR( SSL_get_ex_data );
 122 MAKE_FUNCPTR( SSL_set_ex_data );
 123 MAKE_FUNCPTR( SSL_get_ex_data_X509_STORE_CTX_idx );
 124 MAKE_FUNCPTR( SSL_get_peer_certificate );
 125 MAKE_FUNCPTR( SSL_CTX_set_default_verify_paths );
 126 MAKE_FUNCPTR( SSL_CTX_set_verify );
 127 MAKE_FUNCPTR( SSL_get_current_cipher );
 128 MAKE_FUNCPTR( SSL_CIPHER_get_bits );
 129
 130 MAKE_FUNCPTR( CRYPTO_num_locks );
 131 MAKE_FUNCPTR( CRYPTO_set_id_callback );
 132 MAKE_FUNCPTR( CRYPTO_set_locking_callback );
 133 MAKE_FUNCPTR( ERR_free_strings );
 134 MAKE_FUNCPTR( ERR_get_error );
 135 MAKE_FUNCPTR( ERR_error_string );
 136 MAKE_FUNCPTR( X509_STORE_CTX_get_ex_data );
 137 MAKE_FUNCPTR( X509_STORE_CTX_get_chain );
 138 MAKE_FUNCPTR( i2d_X509 );
 139 MAKE_FUNCPTR( sk_value );
 140 MAKE_FUNCPTR( sk_num );
 141 #undef MAKE_FUNCPTR
 142
 143 static CRITICAL_SECTION *ssl_locks;
 144 static unsigned int num_ssl_locks;
 145
 146 static unsigned long ssl_thread_id(void)
 147 {
 148     return GetCurrentThreadId();
 149 }
 150
 151 static void ssl_lock_callback(int mode, int type, const char *file, int line)
 152 {
 153     if (mode & CRYPTO_LOCK)
 154         EnterCriticalSection( &ssl_locks[type] );
 155     else
 156         LeaveCriticalSection( &ssl_locks[type] );
 157 }
 158
 159 #endif
 160
 161 /* translate a unix error code into a winsock error code */
 162 static int sock_get_error( int err )
 163 {
 164 #if !defined(__MINGW32__) && !defined (_MSC_VER)
 165     switch (err)
 166     {
 167         case EINTR:             return WSAEINTR;
 168         case EBADF:             return WSAEBADF;
 169         case EPERM:
 170         case EACCES:            return WSAEACCES;
 171         case EFAULT:            return WSAEFAULT;
 172         case EINVAL:            return WSAEINVAL;
 173         case EMFILE:            return WSAEMFILE;
 174         case EWOULDBLOCK:       return WSAEWOULDBLOCK;
 175         case EINPROGRESS:       return WSAEINPROGRESS;
 176         case EALREADY:          return WSAEALREADY;
 177         case ENOTSOCK:          return WSAENOTSOCK;
 178         case EDESTADDRREQ:      return WSAEDESTADDRREQ;
 179         case EMSGSIZE:          return WSAEMSGSIZE;
 180         case EPROTOTYPE:        return WSAEPROTOTYPE;
 181         case ENOPROTOOPT:       return WSAENOPROTOOPT;
 182         case EPROTONOSUPPORT:   return WSAEPROTONOSUPPORT;
 183         case ESOCKTNOSUPPORT:   return WSAESOCKTNOSUPPORT;
 184         case EOPNOTSUPP:        return WSAEOPNOTSUPP;
 185         case EPFNOSUPPORT:      return WSAEPFNOSUPPORT;
 186         case EAFNOSUPPORT:      return WSAEAFNOSUPPORT;
 187         case EADDRINUSE:        return WSAEADDRINUSE;
 188         case EADDRNOTAVAIL:     return WSAEADDRNOTAVAIL;
 189         case ENETDOWN:          return WSAENETDOWN;
 190         case ENETUNREACH:       return WSAENETUNREACH;
 191         case ENETRESET:         return WSAENETRESET;
 192         case ECONNABORTED:      return WSAECONNABORTED;
 193         case EPIPE:
 194         case ECONNRESET:        return WSAECONNRESET;
 195         case ENOBUFS:           return WSAENOBUFS;
 196         case EISCONN:           return WSAEISCONN;
 197         case ENOTCONN:          return WSAENOTCONN;
 198         case ESHUTDOWN:         return WSAESHUTDOWN;
 199         case ETOOMANYREFS:      return WSAETOOMANYREFS;
 200         case ETIMEDOUT:         return WSAETIMEDOUT;
 201         case ECONNREFUSED:      return WSAECONNREFUSED;
 202         case ELOOP:             return WSAELOOP;
 203         case ENAMETOOLONG:      return WSAENAMETOOLONG;
 204         case EHOSTDOWN:         return WSAEHOSTDOWN;
 205         case EHOSTUNREACH:      return WSAEHOSTUNREACH;
 206         case ENOTEMPTY:         return WSAENOTEMPTY;
 207 #ifdef EPROCLIM
 208         case EPROCLIM:          return WSAEPROCLIM;
 209 #endif
 210 #ifdef EUSERS
 211         case EUSERS:            return WSAEUSERS;
 212 #endif
 213 #ifdef EDQUOT
 214         case EDQUOT:            return WSAEDQUOT;
 215 #endif
 216 #ifdef ESTALE
 217         case ESTALE:            return WSAESTALE;
 218 #endif
 219 #ifdef EREMOTE
 220         case EREMOTE:           return WSAEREMOTE;
 221 #endif
 222     default: errno = err; perror( "sock_set_error" ); return WSAEFAULT;
 223     }
 224 #endif
 225     return err;
 226 }
 227
 228 #ifdef SONAME_LIBSSL
 229 static PCCERT_CONTEXT X509_to_cert_context(X509 *cert)
 230 {
 231     unsigned char *buffer, *p;
 232     int len;
 233     BOOL malloc = FALSE;
 234     PCCERT_CONTEXT ret;
 235
 236     p = NULL;
 237     if ((len = pi2d_X509( cert, &p )) < 0) return NULL;
 238     /*
 239      * SSL 0.9.7 and above malloc the buffer if it is null.
 240      * however earlier version do not and so we would need to alloc the buffer.
 241      *
 242      * see the i2d_X509 man page for more details.
 243      */
 244     if (!p)
 245     {
 246         if (!(buffer = heap_alloc( len ))) return NULL;
 247         p = buffer;
 248         len = pi2d_X509( cert, &p );
 249     }
 250     else
 251     {
 252         buffer = p;
 253         malloc = TRUE;
 254     }
 255
 256     ret = CertCreateCertificateContext( X509_ASN_ENCODING, buffer, len );
 257
 258     if (malloc) free( buffer );
 259     else heap_free( buffer );
 260
 261     return ret;
 262 }
 263
 264 static DWORD netconn_verify_cert( PCCERT_CONTEXT cert, HCERTSTORE store,
 265                                   WCHAR *server, DWORD security_flags )
 266 {
 267     BOOL ret;
 268     CERT_CHAIN_PARA chainPara = { sizeof(chainPara), { 0 } };
 269     PCCERT_CHAIN_CONTEXT chain;
 270     char oid_server_auth[] = szOID_PKIX_KP_SERVER_AUTH;
 271     char *server_auth[] = { oid_server_auth };
 272     DWORD err = ERROR_SUCCESS;
 273
 274     TRACE("verifying %s\n", debugstr_w( server ));
 275     chainPara.RequestedUsage.Usage.cUsageIdentifier = 1;
 276     chainPara.RequestedUsage.Usage.rgpszUsageIdentifier = server_auth;
 277     if ((ret = CertGetCertificateChain( NULL, cert, NULL, store, &chainPara,
 278                                         CERT_CHAIN_REVOCATION_CHECK_CHAIN_EXCLUDE_ROOT,
 279                                         NULL, &chain )))
 280     {
 281         if (chain->TrustStatus.dwErrorStatus)
 282         {
 283             static const DWORD supportedErrors =
 284                 CERT_TRUST_IS_NOT_TIME_VALID |
 285                 CERT_TRUST_IS_UNTRUSTED_ROOT |
 286                 CERT_TRUST_IS_NOT_VALID_FOR_USAGE;
 287
 288             if (chain->TrustStatus.dwErrorStatus & CERT_TRUST_IS_NOT_TIME_VALID)
 289             {
 290                 if (!(security_flags & SECURITY_FLAG_IGNORE_CERT_DATE_INVALID))
 291                     err = ERROR_WINHTTP_SECURE_CERT_DATE_INVALID;
 292             }
 293             else if (chain->TrustStatus.dwErrorStatus &
 294                      CERT_TRUST_IS_UNTRUSTED_ROOT)
 295             {
 296                 if (!(security_flags & SECURITY_FLAG_IGNORE_UNKNOWN_CA))
 297                     err = ERROR_WINHTTP_SECURE_INVALID_CA;
 298             }
 299             else if ((chain->TrustStatus.dwErrorStatus &
 300                       CERT_TRUST_IS_OFFLINE_REVOCATION) ||
 301                      (chain->TrustStatus.dwErrorStatus &
 302                       CERT_TRUST_REVOCATION_STATUS_UNKNOWN))
 303                 err = ERROR_WINHTTP_SECURE_CERT_REV_FAILED;
 304             else if (chain->TrustStatus.dwErrorStatus & CERT_TRUST_IS_REVOKED)
 305                 err = ERROR_WINHTTP_SECURE_CERT_REVOKED;
 306             else if (chain->TrustStatus.dwErrorStatus &
 307                 CERT_TRUST_IS_NOT_VALID_FOR_USAGE)
 308             {
 309                 if (!(security_flags & SECURITY_FLAG_IGNORE_CERT_WRONG_USAGE))
 310                     err = ERROR_WINHTTP_SECURE_CERT_WRONG_USAGE;
 311             }
 312             else if (chain->TrustStatus.dwErrorStatus & ~supportedErrors)
 313                 err = ERROR_WINHTTP_SECURE_INVALID_CERT;
 314         }
 315         if (!err)
 316         {
 317             CERT_CHAIN_POLICY_PARA policyPara;
 318             SSL_EXTRA_CERT_CHAIN_POLICY_PARA sslExtraPolicyPara;
 319             CERT_CHAIN_POLICY_STATUS policyStatus;
 320             CERT_CHAIN_CONTEXT chainCopy;
 321
 322             /* Clear chain->TrustStatus.dwErrorStatus so
 323              * CertVerifyCertificateChainPolicy will verify additional checks
 324              * rather than stopping with an existing, ignored error.
 325              */
 326             memcpy(&chainCopy, chain, sizeof(chainCopy));
 327             chainCopy.TrustStatus.dwErrorStatus = 0;
 328             sslExtraPolicyPara.u.cbSize = sizeof(sslExtraPolicyPara);
 329             sslExtraPolicyPara.dwAuthType = AUTHTYPE_SERVER;
 330             sslExtraPolicyPara.pwszServerName = server;
 331             sslExtraPolicyPara.fdwChecks = security_flags;
 332             policyPara.cbSize = sizeof(policyPara);
 333             policyPara.dwFlags = 0;
 334             policyPara.pvExtraPolicyPara = &sslExtraPolicyPara;
 335             ret = CertVerifyCertificateChainPolicy( CERT_CHAIN_POLICY_SSL,
 336                                                     &chainCopy, &policyPara,
 337                                                     &policyStatus );
 338             /* Any error in the policy status indicates that the
 339              * policy couldn't be verified.
 340              */
 341             if (ret && policyStatus.dwError)
 342             {
 343                 if (policyStatus.dwError == CERT_E_CN_NO_MATCH)
 344                     err = ERROR_WINHTTP_SECURE_CERT_CN_INVALID;
 345                 else
 346                     err = ERROR_WINHTTP_SECURE_INVALID_CERT;
 347             }
 348         }
 349         CertFreeCertificateChain( chain );
 350     }
 351     else
 352         err = ERROR_WINHTTP_SECURE_CHANNEL_ERROR;
 353     TRACE("returning %08x\n", err);
 354     return err;
 355 }
 356
 357 static int netconn_secure_verify( int preverify_ok, X509_STORE_CTX *ctx )
 358 {
 359     SSL *ssl;
 360     WCHAR *server;
 361     BOOL ret = FALSE;
 362     netconn_t *conn;
 363     HCERTSTORE store = CertOpenStore( CERT_STORE_PROV_MEMORY, 0, 0,
 364      CERT_STORE_CREATE_NEW_FLAG, NULL );
 365
 366     ssl = pX509_STORE_CTX_get_ex_data( ctx, pSSL_get_ex_data_X509_STORE_CTX_idx() );
 367     server = pSSL_get_ex_data( ssl, hostname_idx );
 368     conn = pSSL_get_ex_data( ssl, conn_idx );
 369     if (store)
 370     {
 371         X509 *cert;
 372         int i;
 373         PCCERT_CONTEXT endCert = NULL;
 374         struct stack_st *chain = (struct stack_st *)pX509_STORE_CTX_get_chain( ctx );
 375
 376         ret = TRUE;
 377         for (i = 0; ret && i < psk_num(chain); i++)
 378         {
 379             PCCERT_CONTEXT context;
 380
 381             cert = (X509 *)psk_value(chain, i);
 382             if ((context = X509_to_cert_context( cert )))
 383             {
 384                 if (i == 0)
 385                     ret = CertAddCertificateContextToStore( store, context,
 386                         CERT_STORE_ADD_ALWAYS, &endCert );
 387                 else
 388                     ret = CertAddCertificateContextToStore( store, context,
 389                         CERT_STORE_ADD_ALWAYS, NULL );
 390                 CertFreeCertificateContext( context );
 391             }
 392         }
 393         if (!endCert) ret = FALSE;
 394         if (ret)
 395         {
 396             DWORD_PTR err = netconn_verify_cert( endCert, store, server,
 397                                                  conn->security_flags );
 398
 399             if (err)
 400             {
 401                 pSSL_set_ex_data( ssl, error_idx, (void *)err );
 402                 ret = FALSE;
 403             }
 404         }
 405         CertFreeCertificateContext( endCert );
 406         CertCloseStore( store, 0 );
 407     }
 408     return ret;
 409 }
 410 #endif
 411
 412 BOOL netconn_init( netconn_t *conn, BOOL secure )
 413 {
 414 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
 415     int i;
 416 #endif
 417
 418     conn->socket = -1;
 419     if (!secure) return TRUE;
 420
 421 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
 422     EnterCriticalSection( &init_ssl_cs );
 423     if (libssl_handle)
 424     {
 425         LeaveCriticalSection( &init_ssl_cs );
 426         return TRUE;
 427     }
 428     if (!(libssl_handle = wine_dlopen( SONAME_LIBSSL, RTLD_NOW, NULL, 0 )))
 429     {
 430         ERR("Trying to use SSL but couldn't load %s. Expect trouble.\n", SONAME_LIBSSL);
 431         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 432         LeaveCriticalSection( &init_ssl_cs );
 433         return FALSE;
 434     }
 435     if (!(libcrypto_handle = wine_dlopen( SONAME_LIBCRYPTO, RTLD_NOW, NULL, 0 )))
 436     {
 437         ERR("Trying to use SSL but couldn't load %s. Expect trouble.\n", SONAME_LIBCRYPTO);
 438         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 439         LeaveCriticalSection( &init_ssl_cs );
 440         return FALSE;
 441     }
 442 #define LOAD_FUNCPTR(x) \
 443     if (!(p##x = wine_dlsym( libssl_handle, #x, NULL, 0 ))) \
 444     { \
 445         ERR("Failed to load symbol %s\n", #x); \
 446         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR ); \
 447         LeaveCriticalSection( &init_ssl_cs ); \
 448         return FALSE; \
 449     }
 450     LOAD_FUNCPTR( SSL_library_init );
 451     LOAD_FUNCPTR( SSL_load_error_strings );
 452     LOAD_FUNCPTR( SSLv23_method );
 453     LOAD_FUNCPTR( SSL_CTX_free );
 454     LOAD_FUNCPTR( SSL_CTX_new );
 455     LOAD_FUNCPTR( SSL_new );
 456     LOAD_FUNCPTR( SSL_free );
 457     LOAD_FUNCPTR( SSL_set_fd );
 458     LOAD_FUNCPTR( SSL_connect );
 459     LOAD_FUNCPTR( SSL_shutdown );
 460     LOAD_FUNCPTR( SSL_write );
 461     LOAD_FUNCPTR( SSL_read );
 462     LOAD_FUNCPTR( SSL_get_error );
 463     LOAD_FUNCPTR( SSL_get_ex_new_index );
 464     LOAD_FUNCPTR( SSL_get_ex_data );
 465     LOAD_FUNCPTR( SSL_set_ex_data );
 466     LOAD_FUNCPTR( SSL_get_ex_data_X509_STORE_CTX_idx );
 467     LOAD_FUNCPTR( SSL_get_peer_certificate );
 468     LOAD_FUNCPTR( SSL_CTX_set_default_verify_paths );
 469     LOAD_FUNCPTR( SSL_CTX_set_verify );
 470     LOAD_FUNCPTR( SSL_get_current_cipher );
 471     LOAD_FUNCPTR( SSL_CIPHER_get_bits );
 472 #undef LOAD_FUNCPTR
 473
 474 #define LOAD_FUNCPTR(x) \
 475     if (!(p##x = wine_dlsym( libcrypto_handle, #x, NULL, 0 ))) \
 476     { \
 477         ERR("Failed to load symbol %s\n", #x); \
 478         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR ); \
 479         LeaveCriticalSection( &init_ssl_cs ); \
 480         return FALSE; \
 481     }
 482     LOAD_FUNCPTR( CRYPTO_num_locks );
 483     LOAD_FUNCPTR( CRYPTO_set_id_callback );
 484     LOAD_FUNCPTR( CRYPTO_set_locking_callback );
 485     LOAD_FUNCPTR( ERR_free_strings );
 486     LOAD_FUNCPTR( ERR_get_error );
 487     LOAD_FUNCPTR( ERR_error_string );
 488     LOAD_FUNCPTR( X509_STORE_CTX_get_ex_data );
 489     LOAD_FUNCPTR( X509_STORE_CTX_get_chain );
 490     LOAD_FUNCPTR( i2d_X509 );
 491     LOAD_FUNCPTR( sk_value );
 492     LOAD_FUNCPTR( sk_num );
 493 #undef LOAD_FUNCPTR
 494
 495     pSSL_library_init();
 496     pSSL_load_error_strings();
 497
 498     method = pSSLv23_method();
 499     ctx = pSSL_CTX_new( method );
 500     if (!pSSL_CTX_set_default_verify_paths( ctx ))
 501     {
 502         ERR("SSL_CTX_set_default_verify_paths failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 503         set_last_error( ERROR_OUTOFMEMORY );
 504         LeaveCriticalSection( &init_ssl_cs );
 505         return FALSE;
 506     }
 507     hostname_idx = pSSL_get_ex_new_index( 0, (void *)"hostname index", NULL, NULL, NULL );
 508     if (hostname_idx == -1)
 509     {
 510         ERR("SSL_get_ex_new_index failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 511         set_last_error( ERROR_OUTOFMEMORY );
 512         LeaveCriticalSection( &init_ssl_cs );
 513         return FALSE;
 514     }
 515     error_idx = pSSL_get_ex_new_index( 0, (void *)"error index", NULL, NULL, NULL );
 516     if (error_idx == -1)
 517     {
 518         ERR("SSL_get_ex_new_index failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 519         set_last_error( ERROR_OUTOFMEMORY );
 520         LeaveCriticalSection( &init_ssl_cs );
 521         return FALSE;
 522     }
 523     conn_idx = pSSL_get_ex_new_index( 0, (void *)"netconn index", NULL, NULL, NULL );
 524     if (conn_idx == -1)
 525     {
 526         ERR("SSL_get_ex_new_index failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 527         set_last_error( ERROR_OUTOFMEMORY );
 528         LeaveCriticalSection( &init_ssl_cs );
 529         return FALSE;
 530     }
 531     pSSL_CTX_set_verify( ctx, SSL_VERIFY_PEER, netconn_secure_verify );
 532
 533     pCRYPTO_set_id_callback(ssl_thread_id);
 534     num_ssl_locks = pCRYPTO_num_locks();
 535     ssl_locks = heap_alloc(num_ssl_locks * sizeof(CRITICAL_SECTION));
 536     if (!ssl_locks)
 537     {
 538         set_last_error( ERROR_OUTOFMEMORY );
 539         LeaveCriticalSection( &init_ssl_cs );
 540         return FALSE;
 541     }
 542     for (i = 0; i < num_ssl_locks; i++)
 543     {
 544         InitializeCriticalSection( &ssl_locks[i] );
 545         ssl_locks[i].DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": ssl_locks");
 546     }
 547     pCRYPTO_set_locking_callback(ssl_lock_callback);
 548
 549     LeaveCriticalSection( &init_ssl_cs );
 550 #else
 551     WARN("SSL support not compiled in.\n");
 552     set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 553     return FALSE;
 554 #endif
 555     return TRUE;
 556 }
 557
 558 void netconn_unload( void )
 559 {
 560 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
 561     if (libcrypto_handle)
 562     {
 563         pERR_free_strings();
 564         wine_dlclose( libcrypto_handle, NULL, 0 );
 565     }
 566     if (libssl_handle)
 567     {
 568         if (ctx)
 569             pSSL_CTX_free( ctx );
 570         wine_dlclose( libssl_handle, NULL, 0 );
 571     }
 572     if (ssl_locks)
 573     {
 574         int i;
 575         for (i = 0; i < num_ssl_locks; i++)
 576         {
 577             ssl_locks[i].DebugInfo->Spare[0] = 0;
 578             DeleteCriticalSection( &ssl_locks[i] );
 579         }
 580         heap_free( ssl_locks );
 581     }
 582     DeleteCriticalSection(&init_ssl_cs);
 583 #endif
 584 #ifndef HAVE_GETADDRINFO
 585     DeleteCriticalSection(&cs_gethostbyname);
 586 #endif
 587 }
 588
 589 BOOL netconn_connected( netconn_t *conn )
 590 {
 591     return (conn->socket != -1);
 592 }
 593
 594 BOOL netconn_create( netconn_t *conn, int domain, int type, int protocol )
 595 {
 596     if ((conn->socket = socket( domain, type, protocol )) == -1)
 597     {
 598         WARN("unable to create socket (%s)\n", strerror(errno));
 599         set_last_error( sock_get_error( errno ) );
 600         return FALSE;
 601     }
 602     return TRUE;
 603 }
 604
 605 BOOL netconn_close( netconn_t *conn )
 606 {
 607     int res;
 608
 609 #ifdef SONAME_LIBSSL
 610     if (conn->secure)
 611     {
 612         heap_free( conn->peek_msg_mem );
 613         conn->peek_msg_mem = NULL;
 614         conn->peek_msg = NULL;
 615         conn->peek_len = 0;
 616
 617         pSSL_shutdown( conn->ssl_conn );
 618         pSSL_free( conn->ssl_conn );
 619
 620         conn->ssl_conn = NULL;
 621         conn->secure = FALSE;
 622     }
 623 #endif
 624     res = closesocket( conn->socket );
 625     conn->socket = -1;
 626     if (res == -1)
 627     {
 628         set_last_error( sock_get_error( errno ) );
 629         return FALSE;
 630     }
 631     return TRUE;
 632 }
 633
 634 BOOL netconn_connect( netconn_t *conn, const struct sockaddr *sockaddr, unsigned int addr_len, int timeout )
 635 {
 636     BOOL ret = FALSE;
 637     int res = 0, state;
 638
 639     if (timeout > 0)
 640     {
 641         state = 1;
 642         ioctlsocket( conn->socket, FIONBIO, &state );
 643     }
 644     if (connect( conn->socket, sockaddr, addr_len ) < 0)
 645     {
 646         res = sock_get_error( errno );
 647         if (res == WSAEWOULDBLOCK || res == WSAEINPROGRESS)
 648         {
 649             struct pollfd pfd;
 650
 651             pfd.fd = conn->socket;
 652             pfd.events = POLLOUT;
 653             if (poll( &pfd, 1, timeout ) > 0)
 654                 ret = TRUE;
 655             else
 656                 res = sock_get_error( errno );
 657         }
 658     }
 659     else
 660         ret = TRUE;
 661     if (timeout > 0)
 662     {
 663         state = 0;
 664         ioctlsocket( conn->socket, FIONBIO, &state );
 665     }
 666     if (!ret)
 667     {
 668         WARN("unable to connect to host (%d)\n", res);
 669         set_last_error( res );
 670     }
 671     return ret;
 672 }
 673
 674 BOOL netconn_secure_connect( netconn_t *conn, WCHAR *hostname )
 675 {
 676 #ifdef SONAME_LIBSSL
 677     if (!(conn->ssl_conn = pSSL_new( ctx )))
 678     {
 679         ERR("SSL_new failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 680         set_last_error( ERROR_OUTOFMEMORY );
 681         goto fail;
 682     }
 683     if (!pSSL_set_ex_data( conn->ssl_conn, hostname_idx, hostname ))
 684     {
 685         ERR("SSL_set_ex_data failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 686         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 687         goto fail;
 688     }
 689     if (!pSSL_set_ex_data( conn->ssl_conn, conn_idx, conn ))
 690     {
 691         ERR("SSL_set_ex_data failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 692         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 693         return FALSE;
 694     }
 695     if (!pSSL_set_fd( conn->ssl_conn, conn->socket ))
 696     {
 697         ERR("SSL_set_fd failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
 698         set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
 699         goto fail;
 700     }
 701     if (pSSL_connect( conn->ssl_conn ) <= 0)
 702     {
 703         DWORD err;
 704
 705         err = (DWORD_PTR)pSSL_get_ex_data( conn->ssl_conn, error_idx );
 706         if (!err) err = ERROR_WINHTTP_SECURE_CHANNEL_ERROR;
 707         ERR("couldn't verify server certificate (%d)\n", err);
 708         set_last_error( err );
 709         goto fail;
 710     }
 711     TRACE("established SSL connection\n");
 712     conn->secure = TRUE;
 713     return TRUE;
 714
 715 fail:
 716     if (conn->ssl_conn)
 717     {
 718         pSSL_shutdown( conn->ssl_conn );
 719         pSSL_free( conn->ssl_conn );
 720         conn->ssl_conn = NULL;
 721     }
 722 #endif
 723     return FALSE;
 724 }
 725
 726 BOOL netconn_send( netconn_t *conn, const void *msg, size_t len, int flags, int *sent )
 727 {
 728     if (!netconn_connected( conn )) return FALSE;
 729     if (conn->secure)
 730     {
 731 #ifdef SONAME_LIBSSL
 732         if (flags) FIXME("SSL_write doesn't support any flags (%08x)\n", flags);
 733         *sent = pSSL_write( conn->ssl_conn, msg, len );
 734         if (*sent < 1 && len) return FALSE;
 735         return TRUE;
 736 #else
 737         return FALSE;
 738 #endif
 739     }
 740     if ((*sent = send( conn->socket, msg, len, flags )) == -1)
 741     {
 742         set_last_error( sock_get_error( errno ) );
 743         return FALSE;
 744     }
 745     return TRUE;
 746 }
 747
 748 BOOL netconn_recv( netconn_t *conn, void *buf, size_t len, int flags, int *recvd )
 749 {
 750     *recvd = 0;
 751     if (!netconn_connected( conn )) return FALSE;
 752     if (!len) return TRUE;
 753
 754     if (conn->secure)
 755     {
 756 #ifdef SONAME_LIBSSL
 757         int ret;
 758
 759         if (flags & ~(MSG_PEEK | MSG_WAITALL))
 760             FIXME("SSL_read does not support the following flags: %08x\n", flags);
 761
 762         /* this ugly hack is all for MSG_PEEK */
 763         if (flags & MSG_PEEK && !conn->peek_msg)
 764         {
 765             if (!(conn->peek_msg = conn->peek_msg_mem = heap_alloc( len + 1 ))) return FALSE;
 766         }
 767         else if (flags & MSG_PEEK && conn->peek_msg)
 768         {
 769             if (len < conn->peek_len) FIXME("buffer isn't big enough, should we wrap?\n");
 770             *recvd = min( len, conn->peek_len );
 771             memcpy( buf, conn->peek_msg, *recvd );
 772             return TRUE;
 773         }
 774         else if (conn->peek_msg)
 775         {
 776             *recvd = min( len, conn->peek_len );
 777             memcpy( buf, conn->peek_msg, *recvd );
 778             conn->peek_len -= *recvd;
 779             conn->peek_msg += *recvd;
 780
 781             if (conn->peek_len == 0)
 782             {
 783                 heap_free( conn->peek_msg_mem );
 784                 conn->peek_msg_mem = NULL;
 785                 conn->peek_msg = NULL;
 786             }
 787             /* check if we have enough data from the peek buffer */
 788             if (!(flags & MSG_WAITALL) || (*recvd == len)) return TRUE;
 789         }
 790         ret = pSSL_read( conn->ssl_conn, (char *)buf + *recvd, len - *recvd );
 791         if (ret < 0)
 792             return FALSE;
 793
 794         /* check if EOF was received */
 795         if (!ret && (pSSL_get_error( conn->ssl_conn, ret ) == SSL_ERROR_ZERO_RETURN ||
 796                      pSSL_get_error( conn->ssl_conn, ret ) == SSL_ERROR_SYSCALL ))
 797         {
 798             netconn_close( conn );
 799             return TRUE;
 800         }
 801         if (flags & MSG_PEEK) /* must copy into buffer */
 802         {
 803             conn->peek_len = ret;
 804             if (!ret)
 805             {
 806                 heap_free( conn->peek_msg_mem );
 807                 conn->peek_msg_mem = NULL;
 808                 conn->peek_msg = NULL;
 809             }
 810             else memcpy( conn->peek_msg, buf, ret );
 811         }
 812         *recvd = ret;
 813         return TRUE;
 814 #else
 815         return FALSE;
 816 #endif
 817     }
 818     if ((*recvd = recv( conn->socket, buf, len, flags )) == -1)
 819     {
 820         set_last_error( sock_get_error( errno ) );
 821         return FALSE;
 822     }
 823     return TRUE;
 824 }
 825
 826 BOOL netconn_query_data_available( netconn_t *conn, DWORD *available )
 827 {
 828 #ifdef FIONREAD
 829     int ret, unread;
 830 #endif
 831     *available = 0;
 832     if (!netconn_connected( conn )) return FALSE;
 833
 834     if (conn->secure)
 835     {
 836 #ifdef SONAME_LIBSSL
 837         if (conn->peek_msg) *available = conn->peek_len;
 838 #endif
 839         return TRUE;
 840     }
 841 #ifdef FIONREAD
 842     if (!(ret = ioctlsocket( conn->socket, FIONREAD, &unread ))) *available = unread;
 843 #endif
 844     return TRUE;
 845 }
 846
 847 BOOL netconn_get_next_line( netconn_t *conn, char *buffer, DWORD *buflen )
 848 {
 849     struct pollfd pfd;
 850     BOOL ret = FALSE;
 851     DWORD recvd = 0;
 852
 853     if (!netconn_connected( conn )) return FALSE;
 854
 855     if (conn->secure)
 856     {
 857 #ifdef SONAME_LIBSSL
 858         while (recvd < *buflen)
 859         {
 860             int dummy;
 861             if (!netconn_recv( conn, &buffer[recvd], 1, 0, &dummy ))
 862             {
 863                 set_last_error( ERROR_CONNECTION_ABORTED );
 864                 break;
 865             }
 866             if (buffer[recvd] == '\n')
 867             {
 868                 ret = TRUE;
 869                 break;
 870             }
 871             if (buffer[recvd] != '\r') recvd++;
 872         }
 873         if (ret)
 874         {
 875             buffer[recvd++] = 0;
 876             *buflen = recvd;
 877             TRACE("received line %s\n", debugstr_a(buffer));
 878         }
 879         return ret;
 880 #else
 881         return FALSE;
 882 #endif
 883     }
 884
 885     pfd.fd = conn->socket;
 886     pfd.events = POLLIN;
 887     while (recvd < *buflen)
 888     {
 889         int timeout, res;
 890         struct timeval tv;
 891         socklen_t len = sizeof(tv);
 892
 893         if ((res = getsockopt( conn->socket, SOL_SOCKET, SO_RCVTIMEO, (void*)&tv, &len ) != -1))
 894             timeout = tv.tv_sec * 1000 + tv.tv_usec / 1000;
 895         else
 896             timeout = -1;
 897         if (poll( &pfd, 1, timeout ) > 0)
 898         {
 899             if ((res = recv( conn->socket, &buffer[recvd], 1, 0 )) <= 0)
 900             {
 901                 if (res == -1) set_last_error( sock_get_error( errno ) );
 902                 break;
 903             }
 904             if (buffer[recvd] == '\n')
 905             {
 906                 ret = TRUE;
 907                 break;
 908             }
 909             if (buffer[recvd] != '\r') recvd++;
 910         }
 911         else
 912         {
 913             set_last_error( ERROR_WINHTTP_TIMEOUT );
 914             break;
 915         }
 916     }
 917     if (ret)
 918     {
 919         buffer[recvd++] = 0;
 920         *buflen = recvd;
 921         TRACE("received line %s\n", debugstr_a(buffer));
 922     }
 923     return ret;
 924 }
 925
 926 DWORD netconn_set_timeout( netconn_t *netconn, BOOL send, int value )
 927 {
 928     int res;
 929     struct timeval tv;
 930
 931     /* value is in milliseconds, convert to struct timeval */
 932     tv.tv_sec = value / 1000;
 933     tv.tv_usec = (value % 1000) * 1000;
 934
 935     if ((res = setsockopt( netconn->socket, SOL_SOCKET, send ? SO_SNDTIMEO : SO_RCVTIMEO, (void*)&tv, sizeof(tv) ) == -1))
 936     {
 937         WARN("setsockopt failed (%s)\n", strerror( errno ));
 938         return sock_get_error( errno );
 939     }
 940     return ERROR_SUCCESS;
 941 }
 942
 943 static DWORD resolve_hostname( WCHAR *hostnameW, INTERNET_PORT port, struct sockaddr *sa, socklen_t *sa_len )
 944 {
 945     char *hostname;
 946 #ifdef HAVE_GETADDRINFO
 947     struct addrinfo *res, hints;
 948     int ret;
 949 #else
 950     struct hostent *he;
 951     struct sockaddr_in *sin = (struct sockaddr_in *)sa;
 952 #endif
 953
 954     if (!(hostname = strdupWA( hostnameW ))) return ERROR_OUTOFMEMORY;
 955
 956 #ifdef HAVE_GETADDRINFO
 957     memset( &hints, 0, sizeof(struct addrinfo) );
 958     /* Prefer IPv4 to IPv6 addresses, since some web servers do not listen on
 959      * their IPv6 addresses even though they have IPv6 addresses in the DNS.
 960      */
 961     hints.ai_family = AF_INET;
 962
 963     ret = getaddrinfo( hostname, NULL, &hints, &res );
 964     if (ret != 0)
 965     {
 966         TRACE("failed to get IPv4 address of %s (%s), retrying with IPv6\n", debugstr_w(hostnameW), gai_strerror(ret));
 967         hints.ai_family = AF_INET6;
 968         ret = getaddrinfo( hostname, NULL, &hints, &res );
 969         if (ret != 0)
 970         {
 971             TRACE("failed to get address of %s (%s)\n", debugstr_w(hostnameW), gai_strerror(ret));
 972             heap_free( hostname );
 973             return ERROR_WINHTTP_NAME_NOT_RESOLVED;
 974         }
 975     }
 976     heap_free( hostname );
 977     if (*sa_len < res->ai_addrlen)
 978     {
 979         WARN("address too small\n");
 980         freeaddrinfo( res );
 981         return ERROR_WINHTTP_NAME_NOT_RESOLVED;
 982     }
 983     *sa_len = res->ai_addrlen;
 984     memcpy( sa, res->ai_addr, res->ai_addrlen );
 985     /* Copy port */
 986     switch (res->ai_family)
 987     {
 988     case AF_INET:
 989         ((struct sockaddr_in *)sa)->sin_port = htons( port );
 990         break;
 991     case AF_INET6:
 992         ((struct sockaddr_in6 *)sa)->sin6_port = htons( port );
 993         break;
 994     }
 995
 996     freeaddrinfo( res );
 997     return ERROR_SUCCESS;
 998 #else
 999     EnterCriticalSection( &cs_gethostbyname );
1000
1001     he = gethostbyname( hostname );
1002     heap_free( hostname );
1003     if (!he)
1004     {
1005         TRACE("failed to get address of %s (%d)\n", debugstr_w(hostnameW), h_errno);
1006         LeaveCriticalSection( &cs_gethostbyname );
1007         return ERROR_WINHTTP_NAME_NOT_RESOLVED;
1008     }
1009     if (*sa_len < sizeof(struct sockaddr_in))
1010     {
1011         WARN("address too small\n");
1012         LeaveCriticalSection( &cs_gethostbyname );
1013         return ERROR_WINHTTP_NAME_NOT_RESOLVED;
1014     }
1015     *sa_len = sizeof(struct sockaddr_in);
1016     memset( sa, 0, sizeof(struct sockaddr_in) );
1017     memcpy( &sin->sin_addr, he->h_addr, he->h_length );
1018     sin->sin_family = he->h_addrtype;
1019     sin->sin_port = htons( port );
1020
1021     LeaveCriticalSection( &cs_gethostbyname );
1022     return ERROR_SUCCESS;
1023 #endif
1024 }
1025
1026 struct resolve_args
1027 {
1028     WCHAR           *hostname;
1029     INTERNET_PORT    port;
1030     struct sockaddr *sa;
1031     socklen_t       *sa_len;
1032 };
1033
1034 static DWORD CALLBACK resolve_proc( LPVOID arg )
1035 {
1036     struct resolve_args *ra = arg;
1037     return resolve_hostname( ra->hostname, ra->port, ra->sa, ra->sa_len );
1038 }
1039
1040 BOOL netconn_resolve( WCHAR *hostname, INTERNET_PORT port, struct sockaddr *sa, socklen_t *sa_len, int timeout )
1041 {
1042     DWORD ret;
1043
1044     if (timeout)
1045     {
1046         DWORD status;
1047         HANDLE thread;
1048         struct resolve_args ra;
1049
1050         ra.hostname = hostname;
1051         ra.port     = port;
1052         ra.sa       = sa;
1053         ra.sa_len   = sa_len;
1054
1055         thread = CreateThread( NULL, 0, resolve_proc, &ra, 0, NULL );
1056         if (!thread) return FALSE;
1057
1058         status = WaitForSingleObject( thread, timeout );
1059         if (status == WAIT_OBJECT_0) GetExitCodeThread( thread, &ret );
1060         else ret = ERROR_WINHTTP_TIMEOUT;
1061         CloseHandle( thread );
1062     }
1063     else ret = resolve_hostname( hostname, port, sa, sa_len );
1064
1065     if (ret)
1066     {
1067         set_last_error( ret );
1068         return FALSE;
1069     }
1070     return TRUE;
1071 }
1072
1073 const void *netconn_get_certificate( netconn_t *conn )
1074 {
1075 #ifdef SONAME_LIBSSL
1076     X509 *cert;
1077     const CERT_CONTEXT *ret;
1078
1079     if (!conn->secure) return NULL;
1080
1081     if (!(cert = pSSL_get_peer_certificate( conn->ssl_conn ))) return NULL;
1082     ret = X509_to_cert_context( cert );
1083     return ret;
1084 #else
1085     return NULL;
1086 #endif
1087 }
1088
1089 int netconn_get_cipher_strength( netconn_t *conn )
1090 {
1091 #ifdef SONAME_LIBSSL
1092 #if defined(OPENSSL_VERSION_NUMBER) && (OPENSSL_VERSION_NUMBER >= 0x0090707f)
1093     const SSL_CIPHER *cipher;
1094 #else
1095     SSL_CIPHER *cipher;
1096 #endif
1097     int bits = 0;
1098
1099     if (!conn->secure) return 0;
1100     if (!(cipher = pSSL_get_current_cipher( conn->ssl_conn ))) return 0;
1101     pSSL_CIPHER_get_bits( cipher, &bits );
1102     return bits;
1103 #else
1104     return 0;
1105 #endif
1106 }