summaryrefslogtreecommitdiff
path: root/usr/src/lib/libldap4/common/referral.c
diff options
context:
space:
mode:
Diffstat (limited to 'usr/src/lib/libldap4/common/referral.c')
-rw-r--r--usr/src/lib/libldap4/common/referral.c511
1 files changed, 0 insertions, 511 deletions
diff --git a/usr/src/lib/libldap4/common/referral.c b/usr/src/lib/libldap4/common/referral.c
deleted file mode 100644
index 173ee2cfe6..0000000000
--- a/usr/src/lib/libldap4/common/referral.c
+++ /dev/null
@@ -1,511 +0,0 @@
-/*
- *
- * Copyright 1999 Sun Microsystems, Inc. All rights reserved.
- * Use is subject to license terms.
- *
- *
- * Comments:
- *
- */
-
-#pragma ident "%Z%%M% %I% %E% SMI"
-
-#include <stdio.h>
-#include <string.h>
-#include <sys/time.h>
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <sys/errno.h>
-#include "portable.h"
-#include "lber.h"
-#include "ldap.h"
-#include "ldap-private.h"
-#include "ldap-int.h"
-
-static BerElement *
-re_encode_request( LDAP *ld, BerElement *origber, int msgid, LDAPURLDesc *urldesc );
-static void addFollowedRef(LDAPRequest *lr, char *ref);
-static void addToFollowRef(LDAPRequest *lr, char *ref);
-static int addUnFollowedRef(LDAP *ld, LDAPRequest *lr, char *ref);
-
-char ** ldap_errormsg2referrals(char *errmsg) {
- char ** refs;
- int count;
- size_t len;
- char *p, *ref;
-
- if (errmsg == NULL){
- return (NULL);
- }
- len = strlen( errmsg );
- for ( p = errmsg; len >= LDAP_REF_STR_LEN; ++p, --len ) {
- if (( *p == 'R' || *p == 'r' ) && strncasecmp( p,
- LDAP_REF_STR, LDAP_REF_STR_LEN ) == 0 ) {
- *p = '\0';
- p += LDAP_REF_STR_LEN;
- break;
- }
- }
-
- if ( len < LDAP_REF_STR_LEN ) {
- return( NULL);
- }
- count = 1;
- ref = p;
- while ((ref = strchr(ref, '\n')) != NULL)
- count++;
-
- if ((refs = (char **)calloc(count + 1, sizeof(char *))) == NULL){
- return (NULL);
- }
-
- count = 0;
- for (ref = p; ref != NULL; ref= p){
- if ((p = strchr(ref, '\n')) != NULL){
- *p = '\0';
- }
- refs[count++] = strdup(ref);
- if (p != NULL)
- *p++ = '\n';
- }
- return (refs);
-}
-
-char *ldap_referral2error_msg(char ** refs)
-{
- int i;
- size_t len = 0;
- char *msg = NULL;
-
- if (refs == NULL)
- return (msg);
-
- for (i = 0; refs[i] != NULL; i++){
- len += strlen (refs[i]) + 1;
- }
-
- if ((len > 0) && ((msg = (char *)malloc(len + LDAP_REF_STR_LEN + 2)) != NULL)) {
- strncpy(msg, LDAP_REF_STR, LDAP_REF_STR_LEN);
- for (i = 0; refs[i] != NULL; i++) {
- strcat(msg, refs[i]);
- strcat(msg, "\n");
- }
- }
- return (msg);
-}
-
-
-int
-chase_referrals( LDAP *ld, LDAPRequest *lr, char **refs, int *count, int samerequest )
-{
- int rc, len, newdn, i, j, refcnt, errCode;
- char *p, *ports, *ref, *tmpref, *refdn;
- LDAPRequest *origreq;
- LDAPServer *srv;
- BerElement *ber;
- LDAPURLDesc *ludp;
-
-
- Debug( LDAP_DEBUG_TRACE, catgets(slapdcat, 1, 215, "=> chase_referrals\n"), 0, 0, 0 );
-
- ld->ld_errno = LDAP_SUCCESS; /* optimistic */
- *count = 0;
- if ( refs == NULL ) {
- return( LDAP_SUCCESS );
- }
-
-#ifdef _REENTRANT
- LOCK_LDAP(ld);
-#endif
-
- if ( lr->lr_parentcnt >= ld->ld_refhoplimit ) {
- Debug( LDAP_DEBUG_ANY,
- catgets(slapdcat, 1, 216, "more than %d referral hops (dropping)\n"),
- ld->ld_refhoplimit, 0, 0 );
- /* XXX report as error in ld->ld_errno? */
- rc = ld->ld_errno = (ld->ld_version >= LDAP_VERSION3) ? LDAP_REFERRAL_LIMIT_EXCEEDED : LDAP_OTHER;
-#ifdef _REENTRANT
- UNLOCK_LDAP(ld);
-#endif
- return( rc );
- }
-
- /* find original request */
- for ( origreq = lr; origreq->lr_parent != NULL;
- origreq = origreq->lr_parent ) {
- ;
- }
-
- for (refcnt = 0; refs[refcnt] != NULL; refcnt++)
- ; /* Count number of referrals */
- Debug(LDAP_DEBUG_TRACE, catgets(slapdcat, 1, 1277, "%d possible referrals to chase\n"), refcnt, 0,0);
-
- rc = 0;
- /* parse out & follow referrals */
- for (i = 0; rc == 0 && refs[i] != NULL; i++) {
- Debug(LDAP_DEBUG_TRACE, catgets(slapdcat, 1, -1, "Try to chase %s\n"), refs[i], 0,0);
-
- /* Parse URL */
- if (ldap_url_parse(refs[i], &ludp) != 0){
- Debug(LDAP_DEBUG_TRACE, catgets(slapdcat, 1, -1, "Bad URL for referral %s\n"), refs[i], 0,0);
- errCode = LDAP_PARAM_ERROR;
- addUnFollowedRef(ld, lr, refs[i]);
- /* try next URL */
- continue;
- }
-
- /* Encode previous request with new URL */
- if (( ber = re_encode_request( ld, origreq->lr_ber, ++ld->ld_msgid, ludp )) == NULL ) {
- Debug(LDAP_DEBUG_TRACE, catgets(slapdcat, 1, -1, "Error while encoding request for referral\n"), 0, 0,0);
- ldap_free_urldesc(ludp);
- errCode = ld->ld_errno;
- addUnFollowedRef(ld, lr, refs[i]);
- /* try next URL */
- continue;
- }
-
- if (( srv = (LDAPServer *)calloc( 1, sizeof( LDAPServer ))) == NULL ) {
- ldap_free_urldesc(ludp);
- ber_free( ber, 1 );
- rc = ld->ld_errno = LDAP_NO_MEMORY;
-#ifdef _REENTRANT
- UNLOCK_LDAP(ld);
-#endif
- return( rc );
- }
-
- if (( srv->lsrv_host = strdup( ludp->lud_host ? ludp->lud_host : ld->ld_defhost)) == NULL ) {
- ldap_free_urldesc(ludp);
- free( (char *)srv );
- ber_free( ber, 1 );
- rc = ld->ld_errno = LDAP_NO_MEMORY;
-#ifdef _REENTRANT
- UNLOCK_LDAP(ld);
-#endif
- return( rc );
- }
-
- srv->lsrv_port = ludp->lud_port ? ludp->lud_port : LDAP_PORT;
-
- if ( srv != NULL && send_server_request( ld, ber, ld->ld_msgid,
- lr, srv, NULL, 1 ) >= 0 ) {
- ++*count;
- Debug(LDAP_DEBUG_TRACE, catgets(slapdcat, 1, -1, "Request has been forwarded to %s\n"), refs[i], 0,0);
- addFollowedRef(lr, refs[i]);
- for (j = i+1; refs[j] != NULL; j++){
- addToFollowRef(lr, refs[j]);
- }
- ldap_free_urldesc(ludp);
- break;
- } else {
- Debug( LDAP_DEBUG_ANY,
- catgets(slapdcat, 1, 220, "Unable to chase referral (%s)\n"),
- ldap_err2string( ld->ld_errno ), 0, 0 );
- addUnFollowedRef(ld, lr, refs[i]);
- errCode = ld->ld_errno;
- }
- ldap_free_urldesc(ludp); /* So far spawn all requests */
- }
-
-#ifdef _REENTRANT
- UNLOCK_LDAP(ld);
-#endif
- if (refs[i] != NULL) {
- rc = LDAP_SUCCESS;
- } else {
- Debug(LDAP_DEBUG_TRACE, catgets(slapdcat, 1, -1, "No referral was successfully chased (last error %d)\n"), errCode, 0, 0);
- rc = errCode;
- }
- Debug ( LDAP_DEBUG_TRACE, catgets(slapdcat, 1, 1278, "<= chase_referrals --- \n"), 0,0,0);
-
- return( rc );
-}
-
-static void addFollowedRef(LDAPRequest *lr, char *ref)
-{
- int i;
-
- if (lr->lr_ref_followed == NULL){
- if ((lr->lr_ref_followed = (char **)calloc(2, sizeof(char*))) == NULL)
- return;
- i = 0;
- } else {
- for (i = 0; lr->lr_ref_followed[i] != NULL; i++);
- if ((lr->lr_ref_followed = (char **)realloc((char *)lr->lr_ref_followed, (i+2) * sizeof(char *))) == NULL){
- return;
- }
- }
- lr->lr_ref_followed[i++] = strdup(ref);
- lr->lr_ref_followed[i] = NULL;
- return;
-}
-
-static void addToFollowRef(LDAPRequest *lr, char *ref)
-{
- int i;
-
- if (lr->lr_ref_tofollow == NULL){
- if ((lr->lr_ref_tofollow = (char **)calloc(2, sizeof(char*))) == NULL)
- return;
- i = 0;
- } else {
- for (i = 0; lr->lr_ref_tofollow[i] != NULL; i++);
- if ((lr->lr_ref_tofollow = (char **)realloc((char *)lr->lr_ref_tofollow, (i+2) * sizeof(char *))) == NULL){
- return;
- }
- }
- lr->lr_ref_tofollow[i++] = strdup(ref);
- lr->lr_ref_tofollow[i] = NULL;
- return;
-}
-
-static int addUnFollowedRef(LDAP *ld, LDAPRequest *lr, char *ref)
-{
- int i;
-
- if (lr->lr_ref_unfollowed == NULL){
- if ((lr->lr_ref_unfollowed = (char **)calloc(2, sizeof(char*))) == NULL){
- ld->ld_errno = LDAP_NO_MEMORY;
- return (-1);
- }
- i = 0;
- } else {
- for (i = 0; lr->lr_ref_unfollowed[i] != NULL; i++);
- if ((lr->lr_ref_unfollowed = (char **)realloc((char *)lr->lr_ref_unfollowed, (i+2) * sizeof(char *))) == NULL){
- ld->ld_errno = LDAP_NO_MEMORY;
- return (-1);
- }
- }
- lr->lr_ref_unfollowed[i++] = strdup(ref);
- lr->lr_ref_unfollowed[i] = NULL;
- return (0);
-}
-
-
-int
-append_referral( LDAP *ld, char **referralsp, char *s )
-{
- int first;
-
- if ( *referralsp == NULL ) {
- first = 1;
- *referralsp = (char *)malloc( strlen( s ) + LDAP_REF_STR_LEN
- + 1 );
- } else {
- first = 0;
- *referralsp = (char *)realloc( *referralsp,
- strlen( *referralsp ) + strlen( s ) + 2 );
- }
-
- if ( *referralsp == NULL ) {
- ld->ld_errno = LDAP_NO_MEMORY;
- return( -1 );
- }
-
- if ( first ) {
- strcpy( *referralsp, LDAP_REF_STR );
- } else {
- strcat( *referralsp, "\n" );
- }
- strcat( *referralsp, s );
-
- return( 0 );
-}
-
-
-
-static BerElement *
-re_encode_request( LDAP *ld, BerElement *origber, int msgid, LDAPURLDesc *urldesc )
-{
-/*
- * XXX this routine knows way too much about how the lber library works!
- */
- unsigned int along, tag, len;
- int ver, scope, deref, sizelimit, timelimit, attrsonly;
- int rc, hasCtrls;
- BerElement tmpber, *ber;
- char *dn, *seqstart;
-
- Debug( LDAP_DEBUG_TRACE,
- catgets(slapdcat, 1, 221, "re_encode_request: new msgid %1$d, new dn <%2$s>\n"),
- msgid, ( urldesc->lud_dn == NULL ) ? "NONE" : urldesc->lud_dn, 0 );
-
- tmpber = *origber;
-
- /*
- * all LDAP requests are sequences that start with a message id,
- * followed by a sequence that is tagged with the operation code
- */
- /* Bad assumption : delete op is not a sequence.
- * So we have a special processing for it : it's much simpler
- */
- if ( ber_scanf( &tmpber, "{i", &along ) != LDAP_TAG_MSGID ||
- ( tag = ber_peek_tag( &tmpber, &along )) == LBER_DEFAULT ) {
- ld->ld_errno = LDAP_DECODING_ERROR;
- return( NULL );
- }
-
- /* Special case : delete request is not a sequence of... */
- if (tag == LDAP_REQ_EXTENDED){
- /* return error, I don't know how to do it automatically */
- ld->ld_errno = LDAP_NOT_SUPPORTED;
- return (NULL);
- }
-
- if ( (ber = alloc_ber_with_options( ld )) == NULLBER ) {
- return (NULL);
- }
-
- if (tag == LDAP_REQ_DELETE) {
- if ( ber_get_stringa( &tmpber, &dn ) == LBER_DEFAULT ) {
- ld->ld_errno = LDAP_DECODING_ERROR;
- Debug(LDAP_DEBUG_TRACE,
- catgets(slapdcat, 1, 1279,"Error in decoding delete DN"),0,0,0);
- ber_free( ber, 1);
- return( NULL );
- }
- /* Check if controls */
- hasCtrls = 0;
- if (ber_peek_tag(&tmpber, &len) == LDAP_TAG_CONTROL_LIST){
- hasCtrls = 1;
- }
-
- if ( urldesc->lud_dn && *urldesc->lud_dn ) {
- free( dn );
- dn = urldesc->lud_dn;
- }
- if ( ber_printf( ber, "{its", msgid, tag, dn ) == -1 ) {
- Debug(LDAP_DEBUG_TRACE, "Error in re_encoding delete request",0,0,0);
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return (NULL);
- }
- /* Now add controls if any */
- if (hasCtrls && ber_write( ber, tmpber.ber_ptr, len, 0 ) != len ) {
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
- if (ber_printf( ber, "}" ) == -1 ) {
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
-
-#ifdef LDAP_DEBUG
- if ( ldap_debug & LDAP_DEBUG_PACKETS ) {
- Debug( LDAP_DEBUG_ANY, catgets(slapdcat, 1, 222, "re_encode_request new request is:\n"),
- 0, 0, 0 );
- ber_dump( ber, 0 );
- }
-#endif /* LDAP_DEBUG */
- return (ber);
- }
-
- if (( tag = ber_skip_tag( &tmpber, &along )) == LBER_DEFAULT ) {
- ld->ld_errno = LDAP_DECODING_ERROR;
- return( NULL );
- }
- /* Keep length and pointer */
- seqstart = tmpber.ber_ptr;
-
- /* bind requests have a version number before the DN & other stuff */
- if ( tag == LDAP_REQ_BIND && ber_get_int( &tmpber, &ver ) ==
- LBER_DEFAULT ) {
- ld->ld_errno = LDAP_DECODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
-
- /* the rest of the request is the DN followed by other stuff */
- if ( ber_get_stringa( &tmpber, &dn ) == LBER_DEFAULT ) {
- ber_free( ber, 1 );
- return( NULL );
- }
- if ( urldesc->lud_dn != NULL ) {
- free( dn );
- dn = urldesc->lud_dn;
- }
-
- /* see what to do with CONTROLS */
-
- if ( tag == LDAP_REQ_BIND ) {
- rc = ber_printf( ber, "{it{is", msgid, tag, ver, dn );
- } else {
- rc = ber_printf( ber, "{it{s", msgid, tag, dn );
- }
-
- if ( rc == -1 ) {
- ber_free( ber, 1 );
- return( NULL );
- }
-
- if (tag == LDAP_REQ_SEARCH) {
- /* Now for SEARCH, decode more of the request */
- if (ber_scanf(&tmpber, "iiiib", &scope, &deref, &sizelimit, &timelimit, &attrsonly) == LBER_DEFAULT){
- ld->ld_errno = LDAP_DECODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
- if (ber_printf(ber, "iiiib", urldesc->lud_scope == LDAP_SCOPE_UNKNOWN ? scope : urldesc->lud_scope,
- deref, sizelimit, timelimit, attrsonly) == -1) {
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
- /* We should then decode and check the filter as opposed to ludp->lud_filter */
- /* Same for attributes */
- /* Later */
- }
- /* The rest is the same for all requests */
-
- /* Copy Buffer from tmpber.ber_ptr for along - (tmpber.ber_ptr - seqstart) */
- /* It's the rest of the request */
- len = along - ( tmpber.ber_ptr - seqstart);
- if ( ber_write( ber, tmpber.ber_ptr, len, 0) != len ||
- ber_printf( ber, "}" ) == -1 ) {
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
-
- if (seqstart + along < tmpber.ber_end){ /* there's probably some controls, copy them also */
- len = tmpber.ber_end - seqstart - along;
- if ( ber_write( ber, seqstart + along, len, 0) != len ){
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
- }
-
- if ( ber_printf(ber, "}") == -1) {
- ld->ld_errno = LDAP_ENCODING_ERROR;
- ber_free( ber, 1 );
- return( NULL );
- }
-
-#ifdef LDAP_DEBUG
- if ( ldap_debug & LDAP_DEBUG_PACKETS ) {
- Debug( LDAP_DEBUG_ANY, catgets(slapdcat, 1, 222, "re_encode_request new request is:\n"),
- 0, 0, 0 );
- ber_dump( ber, 0 );
- }
-#endif /* LDAP_DEBUG */
-
- return( ber );
-}
-
-
-LDAPRequest *
-find_request_by_msgid( LDAP *ld, int msgid )
-{
- LDAPRequest *lr;
-
- for ( lr = ld->ld_requests; lr != NULL; lr = lr->lr_next ) {
- if ( msgid == lr->lr_msgid ) {
- break;
- }
- }
-
- return( lr );
-}