Skip to content
Snippets Groups Projects
ssluse.c 25.3 KiB
Newer Older
  • Learn to ignore specific revisions
  • Daniel Stenberg's avatar
    Daniel Stenberg committed
    /*****************************************************************************
     *                                  _   _ ____  _     
     *  Project                     ___| | | |  _ \| |    
     *                             / __| | | | |_) | |    
     *                            | (__| |_| |  _ <| |___ 
     *                             \___|\___/|_| \_\_____|
     *
    
     * Copyright (C) 2001, Daniel Stenberg, <daniel@haxx.se>, et al.
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     *
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     * In order to be useful for every potential user, curl and libcurl are
     * dual-licensed under the MPL and the MIT/X-derivate licenses.
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     *
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     * You may opt to use, copy, modify, merge, publish, distribute and/or sell
     * copies of the Software, and permit persons to whom the Software is
     * furnished to do so, under the terms of the MPL or the MIT/X-derivate
     * licenses. You may pick one of these licenses.
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     *
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
     * KIND, either express or implied.
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     *
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
     * $Id$
     *****************************************************************************/
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
     * The original SSL code for curl was written by
    
     * Linas Vepstas <linas@linas.org> and Sampo Kellomaki <sampo@iki.fi>
     */
    
    
    #include "setup.h"
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    #include <string.h>
    #include <stdlib.h>
    
    #include "urldata.h"
    #include "sendf.h"
    
    #include "formdata.h" /* for the boundary function */
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    #ifdef USE_SSLEAY
    
    #include <openssl/rand.h>
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
    /* The last #include file should be: */
    #ifdef MALLOCDEBUG
    #include "memdebug.h"
    #endif
    
    
    #if OPENSSL_VERSION_NUMBER >= 0x00904100L
    #define HAVE_USERDATA_IN_PWD_CALLBACK 1
    #else
    #undef HAVE_USERDATA_IN_PWD_CALLBACK
    #endif
    
    #ifndef HAVE_USERDATA_IN_PWD_CALLBACK
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    static char global_passwd[64];
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    static int passwd_callback(char *buf, int num, int verify
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
                               /* This was introduced in 0.9.4, we can set this
                                  using SSL_CTX_set_default_passwd_cb_userdata()
                                  */
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    #endif
                               )
    {
      if(verify)
        fprintf(stderr, "%s\n", buf);
      else {
    
        if(num > (int)strlen((char *)global_passwd)) {
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
          strcpy(buf, global_passwd);
          return strlen(buf);
        }
      }  
      return 0;
    }
    
    
    static
    bool seed_enough(struct connectdata *conn, /* unused for now */
                     int nread)
    {
    
      conn = NULL; /* to prevent compiler warnings */
    
    #ifdef HAVE_RAND_STATUS
    
      nread = 0; /* to prevent compiler warnings */
    
    
      /* only available in OpenSSL 0.9.5a and later */
      if(RAND_status())
        return TRUE;
    #else
      if(nread > 500)
        /* this is a very silly decision to make */
        return TRUE;
    #endif
      return FALSE; /* not enough */
    }
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
    int random_the_seed(struct connectdata *conn)
    {
    
      char *buf = conn->data->state.buffer; /* point to the big buffer */
    
      struct SessionHandle *data=conn->data;
    
    
      /* Q: should we add support for a random file name as a libcurl option?
    
         A: Yes, it is here */
    
    #ifndef RANDOM_FILE
      /* if RANDOM_FILE isn't defined, we only perform this if an option tells
         us to! */
    
    #define RANDOM_FILE "" /* doesn't matter won't be used */
    
      {
        /* let the option override the define */
    
        nread += RAND_load_file((data->set.ssl.random_file?
                                 data->set.ssl.random_file:RANDOM_FILE),
    
        if(seed_enough(conn, nread))
          return nread;
      }
    
    
      /* only available in OpenSSL 0.9.5 and later */
    
      /* EGD_SOCKET is set at configure time or not at all */
    #ifndef EGD_SOCKET
      /* If we don't have the define set, we only do this if the egd-option
         is set */
    
    #define EGD_SOCKET "" /* doesn't matter won't be used */
    #endif
    
        /* If there's an option and a define, the option overrides the
           define */
    
        int ret = RAND_egd(data->set.ssl.egdsocket?data->set.ssl.egdsocket:EGD_SOCKET);
    
        if(-1 != ret) {
          nread += ret;
          if(seed_enough(conn, nread))
            return nread;
        }
    
      }
    #endif
    
      /* If we get here, it means we need to seed the PRNG using a "silly"
         approach! */
    #ifdef HAVE_RAND_SCREEN
      /* This one gets a random value by reading the currently shown screen */
      RAND_screen();
      nread = 100; /* just a value */
    #else
      {
        int len;
        char *area = Curl_FormBoundary();
        if(!area)
          return 3; /* out of memory */
    	
        len = strlen(area);
        RAND_seed(area, len);
    
        free(area); /* now remove the random junk */
      }
    
      /* generates a default path for the random seed file */
      buf[0]=0; /* blank it first */
      RAND_file_name(buf, BUFSIZE);
      if ( buf[0] ) {
        /* we got a file name to try */
        nread += RAND_load_file(buf, 16384);
        if(seed_enough(conn, nread))
          return nread;
      }
    
    
      infof(conn->data, "Your connection is using a weak random seed!\n");
      return nread;
    }
    
    
    #ifndef SSL_FILETYPE_ENGINE
    #define SSL_FILETYPE_ENGINE 42
    #endif
    static int do_file_type(const char *type)
    {
      if (!type || !type[0])
        return SSL_FILETYPE_PEM;
      if (curl_strequal(type, "PEM"))
        return SSL_FILETYPE_PEM;
      if (curl_strequal(type, "DER"))
        return SSL_FILETYPE_ASN1;
      if (curl_strequal(type, "ENG"))
        return SSL_FILETYPE_ENGINE;
      return -1;
    }
    
    
    static
    int cert_stuff(struct connectdata *conn,
    
                   const char *cert_type,
                   char *key_file,
                   const char *key_type)
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    {
    
      struct SessionHandle *data = conn->data;
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
      if (cert_file != NULL) {
        SSL *ssl;
        X509 *x509;
    
    
        if(data->set.key_passwd) {
    
    #ifndef HAVE_USERDATA_IN_PWD_CALLBACK
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
          /*
           * If password has been given, we store that in the global
           * area (*shudder*) for a while:
           */
    
          strcpy(global_passwd, data->set.key_passwd);
    
    #else
          /*
           * We set the password in the callback userdata
           */
    
          SSL_CTX_set_default_passwd_cb_userdata(conn->ssl.ctx,
                                                 data->set.key_passwd);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
          /* Set passwd callback: */
    
          SSL_CTX_set_default_passwd_cb(conn->ssl.ctx, passwd_callback);
    
        if (SSL_CTX_use_certificate_file(conn->ssl.ctx,
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    				     cert_file,
    
          failf(data, "unable to set certificate file (wrong password?)");
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
          return(0);
        }
        if (key_file == NULL)
          key_file=cert_file;
    
    
        if (SSL_CTX_use_PrivateKey_file(conn->ssl.ctx,
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    				    key_file,
    
          failf(data, "unable to set public key file");
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
          return(0);
        }
    
    #else
        /* The '#ifdef 0' section above was removed on 17-dec-2001 */
    
        file_type = do_file_type(cert_type);
    
        switch(file_type) {
        case SSL_FILETYPE_PEM:
        case SSL_FILETYPE_ASN1:
          if (SSL_CTX_use_certificate_file(conn->ssl.ctx,
                                           cert_file,
                                           file_type) != 1) {
            failf(data, "unable to set certificate file (wrong password?)");
            return 0;
          }
          break;
        case SSL_FILETYPE_ENGINE:
          failf(data, "file type ENG for certificate not implemented");
          return 0;
    
        default:
          failf(data, "not supported file type '%s' for certificate", cert_type);
          return 0;
        }
    
        file_type = do_file_type(key_type);
    
        switch(file_type) {
        case SSL_FILETYPE_PEM:
          if (key_file == NULL)
            /* cert & key can only be in PEM case in the same file */
            key_file=cert_file;
        case SSL_FILETYPE_ASN1:
          if (SSL_CTX_use_PrivateKey_file(conn->ssl.ctx,
                                          key_file,
                                          file_type) != 1) {
            failf(data, "unable to set private key file\n");
            return 0;
          }
          break;
        case SSL_FILETYPE_ENGINE:
    #ifdef HAVE_OPENSSL_ENGINE_H
          {                         /* XXXX still needs some work */
            EVP_PKEY *priv_key = NULL;
            if (conn && conn->data && conn->data->engine) {
              if (!key_file || !key_file[0]) {
                failf(data, "no key set to load from crypto engine\n");
                return 0;
              }
              priv_key = ENGINE_load_private_key(conn->data->engine,key_file,
                                                 data->set.key_passwd);
              if (!priv_key) {
                failf(data, "failed to load private key from crypto engine\n");
                return 0;
              }
              if (SSL_CTX_use_PrivateKey(conn->ssl.ctx, priv_key) != 1) {
                failf(data, "unable to set private key\n");
                EVP_PKEY_free(priv_key);
                return 0;
              }
              EVP_PKEY_free(priv_key);  /* we don't need the handle any more... */
            }
            else {
              failf(data, "crypto engine not set, can't load private key\n");
              return 0;
            }
          }
    #else
          failf(data, "file type ENG for private key not supported\n");
          return 0;
    #endif
          break;
        default:
          failf(data, "not supported file type for private key\n");
          return 0;
        }
    
    #endif
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
        
    
        ssl=SSL_new(conn->ssl.ctx);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
        x509=SSL_get_certificate(ssl);
        
        if (x509 != NULL)
          EVP_PKEY_copy_parameters(X509_get_pubkey(x509),
    			       SSL_get_privatekey(ssl));
        SSL_free(ssl);
    
        /* If we are using DSA, we can copy the parameters from
         * the private key */
    		
        
        /* Now we know that a key and cert have been set against
         * the SSL context */
    
        if (!SSL_CTX_check_private_key(conn->ssl.ctx)) {
    
          failf(data, "Private key does not match the certificate public key");
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
          return(0);
        }
    
    #ifndef HAVE_USERDATA_IN_PWD_CALLBACK    
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
        /* erase it now */
        memset(global_passwd, 0, sizeof(global_passwd));
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
      }
      return(1);
    }
    
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    int cert_verify_callback(int ok, X509_STORE_CTX *ctx)
    {
      X509 *err_cert;
      char buf[256];
    
      err_cert=X509_STORE_CTX_get_current_cert(ctx);
      X509_NAME_oneline(X509_get_subject_name(err_cert),buf,256);
    
    
    #ifdef USE_SSLEAY
    /* "global" init done? */
    static int init_ssl=0;
    #endif
    
    
    /* Global init */
    void Curl_SSL_init(void)
    {
    #ifdef USE_SSLEAY
      /* make sure this is only done once */
    
      init_ssl++; /* never again */
    
    #ifdef HAVE_ENGINE_LOAD_BUILTIN_ENGINES
      ENGINE_load_builtin_engines();
    #endif
    
    
      /* Lets get nice error messages */
      SSL_load_error_strings();
    
      /* Setup all the global SSL stuff */
      SSLeay_add_ssl_algorithms();
    
    #else
      /* SSL disabled, do nothing */
    
    /* Global cleanup */
    void Curl_SSL_cleanup(void)
    {
    #ifdef USE_SSLEAY
      if(init_ssl) {
        /* only cleanup if we did a previous init */
    
        /* Free the SSL error strings */
        ERR_free_strings();
      
        /* EVP_cleanup() removes all ciphers and digests from the
           table. */
        EVP_cleanup();
    
    #ifdef HAVE_ENGINE_cleanup
        ENGINE_cleanup();
    #endif
    
    
      }
    #else
      /* SSL disabled, do nothing */
    #endif
    }
    
    #ifdef USE_SSLEAY
    
    
    /*
     * This function is called when an SSL connection is closed.
     */
    void Curl_SSL_Close(struct connectdata *conn)
    {
      if (conn->ssl.use) {
        /*
          ERR_remove_state() frees the error queue associated with
          thread pid.  If pid == 0, the current thread will have its
          error queue removed.
    
          Since error queue data structures are allocated
          automatically for new threads, they must be freed when
          threads are terminated in oder to avoid memory leaks.
        */
        ERR_remove_state(0);
    
        if(conn->ssl.handle) {
          (void)SSL_shutdown(conn->ssl.handle);
          SSL_set_connect_state(conn->ssl.handle);
    
          SSL_free (conn->ssl.handle);
          conn->ssl.handle = NULL;
        }
        if(conn->ssl.ctx) {
          SSL_CTX_free (conn->ssl.ctx);
          conn->ssl.ctx = NULL;
        }
        conn->ssl.use = FALSE; /* get back to ordinary socket usage */
      }
    }
    
    
    /*
     * This sets up a session cache to the specified size.
     */
    
    CURLcode Curl_SSL_InitSessions(struct SessionHandle *data, long amount)
    
        /* this is just a precaution to prevent multiple inits */
        return CURLE_OK;
    
      session = (struct curl_ssl_session *)
        malloc(amount * sizeof(struct curl_ssl_session));
      if(!session)
        return CURLE_OUT_OF_MEMORY;
    
      /* "blank out" the newly allocated memory */
      memset(session, 0, amount * sizeof(struct curl_ssl_session));
    
      /* store the info in the SSL section */
    
      data->state.session = session;
      data->state.sessionage = 1; /* this is brand new */
    
    
      return CURLE_OK;
    }
    
    /*
     * Check if there's a session ID for the given connection in the cache,
     * and if there's one suitable, it is returned.
     */
    static int Get_SSL_Session(struct connectdata *conn,
                               SSL_SESSION **ssl_sessionid)
    {
      struct curl_ssl_session *check;
    
      struct SessionHandle *data = conn->data;
    
      for(i=0; i< data->set.ssl.numsessions; i++) {
    
        if(!check->sessionid)
          /* not session ID means blank entry */
          continue;
    
        if(strequal(conn->name, check->name) &&
           (conn->remote_port == check->remote_port) ) {
    
          data->state.sessionage++;            /* increase general age */
          check->age = data->state.sessionage; /* set this as used in this age */
    
          *ssl_sessionid = check->sessionid;
          return FALSE;
        }
      }
      *ssl_sessionid = (SSL_SESSION *)NULL;
      return TRUE;
    }
    
    /*
     * Kill a single session ID entry in the cache.
     */
    static int Kill_Single_Session(struct curl_ssl_session *session)
    {
      if(session->sessionid) {
        /* defensive check */
    
        /* free the ID */
        SSL_SESSION_free(session->sessionid);
        session->sessionid=NULL;
        session->age = 0; /* fresh */
        free(session->name);
        session->name = NULL; /* no name */
    
        return 0; /* ok */
      }
      else
        return 1;
    }
    
    /*
     * This function is called when the 'data' struct is going away. Close
     * down everything and free all resources!
     */
    
    int Curl_SSL_Close_All(struct SessionHandle *data)
    
        for(i=0; i< data->set.ssl.numsessions; i++)
          /* the single-killer function handles empty table slots */
    
          Kill_Single_Session(&data->state.session[i]);
    
    #ifdef HAVE_OPENSSL_ENGINE_H
      if (data->engine)
      {
        ENGINE_free(data->engine);
        data->engine = NULL;
      }
    #endif
    
      return 0;
    }
    
    /*
     * Extract the session id and store it in the session cache.
     */
    static int Store_SSL_Session(struct connectdata *conn)
    {
      SSL_SESSION *ssl_sessionid;
      struct curl_ssl_session *store;
      int i;
    
      struct SessionHandle *data=conn->data; /* the mother of all structs */
    
      int oldest_age=data->state.session[0].age; /* zero if unused */
    
    
      /* ask OpenSSL, say please */
      ssl_sessionid = SSL_get1_session(conn->ssl.handle);
    
      /* SSL_get1_session() will increment the reference
         count and the session will stay in memory until explicitly freed with
         SSL_SESSION_free(3), regardless of its state. */
    
      /* Now we should add the session ID and the host name to the cache, (remove
         the oldest if necessary) */
    
      /* find an empty slot for us, or find the oldest */
    
      for(i=0; (i<data->set.ssl.numsessions) && data->state.session[i].sessionid; i++) {
        if(data->state.session[i].age < oldest_age) {
          oldest_age = data->state.session[i].age;
          store = &data->state.session[i];
    
        /* cache is full, we must "kill" the oldest entry! */
        Kill_Single_Session(store);
      else
    
        store = &data->state.session[i]; /* use this slot */
    
      
      /* now init the session struct wisely */
      store->sessionid = ssl_sessionid;
    
      store->age = data->state.sessionage;      /* set current age */
    
      store->name = strdup(conn->name);       /* clone host name */
      store->remote_port = conn->remote_port; /* port number */
    
    static int Curl_ASN1_UTCTIME_output(struct connectdata *conn,
                                        const char *prefix,
                                        ASN1_UTCTIME *tm)
    {
      char *asn1_string;
      int gmt=FALSE;
      int i;
      int year=0,month=0,day=0,hour=0,minute=0,second=0;
      struct SessionHandle *data = conn->data;
    
      if(!data->set.verbose)
        return 0;
    
      i=tm->length;
      asn1_string=(char *)tm->data;
    
      if (i < 10)
        return 1;
      if (asn1_string[i-1] == 'Z')
        gmt=TRUE;
      for (i=0; i<10; i++)
        if ((asn1_string[i] > '9') || (asn1_string[i] < '0'))
          return 2;
    
      year= (asn1_string[0]-'0')*10+(asn1_string[1]-'0');
      if (year < 50)
        year+=100;
    
      month= (asn1_string[2]-'0')*10+(asn1_string[3]-'0');
      if ((month > 12) || (month < 1))
        return 3;
    
      day= (asn1_string[4]-'0')*10+(asn1_string[5]-'0');
      hour= (asn1_string[6]-'0')*10+(asn1_string[7]-'0');
      minute=  (asn1_string[8]-'0')*10+(asn1_string[9]-'0');
    
      if ( (asn1_string[10] >= '0') && (asn1_string[10] <= '9') &&
           (asn1_string[11] >= '0') && (asn1_string[11] <= '9'))
        second= (asn1_string[10]-'0')*10+(asn1_string[11]-'0');
      
      infof(data,
            "%s%04d-%02d-%02d %02d:%02d:%02d %s\n",
            prefix, year+1900, month, day, hour, minute, second, (gmt?"GMT":""));
    
      return 0;
    }
    
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    /* ====================================================== */
    
    Curl_SSLConnect(struct connectdata *conn)
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    {
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    #ifdef USE_SSLEAY
    
      struct SessionHandle *data = conn->data;
    
      int err;
      char * str;
      SSL_METHOD *req_method;
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      /* mark this is being ssl enabled from here on out. */
      conn->ssl.use = TRUE;
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      /* Make funny stuff to get random input */
      random_the_seed(conn);
    
    
      /* check to see if we've been told to use an explicit SSL/TLS version */
    
      case CURL_SSLVERSION_DEFAULT:
        /* we try to figure out version */
    
        req_method = SSLv23_client_method();
        break;
    
      case CURL_SSLVERSION_TLSv1:
        req_method = TLSv1_client_method();
        break;
      case CURL_SSLVERSION_SSLv2:
    
        req_method = SSLv2_client_method();
        break;
    
        req_method = SSLv3_client_method();
        break;
      }
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
        
    
      conn->ssl.ctx = SSL_CTX_new(req_method);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      if(!conn->ssl.ctx) {
        failf(data, "SSL: couldn't create a context!");
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
        
    
        if (!cert_stuff(conn,
                        data->set.cert,
                        data->set.cert_type,
                        data->set.key,
                        data->set.key_type)) {
    
          /* failf() is already done in cert_stuff() */
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
        }
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      if(data->set.ssl.cipher_list) {
        if (!SSL_CTX_set_cipher_list(conn->ssl.ctx,
                                     data->set.ssl.cipher_list)) {
    
          failf(data, "failed setting cipher list");
    
          return CURLE_SSL_CONNECT_ERROR;
        }
      }
    
    
        SSL_CTX_set_verify(conn->ssl.ctx,
                           SSL_VERIFY_PEER|SSL_VERIFY_FAIL_IF_NO_PEER_CERT|
                           SSL_VERIFY_CLIENT_ONCE,
                           cert_verify_callback);
        if (!SSL_CTX_load_verify_locations(conn->ssl.ctx,
    
                                           data->set.ssl.CAfile,
                                           data->set.ssl.CApath)) {
    
          failf(data,"error setting cerficate verify locations");
    
      }
      else
        SSL_CTX_set_verify(conn->ssl.ctx, SSL_VERIFY_NONE, cert_verify_callback);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      /* Lets make an SSL structure */
      conn->ssl.handle = SSL_new (conn->ssl.ctx);
      SSL_set_connect_state (conn->ssl.handle);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      conn->ssl.server_cert = 0x0;
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      if(!conn->bits.reuse) {
        /* We're not re-using a connection, check if there's a cached ID we
           can/should use here! */
        if(!Get_SSL_Session(conn, &ssl_sessionid)) {
          /* we got a session id, use it! */
          SSL_set_session(conn->ssl.handle, ssl_sessionid);
          /* Informational message */
          infof (data, "SSL re-using session ID\n");
        }
      }
    
    
      /* pass the raw socket into the SSL layers */
    
      SSL_set_fd(conn->ssl.handle, conn->firstsocket);
    
      do {
        int what;
        fd_set writefd;
        fd_set readfd;
        struct timeval interval;
        long timeout_ms;
    
        err = SSL_connect(conn->ssl.handle);
    
        what = SSL_get_error(conn->ssl.handle, err);
    
        FD_ZERO(&writefd);
        FD_ZERO(&readfd);
    
        if(SSL_ERROR_WANT_READ == what)
          FD_SET(conn->firstsocket, &readfd);
        else if(SSL_ERROR_WANT_WRITE == what)
          FD_SET(conn->firstsocket, &writefd);
        else
          break; /* untreated error */
    
        /* Find out if any timeout is set. If not, use 300 seconds.
           Otherwise, figure out the most strict timeout of the two possible one
           and then how much time that has elapsed to know how much time we
           allow for the connect call */
        if(data->set.timeout || data->set.connecttimeout) {
          double has_passed;
    
          /* Evaluate in milliseconds how much time that has passed */
          has_passed = Curl_tvdiff(Curl_tvnow(), data->progress.start);
    
    #ifndef min
    #define min(a, b)   ((a) < (b) ? (a) : (b))
    #endif
    
          /* get the most strict timeout of the ones converted to milliseconds */
          if(data->set.timeout &&
             (data->set.timeout>data->set.connecttimeout))
            timeout_ms = data->set.timeout*1000;
          else
            timeout_ms = data->set.connecttimeout*1000;
          
          /* subtract the passed time */
          timeout_ms -= (long)has_passed;
          
          if(timeout_ms < 0)
            /* a precaution, no need to continue if time already is up */
            return CURLE_OPERATION_TIMEOUTED;      
        }
        else
          /* no particular time-out has been set */
          timeout_ms=300000; /* milliseconds, default to five minutes */
    
        interval.tv_sec = timeout_ms/1000;
        timeout_ms -= interval.tv_sec*1000;
    
        interval.tv_usec = timeout_ms*1000;
    
        what = select(conn->firstsocket+1, &readfd, &writefd, NULL, &interval);
        if(what > 0)
          /* reabable or writable, go loop yourself */
          continue;
        else if(0 == what) {
          /* timeout */
          failf(data, "SSL connection timeout");
          return CURLE_OPERATION_TIMEOUTED;
        }
        else
          break; /* get out of loop */
      } while(1);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      /* 1  is fine
         0  is "not successful but was shut down controlled"
         <0 is "handshake was not successful, because a fatal error occurred" */
      if (err <= 0) {
    
        err = ERR_get_error(); 
        failf(data, "SSL: %s", ERR_error_string(err, NULL));
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      /* Informational message */
      infof (data, "SSL connection using %s\n",
             SSL_get_cipher(conn->ssl.handle));
    
    
      if(!ssl_sessionid) {
        /* Since this is not a cached session ID, then we want to stach this one
           in the cache! */
        Store_SSL_Session(conn);
      }
    
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
      
    
      /* Get server's certificate (note: beware of dynamic allocation) - opt */
      /* major serious hack alert -- we should check certificates
       * to authenticate the server; otherwise we risk man-in-the-middle
       * attack
       */
    
      conn->ssl.server_cert = SSL_get_peer_certificate (conn->ssl.handle);
      if(!conn->ssl.server_cert) {
        failf(data, "SSL: couldn't get peer certificate!");
    
      }
      infof (data, "Server certificate:\n");
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
      
    
      str = X509_NAME_oneline (X509_get_subject_name (conn->ssl.server_cert),
                               NULL, 0);
      if(!str) {
        failf(data, "SSL: couldn't get X509-subject!");
    
      }
      infof(data, "\t subject: %s\n", str);
      CRYPTO_free(str);
    
    
      certdate = X509_get_notBefore(conn->ssl.server_cert);
      Curl_ASN1_UTCTIME_output(conn, "\t start date: ", certdate);
    
      certdate = X509_get_notAfter(conn->ssl.server_cert);
      Curl_ASN1_UTCTIME_output(conn, "\t expire date: ", certdate);
    
    
        if (X509_NAME_get_text_by_NID(X509_get_subject_name(conn->ssl.server_cert),
                                      NID_commonName,
                                      peer_CN,
                                      sizeof(peer_CN)) < 0) {
    
          failf(data, "SSL: unable to obtain common name from peer certificate");
          X509_free(conn->ssl.server_cert);
          return CURLE_SSL_PEER_CERTIFICATE;
        }
    
    
        if (!strequal(peer_CN, conn->hostname)) {
    
            failf(data, "SSL: certificate subject name '%s' does not match "
                  "target host name '%s'",
                  peer_CN, conn->hostname);
    
            X509_free(conn->ssl.server_cert);
            return CURLE_SSL_PEER_CERTIFICATE;
          }
          else
    
            infof(data,
                  "\t common name: %s (does not match '%s')\n",
                  peer_CN, conn->hostname);
    
        }
        else
          infof(data, "\t common name: %s (matched)\n", peer_CN);
      }
    
    
      str = X509_NAME_oneline (X509_get_issuer_name  (conn->ssl.server_cert),
                               NULL, 0);
      if(!str) {
        failf(data, "SSL: couldn't get X509-issuer name!");
    
      }
      infof(data, "\t issuer: %s\n", str);
      CRYPTO_free(str);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      /* We could do all sorts of certificate verification stuff here before
         deallocating the certificate. */
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      if(data->set.ssl.verifypeer) {
        data->set.ssl.certverifyresult=SSL_get_verify_result(conn->ssl.handle);
        if (data->set.ssl.certverifyresult != X509_V_OK) {
    
          failf(data, "SSL certificate verify result: %d",
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    
    
      X509_free(conn->ssl.server_cert);
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    #else /* USE_SSLEAY */
    
      /* this is for "-ansi -Wall -pedantic" to stop complaining!   (rabe) */
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    #endif
    
    Daniel Stenberg's avatar
    Daniel Stenberg committed
    }
    
    
    /*
     * local variables:
     * eval: (load-file "../curl-mode.el")
     * end:
    
     * vim600: fdm=marker
     * vim: et sw=2 ts=2 sts=2 tw=78