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

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