X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Ffilter.c;h=7ebb83100afa5a3a803539ae4593a8c08d5d0471;hb=f8fb4aca7668c722f41941be719203aa8c298e12;hp=345bac312d79ac2936667b5586b61a7ef0faf555;hpb=59aba7711b70848c693e1fe46deeb5fc50b982df;p=openldap

diff --git a/servers/slapd/filter.c b/servers/slapd/filter.c
index 345bac312d..7ebb83100a 100644
--- a/servers/slapd/filter.c
+++ b/servers/slapd/filter.c
@@ -1,7 +1,7 @@
 /* filter.c - routines for parsing and dealing with filters */
 /* $OpenLDAP$ */
 /*
- * Copyright 1998-2000 The OpenLDAP Foundation, All Rights Reserved.
+ * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved.
  * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
  */
 
@@ -18,31 +18,41 @@ static int	get_filter_list(
 	Connection *conn,
 	BerElement *ber,
 	Filter **f,
-	char **fstr,
-	char **text );
+	struct berval *fstr,
+	const char **text );
+
 static int	get_substring_filter(
 	Connection *conn,
 	BerElement *ber,
 	Filter *f,
-	char **fstr,
-	char **text );
+	struct berval *fstr,
+	const char **text );
+
+static int filter_escape_value(
+	struct berval *in,
+	struct berval *out );
 
 int
 get_filter(
 	Connection *conn,
 	BerElement *ber,
 	Filter **filt,
-	char **fstr,
-	char **text )
+	struct berval *fstr,
+	const char **text )
 {
 	ber_tag_t	tag;
 	ber_len_t	len;
 	int		err;
 	Filter		*f;
-	char		*ftmp;
+	struct berval	ftmp = { 0, NULL };
+	struct berval escaped;
 
+#ifdef NEW_LOGGING
+	LDAP_LOG(( "filter", LDAP_LEVEL_ENTRY, "get_filter: conn %d\n",
+		   conn->c_connid ));
+#else
 	Debug( LDAP_DEBUG_FILTER, "begin get_filter\n", 0, 0, 0 );
-
+#endif
 	/*
 	 * A filter looks like this coming in:
 	 *	Filter ::= CHOICE {
@@ -59,19 +69,19 @@ get_filter(
 	 *	}
 	 *
 	 *	SubstringFilter ::= SEQUENCE {
-	 *		type               AttributeType,
+	 *		type		   AttributeType,
 	 *		SEQUENCE OF CHOICE {
-	 *			initial          [0] IA5String,
-	 *			any              [1] IA5String,
-	 *			final            [2] IA5String
+	 *			initial		 [0] IA5String,
+	 *			any		 [1] IA5String,
+	 *			final		 [2] IA5String
 	 *		}
 	 *	}
 	 *
-     *  MatchingRuleAssertion ::= SEQUENCE {
-     *          matchingRule    [1] MatchingRuleId OPTIONAL,
-     *          type            [2] AttributeDescription OPTIONAL,
-     *          matchValue      [3] AssertionValue,
-     *          dnAttributes    [4] BOOLEAN DEFAULT FALSE
+     *	MatchingRuleAssertion ::= SEQUENCE {
+     *		matchingRule	[1] MatchingRuleId OPTIONAL,
+     *		type		[2] AttributeDescription OPTIONAL,
+     *		matchValue	[3] AssertionValue,
+     *		dnAttributes	[4] BOOLEAN DEFAULT FALSE
 	 *	}
 	 *
 	 */
@@ -87,251 +97,318 @@ get_filter(
 	f->f_next = NULL;
 
 	err = LDAP_SUCCESS;
-	*fstr = NULL;
+	*fstr = ftmp;
 	f->f_choice = tag; 
 
 	switch ( f->f_choice ) {
 	case LDAP_FILTER_EQUALITY:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL2,
+			   "get_filter: conn %d  EQUALITY\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "EQUALITY\n", 0, 0, 0 );
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "error decoding filter";
+#endif
+		err = get_ava( ber, &f->f_ava, SLAP_MR_EQUALITY, text );
+		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
 
-		*fstr = ch_malloc( sizeof("(=)")
-			+ f->f_av_desc->ad_cname->bv_len
-			+ f->f_av_value->bv_len );
+		assert( f->f_ava != NULL );
 
-		sprintf( *fstr, "(%s=%s)",
-			f->f_av_desc->ad_cname->bv_val,
-		    f->f_av_value->bv_val );
+		filter_escape_value( &f->f_av_value, &escaped );
 
-#else
-		if ( (err = get_ava( ber, f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "error decoding filter";
-			break;
-		}
+		fstr->bv_len = sizeof("(=)")-1
+			+ f->f_av_desc->ad_cname.bv_len
+			+ escaped.bv_len;
 
-		*fstr = ch_malloc( sizeof("(=)")
-			+ strlen( f->f_avtype )
-			+ f->f_avvalue.bv_len);
-		sprintf( *fstr, "(%s=%s)", f->f_avtype,
-		    f->f_avvalue.bv_val );
-#endif
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+
+		sprintf( fstr->bv_val, "(%s=%s)",
+			f->f_av_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_SUBSTRINGS:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  SUBSTRINGS\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "SUBSTRINGS\n", 0, 0, 0 );
+#endif
 		err = get_substring_filter( conn, ber, f, fstr, text );
 		break;
 
 	case LDAP_FILTER_GE:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  GE\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "GE\n", 0, 0, 0 );
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "decoding filter error";
+#endif
+		err = get_ava( ber, &f->f_ava, SLAP_MR_ORDERING, text );
+		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
 
-		*fstr = ch_malloc( sizeof("(>=)")
-			+ f->f_av_desc->ad_cname->bv_len
-			+ f->f_av_value->bv_len );
+		filter_escape_value( &f->f_av_value, &escaped );
 
-		sprintf( *fstr, "(%s>=%s)",
-			f->f_av_desc->ad_cname->bv_val,
-		    f->f_av_value->bv_val );
+		fstr->bv_len = sizeof("(>=)")-1
+			+ f->f_av_desc->ad_cname.bv_len
+			+ escaped.bv_len;
 
-#else
-		if ( (err = get_ava( ber, f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "decoding filter error";
-			break;
-		}
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
 
-		*fstr = ch_malloc( sizeof("(>=)"
-			+ strlen( f->f_avtype )
-			+ f->f_avvalue.bv_len);
-		sprintf( *fstr, "(%s>=%s)", f->f_avtype,
-		    f->f_avvalue.bv_val );
-#endif
+		sprintf( fstr->bv_val, "(%s>=%s)",
+			f->f_av_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_LE:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  LE\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "LE\n", 0, 0, 0 );
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "decoding filter error";
+#endif
+		err = get_ava( ber, &f->f_ava, SLAP_MR_ORDERING, text );
+		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
 
-		*fstr = ch_malloc( sizeof("(<=)")
-			+ f->f_av_desc->ad_cname->bv_len
-			+ f->f_av_value->bv_len );
 
-		sprintf( *fstr, "(%s<=%s)",
-			f->f_av_desc->ad_cname->bv_val,
-		    f->f_av_value->bv_val );
+		filter_escape_value( &f->f_av_value, &escaped );
 
-#else
-		if ( (err = get_ava( ber, f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "error decoding filter";
-			break;
-		}
-		*fstr = ch_malloc( sizeof("(<=)"
-			+ strlen( f->f_avtype )
-			+ f->f_avvalue.bv_len);
-		sprintf( *fstr, "(%s<=%s)", f->f_avtype,
-		    f->f_avvalue.bv_val );
-#endif
+		fstr->bv_len = sizeof("(<=)")-1
+			+ f->f_av_desc->ad_cname.bv_len
+			+ escaped.bv_len;
+
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+
+		sprintf( fstr->bv_val, "(%s<=%s)",
+			f->f_av_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_PRESENT: {
 		struct berval type;
 
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d PRESENT\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "PRESENT\n", 0, 0, 0 );
-
-		if ( ber_scanf( ber, "o", &type ) == LBER_ERROR ) {
+#endif
+		if ( ber_scanf( ber, "m", &type ) == LBER_ERROR ) {
 			err = SLAPD_DISCONNECT;
 			*text = "error decoding filter";
 			break;
 		}
 
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		{
-			char *text;
-			int rc;
+		f->f_desc = NULL;
+		err = slap_bv2ad( &type, &f->f_desc, text );
 
-			err = slap_bv2ad( &type, &f->f_desc, &text );
-
-			if( err != LDAP_SUCCESS ) {
-				ch_free( type.bv_val );
-				break;
-			}
-
-			ch_free( type.bv_val );
+		if( err != LDAP_SUCCESS ) {
+			/* unrecognized attribute description or other error */
+			f->f_choice = SLAPD_FILTER_COMPUTED;
+			f->f_result = LDAP_COMPARE_FALSE;
+			ber_str2bv("(unrecognized=*)",
+				sizeof("(unrecognized=*)")-1, 1, fstr);
+			err = LDAP_SUCCESS;
+			break;
 		}
 
-		*fstr = ch_malloc( sizeof("(=*)")
-			+ f->f_desc->ad_cname->bv_len );
-		sprintf( *fstr, "(%s=*)",
-			f->f_desc->ad_cname->bv_val );
-#else
-		f->f_type = type.bv_val;
-		err = LDAP_SUCCESS;
-		attr_normalize( f->f_type );
-		*fstr = ch_malloc( sizeof("(=*)")
-			+ strlen( f->f_type ) );
-		sprintf( *fstr, "(%s=*)", f->f_type );
-#endif
+		fstr->bv_len = sizeof("(=*)") - 1 
+			+ f->f_desc->ad_cname.bv_len;
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1);
+		sprintf( fstr->bv_val, "(%s=*)",
+			f->f_desc->ad_cname.bv_val );
+
 		} break;
 
 	case LDAP_FILTER_APPROX:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  APPROX\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "APPROX\n", 0, 0, 0 );
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		if ( (err = get_ava( ber, &f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "decoding filter error";
+#endif
+		err = get_ava( ber, &f->f_ava, SLAP_MR_EQUALITY_APPROX, text );
+		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
 
-		*fstr = ch_malloc( sizeof("(~=)")
-			+ f->f_av_desc->ad_cname->bv_len
-			+ f->f_av_value->bv_len );
+		filter_escape_value( &f->f_av_value, &escaped );
 
-		sprintf( *fstr, "(%s~=%s)",
-			f->f_av_desc->ad_cname->bv_val,
-		    f->f_av_value->bv_val );
+		fstr->bv_len = sizeof("(~=)") - 1
+			+ f->f_av_desc->ad_cname.bv_len
+			+ escaped.bv_len;
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1);
 
-#else
-		if ( (err = get_ava( ber, f->f_ava )) != LDAP_SUCCESS ) {
-			*text = "error decoding filter";
-			break;
-		}
-		*fstr = ch_malloc( sizeof("(~=)"
-			+ strlen( f->f_avtype )
-			+ f->f_avvalue.bv_len);
-		sprintf( *fstr, "(%s~=%s)", f->f_avtype,
-		    f->f_avvalue.bv_val );
-#endif
+		sprintf( fstr->bv_val, "(%s~=%s)",
+			f->f_av_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_AND:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  AND\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "AND\n", 0, 0, 0 );
+#endif
 		err = get_filter_list( conn, ber, &f->f_and, &ftmp, text );
 		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
-		if (ftmp == NULL) ftmp = ch_strdup("");
-		*fstr = ch_malloc( 4 + strlen( ftmp ) );
-		sprintf( *fstr, "(&%s)", ftmp );
-		free( ftmp );
+		fstr->bv_len = sizeof("(&)") - 1 + ftmp.bv_len;
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+		sprintf( fstr->bv_val, "(&%s)",
+			ftmp.bv_len ? ftmp.bv_val : "" );
 		break;
 
 	case LDAP_FILTER_OR:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  OR\n", conn->c_connid  ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "OR\n", 0, 0, 0 );
+#endif
 		err = get_filter_list( conn, ber, &f->f_and, &ftmp, text );
 		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
-		if (ftmp == NULL) ftmp = ch_strdup("");
-		*fstr = ch_malloc( 4 + strlen( ftmp ) );
-		sprintf( *fstr, "(|%s)", ftmp );
-		free( ftmp );
+		fstr->bv_len = sizeof("(|)") - 1 + ftmp.bv_len;
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+		sprintf( fstr->bv_val, "(|%s)",
+			ftmp.bv_len ? ftmp.bv_val : "" );
 		break;
 
 	case LDAP_FILTER_NOT:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  NOT\n", conn->c_connid ));
+#else
 		Debug( LDAP_DEBUG_FILTER, "NOT\n", 0, 0, 0 );
+#endif
 		(void) ber_skip_tag( ber, &len );
 		err = get_filter( conn, ber, &f->f_not, &ftmp, text );
 		if ( err != LDAP_SUCCESS ) {
 			break;
 		}
-		if (ftmp == NULL) ftmp = ch_strdup("");
-		*fstr = ch_malloc( 4 + strlen( ftmp ) );
-		sprintf( *fstr, "(!%s)", ftmp );
-		free( ftmp );
+		fstr->bv_len = sizeof("(!)") - 1 + ftmp.bv_len;
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+		sprintf( fstr->bv_val, "(!%s)",
+			ftmp.bv_len ? ftmp.bv_val : "" );
 		break;
 
 	case LDAP_FILTER_EXT:
-		/* not yet implemented */
-		Debug( LDAP_DEBUG_ANY, "extensible match not yet implemented.\n",
-		       f->f_choice, 0, 0 );
-		err = LDAP_PROTOCOL_ERROR;
-		*text = "extensible match not yet implemented";
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+			   "get_filter: conn %d  EXTENSIBLE\n", conn->c_connid ));
+#else
+		Debug( LDAP_DEBUG_FILTER, "EXTENSIBLE\n", 0, 0, 0 );
+#endif
+
+		err = get_mra( ber, &f->f_mra, text );
+		if ( err != LDAP_SUCCESS ) {
+			break;
+		}
+
+		assert( f->f_mra != NULL );
+
+		filter_escape_value( &f->f_mr_value, &escaped );
+
+		fstr->bv_len = sizeof("(:dn::=)") - 1
+			+ (f->f_mr_desc ? f->f_mr_desc->ad_cname.bv_len : 0)
+			+ f->f_mr_rule_text.bv_len
+			+ escaped.bv_len;
+
+		fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+		sprintf( fstr->bv_val, "(%s%s%s%s:=%s)",
+			 (f->f_mr_desc ? f->f_mr_desc->ad_cname.bv_val : ""),
+			 (f->f_mr_dnattrs ? ":dn" : ""),
+			 (f->f_mr_rule_text.bv_len ? ":" : ""),
+			 (f->f_mr_rule_text.bv_len ? f->f_mr_rule_text.bv_val : ""),
+			 escaped.bv_val );
+
+		ber_memfree( escaped.bv_val );
 		break;
 
 	default:
+		(void) ber_scanf( ber, "x" ); /* skip the element */
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_ERR,
+			   "get_filter: conn %d unknown filter type=%lu\n",
+			   conn->c_connid, f->f_choice ));
+#else
 		Debug( LDAP_DEBUG_ANY, "get_filter: unknown filter type=%lu\n",
 		       f->f_choice, 0, 0 );
-		err = LDAP_PROTOCOL_ERROR;
-		*text = "unknown filter type";
+#endif
+		f->f_choice = SLAPD_FILTER_COMPUTED;
+		f->f_result = SLAPD_COMPARE_UNDEFINED;
+		ber_str2bv( "(undefined)", sizeof("(undefined)") - 1,
+			1, fstr );
 		break;
 	}
 
+	if ( ftmp.bv_val ) free( ftmp.bv_val );
+
 	if ( err != LDAP_SUCCESS ) {
-		free( (char *) f );
-		if ( *fstr != NULL ) {
-			free( *fstr );
+		if ( fstr->bv_val != NULL ) {
+			free( fstr->bv_val );
+		}
+
+		if( err != SLAPD_DISCONNECT ) {
+			/* ignore error */
+			f->f_choice = SLAPD_FILTER_COMPUTED;
+			f->f_result = SLAPD_COMPARE_UNDEFINED;
+			ber_str2bv( "(badfilter)", sizeof("(badfilter)") - 1,
+				1, fstr );
+			err = LDAP_SUCCESS;
+			*filt = f;
+
+		} else {
+			free(f);
 		}
 	} else {
 		*filt = f;
 	}
 
+#ifdef NEW_LOGGING
+	LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL2,
+		"get_filter: conn %d exit\n", conn->c_connid ));
+#else
 	Debug( LDAP_DEBUG_FILTER, "end get_filter %d\n", err, 0, 0 );
+#endif
 	return( err );
 }
 
 static int
-get_filter_list( Connection *conn, BerElement *ber, Filter **f, char **fstr, char **text )
+get_filter_list( Connection *conn, BerElement *ber,
+	Filter **f, struct berval *fstr,
+	const char **text )
 {
 	Filter		**new;
 	int		err;
 	ber_tag_t	tag;
 	ber_len_t	len;
-	char		*last, *ftmp;
+	char		*last;
+	struct berval	ftmp;
 
+#ifdef NEW_LOGGING
+	LDAP_LOG(( "filter", LDAP_LEVEL_ENTRY,
+		   "get_filter_list: conn %d start\n", conn->c_connid ));
+#else
 	Debug( LDAP_DEBUG_FILTER, "begin get_filter_list\n", 0, 0, 0 );
-
-	*fstr = NULL;
+#endif
 	new = f;
 	for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT;
 	    tag = ber_next_element( ber, &len, last ) )
@@ -340,19 +417,26 @@ get_filter_list( Connection *conn, BerElement *ber, Filter **f, char **fstr, cha
 		if ( err != LDAP_SUCCESS )
 			return( err );
 
-		if ( *fstr == NULL ) {
+		if ( !fstr->bv_len ) {
 			*fstr = ftmp;
 		} else {
-			*fstr = ch_realloc( *fstr, strlen( *fstr ) +
-			    strlen( ftmp ) + 1 );
-			strcat( *fstr, ftmp );
-			free( ftmp );
+			int i = fstr->bv_len;
+			fstr->bv_len += ftmp.bv_len;
+			fstr->bv_val = ch_realloc( fstr->bv_val,
+				fstr->bv_len + 1 );
+			strcpy( fstr->bv_val+i, ftmp.bv_val );
+			free( ftmp.bv_val );
 		}
 		new = &(*new)->f_next;
 	}
 	*new = NULL;
 
+#ifdef NEW_LOGGING
+	LDAP_LOG(( "filter", LDAP_LEVEL_ENTRY,
+		   "get_filter_list: conn %d exit\n", conn->c_connid ));
+#else
 	Debug( LDAP_DEBUG_FILTER, "end get_filter_list\n", 0, 0, 0 );
+#endif
 	return( LDAP_SUCCESS );
 }
 
@@ -361,159 +445,245 @@ get_substring_filter(
     Connection	*conn,
     BerElement	*ber,
     Filter	*f,
-    char	**fstr,
-	char	**text
+    struct berval	*fstr,
+	const char	**text
 )
 {
 	ber_tag_t	tag;
 	ber_len_t	len;
 	ber_tag_t	rc;
-	struct berval *val;
+	struct berval value;
+	struct berval escaped;
 	char		*last;
-	char		*type;
-	int		syntax;
-
+	struct berval bv;
 	*text = "error decoding filter";
 
+#ifdef NEW_LOGGING
+	LDAP_LOG(( "filter", LDAP_LEVEL_ENTRY,
+		   "get_substring_filter: conn %d  begin\n", conn->c_connid ));
+#else
 	Debug( LDAP_DEBUG_FILTER, "begin get_substring_filter\n", 0, 0, 0 );
-
-	if ( ber_scanf( ber, "{a" /*}*/, &type ) == LBER_ERROR ) {
+#endif
+	if ( ber_scanf( ber, "{m" /*}*/, &bv ) == LBER_ERROR ) {
 		return SLAPD_DISCONNECT;
 	}
 
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-	/* not yet implemented */
-#else
-	f->f_sub_type = type;
-	attr_normalize( f->f_sub_type );
-
-	/* should get real syntax and see if we have a substring matching rule */
-	syntax = attr_syntax( f->f_sub_type );
-#endif
+	f->f_sub = ch_calloc( 1, sizeof(SubstringsAssertion) );
+	f->f_sub_desc = NULL;
+	rc = slap_bv2ad( &bv, &f->f_sub_desc, text );
+
+	if( rc != LDAP_SUCCESS ) {
+		text = NULL;
+		ch_free( f->f_sub );
+		f->f_choice = SLAPD_FILTER_COMPUTED;
+		f->f_result = SLAPD_COMPARE_UNDEFINED;
+		ber_str2bv( "(undefined)", sizeof("(undefined)")-1, 1, fstr );
+		return LDAP_SUCCESS;
+	}
 
-	f->f_sub_initial = NULL;
+	f->f_sub_initial.bv_val = NULL;
 	f->f_sub_any = NULL;
-	f->f_sub_final = NULL;
+	f->f_sub_final.bv_val = NULL;
 
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-	/* not yet implemented */
-#else
-	if( fstr ) {
-		*fstr = ch_malloc( strlen( f->f_sub_type ) + 3 );
-		sprintf( *fstr, "(%s=" /*)*/, f->f_sub_type );
-	}
-#endif
+	fstr->bv_len = sizeof("(=" /*)*/) - 1 +
+		f->f_sub_desc->ad_cname.bv_len;
+	fstr->bv_val = ch_malloc( fstr->bv_len + 1 );
+	sprintf( fstr->bv_val, "(%s=" /*)*/, f->f_sub_desc->ad_cname.bv_val );
 
 	for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT;
 	    tag = ber_next_element( ber, &len, last ) )
 	{
-		rc = ber_scanf( ber, "O", &val );
+		unsigned usage;
+
+		rc = ber_scanf( ber, "m", &value );
 		if ( rc == LBER_ERROR ) {
 			rc = SLAPD_DISCONNECT;
 			goto return_error;
 		}
 
-		if ( val == NULL || val->bv_len == 0 ) {
-			ber_bvfree( val );
+		if ( value.bv_val == NULL || value.bv_len == 0 ) {
 			rc = LDAP_INVALID_SYNTAX;
 			goto return_error;
 		} 
 
-		rc = LDAP_PROTOCOL_ERROR;
+		switch ( tag ) {
+		case LDAP_SUBSTRING_INITIAL:
+			usage = SLAP_MR_SUBSTR_INITIAL;
+			break;
 
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		/* not yet implemented */
+		case LDAP_SUBSTRING_ANY:
+			usage = SLAP_MR_SUBSTR_ANY;
+			break;
+
+		case LDAP_SUBSTRING_FINAL:
+			usage = SLAP_MR_SUBSTR_FINAL;
+			break;
+
+		default:
+			rc = LDAP_PROTOCOL_ERROR;
+
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "filter", LDAP_LEVEL_ERR,
+				   "get_filter_substring: conn %d  unknown substring choice=%ld\n",
+				   conn->c_connid, (long)tag ));
 #else
-		/* we should call a substring syntax normalization routine */
-		value_normalize( val->bv_val, syntax );
-		/* this is bogus, value_normalize should take a berval */
-		val->bv_len = strlen( val->bv_val );
+			Debug( LDAP_DEBUG_FILTER,
+				"  unknown substring choice=%ld\n",
+				(long) tag, 0, 0 );
 #endif
+			goto return_error;
+		}
+
+		rc = value_normalize( f->f_sub_desc, usage, &value, &bv, text );
+
+		if( rc != LDAP_SUCCESS ) {
+			goto return_error;
+		}
+
+		value = bv;
+
+		rc = LDAP_PROTOCOL_ERROR;
 
 		switch ( tag ) {
 		case LDAP_SUBSTRING_INITIAL:
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+				   "get_substring_filter: conn %d  INITIAL\n",
+				   conn->c_connid ));
+#else
 			Debug( LDAP_DEBUG_FILTER, "  INITIAL\n", 0, 0, 0 );
-			if ( f->f_sub_initial != NULL ) {
-				ber_bvfree( val );
+#endif
+
+			if ( f->f_sub_initial.bv_val != NULL
+				|| f->f_sub_any != NULL 
+				|| f->f_sub_final.bv_val != NULL )
+			{
+				free( value.bv_val );
 				goto return_error;
 			}
-			f->f_sub_initial = val;
 
-			if( fstr ) {
-				*fstr = ch_realloc( *fstr,
-					strlen( *fstr ) + val->bv_len + 1 );
-				strcat( *fstr, val->bv_val );
+			f->f_sub_initial = value;
+
+			if( fstr->bv_val ) {
+				int i = fstr->bv_len;
+				filter_escape_value( &value, &escaped );
+				fstr->bv_len += escaped.bv_len;
+				fstr->bv_val = ch_realloc( fstr->bv_val,
+					fstr->bv_len + 1 );
+				strcpy( fstr->bv_val+i, escaped.bv_val );
+				ber_memfree( escaped.bv_val );
 			}
 			break;
 
 		case LDAP_SUBSTRING_ANY:
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+				   "get_substring_filter: conn %d  ANY\n",
+				   conn->c_connid ));
+#else
 			Debug( LDAP_DEBUG_FILTER, "  ANY\n", 0, 0, 0 );
-			if( ber_bvecadd( &f->f_sub_any, val ) < 0 ) {
-				ber_bvfree( val );
+#endif
+
+			if ( f->f_sub_final.bv_val != NULL ) {
+				free( value.bv_val );
 				goto return_error;
 			}
 
-			if( fstr ) {
-				*fstr = ch_realloc( *fstr,
-					strlen( *fstr ) + val->bv_len + 2 );
-				strcat( *fstr, "*" );
-				strcat( *fstr, val->bv_val );
+			bvarray_add( &f->f_sub_any, &value );
+
+			if( fstr->bv_val ) {
+				int i = fstr->bv_len;
+				filter_escape_value( &value, &escaped );
+				fstr->bv_len += escaped.bv_len + 2;
+				fstr->bv_val = ch_realloc( fstr->bv_val,
+					fstr->bv_len + 1 );
+				strcpy( fstr->bv_val+i, "*" );
+				strcpy( fstr->bv_val+i+1, escaped.bv_val );
+				ber_memfree( escaped.bv_val );
 			}
 			break;
 
 		case LDAP_SUBSTRING_FINAL:
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "filter", LDAP_LEVEL_DETAIL1,
+				   "get_substring_filter: conn %d  FINAL\n",
+				   conn->c_connid ));
+#else
 			Debug( LDAP_DEBUG_FILTER, "  FINAL\n", 0, 0, 0 );
-			if ( f->f_sub_final != NULL ) {
-				ber_bvfree( val );
+#endif
+
+			if ( f->f_sub_final.bv_val != NULL ) {
+				free( value.bv_val );
 				goto return_error;
 			}
-			f->f_sub_final = val;
 
-			if( fstr ) {
-				*fstr = ch_realloc( *fstr,
-					strlen( *fstr ) + val->bv_len + 2 );
-				strcat( *fstr, "*" );
-				strcat( *fstr, val->bv_val );
+			f->f_sub_final = value;
+
+			if( fstr->bv_val ) {
+				int i = fstr->bv_len;
+				filter_escape_value( &value, &escaped );
+				fstr->bv_len += escaped.bv_len + 2;
+				fstr->bv_val = ch_realloc( fstr->bv_val,
+					fstr->bv_len + 1 );
+				strcpy( fstr->bv_val+i, "*" );
+				strcpy( fstr->bv_val+i+1, escaped.bv_val );
+				ber_memfree( escaped.bv_val );
 			}
 			break;
 
 		default:
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "filter", LDAP_LEVEL_INFO,
+				   "get_substring_filter: conn %d  unknown substring type %ld\n",
+				   conn->c_connid, (long)tag ));
+#else
 			Debug( LDAP_DEBUG_FILTER,
 				"  unknown substring type=%ld\n",
 				(long) tag, 0, 0 );
+#endif
 
-			ber_bvfree( val );
+			free( value.bv_val );
 
 return_error:
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "filter", LDAP_LEVEL_INFO,
+				   "get_substring_filter: conn %d  error %ld\n",
+				   conn->c_connid, (long)rc ));
+#else
 			Debug( LDAP_DEBUG_FILTER, "  error=%ld\n",
 				(long) rc, 0, 0 );
-
-			if( fstr ) {
-				free( *fstr );
-				*fstr = NULL;
+#endif
+			if( fstr->bv_val ) {
+				free( fstr->bv_val );
+				fstr->bv_val = NULL;
+				fstr->bv_len = 0;
 			}
 
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-			/* not yet implemented */
-#else
-			ch_free( f->f_sub_type );
-#endif
-			ber_bvfree( f->f_sub_initial );
-			ber_bvecfree( f->f_sub_any );
-			ber_bvfree( f->f_sub_final );
+			free( f->f_sub_initial.bv_val );
+			bvarray_free( f->f_sub_any );
+			free( f->f_sub_final.bv_val );
+			ch_free( f->f_sub );
 			return rc;
 		}
 	}
 
-	if( fstr ) {
-		*fstr = ch_realloc( *fstr, strlen( *fstr ) + 3 );
-		if ( f->f_sub_final == NULL ) {
-			strcat( *fstr, "*" );
+	if( fstr->bv_val ) {
+		int i = fstr->bv_len;
+		fstr->bv_len += 3;
+		fstr->bv_val = ch_realloc( fstr->bv_val, fstr->bv_len + 3 );
+		if ( f->f_sub_final.bv_val == NULL ) {
+			strcpy( fstr->bv_val+i, "*" );
+			i++;
 		}
-		strcat( *fstr, /*(*/ ")" );
+		strcpy( fstr->bv_val+i, /*(*/ ")" );
 	}
 
+#ifdef NEW_LOGGING
+	LDAP_LOG(( "filter", LDAP_LEVEL_ENTRY,
+		   "get_substring_filter: conn %d exit\n", conn->c_connid ));
+#else
 	Debug( LDAP_DEBUG_FILTER, "end get_substring_filter\n", 0, 0, 0 );
+#endif
 	return( LDAP_SUCCESS );
 }
 
@@ -528,48 +698,24 @@ filter_free( Filter *f )
 
 	switch ( f->f_choice ) {
 	case LDAP_FILTER_PRESENT:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		ad_free( f->f_desc, 1 );
-#else
-		if ( f->f_type != NULL ) {
-			free( f->f_type );
-		}
-#endif
 		break;
 
 	case LDAP_FILTER_EQUALITY:
 	case LDAP_FILTER_GE:
 	case LDAP_FILTER_LE:
 	case LDAP_FILTER_APPROX:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
 		ava_free( f->f_ava, 1 );
-#else
-		ava_free( &f->f_ava, 0 );
-#endif
 		break;
 
 	case LDAP_FILTER_SUBSTRINGS:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
-		ad_free( f->f_sub_desc, 1 );
-		if ( f->f_sub_initial != NULL ) {
-			ber_bvfree( f->f_sub_initial );
-		}
-		ber_bvecfree( f->f_sub_any );
-		if ( f->f_sub_final != NULL ) {
-			ber_bvfree( f->f_sub_final );
-		}
-#else
-		if ( f->f_sub_type != NULL ) {
-			free( f->f_sub_type );
+		if ( f->f_sub_initial.bv_val != NULL ) {
+			free( f->f_sub_initial.bv_val );
 		}
-		if ( f->f_sub_initial != NULL ) {
-			ber_bvfree( f->f_sub_initial );
+		bvarray_free( f->f_sub_any );
+		if ( f->f_sub_final.bv_val != NULL ) {
+			free( f->f_sub_final.bv_val );
 		}
-		ber_bvecfree( f->f_sub_any );
-		if ( f->f_sub_final != NULL ) {
-			ber_bvfree( f->f_sub_final );
-		}
-#endif
+		ch_free( f->f_sub );
 		break;
 
 	case LDAP_FILTER_AND:
@@ -581,12 +727,21 @@ filter_free( Filter *f )
 		}
 		break;
 
+	case LDAP_FILTER_EXT:
+		mra_free( f->f_mra, 1 );
+		break;
+
 	case SLAPD_FILTER_COMPUTED:
 		break;
 
 	default:
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "filter", LDAP_LEVEL_ERR,
+			   "filter_free: unknown filter type %lu\n", f->f_choice ));
+#else
 		Debug( LDAP_DEBUG_ANY, "filter_free: unknown filter type=%lu\n",
 		       f->f_choice, 0, 0 );
+#endif
 		break;
 	}
 
@@ -594,12 +749,12 @@ filter_free( Filter *f )
 }
 
 #ifdef LDAP_DEBUG
-
 void
 filter_print( Filter *f )
 {
 	int	i;
 	Filter	*p;
+	struct berval escaped;
 
 	if ( f == NULL ) {
 		fprintf( stderr, "No filter!" );
@@ -607,77 +762,66 @@ filter_print( Filter *f )
 
 	switch ( f->f_choice ) {
 	case LDAP_FILTER_EQUALITY:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
+		filter_escape_value( &f->f_av_value, &escaped );
 		fprintf( stderr, "(%s=%s)",
-			f->f_av_desc->ad_cname->bv_val,
-		    f->f_av_value->bv_val );
-#else
-		fprintf( stderr, "(%s=%s)", f->f_ava.ava_type,
-		    f->f_ava.ava_value.bv_val );
-#endif
+			f->f_av_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_GE:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
+		filter_escape_value( &f->f_av_value, &escaped );
 		fprintf( stderr, "(%s>=%s)",
-			f->f_av_desc->ad_cname->bv_val,
-		    f->f_av_value->bv_val );
-#else
-		fprintf( stderr, "(%s>=%s)", f->f_ava.ava_type,
-		    f->f_ava.ava_value.bv_val );
-#endif
+			f->f_av_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_LE:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
+		filter_escape_value( &f->f_av_value, &escaped );
 		fprintf( stderr, "(%s<=%s)",
-			f->f_ava->aa_desc->ad_cname->bv_val,
-		    f->f_ava->aa_value->bv_val );
-#else
-		fprintf( stderr, "(%s<=%s)", f->f_ava.ava_type,
-		    f->f_ava.ava_value.bv_val );
-#endif
+			f->f_ava->aa_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_APPROX:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
+		filter_escape_value( &f->f_av_value, &escaped );
 		fprintf( stderr, "(%s~=%s)",
-			f->f_ava->aa_desc->ad_cname->bv_val,
-		    f->f_ava->aa_value->bv_val );
-#else
-		fprintf( stderr, "(%s~=%s)", f->f_ava.ava_type,
-		    f->f_ava.ava_value.bv_val );
-#endif
+			f->f_ava->aa_desc->ad_cname.bv_val,
+		    escaped.bv_val );
+		ber_memfree( escaped.bv_val );
 		break;
 
 	case LDAP_FILTER_SUBSTRINGS:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
 		fprintf( stderr, "(%s=" /*)*/,
-			f->f_sub_desc->ad_cname->bv_val );
-#else
-		fprintf( stderr, "(%s=" /*)*/, f->f_sub_type );
-#endif
-		if ( f->f_sub_initial != NULL ) {
-			fprintf( stderr, "%s", f->f_sub_initial->bv_val );
+			f->f_sub_desc->ad_cname.bv_val );
+		if ( f->f_sub_initial.bv_val != NULL ) {
+			filter_escape_value( &f->f_sub_initial, &escaped );
+			fprintf( stderr, "%s",
+				escaped.bv_val );
+			ber_memfree( escaped.bv_val );
 		}
 		if ( f->f_sub_any != NULL ) {
-			for ( i = 0; f->f_sub_any[i] != NULL; i++ ) {
-				fprintf( stderr, "*%s", f->f_sub_any[i]->bv_val );
+			for ( i = 0; f->f_sub_any[i].bv_val != NULL; i++ ) {
+				filter_escape_value( &f->f_sub_any[i], &escaped );
+				fprintf( stderr, "*%s",
+					escaped.bv_val );
+				ber_memfree( escaped.bv_val );
 			}
 		}
-		if ( f->f_sub_final != NULL ) {
-			fprintf( stderr, "*%s", f->f_sub_final->bv_val );
+		if ( f->f_sub_final.bv_val != NULL ) {
+			filter_escape_value( &f->f_sub_final, &escaped );
+			fprintf( stderr,
+				"*%s", escaped.bv_val );
+			ber_memfree( escaped.bv_val );
 		}
 		fprintf( stderr, /*(*/ ")" );
 		break;
 
 	case LDAP_FILTER_PRESENT:
-#ifdef SLAPD_SCHEMA_NOT_COMPAT
 		fprintf( stderr, "(%s=*)",
-			f->f_desc->ad_cname->bv_val );
-#else
-		fprintf( stderr, "(%s=*)", f->f_type );
-#endif
+			f->f_desc->ad_cname.bv_val );
 		break;
 
 	case LDAP_FILTER_AND:
@@ -693,7 +837,7 @@ filter_print( Filter *f )
 		break;
 
 	case SLAPD_FILTER_COMPUTED:
-		fprintf( stderr, "(%s)",
+		fprintf( stderr, "(?=%s)",
 			f->f_result == LDAP_COMPARE_FALSE ? "false" :
 			f->f_result == LDAP_COMPARE_TRUE ? "true" :
 			f->f_result == SLAPD_COMPARE_UNDEFINED ? "undefined" :
@@ -701,9 +845,34 @@ filter_print( Filter *f )
 		break;
 
 	default:
-		fprintf( stderr, "(unknown filter %lu)", f->f_choice );
+		fprintf( stderr, "(unknown-filter=%lu)", f->f_choice );
 		break;
 	}
 }
 
 #endif /* ldap_debug */
+
+static int filter_escape_value(
+	struct berval *in,
+	struct berval *out )
+{
+	ber_len_t i;
+	assert( in );
+	assert( out );
+
+	out->bv_val = (char *) ch_malloc( ( in->bv_len * 3 ) + 1 );
+	out->bv_len = 0;
+
+	for( i=0; i < in->bv_len ; i++ ) {
+		if( FILTER_ESCAPE(in->bv_val[i]) ) {
+			out->bv_val[out->bv_len++] = SLAP_ESCAPE_CHAR;
+			out->bv_val[out->bv_len++] = SLAP_ESCAPE_HI( in->bv_val[i] );
+			out->bv_val[out->bv_len++] = SLAP_ESCAPE_LO( in->bv_val[i] );
+		} else {
+			out->bv_val[out->bv_len++] = in->bv_val[i];
+		}
+	}
+
+	out->bv_val[out->bv_len] = '\0';
+	return LDAP_SUCCESS;
+}