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 void *
 862 ldap_pvt_tls_sb_ctx( Sockbuf *sb )
 863 {
 864         void                    *p;
 865
 866         if (HAS_TLS( sb )) {
 867                 ber_sockbuf_ctrl( sb, LBER_SB_OPT_GET_SSL, (void *)&p );
 868                 return p;
 869         }
 870
 871         return NULL;
 872 }
 873
 874 int
 875 ldap_pvt_tls_get_strength( void *s )
 876 {
 877         SSL_CIPHER *c;
 878
 879         c = SSL_get_current_cipher((SSL *)s);
 880         return SSL_CIPHER_get_bits(c, NULL);
 881 }
 882
 883
 884 int
 885 ldap_pvt_tls_get_my_dn( void *s, struct berval *dn, LDAPDN_rewrite_dummy *func, unsigned flags )
 886 {
 887         X509 *x;
 888         X509_NAME *xn;
 889         int rc;
 890
 891         x = SSL_get_certificate((SSL *)s);
 892
 893         if (!x) return LDAP_INVALID_CREDENTIALS;
 894
 895         xn = X509_get_subject_name(x);
 896         rc = ldap_X509dn2bv(xn, dn, (LDAPDN_rewrite_func *)func, flags );
 897         return rc;
 898 }
 899
 900 static X509 *
 901 tls_get_cert( SSL *s )
 902 {
 903         /* If peer cert was bad, treat as if no cert was given */
 904         if (SSL_get_verify_result(s)) {
 905                 /* If we can send an alert, do so */
 906                 if (SSL_version(s) != SSL2_VERSION) {
 907                         ssl3_send_alert(s,SSL3_AL_WARNING,SSL3_AD_BAD_CERTIFICATE);
 908                 }
 909                 return NULL;
 910         }
 911         return SSL_get_peer_certificate(s);
 912 }
 913
 914 int
 915 ldap_pvt_tls_get_peer_dn( void *s, struct berval *dn, LDAPDN_rewrite_dummy *func, unsigned flags )
 916 {
 917         X509 *x;
 918         X509_NAME *xn;
 919         int rc;
 920
 921         x = tls_get_cert((SSL *)s);
 922
 923         if (!x) return LDAP_INVALID_CREDENTIALS;
 924
 925         xn = X509_get_subject_name(x);
 926         rc = ldap_X509dn2bv(xn, dn, (LDAPDN_rewrite_func *)func, flags);
 927         X509_free(x);
 928         return rc;
 929 }
 930
 931 char *
 932 ldap_pvt_tls_get_peer_hostname( void *s )
 933 {
 934         X509 *x;
 935         X509_NAME *xn;
 936         char buf[2048], *p;
 937         int ret;
 938
 939         x = tls_get_cert((SSL *)s);
 940         if (!x) return NULL;
 941
 942         xn = X509_get_subject_name(x);
 943
 944         ret = X509_NAME_get_text_by_NID(xn, NID_commonName, buf, sizeof(buf));
 945         if( ret == -1 ) {
 946                 X509_free(x);
 947                 return NULL;
 948         }
 949
 950         p = LDAP_STRDUP(buf);
 951         X509_free(x);
 952         return p;
 953 }
 954
 955 /* what kind of hostname were we given? */
 956 #define IS_DNS  0
 957 #define IS_IP4  1
 958 #define IS_IP6  2
 959
 960 int
 961 ldap_pvt_tls_check_hostname( LDAP *ld, void *s, const char *name_in )
 962 {
 963         int i, ret = LDAP_LOCAL_ERROR;
 964         X509 *x;
 965         const char *name;
 966         char *ptr;
 967         int ntype = IS_DNS;
 968 #ifdef LDAP_PF_INET6
 969         struct in6_addr addr;
 970 #else
 971         struct in_addr addr;
 972 #endif
 973
 974         if( ldap_int_hostname &&
 975                 ( !name_in || !strcasecmp( name_in, "localhost" ) ) )
 976         {
 977                 name = ldap_int_hostname;
 978         } else {
 979                 name = name_in;
 980         }
 981
 982         x = tls_get_cert((SSL *)s);
 983         if (!x) {
 984 #ifdef NEW_LOGGING
 985                 LDAP_LOG ( TRANSPORT, ERR,
 986                         "ldap_pvt_tls_check_hostname: "
 987                         "TLS unable to get peer certificate.\n" , 0, 0, 0 );
 988 #else
 989                 Debug( LDAP_DEBUG_ANY,
 990                         "TLS: unable to get peer certificate.\n",
 991                         0, 0, 0 );
 992 #endif
 993                 /* If this was a fatal condition, things would have
 994                  * aborted long before now.
 995                  */
 996                 return LDAP_SUCCESS;
 997         }
 998
 999 #ifdef LDAP_PF_INET6
1000         if (name[0] == '[' && strchr(name, ']')) {
1001                 char *n2 = ldap_strdup(name+1);
1002                 *strchr(n2, ']') = 2;
1003                 if (inet_pton(AF_INET6, n2, &addr))
1004                         ntype = IS_IP6;
1005                 LDAP_FREE(n2);
1006         } else
1007 #endif
1008         if ((ptr = strrchr(name, '.')) && isdigit((unsigned char)ptr[1])) {
1009                 if (inet_aton(name, (struct in_addr *)&addr))
1010                         ntype = IS_IP4;
1011         }
1012
1013         i = X509_get_ext_by_NID(x, NID_subject_alt_name, -1);
1014         if (i >= 0) {
1015                 X509_EXTENSION *ex;
1016                 STACK_OF(GENERAL_NAME) *alt;
1017
1018                 ex = X509_get_ext(x, i);
1019                 alt = X509V3_EXT_d2i(ex);
1020                 if (alt) {
1021                         int n, len1 = 0, len2 = 0;
1022                         char *domain = NULL;
1023                         GENERAL_NAME *gn;
1024
1025                         if (ntype == IS_DNS) {
1026                                 len1 = strlen(name);
1027                                 domain = strchr(name, '.');
1028                                 if (domain) {
1029                                         len2 = len1 - (domain-name);
1030                                 }
1031                         }
1032                         n = sk_GENERAL_NAME_num(alt);
1033                         for (i=0; i<n; i++) {
1034                                 char *sn;
1035                                 int sl;
1036                                 gn = sk_GENERAL_NAME_value(alt, i);
1037                                 if (gn->type == GEN_DNS) {
1038                                         if (ntype != IS_DNS) continue;
1039
1040                                         sn = (char *) ASN1_STRING_data(gn->d.ia5);
1041                                         sl = ASN1_STRING_length(gn->d.ia5);
1042
1043                                         /* Is this an exact match? */
1044                                         if ((len1 == sl) && !strncasecmp(name, sn, len1)) {
1045                                                 break;
1046                                         }
1047
1048                                         /* Is this a wildcard match? */
1049                                         if ((*sn == '*') && domain && (len2 == sl-1) &&
1050                                                 !strncasecmp(domain, sn+1, len2)) {
1051                                                 break;
1052                                         }
1053
1054 #if 0
1055                                         /* Is this a RFC 2459 style wildcard match? */
1056                                         if ((*sn == '.') && domain && (len2 == sl) &&
1057                                                 !strncasecmp(domain, sn, len2)) {
1058                                                 break;
1059                                         }
1060 #endif
1061                                 } else if (gn->type == GEN_IPADD) {
1062                                         if (ntype == IS_DNS) continue;
1063
1064                                         sn = (char *) ASN1_STRING_data(gn->d.ia5);
1065                                         sl = ASN1_STRING_length(gn->d.ia5);
1066
1067 #ifdef LDAP_PF_INET6
1068                                         if (ntype == IS_IP6 && sl != sizeof(struct in6_addr)) {
1069                                                 continue;
1070                                         } else
1071 #endif
1072                                         if (ntype == IS_IP4 && sl != sizeof(struct in_addr)) {
1073                                                 continue;
1074                                         }
1075                                         if (!memcmp(sn, &addr, sl)) {
1076                                                 break;
1077                                         }
1078                                 }
1079                         }
1080
1081                         GENERAL_NAMES_free(alt);
1082                         if (i < n) {    /* Found a match */
1083                                 ret = LDAP_SUCCESS;
1084                         }
1085                 }
1086         }
1087
1088         if (ret != LDAP_SUCCESS) {
1089                 X509_NAME *xn;
1090                 char buf[2048];
1091
1092                 xn = X509_get_subject_name(x);
1093
1094                 if( X509_NAME_get_text_by_NID( xn, NID_commonName,
1095                         buf, sizeof(buf)) == -1)
1096                 {
1097 #ifdef NEW_LOGGING
1098                         LDAP_LOG ( TRANSPORT, ERR, "ldap_pvt_tls_check_hostname: "
1099                                 "TLS unable to get common name from peer certificate.\n",
1100                                 0, 0, 0 );
1101 #else
1102                         Debug( LDAP_DEBUG_ANY,
1103                                 "TLS: unable to get common name from peer certificate.\n",
1104                                 0, 0, 0 );
1105 #endif
1106                         ld->ld_error = LDAP_STRDUP(
1107                                 _("TLS: unable to get CN from peer certificate"));
1108
1109                 } else if (strcasecmp(name, buf)) {
1110 #ifdef NEW_LOGGING
1111                         LDAP_LOG ( TRANSPORT, ERR, "ldap_pvt_tls_check_hostname: "
1112                                 "TLS hostname (%s) does not match "
1113                                 "common name in certificate (%s).\n", name, buf, 0 );
1114 #else
1115                         Debug( LDAP_DEBUG_ANY, "TLS: hostname (%s) does not match "
1116                                 "common name in certificate (%s).\n",
1117                                 name, buf, 0 );
1118 #endif
1119                         ret = LDAP_CONNECT_ERROR;
1120                         ld->ld_error = LDAP_STRDUP(
1121                                 _("TLS: hostname does not match CN in peer certificate"));
1122
1123                 } else {
1124                         ret = LDAP_SUCCESS;
1125                 }
1126         }
1127         X509_free(x);
1128         return ret;
1129 }
1130
1131 const char *
1132 ldap_pvt_tls_get_peer_issuer( void *s )
1133 {
1134 #if 0   /* currently unused; see ldap_pvt_tls_get_peer_dn() if needed */
1135         X509 *x;
1136         X509_NAME *xn;
1137         char buf[2048], *p;
1138
1139         x = SSL_get_peer_certificate((SSL *)s);
1140
1141         if (!x) return NULL;
1142
1143         xn = X509_get_issuer_name(x);
1144         p = LDAP_STRDUP(X509_NAME_oneline(xn, buf, sizeof(buf)));
1145         X509_free(x);
1146         return p;
1147 #else
1148         return NULL;
1149 #endif
1150 }
1151
1152 int
1153 ldap_int_tls_config( LDAP *ld, int option, const char *arg )
1154 {
1155         int i;
1156
1157         switch( option ) {
1158         case LDAP_OPT_X_TLS_CACERTFILE:
1159         case LDAP_OPT_X_TLS_CACERTDIR:
1160         case LDAP_OPT_X_TLS_CERTFILE:
1161         case LDAP_OPT_X_TLS_KEYFILE:
1162         case LDAP_OPT_X_TLS_RANDOM_FILE:
1163                 return ldap_pvt_tls_set_option( ld, option, (void *) arg );
1164
1165         case LDAP_OPT_X_TLS_REQUIRE_CERT:
1166         case LDAP_OPT_X_TLS:
1167                 i = -1;
1168                 if ( strcasecmp( arg, "never" ) == 0 ) {
1169                         i = LDAP_OPT_X_TLS_NEVER ;
1170
1171                 } else if ( strcasecmp( arg, "demand" ) == 0 ) {
1172                         i = LDAP_OPT_X_TLS_DEMAND ;
1173
1174                 } else if ( strcasecmp( arg, "allow" ) == 0 ) {
1175                         i = LDAP_OPT_X_TLS_ALLOW ;
1176
1177                 } else if ( strcasecmp( arg, "try" ) == 0 ) {
1178                         i = LDAP_OPT_X_TLS_TRY ;
1179
1180                 } else if ( ( strcasecmp( arg, "hard" ) == 0 ) ||
1181                         ( strcasecmp( arg, "on" ) == 0 ) ||
1182                         ( strcasecmp( arg, "yes" ) == 0) ||
1183                         ( strcasecmp( arg, "true" ) == 0 ) )
1184                 {
1185                         i = LDAP_OPT_X_TLS_HARD ;
1186                 }
1187
1188                 if (i >= 0) {
1189                         return ldap_pvt_tls_set_option( ld, option, &i );
1190                 }
1191                 return -1;
1192         }
1193
1194         return -1;
1195 }
1196
1197 int
1198 ldap_pvt_tls_get_option( LDAP *ld, int option, void *arg )
1199 {
1200         struct ldapoptions *lo;
1201
1202         if( ld != NULL ) {
1203                 assert( LDAP_VALID( ld ) );
1204
1205                 if( !LDAP_VALID( ld ) ) {
1206                         return LDAP_OPT_ERROR;
1207                 }
1208
1209                 lo = &ld->ld_options;
1210
1211         } else {
1212                 /* Get pointer to global option structure */
1213                 lo = LDAP_INT_GLOBAL_OPT();
1214                 if ( lo == NULL ) {
1215                         return LDAP_NO_MEMORY;
1216                 }
1217         }
1218
1219         switch( option ) {
1220         case LDAP_OPT_X_TLS:
1221                 *(int *)arg = lo->ldo_tls_mode;
1222                 break;
1223         case LDAP_OPT_X_TLS_CTX:
1224                 if ( ld == NULL ) {
1225                         *(void **)arg = (void *) tls_def_ctx;
1226                 } else {
1227                         *(void **)arg = ld->ld_defconn->lconn_tls_ctx;
1228                 }
1229                 break;
1230         case LDAP_OPT_X_TLS_CACERTFILE:
1231                 *(char **)arg = tls_opt_cacertfile ?
1232                         LDAP_STRDUP( tls_opt_cacertfile ) : NULL;
1233                 break;
1234         case LDAP_OPT_X_TLS_CACERTDIR:
1235                 *(char **)arg = tls_opt_cacertdir ?
1236                         LDAP_STRDUP( tls_opt_cacertdir ) : NULL;
1237                 break;
1238         case LDAP_OPT_X_TLS_CERTFILE:
1239                 *(char **)arg = tls_opt_certfile ?
1240                         LDAP_STRDUP( tls_opt_certfile ) : NULL;
1241                 break;
1242         case LDAP_OPT_X_TLS_KEYFILE:
1243                 *(char **)arg = tls_opt_keyfile ?
1244                         LDAP_STRDUP( tls_opt_keyfile ) : NULL;
1245                 break;
1246         case LDAP_OPT_X_TLS_REQUIRE_CERT:
1247                 *(int *)arg = tls_opt_require_cert;
1248                 break;
1249         case LDAP_OPT_X_TLS_RANDOM_FILE:
1250                 *(char **)arg = tls_opt_randfile ?
1251                         LDAP_STRDUP( tls_opt_randfile ) : NULL;
1252                 break;
1253         case LDAP_OPT_X_TLS_SSL_CTX: {
1254                 void *retval = 0;
1255                 if ( ld != NULL ) {
1256                         LDAPConn *conn = ld->ld_defconn;
1257                         if ( conn != NULL ) {
1258                                 Sockbuf *sb = conn->lconn_sb;
1259                                 retval = ldap_pvt_tls_sb_ctx( sb );
1260                         }
1261                 }
1262                 *(void **)arg = retval;
1263                 break;
1264         }
1265         default:
1266                 return -1;
1267         }
1268         return 0;
1269 }
1270
1271 int
1272 ldap_pvt_tls_set_option( LDAP *ld, int option, void *arg )
1273 {
1274         struct ldapoptions *lo;
1275
1276         if( ld != NULL ) {
1277                 assert( LDAP_VALID( ld ) );
1278
1279                 if( !LDAP_VALID( ld ) ) {
1280                         return LDAP_OPT_ERROR;
1281                 }
1282
1283                 lo = &ld->ld_options;
1284
1285         } else {
1286                 /* Get pointer to global option structure */
1287                 lo = LDAP_INT_GLOBAL_OPT();
1288                 if ( lo == NULL ) {
1289                         return LDAP_NO_MEMORY;
1290                 }
1291         }
1292
1293         switch( option ) {
1294         case LDAP_OPT_X_TLS:
1295                 switch( *(int *) arg ) {
1296                 case LDAP_OPT_X_TLS_NEVER:
1297                 case LDAP_OPT_X_TLS_DEMAND:
1298                 case LDAP_OPT_X_TLS_ALLOW:
1299                 case LDAP_OPT_X_TLS_TRY:
1300                 case LDAP_OPT_X_TLS_HARD:
1301                         if (lo != NULL) {
1302                                 lo->ldo_tls_mode = *(int *)arg;
1303                         }
1304
1305                         return 0;
1306                 }
1307                 return -1;
1308
1309         case LDAP_OPT_X_TLS_CTX:
1310                 if ( ld == NULL ) {
1311                         tls_def_ctx = (SSL_CTX *) arg;
1312
1313                 } else {
1314                         ld->ld_defconn->lconn_tls_ctx = arg;
1315                 }
1316                 return 0;
1317         }
1318
1319         if ( ld != NULL ) {
1320                 return -1;
1321         }
1322
1323         switch( option ) {
1324         case LDAP_OPT_X_TLS_CACERTFILE:
1325                 if ( tls_opt_cacertfile ) LDAP_FREE( tls_opt_cacertfile );
1326                 tls_opt_cacertfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1327                 break;
1328         case LDAP_OPT_X_TLS_CACERTDIR:
1329                 if ( tls_opt_cacertdir ) LDAP_FREE( tls_opt_cacertdir );
1330                 tls_opt_cacertdir = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1331                 break;
1332         case LDAP_OPT_X_TLS_CERTFILE:
1333                 if ( tls_opt_certfile ) LDAP_FREE( tls_opt_certfile );
1334                 tls_opt_certfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1335                 break;
1336         case LDAP_OPT_X_TLS_KEYFILE:
1337                 if ( tls_opt_keyfile ) LDAP_FREE( tls_opt_keyfile );
1338                 tls_opt_keyfile = arg ? LDAP_STRDUP( (char *) arg ) : NULL;
1339                 break;
1340         case LDAP_OPT_X_TLS_REQUIRE_CERT:
1341                 switch( *(int *) arg ) {
1342                 case LDAP_OPT_X_TLS_NEVER:
1343                 case LDAP_OPT_X_TLS_DEMAND:
1344                 case LDAP_OPT_X_TLS_ALLOW:
1345                 case LDAP_OPT_X_TLS_TRY:
1346                 case LDAP_OPT_X_TLS_HARD:
1347                         tls_opt_require_cert = * (int *) arg;
1348                         return 0;
1349                 }
1350                 return -1;
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 #ifdef NEW_LOGGING
1434                 LDAP_LOG ( TRANSPORT, DETAIL1, "tls_info_cb: "
1435                         "TLS trace: %s:%s\n", op, state, 0 );
1436 #else
1437                 Debug( LDAP_DEBUG_TRACE,
1438                            "TLS trace: %s:%s\n",
1439                            op, state, 0 );
1440 #endif
1441
1442         } else if ( where & SSL_CB_ALERT ) {
1443                 char *atype = (char *) SSL_alert_type_string_long( ret );
1444                 char *adesc = (char *) SSL_alert_desc_string_long( ret );
1445                 op = ( where & SSL_CB_READ ) ? "read" : "write";
1446 #ifdef HAVE_EBCDIC
1447                 if ( atype ) {
1448                         atype = LDAP_STRDUP( atype );
1449                         __etoa( atype );
1450                 }
1451                 if ( adesc ) {
1452                         adesc = LDAP_STRDUP( adesc );
1453                         __etoa( adesc );
1454                 }
1455 #endif
1456 #ifdef NEW_LOGGING
1457                 LDAP_LOG ( TRANSPORT, DETAIL1,
1458                         "tls_info_cb: TLS trace: SSL3 alert %s:%s:%s\n",
1459                         op, atype, adesc );
1460 #else
1461                 Debug( LDAP_DEBUG_TRACE,
1462                            "TLS trace: SSL3 alert %s:%s:%s\n",
1463                            op, atype, adesc );
1464 #endif
1465 #ifdef HAVE_EBCDIC
1466                 if ( atype ) LDAP_FREE( atype );
1467                 if ( adesc ) LDAP_FREE( adesc );
1468 #endif
1469         } else if ( where & SSL_CB_EXIT ) {
1470                 if ( ret == 0 ) {
1471 #ifdef NEW_LOGGING
1472                         LDAP_LOG ( TRANSPORT, ERR,
1473                                 "tls_info_cb: TLS trace: %s:failed in %s\n",
1474                                 op, state, 0 );
1475 #else
1476                         Debug( LDAP_DEBUG_TRACE,
1477                                    "TLS trace: %s:failed in %s\n",
1478                                    op, state, 0 );
1479 #endif
1480                 } else if ( ret < 0 ) {
1481 #ifdef NEW_LOGGING
1482                         LDAP_LOG ( TRANSPORT, ERR,
1483                                 "tls_info_cb: TLS trace: %s:error in %s\n",
1484                                 op, state, 0 );
1485 #else
1486                         Debug( LDAP_DEBUG_TRACE,
1487                                    "TLS trace: %s:error in %s\n",
1488                                    op, state, 0 );
1489 #endif
1490                 }
1491         }
1492 #ifdef HAVE_EBCDIC
1493         if ( state ) LDAP_FREE( state );
1494 #endif
1495 }
1496
1497 static int
1498 tls_verify_cb( int ok, X509_STORE_CTX *ctx )
1499 {
1500         X509 *cert;
1501         int errnum;
1502         int errdepth;
1503         X509_NAME *subject;
1504         X509_NAME *issuer;
1505         char *sname;
1506         char *iname;
1507         char *certerr = NULL;
1508
1509         cert = X509_STORE_CTX_get_current_cert( ctx );
1510         errnum = X509_STORE_CTX_get_error( ctx );
1511         errdepth = X509_STORE_CTX_get_error_depth( ctx );
1512
1513         /*
1514          * X509_get_*_name return pointers to the internal copies of
1515          * those things requested.  So do not free them.
1516          */
1517         subject = X509_get_subject_name( cert );
1518         issuer = X509_get_issuer_name( cert );
1519         /* X509_NAME_oneline, if passed a NULL buf, allocate memomry */
1520         sname = X509_NAME_oneline( subject, NULL, 0 );
1521         iname = X509_NAME_oneline( issuer, NULL, 0 );
1522         if ( !ok ) certerr = (char *)X509_verify_cert_error_string( errnum );
1523 #ifdef HAVE_EBCDIC
1524         if ( sname ) __etoa( sname );
1525         if ( iname ) __etoa( iname );
1526         if ( certerr ) {
1527                 certerr = LDAP_STRDUP( certerr );
1528                 __etoa( certerr );
1529         }
1530 #endif
1531 #ifdef NEW_LOGGING
1532         LDAP_LOG( TRANSPORT, ERR,
1533                    "TLS certificate verification: depth: %d, err: %d, subject: %s,",
1534                    errdepth, errnum,
1535                    sname ? sname : "-unknown-" );
1536         LDAP_LOG( TRANSPORT, ERR, " issuer: %s\n", iname ? iname : "-unknown-", 0, 0 );
1537         if ( !ok ) {
1538                 LDAP_LOG ( TRANSPORT, ERR,
1539                         "TLS certificate verification: Error, %s\n",
1540                         certerr, 0, 0 );
1541         }
1542 #else
1543         Debug( LDAP_DEBUG_TRACE,
1544                    "TLS certificate verification: depth: %d, err: %d, subject: %s,",
1545                    errdepth, errnum,
1546                    sname ? sname : "-unknown-" );
1547         Debug( LDAP_DEBUG_TRACE, " issuer: %s\n", iname ? iname : "-unknown-", 0, 0 );
1548         if ( !ok ) {
1549                 Debug( LDAP_DEBUG_ANY,
1550                         "TLS certificate verification: Error, %s\n",
1551                         certerr, 0, 0 );
1552         }
1553 #endif
1554         if ( sname )
1555                 CRYPTO_free ( sname );
1556         if ( iname )
1557                 CRYPTO_free ( iname );
1558 #ifdef HAVE_EBCDIC
1559         if ( certerr ) LDAP_FREE( certerr );
1560 #endif
1561         return ok;
1562 }
1563
1564 static int
1565 tls_verify_ok( int ok, X509_STORE_CTX *ctx )
1566 {
1567         (void) tls_verify_cb( ok, ctx );
1568         return 1;
1569 }
1570
1571 /* Inspired by ERR_print_errors in OpenSSL */
1572 static void
1573 tls_report_error( void )
1574 {
1575         unsigned long l;
1576         char buf[200];
1577         const char *file;
1578         int line;
1579
1580         while ( ( l = ERR_get_error_line( &file, &line ) ) != 0 ) {
1581                 ERR_error_string_n( l, buf, sizeof( buf ) );
1582 #ifdef HAVE_EBCDIC
1583                 if ( file ) {
1584                         file = LDAP_STRDUP( file );
1585                         __etoa( (char *)file );
1586                 }
1587                 __etoa( buf );
1588 #endif
1589 #ifdef NEW_LOGGING
1590                 LDAP_LOG ( TRANSPORT, ERR,
1591                         "tls_report_error: TLS %s %s:%d\n",
1592                         buf, file, line );
1593 #else
1594                 Debug( LDAP_DEBUG_ANY, "TLS: %s %s:%d\n",
1595                         buf, file, line );
1596 #endif
1597 #ifdef HAVE_EBCDIC
1598                 if ( file ) LDAP_FREE( (void *)file );
1599 #endif
1600         }
1601 }
1602
1603 static RSA *
1604 tls_tmp_rsa_cb( SSL *ssl, int is_export, int key_length )
1605 {
1606         RSA *tmp_rsa;
1607
1608         /* FIXME:  Pregenerate the key on startup */
1609         /* FIXME:  Who frees the key? */
1610         tmp_rsa = RSA_generate_key( key_length, RSA_F4, NULL, NULL );
1611
1612         if ( !tmp_rsa ) {
1613 #ifdef NEW_LOGGING
1614                 LDAP_LOG ( TRANSPORT, ERR,
1615                         "tls_tmp_rsa_cb: TLS Failed to generate temporary %d-bit %s "
1616                         "RSA key\n", key_length, is_export ? "export" : "domestic", 0 );
1617 #else
1618                 Debug( LDAP_DEBUG_ANY,
1619                         "TLS: Failed to generate temporary %d-bit %s RSA key\n",
1620                         key_length, is_export ? "export" : "domestic", 0 );
1621 #endif
1622                 return NULL;
1623         }
1624         return tmp_rsa;
1625 }
1626
1627 static int
1628 tls_seed_PRNG( const char *randfile )
1629 {
1630 #ifndef URANDOM_DEVICE
1631         /* no /dev/urandom (or equiv) */
1632         long total=0;
1633         char buffer[MAXPATHLEN];
1634
1635         if (randfile == NULL) {
1636                 /* The seed file is $RANDFILE if defined, otherwise $HOME/.rnd.
1637                  * If $HOME is not set or buffer too small to hold the pathname,
1638                  * an error occurs.     - From RAND_file_name() man page.
1639                  * The fact is that when $HOME is NULL, .rnd is used.
1640                  */
1641                 randfile = RAND_file_name( buffer, sizeof( buffer ) );
1642
1643         } else if (RAND_egd(randfile) > 0) {
1644                 /* EGD socket */
1645                 return 0;
1646         }
1647
1648         if (randfile == NULL) {
1649 #ifdef NEW_LOGGING
1650                 LDAP_LOG ( TRANSPORT, DETAIL1,
1651                         "tls_seed_PRNG: TLS Use configuration file or "
1652                         "$RANDFILE to define seed PRNG\n", 0, 0, 0 );
1653 #else
1654                 Debug( LDAP_DEBUG_ANY,
1655                         "TLS: Use configuration file or $RANDFILE to define seed PRNG\n",
1656                         0, 0, 0);
1657 #endif
1658                 return -1;
1659         }
1660
1661         total = RAND_load_file(randfile, -1);
1662
1663         if (RAND_status() == 0) {
1664 #ifdef NEW_LOGGING
1665                 LDAP_LOG ( TRANSPORT, DETAIL1,
1666                         "tls_seed_PRNG: TLS PRNG not been seeded with enough data\n",
1667                         0, 0, 0 );
1668 #else
1669                 Debug( LDAP_DEBUG_ANY,
1670                         "TLS: PRNG not been seeded with enough data\n",
1671                         0, 0, 0);
1672 #endif
1673                 return -1;
1674         }
1675
1676         /* assume if there was enough bits to seed that it's okay
1677          * to write derived bits to the file
1678          */
1679         RAND_write_file(randfile);
1680
1681 #endif
1682
1683         return 0;
1684 }
1685
1686 #if 0
1687 static DH *
1688 tls_tmp_dh_cb( SSL *ssl, int is_export, int key_length )
1689 {
1690         return NULL;
1691 }
1692 #endif
1693 #endif
1694
1695 int
1696 ldap_start_tls_s ( LDAP *ld,
1697         LDAPControl **serverctrls,
1698         LDAPControl **clientctrls )
1699 {
1700         int rc;
1701
1702 #ifdef HAVE_TLS
1703         char *rspoid = NULL;
1704         struct berval *rspdata = NULL;
1705
1706         /* XXYYZ: this initiates operation only on default connection! */
1707
1708         if ( ld->ld_sb != NULL && ldap_pvt_tls_inplace( ld->ld_sb ) != 0 ) {
1709                 return LDAP_LOCAL_ERROR;
1710         }
1711
1712         rc = ldap_extended_operation_s( ld, LDAP_EXOP_START_TLS,
1713                 NULL, serverctrls, clientctrls, &rspoid, &rspdata );
1714         if ( rc != LDAP_SUCCESS ) {
1715                 return rc;
1716         }
1717
1718         if ( rspoid != NULL ) {
1719                 LDAP_FREE(rspoid);
1720         }
1721
1722         if ( rspdata != NULL ) {
1723                 ber_bvfree( rspdata );
1724         }
1725
1726         rc = ldap_int_tls_start( ld, ld->ld_defconn, NULL );
1727 #else
1728         rc = LDAP_NOT_SUPPORTED;
1729 #endif
1730         return rc;
1731 }
1732