slapd/back-ldap/distproc.c

238 #define	LDAP_DISTPROC_CHAINING( lc )	( ( (lc)->lc_flags & LDAP_DISTPROC_F_CHAINING ) == LDAP_DISTPROC_F_CHAINING )
239 #define	LDAP_DISTPROC_CACHE_URI( lc )	( ( (lc)->lc_flags & LDAP_DISTPROC_F_CACHE_URI ) == LDAP_DISTPROC_F_CACHE_URI )
370 	ldap_distproc_t		*lc;
388 	lc = (ldap_distproc_t *)on->on_bi.bi_private;
399 	if ( lc->lc_common_li == NULL && at != NULL ) {
409 	} else if ( lc->lc_common_li != NULL && at == NULL ) {
420 	if ( lc->lc_common_li == NULL ) {
430 			lc->lc_common_li == NULL ? "common " : "", e->e_name.bv_val );
437 	if ( lc->lc_common_li == NULL ) {
438 		lc->lc_common_li = li;
440 	} else if ( ldap_tavl_insert( &lc->lc_lai.lai_tree, (caddr_t)li,
496 	ldap_distproc_t	*lc = (ldap_distproc_t *)on->on_bi.bi_private;
510 		ldap_distproc_cfadd_apply( lc->lc_common_li, op, rs, p, ca, count++ );
512 		edge = ldap_tavl_end( lc->lc_lai.lai_tree, TAVL_DIR_LEFT );
530 	ldap_distproc_t	*lc = (ldap_distproc_t *)on->on_bi.bi_private;
537 			c->value_int = LDAP_DISTPROC_CACHE_URI( lc );
552 			lc->lc_flags &= ~LDAP_DISTPROC_F_CACHE_URI;
564 			lc->lc_flags |= LDAP_DISTPROC_F_CACHE_URI;
566 			lc->lc_flags &= ~LDAP_DISTPROC_F_CACHE_URI;
584 	ldap_distproc_t	*lc = NULL;
594 	lc = ch_malloc( sizeof( ldap_distproc_t ) );
595 	if ( lc == NULL ) {
598 	memset( lc, 0, sizeof( ldap_distproc_t ) );
599 	ldap_pvt_thread_mutex_init( &lc->lc_lai.lai_mutex );
601 	on->on_bi.bi_private = (void *)lc;
615 	ldap_distproc_t	*lc = (ldap_distproc_t *)on->on_bi.bi_private;
619 	if ( lc->lc_common_li == NULL ) {
622 		lc->lc_common_li = lc->lc_cfg_li = (ldapinfo_t *)be->be_private;
644 			lc->lc_cfg_li = be->be_private;
656 		be->be_private = (void *)lc->lc_cfg_li;
672 				db.be_private = (void *)lc->lc_cfg_li;
674 				lc->lc_cfg_li = NULL;
677 				if ( lc->lc_cfg_li->li_bvuri == NULL
678 					|| BER_BVISNULL( &lc->lc_cfg_li->li_bvuri[ 0 ] )
679 					|| !BER_BVISNULL( &lc->lc_cfg_li->li_bvuri[ 1 ] ) )
688 				if ( ldap_tavl_insert( &lc->lc_lai.lai_tree,
689 					(caddr_t)lc->lc_cfg_li,
720 	ldap_distproc_t	*lc = (ldap_distproc_t *)on->on_bi.bi_private;
724 	if ( lc ) {
727 		if ( func != NULL && lc->lc_common_li != NULL ) {
731 			db.be_private = lc->lc_common_li;
739 			if ( lc->lc_lai.lai_tree != NULL ) {
740 				TAvlnode *edge = ldap_tavl_end( lc->lc_lai.lai_tree, TAVL_DIR_LEFT );
780 	ldap_distproc_t	*lc = (ldap_distproc_t *)on->on_bi.bi_private;
786 	if ( lc ) {
787 		ldap_tavl_free( lc->lc_lai.lai_tree, NULL );
788 		ldap_pvt_thread_mutex_destroy( &lc->lc_lai.lai_mutex );
789 		ch_free( lc );
830 	ldap_distproc_t	*lc = (ldap_distproc_t *)on->on_bi.bi_private;
846 	li->li_nretries = lc->lc_common_li->li_nretries;
847 	li->li_flags = lc->lc_common_li->li_flags;
848 	li->li_version = lc->lc_common_li->li_version;
850 		li->li_timeout[ t ] = lc->lc_common_li->li_timeout[ t ];
864 	ldap_distproc_t		*lc = (ldap_distproc_t *)on->on_bi.bi_private;
870 	ldap_pvt_thread_mutex_lock( &lc->lc_lai.lai_mutex );
871 	edge = ldap_tavl_end( lc->lc_lai.lai_tree, TAVL_DIR_LEFT );
882 	ldap_pvt_thread_mutex_unlock( &lc->lc_lai.lai_mutex );