X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=libraries%2Flibldap%2Frequest.c;h=07da8e9bcec79d63a8c3a8c9dc862afc6082c72f;hb=403f4479bc9f9a864122d4aeecf7284408918302;hp=821a29aa7498e1d4626ef8f608b4283d416f9366;hpb=c24d932b02e97472a67f7e71e01b3963469e3e77;p=openldap diff --git a/libraries/libldap/request.c b/libraries/libldap/request.c index 821a29aa74..07da8e9bce 100644 --- a/libraries/libldap/request.c +++ b/libraries/libldap/request.c @@ -1,4 +1,9 @@ +/* $OpenLDAP$ */ /* + * Copyright 1998-1999 The OpenLDAP Foundation, All Rights Reserved. + * COPYING RESTRICTIONS APPLY, see COPYRIGHT file + */ +/* Portions * Copyright (c) 1995 Regents of the University of Michigan. * All rights reserved. * @@ -7,12 +12,9 @@ #include "portable.h" -#ifndef lint -static char copyright[] = "@(#) Copyright (c) 1995 Regents of the University of Michigan.\nAll rights reserved.\n"; -#endif - #include -#include + +#include #include #include @@ -21,22 +23,21 @@ static char copyright[] = "@(#) Copyright (c) 1995 Regents of the University of #include #include "ldap-int.h" +#include "lber.h" -#if defined( LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS ) || defined( LDAP_API_FEATURE_X_OPENLDAP_V2_DNS ) static LDAPConn *find_connection LDAP_P(( LDAP *ld, LDAPServer *srv, int any )); static void use_connection LDAP_P(( LDAP *ld, LDAPConn *lc )); static void free_servers LDAP_P(( LDAPServer *srvlist )); -#endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS || LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ - #ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_DNS -static LDAPServer *dn2servers LDAP_P(( LDAP *ld, char *dn )); +static LDAPServer *dn2servers LDAP_P(( LDAP *ld, const char *dn )); #endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ -#ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS -static BerElement *re_encode_request LDAP_P(( LDAP *ld, BerElement *origber, - int msgid, char **dnp )); -#endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS */ +static BerElement *re_encode_request LDAP_P(( + LDAP *ld, + BerElement *origber, + ber_int_t msgid, + char **dnp )); BerElement * @@ -44,7 +45,7 @@ ldap_alloc_ber_with_options( LDAP *ld ) { BerElement *ber; - if (( ber = ber_alloc_t( ld->ld_lberoptions )) == NULLBER ) { + if (( ber = ber_alloc_t( ld->ld_lberoptions )) == NULL ) { ld->ld_errno = LDAP_NO_MEMORY; #ifdef STR_TRANSLATION } else { @@ -70,28 +71,51 @@ ldap_set_ber_options( LDAP *ld, BerElement *ber ) } -int -ldap_send_initial_request( LDAP *ld, unsigned long msgtype, char *dn, +ber_int_t +ldap_send_initial_request( + LDAP *ld, + ber_tag_t msgtype, + const char *dn, BerElement *ber ) { -#if defined( LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS ) || defined( LDAP_API_FEATURE_X_OPENLDAP_V2_DNS ) - LDAPServer *servers; -#endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS || LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ + LDAPServer *servers, *srv; Debug( LDAP_DEBUG_TRACE, "ldap_send_initial_request\n", 0, 0, 0 ); -#if !defined( LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS ) && !defined( LDAP_API_FEATURE_X_OPENLDAP_V2_DNS ) - if ( ber_flush( &ld->ld_sb, ber, 1 ) != 0 ) { - ld->ld_errno = LDAP_SERVER_DOWN; - return( -1 ); + if ( ! ber_pvt_sb_in_use(&ld->ld_sb ) ) { + /* not connected yet */ + + if (( srv = (LDAPServer *)LDAP_CALLOC( 1, sizeof( LDAPServer ))) == + NULL || ( ld->ld_defhost != NULL && ( srv->lsrv_host = + LDAP_STRDUP( ld->ld_defhost )) == NULL )) + { + if (srv != NULL) LDAP_FREE( srv ); + ber_free( ber, 1 ); + ld->ld_errno = LDAP_NO_MEMORY; + return( -1 ); + } + + srv->lsrv_port = ld->ld_defport; + + if (( ld->ld_defconn = ldap_new_connection( ld, &srv, 1,1,0 )) + == NULL ) + { + if ( ld->ld_defhost != NULL ) LDAP_FREE( srv->lsrv_host ); + LDAP_FREE( (char *)srv ); + ber_free( ber, 1 ); + ld->ld_errno = LDAP_SERVER_DOWN; + return( -1 ); + } + ++ld->ld_defconn->lconn_refcnt; /* so it never gets closed/freed */ + + Debug( LDAP_DEBUG_TRACE, + "ldap_delayed_open successful, ld_host is %s\n", + ( ld->ld_host == NULL ) ? "(null)" : ld->ld_host, 0, 0 ); } - ld->ld_errno = LDAP_SUCCESS; - return( ld->ld_msgid ); -#else /* !LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS && !LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ #ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_DNS - if (( LDAP_BOOL_GET(&ld->ld_options, LDAP_BOOL_DNS ) == LDAP_OPT_ON ) + if ( LDAP_BOOL_GET(&ld->ld_options, LDAP_BOOL_DNS ) && ldap_is_dns_dn( dn ) ) { if (( servers = dn2servers( ld, dn )) == NULL ) { @@ -113,28 +137,31 @@ ldap_send_initial_request( LDAP *ld, unsigned long msgtype, char *dn, } } #endif /* LDAP_DEBUG */ - } else { + } else #endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ + { /* * use of DNS is turned off or this is an X.500 DN... * use our default connection */ servers = NULL; -#ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_DNS } -#endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ return( ldap_send_server_request( ld, ber, ld->ld_msgid, NULL, servers, NULL, 0 )); -#endif /* !LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS && !LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ } -#if defined( LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS ) || defined( LDAP_API_FEATURE_X_OPENLDAP_V2_DNS ) int -ldap_send_server_request( LDAP *ld, BerElement *ber, int msgid, LDAPRequest - *parentreq, LDAPServer *srvlist, LDAPConn *lc, int bind ) +ldap_send_server_request( + LDAP *ld, + BerElement *ber, + ber_int_t msgid, + LDAPRequest *parentreq, + LDAPServer *srvlist, + LDAPConn *lc, + int bind ) { LDAPRequest *lr; int incparent; @@ -174,7 +201,7 @@ ldap_send_server_request( LDAP *ld, BerElement *ber, int msgid, LDAPRequest } use_connection( ld, lc ); - if (( lr = (LDAPRequest *)calloc( 1, sizeof( LDAPRequest ))) == + if (( lr = (LDAPRequest *)LDAP_CALLOC( 1, sizeof( LDAPRequest ))) == NULL ) { ld->ld_errno = LDAP_NO_MEMORY; ldap_free_connection( ld, lc, 0, 0 ); @@ -253,11 +280,10 @@ ldap_new_connection( LDAP *ld, LDAPServer **srvlistp, int use_ldsb, * make a new LDAP server connection * XXX open connection synchronously for now */ - if (( lc = (LDAPConn *)calloc( 1, sizeof( LDAPConn ))) == NULL || - ( !use_ldsb && ( sb = (Sockbuf *)calloc( 1, sizeof( Sockbuf ))) - == NULL )) { + if (( lc = (LDAPConn *)LDAP_CALLOC( 1, sizeof( LDAPConn ))) == NULL || + ( !use_ldsb && ( (sb = ber_sockbuf_alloc()) == NULL ))) { if ( lc != NULL ) { - free( (char *)lc ); + LDAP_FREE( (char *)lc ); } ld->ld_errno = LDAP_NO_MEMORY; return( NULL ); @@ -279,9 +305,9 @@ ldap_new_connection( LDAP *ld, LDAPServer **srvlistp, int use_ldsb, if ( srv == NULL ) { if ( !use_ldsb ) { - free( (char *)lc->lconn_sb ); + ber_sockbuf_free( lc->lconn_sb ); } - free( (char *)lc ); + LDAP_FREE( (char *)lc ); ld->ld_errno = LDAP_SERVER_DOWN; return( NULL ); } @@ -309,7 +335,7 @@ ldap_new_connection( LDAP *ld, LDAPServer **srvlistp, int use_ldsb, freepasswd = err = 0; - if ( ld->ld_rebindproc == NULL ) { + if ( ld->ld_rebindproc == 0 ) { binddn = passwd = ""; authmethod = LDAP_AUTH_SIMPLE; } else { @@ -384,7 +410,7 @@ static void use_connection( LDAP *ld, LDAPConn *lc ) { ++lc->lconn_refcnt; - lc->lconn_lastused = time( 0 ); + lc->lconn_lastused = time( NULL ); } @@ -399,11 +425,12 @@ ldap_free_connection( LDAP *ld, LDAPConn *lc, int force, int unbind ) if ( lc->lconn_status == LDAP_CONNST_CONNECTED ) { ldap_mark_select_clear( ld, lc->lconn_sb ); if ( unbind ) { - ldap_send_unbind( ld, lc->lconn_sb ); + ldap_send_unbind( ld, lc->lconn_sb, NULL, NULL ); } ldap_close_connection( lc->lconn_sb ); - if ( lc->lconn_sb->sb_ber.ber_buf != NULL ) { - free( lc->lconn_sb->sb_ber.ber_buf ); + ber_pvt_sb_destroy( lc->lconn_sb ); + if( lc->lconn_ber != NULL ) { + ber_free( lc->lconn_ber, 1 ); } } prevlc = NULL; @@ -421,16 +448,16 @@ ldap_free_connection( LDAP *ld, LDAPConn *lc, int force, int unbind ) } free_servers( lc->lconn_server ); if ( lc->lconn_krbinstance != NULL ) { - free( lc->lconn_krbinstance ); + LDAP_FREE( lc->lconn_krbinstance ); } if ( lc->lconn_sb != &ld->ld_sb ) { - free( (char *)lc->lconn_sb ); + ber_sockbuf_free( lc->lconn_sb ); } - free( lc ); + LDAP_FREE( lc ); Debug( LDAP_DEBUG_TRACE, "ldap_free_connection: actually freed\n", 0, 0, 0 ); } else { - lc->lconn_lastused = time( 0 ); + lc->lconn_lastused = time( NULL ); Debug( LDAP_DEBUG_TRACE, "ldap_free_connection: refcnt %d\n", lc->lconn_refcnt, 0, 0 ); } @@ -442,6 +469,7 @@ void ldap_dump_connection( LDAP *ld, LDAPConn *lconns, int all ) { LDAPConn *lc; + char timebuf[32]; fprintf( stderr, "** Connection%s:\n", all ? "s" : "" ); for ( lc = lconns; lc != NULL; lc = lc->lconn_next ) { @@ -457,7 +485,7 @@ ldap_dump_connection( LDAP *ld, LDAPConn *lconns, int all ) "NeedSocket" : ( lc->lconn_status == LDAP_CONNST_CONNECTING ) ? "Connecting" : "Connected" ); fprintf( stderr, " last used: %s\n", - ctime( &lc->lconn_lastused )); + ldap_pvt_ctime( &lc->lconn_lastused, timebuf )); if ( !all ) { break; } @@ -487,18 +515,19 @@ ldap_dump_requests_and_responses( LDAP *ld ) } fprintf( stderr, "** Response Queue:\n" ); - if (( lm = ld->ld_responses ) == NULLMSG ) { + if (( lm = ld->ld_responses ) == NULL ) { fprintf( stderr, " Empty\n" ); } - for ( ; lm != NULLMSG; lm = lm->lm_next ) { - fprintf( stderr, " * msgid %d, type %d\n", - lm->lm_msgid, lm->lm_msgtype ); + for ( ; lm != NULL; lm = lm->lm_next ) { + fprintf( stderr, " * msgid %d, type %lu\n", + lm->lm_msgid, (unsigned long) lm->lm_msgtype ); if (( l = lm->lm_chain ) != NULL ) { fprintf( stderr, " chained responses:\n" ); - for ( ; l != NULLMSG; l = l->lm_chain ) { + for ( ; l != NULL; l = l->lm_chain ) { fprintf( stderr, - " * msgid %d, type %d\n", - l->lm_msgid, l->lm_msgtype ); + " * msgid %d, type %lu\n", + l->lm_msgid, + (unsigned long) l->lm_msgtype ); } } } @@ -539,14 +568,14 @@ ldap_free_request( LDAP *ld, LDAPRequest *lr ) } if ( lr->lr_res_error != NULL ) { - free( lr->lr_res_error ); + LDAP_FREE( lr->lr_res_error ); } if ( lr->lr_res_matched != NULL ) { - free( lr->lr_res_matched ); + LDAP_FREE( lr->lr_res_matched ); } - free( lr ); + LDAP_FREE( lr ); } @@ -558,19 +587,17 @@ free_servers( LDAPServer *srvlist ) while ( srvlist != NULL ) { nextsrv = srvlist->lsrv_next; if ( srvlist->lsrv_dn != NULL ) { - free( srvlist->lsrv_dn ); + LDAP_FREE( srvlist->lsrv_dn ); } if ( srvlist->lsrv_host != NULL ) { - free( srvlist->lsrv_host ); + LDAP_FREE( srvlist->lsrv_host ); } - free( srvlist ); + LDAP_FREE( srvlist ); srvlist = nextsrv; } } -#endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS || LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ -#ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS /* * XXX merging of errors in this routine needs to be improved */ @@ -678,15 +705,15 @@ ldap_chase_referrals( LDAP *ld, LDAPRequest *lr, char **errstrp, int *hadrefp ) #ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_DNS if ( ldapref ) { #endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_DNS */ - if (( srv = (LDAPServer *)calloc( 1, + if (( srv = (LDAPServer *)LDAP_CALLOC( 1, sizeof( LDAPServer ))) == NULL ) { ber_free( ber, 1 ); ld->ld_errno = LDAP_NO_MEMORY; return( -1 ); } - if (( srv->lsrv_host = ldap_strdup( tmpref )) == NULL ) { - free( (char *)srv ); + if (( srv->lsrv_host = LDAP_STRDUP( tmpref )) == NULL ) { + LDAP_FREE( (char *)srv ); ber_free( ber, 1 ); ld->ld_errno = LDAP_NO_MEMORY; return( -1 ); @@ -696,7 +723,7 @@ ldap_chase_referrals( LDAP *ld, LDAPRequest *lr, char **errstrp, int *hadrefp ) *ports++ = '\0'; srv->lsrv_port = atoi( ports ); } else { - srv->lsrv_port = LDAP_PORT; + srv->lsrv_port = ldap_int_global_options.ldo_defport; } #ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_DNS } else { @@ -715,11 +742,11 @@ ldap_chase_referrals( LDAP *ld, LDAPRequest *lr, char **errstrp, int *hadrefp ) } if ( !newdn && refdn != NULL ) { - free( refdn ); + LDAP_FREE( refdn ); } } - free( *errstrp ); + LDAP_FREE( *errstrp ); *errstrp = unfollowed; return(( rc == 0 ) ? count : rc ); @@ -733,11 +760,11 @@ ldap_append_referral( LDAP *ld, char **referralsp, char *s ) if ( *referralsp == NULL ) { first = 1; - *referralsp = (char *)malloc( strlen( s ) + LDAP_REF_STR_LEN + *referralsp = (char *)LDAP_MALLOC( strlen( s ) + LDAP_REF_STR_LEN + 1 ); } else { first = 0; - *referralsp = (char *)realloc( *referralsp, + *referralsp = (char *)LDAP_REALLOC( *referralsp, strlen( *referralsp ) + strlen( s ) + 2 ); } @@ -759,20 +786,22 @@ ldap_append_referral( LDAP *ld, char **referralsp, char *s ) static BerElement * -re_encode_request( LDAP *ld, BerElement *origber, int msgid, char **dnp ) +re_encode_request( LDAP *ld, BerElement *origber, ber_int_t msgid, char **dnp ) { /* * XXX this routine knows way too much about how the lber library works! */ - unsigned long along, tag; - long ver; + ber_int_t along; + ber_len_t len; + ber_tag_t tag; + ber_int_t ver; int rc; BerElement tmpber, *ber; char *orig_dn; Debug( LDAP_DEBUG_TRACE, - "re_encode_request: new msgid %d, new dn <%s>\n", - msgid, ( *dnp == NULL ) ? "NONE" : *dnp, 0 ); + "re_encode_request: new msgid %ld, new dn <%s>\n", + (long) msgid, ( *dnp == NULL ) ? "NONE" : *dnp, 0 ); tmpber = *origber; @@ -780,18 +809,18 @@ re_encode_request( LDAP *ld, BerElement *origber, int msgid, char **dnp ) * all LDAP requests are sequences that start with a message id, * followed by a sequence that is tagged with the operation code */ - if ( ber_scanf( &tmpber, "{i", &along ) != LDAP_TAG_MSGID || - ( tag = ber_skip_tag( &tmpber, &along )) == LBER_DEFAULT ) { + if ( ber_scanf( &tmpber, "{i", /*}*/ &along ) != LDAP_TAG_MSGID || + ( tag = ber_skip_tag( &tmpber, &len )) == LBER_DEFAULT ) { ld->ld_errno = LDAP_DECODING_ERROR; return( NULL ); } - if (( ber = ldap_alloc_ber_with_options( ld )) == NULLBER ) { + if (( ber = ldap_alloc_ber_with_options( ld )) == NULL ) { return( NULL ); } /* bind requests have a version number before the DN & other stuff */ - if ( tag == LDAP_REQ_BIND && ber_get_int( &tmpber, (long *)&ver ) == + if ( tag == LDAP_REQ_BIND && ber_get_int( &tmpber, &ver ) == LBER_DEFAULT ) { ld->ld_errno = LDAP_DECODING_ERROR; ber_free( ber, 1 ); @@ -807,13 +836,13 @@ re_encode_request( LDAP *ld, BerElement *origber, int msgid, char **dnp ) if ( *dnp == NULL ) { *dnp = orig_dn; } else { - free( orig_dn ); + LDAP_FREE( orig_dn ); } if ( tag == LDAP_REQ_BIND ) { - rc = ber_printf( ber, "{it{is", msgid, tag, ver, *dnp ); + rc = ber_printf( ber, "{it{is" /*}}*/, msgid, tag, ver, *dnp ); } else { - rc = ber_printf( ber, "{it{s", msgid, tag, *dnp ); + rc = ber_printf( ber, "{it{s" /*}}*/, msgid, tag, *dnp ); } if ( rc == -1 ) { @@ -823,7 +852,7 @@ re_encode_request( LDAP *ld, BerElement *origber, int msgid, char **dnp ) if ( ber_write( ber, tmpber.ber_ptr, ( tmpber.ber_end - tmpber.ber_ptr ), 0 ) != ( tmpber.ber_end - tmpber.ber_ptr ) || - ber_printf( ber, "}}" ) == -1 ) { + ber_printf( ber, /*{{*/ "}}" ) == -1 ) { ld->ld_errno = LDAP_ENCODING_ERROR; ber_free( ber, 1 ); return( NULL ); @@ -833,7 +862,7 @@ re_encode_request( LDAP *ld, BerElement *origber, int msgid, char **dnp ) if ( ldap_debug & LDAP_DEBUG_PACKETS ) { Debug( LDAP_DEBUG_ANY, "re_encode_request new request is:\n", 0, 0, 0 ); - ber_dump( ber, 0 ); + ber_log_dump( LDAP_DEBUG_BER, ldap_debug, ber, 0 ); } #endif /* LDAP_DEBUG */ @@ -842,7 +871,7 @@ re_encode_request( LDAP *ld, BerElement *origber, int msgid, char **dnp ) LDAPRequest * -ldap_find_request_by_msgid( LDAP *ld, int msgid ) +ldap_find_request_by_msgid( LDAP *ld, ber_int_t msgid ) { LDAPRequest *lr; @@ -854,14 +883,14 @@ ldap_find_request_by_msgid( LDAP *ld, int msgid ) return( lr ); } -#endif /* LDAP_API_FEATURE_X_OPENLDAP_V2_REFERRALS */ #ifdef LDAP_API_FEATURE_X_OPENLDAP_V2_DNS static LDAPServer * -dn2servers( LDAP *ld, char *dn ) /* dn can also be a domain.... */ +dn2servers( LDAP *ld, const char *dn ) /* dn can also be a domain.... */ { - char *p, *domain, *host, *server_dn, **dxs; + char *p, *host, *server_dn, **dxs; + const char *domain; int i, port; LDAPServer *srvlist, *prevsrv, *srv; @@ -879,7 +908,7 @@ dn2servers( LDAP *ld, char *dn ) /* dn can also be a domain.... */ srvlist = NULL; for ( i = 0; dxs[ i ] != NULL; ++i ) { - port = LDAP_PORT; + port = ldap_int_global_options.ldo_defport; server_dn = NULL; if ( strchr( dxs[ i ], ':' ) == NULL ) { host = dxs[ i ]; @@ -903,7 +932,7 @@ dn2servers( LDAP *ld, char *dn ) /* dn can also be a domain.... */ } if ( host != NULL ) { /* found a server we can use */ - if (( srv = (LDAPServer *)calloc( 1, + if (( srv = (LDAPServer *)LDAP_CALLOC( 1, sizeof( LDAPServer ))) == NULL ) { free_servers( srvlist ); srvlist = NULL; @@ -919,9 +948,9 @@ dn2servers( LDAP *ld, char *dn ) /* dn can also be a domain.... */ prevsrv = srv; /* copy in info. */ - if (( srv->lsrv_host = ldap_strdup( host )) == NULL || + if (( srv->lsrv_host = LDAP_STRDUP( host )) == NULL || ( server_dn != NULL && ( srv->lsrv_dn = - ldap_strdup( server_dn )) == NULL )) { + LDAP_STRDUP( server_dn )) == NULL )) { free_servers( srvlist ); srvlist = NULL; break; /* exit loop & return */