git.sur5r.net Git - openldap/blob - libraries/libldap/tls.c

   1 /* tls.c - Handle tls/ssl using SSLeay or OpenSSL. */
   2 /* $OpenLDAP$ */
   3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
   4  *
   5  * Copyright 1998-2005 The OpenLDAP Foundation.
   6  * All rights reserved.
   7  *
   8  * Redistribution and use in source and binary forms, with or without
   9  * modification, are permitted only as authorized by the OpenLDAP
  10  * Public License.
  11  *
  12  * A copy of this license is available in the file LICENSE in the
  13  * top-level directory of the distribution or, alternatively, at
  14  * <http://www.OpenLDAP.org/license.html>.
  15  */
  16
  17 #include "portable.h"
  18 #include "ldap_config.h"
  19
  20 #include <stdio.h>
  21
  22 #include <ac/stdlib.h>
  23 #include <ac/errno.h>
  24 #include <ac/socket.h>
  25 #include <ac/string.h>
  26 #include <ac/ctype.h>
  27 #include <ac/time.h>
  28 #include <ac/unistd.h>
  29 #include <ac/param.h>
  30 #include <ac/dirent.h>
  31
  32 #include "ldap-int.h"
  33
  34 #ifdef HAVE_TLS
  35
  36 #ifdef LDAP_R_COMPILE
  37 #include <ldap_pvt_thread.h>
  38 #endif
  39
  40 #ifdef HAVE_OPENSSL_SSL_H
  41 #include <openssl/ssl.h>
  42 #include <openssl/x509v3.h>
  43 #include <openssl/err.h>
  44 #include <openssl/rand.h>
  45 #include <openssl/safestack.h>
  46 #elif defined( HAVE_SSL_H )
  47 #include <ssl.h>
  48 #endif
  49
  50 static int  tls_opt_trace = 1;
  51 static char *tls_opt_certfile = NULL;
  52 static char *tls_opt_keyfile = NULL;
  53 static char *tls_opt_cacertfile = NULL;
  54 static char *tls_opt_cacertdir = NULL;
  55 static int  tls_opt_require_cert = LDAP_OPT_X_TLS_DEMAND;
  56 #ifdef HAVE_OPENSSL_CRL
  57 static int  tls_opt_crlcheck = LDAP_OPT_X_TLS_CRL_NONE;
  58 #endif
  59 static char *tls_opt_ciphersuite = NULL;
  60 static char *tls_opt_randfile = NULL;
  61
  62 #define HAS_TLS( sb )   ber_sockbuf_ctrl( sb, LBER_SB_OPT_HAS_IO, \
  63                                 (void *)&sb_tls_sbio )
  64
  65 static void tls_report_error( void );
  66
  67 static void tls_info_cb( const SSL *ssl, int where, int ret );
  68 static int tls_verify_cb( int ok, X509_STORE_CTX *ctx );
  69 static int tls_verify_ok( int ok, X509_STORE_CTX *ctx );
  70 static RSA * tls_tmp_rsa_cb( SSL *ssl, int is_export, int key_length );
  71 static STACK_OF(X509_NAME) * get_ca_list( char * bundle, char * dir );
  72
  73 #if 0   /* Currently this is not used by anyone */
  74 static DH * tls_tmp_dh_cb( SSL *ssl, int is_export, int key_length );
  75 #endif
  76
  77 static SSL_CTX *tls_def_ctx = NULL;
  78
  79 static int tls_seed_PRNG( const char *randfile );
  80
  81 #ifdef LDAP_R_COMPILE
  82 /*
  83  * provide mutexes for the SSLeay library.
  84  */
  85 static ldap_pvt_thread_mutex_t  tls_mutexes[CRYPTO_NUM_LOCKS];
  86
  87 static void tls_locking_cb( int mode, int type, const char *file, int line )
  88 {
  89         if ( mode & CRYPTO_LOCK ) {
  90                 ldap_pvt_thread_mutex_lock( &tls_mutexes[type] );
  91         } else {
  92                 ldap_pvt_thread_mutex_unlock( &tls_mutexes[type] );
  93         }
  94 }
  95
  96 /*
  97  * an extra mutex for the default ctx.
  98  */
  99
 100 static ldap_pvt_thread_mutex_t tls_def_ctx_mutex;
 101
 102 static void tls_init_threads( void )
 103 {
 104         int i;
 105
 106         for( i=0; i< CRYPTO_NUM_LOCKS ; i++ ) {
 107                 ldap_pvt_thread_mutex_init( &tls_mutexes[i] );
 108         }
 109         CRYPTO_set_locking_callback( tls_locking_cb );
 110         /* FIXME: the thread id should be added somehow... */
 111
 112         ldap_pvt_thread_mutex_init( &tls_def_ctx_mutex );
 113 }
 114 #endif /* LDAP_R_COMPILE */
 115
 116 /*
 117  * Tear down the TLS subsystem. Should only be called once.
 118  */
 119 void
 120 ldap_pvt_tls_destroy( void )
 121 {
 122         SSL_CTX_free(tls_def_ctx);
 123         tls_def_ctx = NULL;
 124
 125         EVP_cleanup();
 126         ERR_remove_state(0);
 127         ERR_free_strings();
 128
 129         if ( tls_opt_certfile ) {
 130                 LDAP_FREE( tls_opt_certfile );
 131                 tls_opt_certfile = NULL;
 132         }
 133         if ( tls_opt_keyfile ) {
 134                 LDAP_FREE( tls_opt_keyfile );
 135                 tls_opt_keyfile = NULL;
 136         }
 137         if ( tls_opt_cacertfile ) {
 138                 LDAP_FREE( tls_opt_cacertfile );
 139                 tls_opt_cacertfile = NULL;
 140         }
 141         if ( tls_opt_cacertdir ) {
 142                 LDAP_FREE( tls_opt_cacertdir );
 143                 tls_opt_cacertdir = NULL;
 144         }
 145         if ( tls_opt_ciphersuite ) {
 146                 LDAP_FREE( tls_opt_ciphersuite );
 147                 tls_opt_ciphersuite = NULL;
 148         }
 149         if ( tls_opt_randfile ) {
 150                 LDAP_FREE( tls_opt_randfile );
 151                 tls_opt_randfile = NULL;
 152         }
 153 }
 154
 155 /*
 156  * Initialize TLS subsystem. Should be called only once.
 157  */
 158 int
 159 ldap_pvt_tls_init( void )
 160 {
 161         static int tls_initialized = 0;
 162
 163         if ( tls_initialized++ ) return 0;
 164
 165 #ifdef HAVE_EBCDIC
 166         {
 167                 char *file = LDAP_STRDUP( tls_opt_randfile );
 168                 if ( file ) __atoe( file );
 169                 (void) tls_seed_PRNG( file );
 170                 LDAP_FREE( file );
 171         }
 172 #else
 173         (void) tls_seed_PRNG( tls_opt_randfile );
 174 #endif
 175
 176 #ifdef LDAP_R_COMPILE
 177         tls_init_threads();
 178 #endif
 179
 180         SSL_load_error_strings();
 181         SSLeay_add_ssl_algorithms();
 182
 183         /* FIXME: mod_ssl does this */
 184         X509V3_add_standard_extensions();
 185         return 0;
 186 }
 187
 188 /*
 189  * initialize the default context
 190  */
 191 int
 192 ldap_pvt_tls_init_def_ctx( void )
 193 {
 194         STACK_OF(X509_NAME) *calist;
 195         int rc = 0;
 196         char *ciphersuite = tls_opt_ciphersuite;
 197         char *cacertfile = tls_opt_cacertfile;
 198         char *cacertdir = tls_opt_cacertdir;
 199         char *certfile = tls_opt_certfile;
 200         char *keyfile = tls_opt_keyfile;
 201
 202 #ifdef LDAP_R_COMPILE
 203         ldap_pvt_thread_mutex_lock( &tls_def_ctx_mutex );
 204 #endif
 205         if (( !cacertfile && !cacertdir ) || !certfile || !keyfile )
 206                 return LDAP_NOT_SUPPORTED;
 207
 208 #ifdef HAVE_EBCDIC
 209         /* This ASCII/EBCDIC handling is a real pain! */
 210         if ( ciphersuite ) {
 211                 ciphersuite = LDAP_STRDUP( ciphersuite );
 212                 __atoe( ciphersuite );
 213         }
 214         if ( cacertfile ) {
 215                 cacertfile = LDAP_STRDUP( cacertfile );
 216                 __atoe( cacertfile );
 217         }
 218         if ( cacertdir ) {
 219                 cacertdir = LDAP_STRDUP( cacertdir );
 220                 __atoe( cacertdir );
 221         }
 222         if ( certfile ) {
 223                 certfile = LDAP_STRDUP( certfile );
 224                 __atoe( certfile );
 225         }
 226         if ( keyfile ) {
 227                 keyfile = LDAP_STRDUP( keyfile );
 228                 __atoe( keyfile );
 229         }
 230 #endif
 231         if ( tls_def_ctx == NULL ) {
 232                 int i;
 233                 tls_def_ctx = SSL_CTX_new( SSLv23_method() );
 234                 if ( tls_def_ctx == NULL ) {
 235                         Debug( LDAP_DEBUG_ANY,
 236                            "TLS: could not allocate default ctx (%lu).\n",
 237                                 ERR_peek_error(),0,0);
 238                         rc = -1;
 239                         goto error_exit;
 240                 }
 241
 242                 SSL_CTX_set_session_id_context( tls_def_ctx,
 243                         (const unsigned char *) "OpenLDAP", sizeof("OpenLDAP")-1 );
 244
 245                 if ( tls_opt_ciphersuite &&
 246                         !SSL_CTX_set_cipher_list( tls_def_ctx, ciphersuite ) )
 247                 {
 248                         Debug( LDAP_DEBUG_ANY,
 249                                    "TLS: could not set cipher list %s.\n",
 250                                    tls_opt_ciphersuite, 0, 0 );
 251                         tls_report_error();
 252                         rc = -1;
 253                         goto error_exit;
 254                 }
 255
 256                 if (tls_opt_cacertfile != NULL || tls_opt_cacertdir != NULL) {
 257                         if ( !SSL_CTX_load_verify_locations( tls_def_ctx,
 258                                         cacertfile, cacertdir ) ||
 259                                 !SSL_CTX_set_default_verify_paths( tls_def_ctx ) )
 260                         {
 261                                 Debug( LDAP_DEBUG_ANY, "TLS: "
 262                                         "could not load verify locations (file:`%s',dir:`%s').\n",
 263                                         tls_opt_cacertfile ? tls_opt_cacertfile : "",
 264                                         tls_opt_cacertdir ? tls_opt_cacertdir : "",
 265                                         0 );
 266                                 tls_report_error();
 267                                 rc = -1;
 268                                 goto error_exit;
 269                         }
 270
 271                         calist = get_ca_list( cacertfile, cacertdir );
 272                         if ( !calist ) {
 273                                 Debug( LDAP_DEBUG_ANY, "TLS: "
 274                                         "could not load client CA list (file:`%s',dir:`%s').\n",
 275                                         tls_opt_cacertfile ? tls_opt_cacertfile : "",
 276                                         tls_opt_cacertdir ? tls_opt_cacertdir : "",
 277                                         0 );
 278                                 tls_report_error();
 279                                 rc = -1;
 280                                 goto error_exit;
 281                         }
 282
 283                         SSL_CTX_set_client_CA_list( tls_def_ctx, calist );
 284                 }
 285
 286                 if ( tls_opt_keyfile &&
 287                         !SSL_CTX_use_PrivateKey_file( tls_def_ctx,
 288                                 keyfile, SSL_FILETYPE_PEM ) )
 289                 {
 290                         Debug( LDAP_DEBUG_ANY,
 291                                 "TLS: could not use key file `%s'.\n",
 292                                 tls_opt_keyfile,0,0);
 293                         tls_report_error();
 294                         rc = -1;
 295                         goto error_exit;
 296                 }
 297
 298                 if ( tls_opt_certfile &&
 299                         !SSL_CTX_use_certificate_file( tls_def_ctx,
 300                                 certfile, SSL_FILETYPE_PEM ) )
 301                 {
 302                         Debug( LDAP_DEBUG_ANY,
 303                                 "TLS: could not use certificate `%s'.\n",
 304                                 tls_opt_certfile,0,0);
 305                         tls_report_error();
 306                         rc = -1;
 307                         goto error_exit;
 308                 }
 309
 310                 if ( ( tls_opt_certfile || tls_opt_keyfile ) &&
 311                         !SSL_CTX_check_private_key( tls_def_ctx ) )
 312                 {
 313                         Debug( LDAP_DEBUG_ANY,
 314                                 "TLS: private key mismatch.\n",
 315                                 0,0,0);
 316                         tls_report_error();
 317                         rc = -1;
 318                         goto error_exit;
 319                 }
 320
 321                 if ( tls_opt_trace ) {
 322                         SSL_CTX_set_info_callback( tls_def_ctx, tls_info_cb );
 323                 }
 324
 325                 i = SSL_VERIFY_NONE;
 326                 if ( tls_opt_require_cert ) {
 327                         i = SSL_VERIFY_PEER;
 328                         if ( tls_opt_require_cert == LDAP_OPT_X_TLS_DEMAND ||
 329                                  tls_opt_require_cert == LDAP_OPT_X_TLS_HARD ) {
 330                                 i |= SSL_VERIFY_FAIL_IF_NO_PEER_CERT;
 331                         }
 332                 }
 333
 334                 SSL_CTX_set_verify( tls_def_ctx, i,
 335                         tls_opt_require_cert == LDAP_OPT_X_TLS_ALLOW ?
 336                         tls_verify_ok : tls_verify_cb );
 337                 SSL_CTX_set_tmp_rsa_callback( tls_def_ctx, tls_tmp_rsa_cb );
 338                 /* SSL_CTX_set_tmp_dh_callback( tls_def_ctx, tls_tmp_dh_cb ); */
 339 #ifdef HAVE_OPENSSL_CRL
 340                 if ( tls_opt_crlcheck ) {
 341                         X509_STORE *x509_s = SSL_CTX_get_cert_store( tls_def_ctx );
 342                         if ( tls_opt_crlcheck == LDAP_OPT_X_TLS_CRL_PEER ) {
 343                                 X509_STORE_set_flags( x509_s, X509_V_FLAG_CRL_CHECK );
 344                         } else if ( tls_opt_crlcheck == LDAP_OPT_X_TLS_CRL_ALL ) {
 345                                 X509_STORE_set_flags( x509_s,
 346                                                 X509_V_FLAG_CRL_CHECK | X509_V_FLAG_CRL_CHECK_ALL  );
 347                         }
 348                 }
 349 #endif
 350         }
 351 error_exit:
 352         if ( rc == -1 && tls_def_ctx != NULL ) {
 353                 SSL_CTX_free( tls_def_ctx );
 354                 tls_def_ctx = NULL;
 355         }
 356 #ifdef HAVE_EBCDIC
 357         LDAP_FREE( ciphersuite );
 358         LDAP_FREE( cacertfile );
 359         LDAP_FREE( cacertdir );
 360         LDAP_FREE( certfile );
 361         LDAP_FREE( keyfile );
 362 #endif
 363 #ifdef LDAP_R_COMPILE
 364         ldap_pvt_thread_mutex_unlock( &tls_def_ctx_mutex );
 365 #endif
 366         return rc;
 367 }
 368
 369 static STACK_OF(X509_NAME) *
 370 get_ca_list( char * bundle, char * dir )
 371 {
 372         STACK_OF(X509_NAME) *ca_list = NULL;
 373
 374         if ( bundle ) {
 375                 ca_list = SSL_load_client_CA_file( bundle );
 376         }
 377 #if defined(HAVE_DIRENT_H) || defined(dirent)
 378         if ( dir ) {
 379                 int freeit = 0;
 380
 381                 if ( !ca_list ) {
 382                         ca_list = sk_X509_NAME_new_null();
 383                         freeit = 1;
 384                 }
 385                 if ( !SSL_add_dir_cert_subjects_to_stack( ca_list, dir ) &&
 386                         freeit ) {
 387                         sk_X509_NAME_free( ca_list );
 388                         ca_list = NULL;
 389                 }
 390         }
 391 #endif
 392         return ca_list;
 393 }
 394
 395 static SSL *
 396 alloc_handle( void *ctx_arg )
 397 {
 398         SSL_CTX *ctx;
 399         SSL     *ssl;
 400
 401         if ( ctx_arg ) {
 402                 ctx = (SSL_CTX *) ctx_arg;
 403         } else {
 404                 if ( ldap_pvt_tls_init_def_ctx() < 0 ) return NULL;
 405                 ctx = tls_def_ctx;
 406         }
 407
 408         ssl = SSL_new( ctx );
 409         if ( ssl == NULL ) {
 410                 Debug( LDAP_DEBUG_ANY,"TLS: can't create ssl handle.\n",0,0,0);
 411                 return NULL;
 412         }
 413         return ssl;
 414 }
 415
 416 static int
 417 update_flags( Sockbuf *sb, SSL * ssl, int rc )
 418 {
 419         int err = SSL_get_error(ssl, rc);
 420
 421         sb->sb_trans_needs_read  = 0;
 422         sb->sb_trans_needs_write = 0;
 423
 424         if (err == SSL_ERROR_WANT_READ) {
 425                 sb->sb_trans_needs_read  = 1;
 426                 return 1;
 427
 428         } else if (err == SSL_ERROR_WANT_WRITE) {
 429                 sb->sb_trans_needs_write = 1;
 430                 return 1;
 431
 432         } else if (err == SSL_ERROR_WANT_CONNECT) {
 433                 return 1;
 434         }
 435         return 0;
 436 }
 437
 438 /*
 439  * TLS support for LBER Sockbufs
 440  */
 441
 442 struct tls_data {
 443         SSL                     *ssl;
 444         Sockbuf_IO_Desc         *sbiod;
 445 };
 446
 447 static BIO_METHOD sb_tls_bio_method;
 448
 449 static int
 450 sb_tls_setup( Sockbuf_IO_Desc *sbiod, void *arg )
 451 {
 452         struct tls_data         *p;
 453         BIO                     *bio;
 454
 455         assert( sbiod != NULL );
 456
 457         p = LBER_MALLOC( sizeof( *p ) );
 458         if ( p == NULL ) {
 459                 return -1;
 460         }
 461
 462         p->ssl = (SSL *)arg;
 463         p->sbiod = sbiod;
 464         bio = BIO_new( &sb_tls_bio_method );
 465         bio->ptr = (void *)p;
 466         SSL_set_bio( p->ssl, bio, bio );
 467         sbiod->sbiod_pvt = p;
 468         return 0;
 469 }
 470
 471 static int
 472 sb_tls_remove( Sockbuf_IO_Desc *sbiod )
 473 {
 474         struct tls_data         *p;
 475
 476         assert( sbiod != NULL );
 477         assert( sbiod->sbiod_pvt != NULL );
 478
 479         p = (struct tls_data *)sbiod->sbiod_pvt;
 480         SSL_free( p->ssl );
 481         LBER_FREE( sbiod->sbiod_pvt );
 482         sbiod->sbiod_pvt = NULL;
 483         return 0;
 484 }
 485
 486 static int
 487 sb_tls_close( Sockbuf_IO_Desc *sbiod )
 488 {
 489         struct tls_data         *p;
 490
 491         assert( sbiod != NULL );
 492         assert( sbiod->sbiod_pvt != NULL );
 493
 494         p = (struct tls_data *)sbiod->sbiod_pvt;
 495         SSL_shutdown( p->ssl );
 496         return 0;
 497 }
 498
 499 static int
 500 sb_tls_ctrl( Sockbuf_IO_Desc *sbiod, int opt, void *arg )
 501 {
 502         struct tls_data         *p;
 503
 504         assert( sbiod != NULL );
 505         assert( sbiod->sbiod_pvt != NULL );
 506
 507         p = (struct tls_data *)sbiod->sbiod_pvt;
 508
 509         if ( opt == LBER_SB_OPT_GET_SSL ) {
 510                 *((SSL **)arg) = p->ssl;
 511                 return 1;
 512
 513         } else if ( opt == LBER_SB_OPT_DATA_READY ) {
 514                 if( SSL_pending( p->ssl ) > 0 ) {
 515                         return 1;
 516                 }
 517         }
 518
 519         return LBER_SBIOD_CTRL_NEXT( sbiod, opt, arg );
 520 }
 521
 522 static ber_slen_t
 523 sb_tls_read( Sockbuf_IO_Desc *sbiod, void *buf, ber_len_t len)
 524 {
 525         struct tls_data         *p;
 526         ber_slen_t              ret;
 527         int                     err;
 528
 529         assert( sbiod != NULL );
 530         assert( SOCKBUF_VALID( sbiod->sbiod_sb ) );
 531
 532         p = (struct tls_data *)sbiod->sbiod_pvt;
 533
 534         ret = SSL_read( p->ssl, (char *)buf, len );
 535 #ifdef HAVE_WINSOCK
 536         errno = WSAGetLastError();
 537 #endif
 538         err = SSL_get_error( p->ssl, ret );
 539         if (err == SSL_ERROR_WANT_READ ) {
 540                 sbiod->sbiod_sb->sb_trans_needs_read = 1;
 541                 errno = EWOULDBLOCK;
 542         }
 543         else
 544                 sbiod->sbiod_sb->sb_trans_needs_read = 0;
 545         return ret;
 546 }
 547
 548 static ber_slen_t
 549 sb_tls_write( Sockbuf_IO_Desc *sbiod, void *buf, ber_len_t len)
 550 {
 551         struct tls_data         *p;
 552         ber_slen_t              ret;
 553         int                     err;
 554
 555         assert( sbiod != NULL );
 556         assert( SOCKBUF_VALID( sbiod->sbiod_sb ) );
 557
 558         p = (struct tls_data *)sbiod->sbiod_pvt;
 559
 560         ret = SSL_write( p->ssl, (char *)buf, len );
 561 #ifdef HAVE_WINSOCK
 562         errno = WSAGetLastError();
 563 #endif
 564         err = SSL_get_error( p->ssl, ret );
 565         if (err == SSL_ERROR_WANT_WRITE ) {
 566                 sbiod->sbiod_sb->sb_trans_needs_write = 1;
 567                 errno = EWOULDBLOCK;
 568
 569         } else {
 570                 sbiod->sbiod_sb->sb_trans_needs_write = 0;
 571         }
 572         return ret;
 573 }
 574
 575 static Sockbuf_IO sb_tls_sbio =
 576 {
 577         sb_tls_setup,           /* sbi_setup */
 578         sb_tls_remove,          /* sbi_remove */
 579         sb_tls_ctrl,            /* sbi_ctrl */
 580         sb_tls_read,            /* sbi_read */
 581         sb_tls_write,           /* sbi_write */
 582         sb_tls_close            /* sbi_close */
 583 };
 584
 585 static int
 586 sb_tls_bio_create( BIO *b ) {
 587         b->init = 1;
 588         b->num = 0;
 589         b->ptr = NULL;
 590         b->flags = 0;
 591         return 1;
 592 }
 593
 594 static int
 595 sb_tls_bio_destroy( BIO *b )
 596 {
 597         if ( b == NULL ) return 0;
 598
 599         b->ptr = NULL;          /* sb_tls_remove() will free it */
 600         b->init = 0;
 601         b->flags = 0;
 602         return 1;
 603 }
 604
 605 static int
 606 sb_tls_bio_read( BIO *b, char *buf, int len )
 607 {
 608         struct tls_data         *p;
 609         int                     ret;
 610
 611         if ( buf == NULL || len <= 0 ) return 0;
 612
 613         p = (struct tls_data *)b->ptr;
 614
 615         if ( p == NULL || p->sbiod == NULL ) {
 616                 return 0;
 617         }
 618
 619         ret = LBER_SBIOD_READ_NEXT( p->sbiod, buf, len );
 620
 621         BIO_clear_retry_flags( b );
 622         if ( ret < 0 ) {
 623                 int err = errno;
 624                 if ( err == EAGAIN || err == EWOULDBLOCK ) {
 625                         BIO_set_retry_read( b );
 626                 }
 627         }
 628
 629         return ret;
 630 }
 631
 632 static int
 633 sb_tls_bio_write( BIO *b, const char *buf, int len )
 634 {
 635         struct tls_data         *p;
 636         int                     ret;
 637
 638         if ( buf == NULL || len <= 0 ) return 0;
 639
 640         p = (struct tls_data *)b->ptr;
 641
 642         if ( p == NULL || p->sbiod == NULL ) {
 643                 return 0;
 644         }
 645
 646         ret = LBER_SBIOD_WRITE_NEXT( p->sbiod, (char *)buf, len );
 647
 648         BIO_clear_retry_flags( b );
 649         if ( ret < 0 ) {
 650                 int err = errno;
 651                 if ( err == EAGAIN || err == EWOULDBLOCK ) {
 652                         BIO_set_retry_write( b );
 653                 }
 654         }
 655
 656         return ret;
 657 }
 658
 659 static long
 660 sb_tls_bio_ctrl( BIO *b, int cmd, long num, void *ptr )
 661 {
 662         if ( cmd == BIO_CTRL_FLUSH ) {
 663                 /* The OpenSSL library needs this */
 664                 return 1;
 665         }
 666         return 0;
 667 }
 668
 669 static int
 670 sb_tls_bio_gets( BIO *b, char *buf, int len )
 671 {
 672         return -1;
 673 }
 674
 675 static int
 676 sb_tls_bio_puts( BIO *b, const char *str )
 677 {
 678         return sb_tls_bio_write( b, str, strlen( str ) );
 679 }
 680
 681 static BIO_METHOD sb_tls_bio_method =
 682 {
 683         ( 100 | 0x400 ),                /* it's a source/sink BIO */
 684         "sockbuf glue",
 685         sb_tls_bio_write,
 686         sb_tls_bio_read,
 687         sb_tls_bio_puts,
 688         sb_tls_bio_gets,
 689         sb_tls_bio_ctrl,
 690         sb_tls_bio_create,
 691         sb_tls_bio_destroy
 692 };
 693
 694 /*
 695  * Call this to do a TLS connect on a sockbuf. ctx_arg can be
 696  * a SSL_CTX * or NULL, in which case the default ctx is used.
 697  *
 698  * Return value:
 699  *
 700  *  0 - Success. Connection is ready for communication.
 701  * <0 - Error. Can't create a TLS stream.
 702  * >0 - Partial success.
 703  *        Do a select (using information from lber_pvt_sb_needs_{read,write}
 704  *              and call again.
 705  */
 706
 707 static int
 708 ldap_int_tls_connect( LDAP *ld, LDAPConn *conn )
 709 {
 710         Sockbuf *sb = conn->lconn_sb;
 711         int     err;
 712         SSL     *ssl;
 713
 714         if ( HAS_TLS( sb ) ) {
 715                 ber_sockbuf_ctrl( sb, LBER_SB_OPT_GET_SSL, (void *)&ssl );
 716
 717         } else {
 718                 struct ldapoptions *lo;
 719                 void *ctx = ld->ld_defconn
 720                         ? ld->ld_defconn->lconn_tls_ctx : NULL;
 721
 722                 ssl = alloc_handle( ctx );
 723
 724                 if ( ssl == NULL ) return -1;
 725
 726 #ifdef LDAP_DEBUG
 727                 ber_sockbuf_add_io( sb, &ber_sockbuf_io_debug,
 728                         LBER_SBIOD_LEVEL_TRANSPORT, (void *)"tls_" );
 729 #endif
 730                 ber_sockbuf_add_io( sb, &sb_tls_sbio,
 731                         LBER_SBIOD_LEVEL_TRANSPORT, (void *)ssl );
 732
 733                 if( ctx == NULL ) {
 734                         ctx = tls_def_ctx;
 735                         conn->lconn_tls_ctx = tls_def_ctx;
 736                 }
 737                 lo = &ld->ld_options;
 738                 if ( lo->ldo_tls_connect_cb )
 739                         lo->ldo_tls_connect_cb( ld, ssl, ctx, lo->ldo_tls_connect_arg );
 740                 lo = LDAP_INT_GLOBAL_OPT();
 741                 if ( lo && lo->ldo_tls_connect_cb )
 742                         lo->ldo_tls_connect_cb( ld, ssl, ctx, lo->ldo_tls_connect_arg );
 743         }
 744
 745         err = SSL_connect( ssl );
 746
 747 #ifdef HAVE_WINSOCK
 748         errno = WSAGetLastError();
 749 #endif
 750
 751         if ( err <= 0 ) {
 752                 if ( update_flags( sb, ssl, err )) {
 753                         return 1;
 754                 }
 755
 756                 if ((err = ERR_peek_error())) {
 757                         char buf[256];
 758
 759                         if ( ld->ld_error ) {
 760                                 LDAP_FREE( ld->ld_error );
 761                         }
 762                         ld->ld_error = LDAP_STRDUP(ERR_error_string(err, buf));
 763 #ifdef HAVE_EBCDIC
 764                         if ( ld->ld_error ) __etoa(ld->ld_error);
 765 #endif
 766                 }
 767
 768                 Debug( LDAP_DEBUG_ANY,"TLS: can't connect.\n",0,0,0);
 769
 770                 ber_sockbuf_remove_io( sb, &sb_tls_sbio,
 771                         LBER_SBIOD_LEVEL_TRANSPORT );
 772 #ifdef LDAP_DEBUG
 773                 ber_sockbuf_remove_io( sb, &ber_sockbuf_io_debug,
 774                         LBER_SBIOD_LEVEL_TRANSPORT );
 775 #endif
 776                 return -1;
 777         }
 778
 779         return 0;
 780 }
 781
 782 /*
 783  * Call this to do a TLS accept on a sockbuf.
 784  * Everything else is the same as with tls_connect.
 785  */
 786 int
 787 ldap_pvt_tls_accept( Sockbuf *sb, void *ctx_arg )
 788 {
 789         int     err;
 790         SSL     *ssl;
 791
 792         if ( HAS_TLS( sb ) ) {
 793                 ber_sockbuf_ctrl( sb, LBER_SB_OPT_GET_SSL, (void *)&ssl );
 794
 795         } else {
 796                 ssl = alloc_handle( ctx_arg );
 797                 if ( ssl == NULL ) return -1;
 798
 799 #ifdef LDAP_DEBUG
 800                 ber_sockbuf_add_io( sb, &ber_sockbuf_io_debug,
 801                         LBER_SBIOD_LEVEL_TRANSPORT, (void *)"tls_" );
 802 #endif
 803                 ber_sockbuf_add_io( sb, &sb_tls_sbio,
 804                         LBER_SBIOD_LEVEL_TRANSPORT, (void *)ssl );
 805         }
 806
 807         err = SSL_accept( ssl );
 808
 809 #ifdef HAVE_WINSOCK
 810         errno = WSAGetLastError();
 811 #endif
 812         if ( err <= 0 ) {
 813                 if ( update_flags( sb, ssl, err )) return 1;
 814
 815                 Debug( LDAP_DEBUG_ANY,"TLS: can't accept.\n",0,0,0 );
 816
 817                 tls_report_error();
 818                 ber_sockbuf_remove_io( sb, &sb_tls_sbio,
 819                         LBER_SBIOD_LEVEL_TRANSPORT );
 820 #ifdef LDAP_DEBUG
 821                 ber_sockbuf_remove_io( sb, &ber_sockbuf_io_debug,
 822                         LBER_SBIOD_LEVEL_TRANSPORT );
 823 #endif
 824                 return -1;
 825         }
 826
 827         return 0;
 828 }
 829
 830 int
 831 ldap_pvt_tls_inplace ( Sockbuf *sb )
 832 {
 833         return HAS_TLS( sb ) ? 1 : 0;
 834 }
 835
 836 int
 837 ldap_tls_inplace( LDAP *ld )
 838 {
 839         Sockbuf         *sb = NULL;
 840
 841         if ( ld->ld_defconn && ld->ld_defconn->lconn_sb ) {
 842                 sb = ld->ld_defconn->lconn_sb;
 843
 844         } else if ( ld->ld_sb ) {
 845                 sb = ld->ld_sb;
 846
 847         } else {
 848                 return 0;
 849         }
 850
 851         return ldap_pvt_tls_inplace( sb );
 852 }
 853
 854 static X509 *
 855 tls_get_cert( SSL *s )
 856 {
 857         /* If peer cert was bad, treat as if no cert was given */
 858         if (SSL_get_verify_result(s)) {
 859                 /* If we can send an alert, do so */
 860                 if (SSL_version(s) != SSL2_VERSION) {
 861                         ssl3_send_alert(s,SSL3_AL_WARNING,SSL3_AD_BAD_CERTIFICATE);
 862                 }
 863                 return NULL;
 864         }
 865         return SSL_get_peer_certificate(s);
 866 }
 867
 868 int
 869 ldap_pvt_tls_get_peer_dn( void *s, struct berval *dn,
 870         LDAPDN_rewrite_dummy *func, unsigned flags )
 871 {
 872         X509 *x;
 873         X509_NAME *xn;
 874         int rc;
 875
 876         x = tls_get_cert((SSL *)s);
 877
 878         if (!x) return LDAP_INVALID_CREDENTIALS;
 879
 880         xn = X509_get_subject_name(x);
 881         rc = ldap_X509dn2bv(xn, dn, (LDAPDN_rewrite_func *)func, flags);
 882         X509_free(x);
 883         return rc;
 884 }
 885
 886 char *
 887 ldap_pvt_tls_get_peer_hostname( void *s )
 888 {
 889         X509 *x;
 890         X509_NAME *xn;
 891         char buf[2048], *p;
 892         int ret;
 893
 894         x = tls_get_cert((SSL *)s);
 895         if (!x) return NULL;
 896
 897         xn = X509_get_subject_name(x);
 898
 899         ret = X509_NAME_get_text_by_NID(xn, NID_commonName, buf, sizeof(buf));
 900         if( ret == -1 ) {
 901                 X509_free(x);
 902                 return NULL;
 903         }
 904
 905         p = LDAP_STRDUP(buf);
 906         X509_free(x);
 907         return p;
 908 }
 909
 910 /* what kind of hostname were we given? */
 911 #define IS_DNS  0
 912 #define IS_IP4  1
 913 #define IS_IP6  2
 914
 915 int
 916 ldap_pvt_tls_check_hostname( LDAP *ld, void *s, const char *name_in )
 917 {
 918         int i, ret = LDAP_LOCAL_ERROR;
 919         X509 *x;
 920         const char *name;
 921         char *ptr;
 922         int ntype = IS_DNS;
 923 #ifdef LDAP_PF_INET6
 924         struct in6_addr addr;
 925 #else
 926         struct in_addr addr;
 927 #endif
 928
 929         if( ldap_int_hostname &&
 930                 ( !name_in || !strcasecmp( name_in, "localhost" ) ) )
 931         {
 932                 name = ldap_int_hostname;
 933         } else {
 934                 name = name_in;
 935         }
 936
 937         x = tls_get_cert((SSL *)s);
 938         if (!x) {
 939                 Debug( LDAP_DEBUG_ANY,
 940                         "TLS: unable to get peer certificate.\n",
 941                         0, 0, 0 );
 942                 /* If this was a fatal condition, things would have
 943                  * aborted long before now.
 944                  */
 945                 return LDAP_SUCCESS;
 946         }
 947
 948 #ifdef LDAP_PF_INET6
 949         if (name[0] == '[' && strchr(name, ']')) {
 950                 char *n2 = ldap_strdup(name+1);
 951                 *strchr(n2, ']') = 2;
 952                 if (inet_pton(AF_INET6, n2, &addr))
 953                         ntype = IS_IP6;
 954                 LDAP_FREE(n2);
 955         } else
 956 #endif
 957         if ((ptr = strrchr(name, '.')) && isdigit((unsigned char)ptr[1])) {
 958                 if (inet_aton(name, (struct in_addr *)&addr)) ntype = IS_IP4;
 959         }
 960
 961         i = X509_get_ext_by_NID(x, NID_subject_alt_name, -1);
 962         if (i >= 0) {
 963                 X509_EXTENSION *ex;
 964                 STACK_OF(GENERAL_NAME) *alt;
 965
 966                 ex = X509_get_ext(x, i);
 967                 alt = X509V3_EXT_d2i(ex);
 968                 if (alt) {
 969                         int n, len1 = 0, len2 = 0;
 970                         char *domain = NULL;
 971                         GENERAL_NAME *gn;
 972
 973                         if (ntype == IS_DNS) {
 974                                 len1 = strlen(name);
 975                                 domain = strchr(name, '.');
 976                                 if (domain) {
 977                                         len2 = len1 - (domain-name);
 978                                 }
 979                         }
 980                         n = sk_GENERAL_NAME_num(alt);
 981                         for (i=0; i<n; i++) {
 982                                 char *sn;
 983                                 int sl;
 984                                 gn = sk_GENERAL_NAME_value(alt, i);
 985                                 if (gn->type == GEN_DNS) {
 986                                         if (ntype != IS_DNS) continue;
 987
 988                                         sn = (char *) ASN1_STRING_data(gn->d.ia5);
 989                                         sl = ASN1_STRING_length(gn->d.ia5);
 990
 991                                         /* ignore empty */
 992                                         if (sl == 0) continue;
 993
 994                                         /* Is this an exact match? */
 995                                         if ((len1 == sl) && !strncasecmp(name, sn, len1)) {
 996                                                 break;
 997                                         }
 998
 999                                         /* Is this a wildcard match? */
1000                                         if (domain && (sn[0] == '*') && (sn[1] == '.') &&
1001                                                 (len2 == sl-1) && !strncasecmp(domain, &sn[1], len2))
1002                                         {
1003                                                 break;
1004                                         }
1005
1006                                 } else if (gn->type == GEN_IPADD) {
1007                                         if (ntype == IS_DNS) continue;
1008
1009                                         sn = (char *) ASN1_STRING_data(gn->d.ia5);
1010                                         sl = ASN1_STRING_length(gn->d.ia5);
1011
1012 #ifdef LDAP_PF_INET6
1013                                         if (ntype == IS_IP6 && sl != sizeof(struct in6_addr)) {
1014                                                 continue;
1015                                         } else
1016 #endif
1017                                         if (ntype == IS_IP4 && sl != sizeof(struct in_addr)) {
1018                                                 continue;
1019                                         }
1020                                         if (!memcmp(sn, &addr, sl)) {
1021                                                 break;
1022                                         }
1023                                 }
1024                         }
1025
1026                         GENERAL_NAMES_free(alt);
1027                         if (i < n) {    /* Found a match */
1028                                 ret = LDAP_SUCCESS;
1029                         }
1030                 }
1031         }
1032
1033         if (ret != LDAP_SUCCESS) {
1034                 X509_NAME *xn;
1035                 char buf[2048];
1036                 buf[0] = '\0';
1037
1038                 xn = X509_get_subject_name(x);
1039                 if( X509_NAME_get_text_by_NID( xn, NID_commonName,
1040                         buf, sizeof(buf)) == -1)
1041                 {
1042                         Debug( LDAP_DEBUG_ANY,
1043                                 "TLS: unable to get common name from peer certificate.\n",
1044                                 0, 0, 0 );
1045                         ret = LDAP_CONNECT_ERROR;
1046                         if ( ld->ld_error ) {
1047                                 LDAP_FREE( ld->ld_error );
1048                         }
1049                         ld->ld_error = LDAP_STRDUP(
1050                                 _("TLS: unable to get CN from peer certificate"));
1051
1052                 } else if (strcasecmp(name, buf) == 0 ) {
1053                         ret = LDAP_SUCCESS;
1054
1055                 } else if (( buf[0] == '*' ) && ( buf[1] == '.' )) {
1056                         char *domain = strchr(name, '.');
1057                         if( domain ) {
1058                                 size_t dlen = 0;
1059                                 size_t sl;
1060
1061                                 sl = strlen(name);
1062                                 dlen = sl - (domain-name);
1063                                 sl = strlen(buf);
1064
1065                                 /* Is this a wildcard match? */
1066                                 if ((dlen == sl-1) && !strncasecmp(domain, &buf[1], dlen)) {
1067                                         ret = LDAP_SUCCESS;
1068                                 }
1069                         }
1070                 }
1071
1072                 if( ret == LDAP_LOCAL_ERROR ) {
1073                         Debug( LDAP_DEBUG_ANY, "TLS: hostname (%s) does not match "
1074                                 "common name in certificate (%s).\n",
1075                                 name, buf, 0 );
1076                         ret = LDAP_CONNECT_ERROR;
1077                         if ( ld->ld_error ) {
1078                                 LDAP_FREE( ld->ld_error );
1079                         }
1080                         ld->ld_error = LDAP_STRDUP(
1081                                 _("TLS: hostname does not match CN in peer certificate"));
1082                 }
1083         }
1084         X509_free(x);
1085         return ret;
1086 }
1087
1088 const char *
1089 ldap_pvt_tls_get_peer_issuer( void *s )
1090 {
1091 #if 0   /* currently unused; see ldap_pvt_tls_get_peer_dn() if needed */
1092         X509 *x;
1093         X509_NAME *xn;
1094         char buf[2048], *p;
1095
1096         x = SSL_get_peer_certificate((SSL *)s);
1097
1098         if (!x) return NULL;
1099
1100         xn = X509_get_issuer_name(x);
1101         p = LDAP_STRDUP(X509_NAME_oneline(xn, buf, sizeof(buf)));
1102         X509_free(x);
1103         return p;
1104 #else
1105         return NULL;
1106 #endif
1107 }
1108
1109 int
1110 ldap_int_tls_config( LDAP *ld, int option, const char *arg )
1111 {
1112         int i;
1113
1114         switch( option ) {
1115         case LDAP_OPT_X_TLS_CACERTFILE:
1116         case LDAP_OPT_X_TLS_CACERTDIR:
1117         case LDAP_OPT_X_TLS_CERTFILE:
1118         case LDAP_OPT_X_TLS_KEYFILE:
1119         case LDAP_OPT_X_TLS_RANDOM_FILE:
1120         case LDAP_OPT_X_TLS_CIPHER_SUITE:
1121                 return ldap_pvt_tls_set_option( ld, option, (void *) arg );
1122
1123         case LDAP_OPT_X_TLS_REQUIRE_CERT:
1124         case LDAP_OPT_X_TLS:
1125                 i = -1;
1126                 if ( strcasecmp( arg, "never" ) == 0 ) {
1127                         i = LDAP_OPT_X_TLS_NEVER ;
1128
1129                 } else if ( strcasecmp( arg, "demand" ) == 0 ) {
1130                         i = LDAP_OPT_X_TLS_DEMAND ;
1131
1132                 } else if ( strcasecmp( arg, "allow" ) == 0 ) {
1133                         i = LDAP_OPT_X_TLS_ALLOW ;
1134
1135                 } else if ( strcasecmp( arg, "try" ) == 0 ) {
1136                         i = LDAP_OPT_X_TLS_TRY ;
1137
1138                 } else if ( ( strcasecmp( arg, "hard" ) == 0 ) ||
1139                         ( strcasecmp( arg, "on" ) == 0 ) ||
1140                         ( strcasecmp( arg, "yes" ) == 0) ||
1141                         ( strcasecmp( arg, "true" ) == 0 ) )
1142                 {
1143                         i = LDAP_OPT_X_TLS_HARD ;
1144                 }
1145
1146                 if (i >= 0) {
1147                         return ldap_pvt_tls_set_option( ld, option, &i );
1148                 }
1149                 return -1;
1150 #ifdef HAVE_OPENSSL_CRL
1151         case LDAP_OPT_X_TLS_CRLCHECK:
1152                 i = -1;
1153                 if ( strcasecmp( arg, "none" ) == 0 ) {
1154                         i = LDAP_OPT_X_TLS_CRL_NONE ;
1155                 } else if ( strcasecmp( arg, "peer" ) == 0 ) {
1156                         i = LDAP_OPT_X_TLS_CRL_PEER ;
1157                 } else if ( strcasecmp( arg, "all" ) == 0 ) {
1158                         i = LDAP_OPT_X_TLS_CRL_ALL ;
1159                 }
1160                 if (i >= 0) {
1161                         return ldap_pvt_tls_set_option( ld, option, &i );
1162                 }
1163                 return -1;
1164 #endif
1165         }
1166         return -1;
1167 }
1168
1169 int
1170 ldap_pvt_tls_get_option( LDAP *ld, int option, void *arg )
1171 {
1172         struct ldapoptions *lo;
1173
1174         if( ld != NULL ) {
1175                 assert( LDAP_VALID( ld ) );
1176
1177                 if( !LDAP_VALID( ld ) ) {
1178                         return LDAP_OPT_ERROR;
1179                 }
1180
1181                 lo = &ld->ld_options;
1182
1183         } else {
1184                 /* Get pointer to global option structure */
1185                 lo = LDAP_INT_GLOBAL_OPT();
1186                 if ( lo == NULL ) {
1187                         return LDAP_NO_MEMORY;
1188                 }
1189         }
1190
1191         switch( option ) {
1192         case LDAP_OPT_X_TLS:
1193                 *(int *)arg = lo->ldo_tls_mode;
1194                 break;
1195         case LDAP_OPT_X_TLS_CTX:
1196                 if ( ld == NULL ) {
1197                         *(void **)arg = (void *) tls_def_ctx;
1198                 } else {
1199                         *(void **)arg = ld->ld_defconn->lconn_tls_ctx;
1200                 }
1201                 break;
1202         case LDAP_OPT_X_TLS_CACERTFILE:
1203                 *(char **)arg = tls_opt_cacertfile ?
1204                         LDAP_STRDUP( tls_opt_cacertfile ) : NULL;
1205                 break;
1206         case LDAP_OPT_X_TLS_CACERTDIR:
1207                 *(char **)arg = tls_opt_cacertdir ?
1208                         LDAP_STRDUP( tls_opt_cacertdir ) : NULL;
1209                 break;
1210         case LDAP_OPT_X_TLS_CERTFILE:
1211                 *(char **)arg = tls_opt_certfile ?
1212                         LDAP_STRDUP( tls_opt_certfile ) : NULL;
1213                 break;
1214         case LDAP_OPT_X_TLS_KEYFILE:
1215                 *(char **)arg = tls_opt_keyfile ?
1216                         LDAP_STRDUP( tls_opt_keyfile ) : NULL;
1217                 break;
1218         case LDAP_OPT_X_TLS_REQUIRE_CERT:
1219                 *(int *)arg = tls_opt_require_cert;
1220                 break;
1221 #ifdef HAVE_OPENSSL_CRL
1222         case LDAP_OPT_X_TLS_CRLCHECK:
1223                 *(int *)arg = tls_opt_crlcheck;
1224                 break;
1225 #endif
1226         case LDAP_OPT_X_TLS_RANDOM_FILE:
1227                 *(char **)arg = tls_opt_randfile ?
1228                         LDAP_STRDUP( tls_opt_randfile ) : NULL;
1229                 break;
1230         case LDAP_OPT_X_TLS_SSL_CTX: {
1231                 void *retval = 0;
1232                 if ( ld != NULL ) {
1233                         LDAPConn *conn = ld->ld_defconn;
1234                         if ( conn != NULL ) {
1235                                 Sockbuf *sb = conn->lconn_sb;
1236                                 retval = ldap_pvt_tls_sb_ctx( sb );
1237                         }
1238                 }
1239                 *(void **)arg = retval;
1240                 break;
1241         }
1242         case LDAP_OPT_X_TLS_CONNECT_CB:
1243                 *(LDAP_TLS_CONNECT_CB **)arg = lo->ldo_tls_connect_cb;
1244                 break;
1245         case LDAP_OPT_X_TLS_CONNECT_ARG:
1246                 *(void **)arg = lo->ldo_tls_connect_arg;
1247                 break;
1248         default:
1249                 return -1;
1250         }
1251         return 0;
1252 }
1253
1254 int
1255 ldap_pvt_tls_set_option( LDAP *ld, int option, void *arg )
1256 {
1257         struct ldapoptions *lo;
1258
1259         if( ld != NULL ) {
1260                 assert( LDAP_VALID( ld ) );
1261
1262                 if( !LDAP_VALID( ld ) ) {
1263                         return LDAP_OPT_ERROR;
1264                 }
1265
1266                 lo = &ld->ld_options;
1267
1268         } else {
1269                 /* Get pointer to global option structure */
1270                 lo = LDAP_INT_GLOBAL_OPT();
1271                 if ( lo == NULL ) {
1272                         return LDAP_NO_MEMORY;
1273                 }
1274         }
1275
1276         switch( option ) {
1277         case LDAP_OPT_X_TLS:
1278                 switch( *(int *) arg ) {
1279                 case LDAP_OPT_X_TLS_NEVER:
1280                 case LDAP_OPT_X_TLS_DEMAND:
1281                 case LDAP_OPT_X_TLS_ALLOW:
1282                 case LDAP_OPT_X_TLS_TRY:
1283                 case LDAP_OPT_X_TLS_HARD:
1284                         if (lo != NULL) {
1285                                 lo->ldo_tls_mode = *(int *)arg;
1286                         }
1287
1288                         return 0;
1289                 }
1290                 return -1;
1291
1292         case LDAP_OPT_X_TLS_CTX:
1293                 if ( ld == NULL ) {
1294                         tls_def_ctx = (SSL_CTX *) arg;
1295
1296                 } else {
1297                         ld->ld_defconn->lconn_tls_ctx = arg;
1298                 }
1299                 return 0;
1300         case LDAP_OPT_X_TLS_CONNECT_CB:
1301                 lo->ldo_tls_connect_cb = (LDAP_TLS_CONNECT_CB *)arg;
1302                 return 0;
1303         case LDAP_OPT_X_TLS_CONNECT_ARG:
1304                 lo->ldo_tls_connect_arg = arg;
1305                 return 0;
1306         }
1307
1308         if ( ld != NULL ) {
1309                 return -1;
1310         }
1311
1312         switch( option ) {
1313         case LDAP_OPT_X_TLS_CACERTFILE:
1314                 if ( tls_opt_cacertfile ) LDAP_FREE( tls_opt_cacertfile );
1315                 tls_opt_cacertfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1316                 break;
1317         case LDAP_OPT_X_TLS_CACERTDIR:
1318                 if ( tls_opt_cacertdir ) LDAP_FREE( tls_opt_cacertdir );
1319                 tls_opt_cacertdir = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1320                 break;
1321         case LDAP_OPT_X_TLS_CERTFILE:
1322                 if ( tls_opt_certfile ) LDAP_FREE( tls_opt_certfile );
1323                 tls_opt_certfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1324                 break;
1325         case LDAP_OPT_X_TLS_KEYFILE:
1326                 if ( tls_opt_keyfile ) LDAP_FREE( tls_opt_keyfile );
1327                 tls_opt_keyfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1328                 break;
1329         case LDAP_OPT_X_TLS_REQUIRE_CERT:
1330                 switch( *(int *) arg ) {
1331                 case LDAP_OPT_X_TLS_NEVER:
1332                 case LDAP_OPT_X_TLS_DEMAND:
1333                 case LDAP_OPT_X_TLS_ALLOW:
1334                 case LDAP_OPT_X_TLS_TRY:
1335                 case LDAP_OPT_X_TLS_HARD:
1336                         tls_opt_require_cert = * (int *) arg;
1337                         return 0;
1338                 }
1339                 return -1;
1340 #ifdef HAVE_OPENSSL_CRL
1341         case LDAP_OPT_X_TLS_CRLCHECK:
1342                 switch( *(int *) arg ) {
1343                 case LDAP_OPT_X_TLS_CRL_NONE:
1344                 case LDAP_OPT_X_TLS_CRL_PEER:
1345                 case LDAP_OPT_X_TLS_CRL_ALL:
1346                         tls_opt_crlcheck = * (int *) arg;
1347                         return 0;
1348                 }
1349                 return -1;
1350 #endif
1351         case LDAP_OPT_X_TLS_CIPHER_SUITE:
1352                 if ( tls_opt_ciphersuite ) LDAP_FREE( tls_opt_ciphersuite );
1353                 tls_opt_ciphersuite = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1354                 break;
1355         case LDAP_OPT_X_TLS_RANDOM_FILE:
1356                 if (tls_opt_randfile ) LDAP_FREE (tls_opt_randfile );
1357                 tls_opt_randfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1358                 break;
1359         default:
1360                 return -1;
1361         }
1362         return 0;
1363 }
1364
1365 int
1366 ldap_int_tls_start ( LDAP *ld, LDAPConn *conn, LDAPURLDesc *srv )
1367 {
1368         Sockbuf *sb = conn->lconn_sb;
1369         char *host;
1370         void *ssl;
1371
1372         if( srv ) {
1373                 host = srv->lud_host;
1374         } else {
1375                 host = conn->lconn_server->lud_host;
1376         }
1377
1378         /* avoid NULL host */
1379         if( host == NULL ) {
1380                 host = "localhost";
1381         }
1382
1383         (void) ldap_pvt_tls_init();
1384
1385         /*
1386          * Fortunately, the lib uses blocking io...
1387          */
1388         if ( ldap_int_tls_connect( ld, conn ) < 0 ) {
1389                 ld->ld_errno = LDAP_CONNECT_ERROR;
1390                 return (ld->ld_errno);
1391         }
1392
1393         ssl = ldap_pvt_tls_sb_ctx( sb );
1394         assert( ssl != NULL );
1395
1396         /*
1397          * compare host with name(s) in certificate
1398          */
1399         if (tls_opt_require_cert != LDAP_OPT_X_TLS_NEVER) {
1400                 ld->ld_errno = ldap_pvt_tls_check_hostname( ld, ssl, host );
1401                 if (ld->ld_errno != LDAP_SUCCESS) {
1402                         return ld->ld_errno;
1403                 }
1404         }
1405
1406         return LDAP_SUCCESS;
1407 }
1408
1409 /* Derived from openssl/apps/s_cb.c */
1410 static void
1411 tls_info_cb( const SSL *ssl, int where, int ret )
1412 {
1413         int w;
1414         char *op;
1415         char *state = (char *) SSL_state_string_long( (SSL *)ssl );
1416
1417         w = where & ~SSL_ST_MASK;
1418         if ( w & SSL_ST_CONNECT ) {
1419                 op = "SSL_connect";
1420         } else if ( w & SSL_ST_ACCEPT ) {
1421                 op = "SSL_accept";
1422         } else {
1423                 op = "undefined";
1424         }
1425
1426 #ifdef HAVE_EBCDIC
1427         if ( state ) {
1428                 state = LDAP_STRDUP( state );
1429                 __etoa( state );
1430         }
1431 #endif
1432         if ( where & SSL_CB_LOOP ) {
1433                 Debug( LDAP_DEBUG_TRACE,
1434                            "TLS trace: %s:%s\n",
1435                            op, state, 0 );
1436
1437         } else if ( where & SSL_CB_ALERT ) {
1438                 char *atype = (char *) SSL_alert_type_string_long( ret );
1439                 char *adesc = (char *) SSL_alert_desc_string_long( ret );
1440                 op = ( where & SSL_CB_READ ) ? "read" : "write";
1441 #ifdef HAVE_EBCDIC
1442                 if ( atype ) {
1443                         atype = LDAP_STRDUP( atype );
1444                         __etoa( atype );
1445                 }
1446                 if ( adesc ) {
1447                         adesc = LDAP_STRDUP( adesc );
1448                         __etoa( adesc );
1449                 }
1450 #endif
1451                 Debug( LDAP_DEBUG_TRACE,
1452                            "TLS trace: SSL3 alert %s:%s:%s\n",
1453                            op, atype, adesc );
1454 #ifdef HAVE_EBCDIC
1455                 if ( atype ) LDAP_FREE( atype );
1456                 if ( adesc ) LDAP_FREE( adesc );
1457 #endif
1458         } else if ( where & SSL_CB_EXIT ) {
1459                 if ( ret == 0 ) {
1460                         Debug( LDAP_DEBUG_TRACE,
1461                                    "TLS trace: %s:failed in %s\n",
1462                                    op, state, 0 );
1463                 } else if ( ret < 0 ) {
1464                         Debug( LDAP_DEBUG_TRACE,
1465                                    "TLS trace: %s:error in %s\n",
1466                                    op, state, 0 );
1467                 }
1468         }
1469 #ifdef HAVE_EBCDIC
1470         if ( state ) LDAP_FREE( state );
1471 #endif
1472 }
1473
1474 static int
1475 tls_verify_cb( int ok, X509_STORE_CTX *ctx )
1476 {
1477         X509 *cert;
1478         int errnum;
1479         int errdepth;
1480         X509_NAME *subject;
1481         X509_NAME *issuer;
1482         char *sname;
1483         char *iname;
1484         char *certerr = NULL;
1485
1486         cert = X509_STORE_CTX_get_current_cert( ctx );
1487         errnum = X509_STORE_CTX_get_error( ctx );
1488         errdepth = X509_STORE_CTX_get_error_depth( ctx );
1489
1490         /*
1491          * X509_get_*_name return pointers to the internal copies of
1492          * those things requested.  So do not free them.
1493          */
1494         subject = X509_get_subject_name( cert );
1495         issuer = X509_get_issuer_name( cert );
1496         /* X509_NAME_oneline, if passed a NULL buf, allocate memomry */
1497         sname = X509_NAME_oneline( subject, NULL, 0 );
1498         iname = X509_NAME_oneline( issuer, NULL, 0 );
1499         if ( !ok ) certerr = (char *)X509_verify_cert_error_string( errnum );
1500 #ifdef HAVE_EBCDIC
1501         if ( sname ) __etoa( sname );
1502         if ( iname ) __etoa( iname );
1503         if ( certerr ) {
1504                 certerr = LDAP_STRDUP( certerr );
1505                 __etoa( certerr );
1506         }
1507 #endif
1508         Debug( LDAP_DEBUG_TRACE,
1509                    "TLS certificate verification: depth: %d, err: %d, subject: %s,",
1510                    errdepth, errnum,
1511                    sname ? sname : "-unknown-" );
1512         Debug( LDAP_DEBUG_TRACE, " issuer: %s\n", iname ? iname : "-unknown-", 0, 0 );
1513         if ( !ok ) {
1514                 Debug( LDAP_DEBUG_ANY,
1515                         "TLS certificate verification: Error, %s\n",
1516                         certerr, 0, 0 );
1517         }
1518         if ( sname )
1519                 CRYPTO_free ( sname );
1520         if ( iname )
1521                 CRYPTO_free ( iname );
1522 #ifdef HAVE_EBCDIC
1523         if ( certerr ) LDAP_FREE( certerr );
1524 #endif
1525         return ok;
1526 }
1527
1528 static int
1529 tls_verify_ok( int ok, X509_STORE_CTX *ctx )
1530 {
1531         (void) tls_verify_cb( ok, ctx );
1532         return 1;
1533 }
1534
1535 /* Inspired by ERR_print_errors in OpenSSL */
1536 static void
1537 tls_report_error( void )
1538 {
1539         unsigned long l;
1540         char buf[200];
1541         const char *file;
1542         int line;
1543
1544         while ( ( l = ERR_get_error_line( &file, &line ) ) != 0 ) {
1545                 ERR_error_string_n( l, buf, sizeof( buf ) );
1546 #ifdef HAVE_EBCDIC
1547                 if ( file ) {
1548                         file = LDAP_STRDUP( file );
1549                         __etoa( (char *)file );
1550                 }
1551                 __etoa( buf );
1552 #endif
1553                 Debug( LDAP_DEBUG_ANY, "TLS: %s %s:%d\n",
1554                         buf, file, line );
1555 #ifdef HAVE_EBCDIC
1556                 if ( file ) LDAP_FREE( (void *)file );
1557 #endif
1558         }
1559 }
1560
1561 static RSA *
1562 tls_tmp_rsa_cb( SSL *ssl, int is_export, int key_length )
1563 {
1564         RSA *tmp_rsa;
1565
1566         /* FIXME:  Pregenerate the key on startup */
1567         /* FIXME:  Who frees the key? */
1568         tmp_rsa = RSA_generate_key( key_length, RSA_F4, NULL, NULL );
1569
1570         if ( !tmp_rsa ) {
1571                 Debug( LDAP_DEBUG_ANY,
1572                         "TLS: Failed to generate temporary %d-bit %s RSA key\n",
1573                         key_length, is_export ? "export" : "domestic", 0 );
1574                 return NULL;
1575         }
1576         return tmp_rsa;
1577 }
1578
1579 static int
1580 tls_seed_PRNG( const char *randfile )
1581 {
1582 #ifndef URANDOM_DEVICE
1583         /* no /dev/urandom (or equiv) */
1584         long total=0;
1585         char buffer[MAXPATHLEN];
1586
1587         if (randfile == NULL) {
1588                 /* The seed file is $RANDFILE if defined, otherwise $HOME/.rnd.
1589                  * If $HOME is not set or buffer too small to hold the pathname,
1590                  * an error occurs.     - From RAND_file_name() man page.
1591                  * The fact is that when $HOME is NULL, .rnd is used.
1592                  */
1593                 randfile = RAND_file_name( buffer, sizeof( buffer ) );
1594
1595         } else if (RAND_egd(randfile) > 0) {
1596                 /* EGD socket */
1597                 return 0;
1598         }
1599
1600         if (randfile == NULL) {
1601                 Debug( LDAP_DEBUG_ANY,
1602                         "TLS: Use configuration file or $RANDFILE to define seed PRNG\n",
1603                         0, 0, 0);
1604                 return -1;
1605         }
1606
1607         total = RAND_load_file(randfile, -1);
1608
1609         if (RAND_status() == 0) {
1610                 Debug( LDAP_DEBUG_ANY,
1611                         "TLS: PRNG not been seeded with enough data\n",
1612                         0, 0, 0);
1613                 return -1;
1614         }
1615
1616         /* assume if there was enough bits to seed that it's okay
1617          * to write derived bits to the file
1618          */
1619         RAND_write_file(randfile);
1620
1621 #endif
1622
1623         return 0;
1624 }
1625
1626 #if 0
1627 static DH *
1628 tls_tmp_dh_cb( SSL *ssl, int is_export, int key_length )
1629 {
1630         return NULL;
1631 }
1632 #endif
1633 #endif
1634
1635 void *
1636 ldap_pvt_tls_sb_ctx( Sockbuf *sb )
1637 {
1638 #ifdef HAVE_TLS
1639         void                    *p;
1640
1641         if (HAS_TLS( sb )) {
1642                 ber_sockbuf_ctrl( sb, LBER_SB_OPT_GET_SSL, (void *)&p );
1643                 return p;
1644         }
1645 #endif
1646
1647         return NULL;
1648 }
1649
1650 int
1651 ldap_pvt_tls_get_strength( void *s )
1652 {
1653 #ifdef HAVE_TLS
1654         SSL_CIPHER *c;
1655
1656         c = SSL_get_current_cipher((SSL *)s);
1657         return SSL_CIPHER_get_bits(c, NULL);
1658 #else
1659         return 0;
1660 #endif
1661 }
1662
1663
1664 int
1665 ldap_pvt_tls_get_my_dn( void *s, struct berval *dn, LDAPDN_rewrite_dummy *func, unsigned flags )
1666 {
1667 #ifdef HAVE_TLS
1668         X509 *x;
1669         X509_NAME *xn;
1670         int rc;
1671
1672         x = SSL_get_certificate((SSL *)s);
1673
1674         if (!x) return LDAP_INVALID_CREDENTIALS;
1675
1676         xn = X509_get_subject_name(x);
1677         rc = ldap_X509dn2bv(xn, dn, (LDAPDN_rewrite_func *)func, flags );
1678         return rc;
1679 #else
1680         return LDAP_NOT_SUPPORTED;
1681 #endif
1682 }
1683
1684 int
1685 ldap_start_tls( LDAP *ld,
1686         LDAPControl **serverctrls,
1687         LDAPControl **clientctrls,
1688         int *msgidp )
1689 {
1690         return ldap_extended_operation( ld, LDAP_EXOP_START_TLS,
1691                 NULL, serverctrls, clientctrls, msgidp );
1692 }
1693
1694 int
1695 ldap_install_tls( LDAP *ld )
1696 {
1697 #ifndef HAVE_TLS
1698         return LDAP_NOT_SUPPORTED;
1699 #else
1700         if ( ldap_tls_inplace( ld ) ) {
1701                 return LDAP_LOCAL_ERROR;
1702         }
1703
1704         return ldap_int_tls_start( ld, ld->ld_defconn, NULL );
1705 #endif
1706 }
1707
1708 int
1709 ldap_start_tls_s ( LDAP *ld,
1710         LDAPControl **serverctrls,
1711         LDAPControl **clientctrls )
1712 {
1713 #ifndef HAVE_TLS
1714         return LDAP_NOT_SUPPORTED;
1715 #else
1716         int rc;
1717         char *rspoid = NULL;
1718         struct berval *rspdata = NULL;
1719
1720         /* XXYYZ: this initiates operation only on default connection! */
1721
1722         if ( ldap_tls_inplace( ld ) ) {
1723                 return LDAP_LOCAL_ERROR;
1724         }
1725
1726         rc = ldap_extended_operation_s( ld, LDAP_EXOP_START_TLS,
1727                 NULL, serverctrls, clientctrls, &rspoid, &rspdata );
1728
1729         if ( rspoid != NULL ) {
1730                 LDAP_FREE(rspoid);
1731         }
1732
1733         if ( rspdata != NULL ) {
1734                 ber_bvfree( rspdata );
1735         }
1736
1737         if ( rc == LDAP_SUCCESS ) {
1738                 rc = ldap_int_tls_start( ld, ld->ld_defconn, NULL );
1739         }
1740
1741         return rc;
1742 #endif
1743 }
1744