]> git.sur5r.net Git - openldap/blobdiff - libraries/libldap/search.c
rename ldap_pvt_init_utils() to ldap_int_utils_init() and provide
[openldap] / libraries / libldap / search.c
index 117d5f4d2ee1f7b9db238d6ca25502433bee531a..ca93ada6f162d3af932ebde3fe58226691529b42 100644 (file)
@@ -30,7 +30,114 @@ static int put_substring_filter LDAP_P(( BerElement *ber, char *type, char *str
 static int put_filter_list LDAP_P(( BerElement *ber, char *str ));
 
 /*
- * ldap_search - initiate an ldap (and X.500) search operation.  Parameters:
+ * ldap_search_ext - initiate an ldap search operation.
+ *
+ * Parameters:
+ *
+ *     ld              LDAP descriptor
+ *     base            DN of the base object
+ *     scope           the search scope - one of LDAP_SCOPE_BASE,
+ *                         LDAP_SCOPE_ONELEVEL, LDAP_SCOPE_SUBTREE
+ *     filter          a string containing the search filter
+ *                     (e.g., "(|(cn=bob)(sn=bob))")
+ *     attrs           list of attribute types to return for matches
+ *     attrsonly       1 => attributes only 0 => attributes and values
+ *
+ * Example:
+ *     char    *attrs[] = { "mail", "title", 0 };
+ *     ldap_search_ext( ld, "c=us@o=UM", LDAP_SCOPE_SUBTREE, "cn~=bob",
+ *         attrs, attrsonly, sctrls, ctrls, timeout, sizelimit,
+ *             &msgid );
+ */
+int
+ldap_search_ext(
+       LDAP *ld,
+       LDAP_CONST char *base,
+       int scope,
+       LDAP_CONST char *filter,
+       char **attrs,
+       int attrsonly,
+       LDAPControl **sctrls,
+       LDAPControl **cctrls,
+       struct timeval *timeout,
+       int sizelimit,
+       int *msgidp )
+{
+       BerElement      *ber;
+       int timelimit;
+
+       Debug( LDAP_DEBUG_TRACE, "ldap_search_ext\n", 0, 0, 0 );
+
+       /*
+        * if timeout is provided, use only tv_sec as timelimit.
+        * otherwise, use default.
+        */
+       timelimit = (timeout != NULL)
+                       ?  timelimit = timeout->tv_sec
+                       : -1;
+
+       ber = ldap_build_search_req( ld, base, scope, filter, attrs,
+           attrsonly, sctrls, cctrls, timelimit, sizelimit ); 
+
+       if ( ber == NULLBER ) {
+               return ld->ld_errno;
+       }
+
+#ifndef LDAP_NOCACHE
+       if ( ld->ld_cache != NULL ) {
+               if ( ldap_check_cache( ld, LDAP_REQ_SEARCH, ber ) == 0 ) {
+                       ber_free( ber, 1 );
+                       ld->ld_errno = LDAP_SUCCESS;
+                       *msgidp = ld->ld_msgid;
+                       return ld->ld_errno;
+               }
+               ldap_add_request_to_cache( ld, LDAP_REQ_SEARCH, ber );
+       }
+#endif /* LDAP_NOCACHE */
+
+       /* send the message */
+       *msgidp = ldap_send_initial_request( ld, LDAP_REQ_SEARCH, base, ber );
+
+       if( *msgidp < 0 )
+               return ld->ld_errno;
+
+       return LDAP_SUCCESS;
+}
+
+int
+ldap_search_ext_s(
+       LDAP *ld,
+       LDAP_CONST char *base,
+       int scope,
+       LDAP_CONST char *filter,
+       char **attrs,
+       int attrsonly,
+       LDAPControl **sctrls,
+       LDAPControl **cctrls,
+       struct timeval *timeout,
+       int sizelimit,
+       LDAPMessage **res )
+{
+       int rc;
+       int     msgid;
+
+       rc = ldap_search_ext( ld, base, scope, filter, attrs, attrsonly,
+               sctrls, cctrls, timeout, sizelimit, &msgid );
+
+       if ( rc != LDAP_SUCCESS ) {
+               return( rc );
+       }
+
+       if ( ldap_result( ld, msgid, 1, timeout, res ) == -1 )
+               return( ld->ld_errno );
+
+       return( ldap_result2error( ld, *res, 0 ) );
+}
+
+/*
+ * ldap_search - initiate an ldap search operation.
+ *
+ * Parameters:
  *
  *     ld              LDAP descriptor
  *     base            DN of the base object
@@ -47,15 +154,18 @@ static int put_filter_list LDAP_P(( BerElement *ber, char *str ));
  *         attrs, attrsonly );
  */
 int
-ldap_search( LDAP *ld, char *base, int scope, char *filter,
+ldap_search(
+       LDAP *ld, LDAP_CONST char *base, int scope, LDAP_CONST char *filter,
        char **attrs, int attrsonly )
 {
        BerElement      *ber;
 
        Debug( LDAP_DEBUG_TRACE, "ldap_search\n", 0, 0, 0 );
 
-       if (( ber = ldap_build_search_req( ld, base, scope, filter, attrs,
-           attrsonly )) == NULLBER ) {
+       ber = ldap_build_search_req( ld, base, scope, filter, attrs,
+           attrsonly, NULL, NULL, -1, -1 ); 
+
+       if ( ber == NULLBER ) {
                return( -1 );
        }
 
@@ -76,11 +186,22 @@ ldap_search( LDAP *ld, char *base, int scope, char *filter,
 
 
 BerElement *
-ldap_build_search_req( LDAP *ld, char *base, int scope, char *filter,
-       char **attrs, int attrsonly )
+ldap_build_search_req(
+       LDAP *ld,
+       LDAP_CONST char *base_in,
+       int scope,
+       LDAP_CONST char *filter_in,
+       char **attrs,
+       int attrsonly,
+       LDAPControl **sctrls,
+       LDAPControl **cctrls,
+       int timelimit,
+       int sizelimit )
 {
        BerElement      *ber;
        int             err;
+       char    *base;
+       char    *filter;
 
        /*
         * Create the search request.  It looks like this:
@@ -111,9 +232,11 @@ ldap_build_search_req( LDAP *ld, char *base, int scope, char *filter,
                return( NULLBER );
        }
 
-       if ( base == NULL ) {
+       if ( base_in == NULL ) {
                /* no base provided, use session default base */
                base = ld->ld_options.ldo_defbase;
+       } else {
+               base = (char *) base_in;
        }
 
        if ( base == NULL ) {
@@ -124,13 +247,17 @@ ldap_build_search_req( LDAP *ld, char *base, int scope, char *filter,
 #ifdef LDAP_CONNECTIONLESS
        if ( ld->ld_cldapnaddr > 0 ) {
            err = ber_printf( ber, "{ist{seeiib", ++ld->ld_msgid,
-               ld->ld_cldapdn, LDAP_REQ_SEARCH, base, scope, ld->ld_deref,
-               ld->ld_sizelimit, ld->ld_timelimit, attrsonly );
+                       ld->ld_cldapdn, LDAP_REQ_SEARCH, base, scope, ld->ld_deref,
+                       (sizelimit < 0) ? ld->ld_sizelimit : sizelimit,
+                       (timelimit < 0) ? ld->ld_timelimit : timelimit,
+                       attrsonly );
        } else {
 #endif /* LDAP_CONNECTIONLESS */
                err = ber_printf( ber, "{it{seeiib", ++ld->ld_msgid,
                    LDAP_REQ_SEARCH, base, scope, ld->ld_deref,
-                   ld->ld_sizelimit, ld->ld_timelimit, attrsonly );
+                       (sizelimit < 0) ? ld->ld_sizelimit : sizelimit,
+                       (timelimit < 0) ? ld->ld_timelimit : timelimit,
+                   attrsonly );
 #ifdef LDAP_CONNECTIONLESS
        }
 #endif /* LDAP_CONNECTIONLESS */
@@ -141,7 +268,7 @@ ldap_build_search_req( LDAP *ld, char *base, int scope, char *filter,
                return( NULLBER );
        }
 
-       filter = strdup( filter );
+       filter = strdup( filter_in );
        err = put_filter( ber, filter );
        free( filter );
 
@@ -151,7 +278,19 @@ ldap_build_search_req( LDAP *ld, char *base, int scope, char *filter,
                return( NULLBER );
        }
 
-       if ( ber_printf( ber, "{v}}}", attrs ) == -1 ) {
+       if ( ber_printf( ber, "{v}}", attrs ) == -1 ) {
+               ld->ld_errno = LDAP_ENCODING_ERROR;
+               ber_free( ber, 1 );
+               return( NULLBER );
+       }
+
+       /* Put Server Controls */
+       if( ldap_int_put_controls( ld, sctrls, ber ) != LDAP_SUCCESS ) {
+               ber_free( ber, 1 );
+               return( NULLBER );
+       }
+
+       if ( ber_printf( ber, "}", attrs ) == -1 ) {
                ld->ld_errno = LDAP_ENCODING_ERROR;
                ber_free( ber, 1 );
                return( NULLBER );
@@ -200,10 +339,11 @@ put_complex_filter( BerElement *ber, char *str, unsigned long tag, int not )
        /* put explicit tag */
        if ( ber_printf( ber, "t{", tag ) == -1 )
                return( NULL );
-/*
+
+#if 0
        if ( !not && ber_printf( ber, "{" ) == -1 )
                return( NULL );
-*/
+#endif
 
        str++;
        if ( (next = find_right_paren( str )) == NULL )
@@ -217,10 +357,11 @@ put_complex_filter( BerElement *ber, char *str, unsigned long tag, int not )
        /* flush explicit tagged thang */
        if ( ber_printf( ber, "}" ) == -1 )
                return( NULL );
-/*
+
+#if 0
        if ( !not && ber_printf( ber, "}" ) == -1 )
                return( NULL );
-*/
+#endif
 
        return( next );
 }
@@ -519,7 +660,9 @@ put_substring_filter( BerElement *ber, char *type, char *val )
 }
 
 int
-ldap_search_st( LDAP *ld, char *base, int scope, char *filter, char **attrs,
+ldap_search_st(
+       LDAP *ld, LDAP_CONST char *base, int scope,
+       LDAP_CONST char *filter, char **attrs,
        int attrsonly, struct timeval *timeout, LDAPMessage **res )
 {
        int     msgid;
@@ -541,8 +684,14 @@ ldap_search_st( LDAP *ld, char *base, int scope, char *filter, char **attrs,
 }
 
 int
-ldap_search_s( LDAP *ld, char *base, int scope, char *filter, char **attrs,
-       int attrsonly, LDAPMessage **res )
+ldap_search_s(
+       LDAP *ld,
+       LDAP_CONST char *base,
+       int scope,
+       LDAP_CONST char *filter,
+       char **attrs,
+       int attrsonly,
+       LDAPMessage **res )
 {
        int     msgid;