From a49e2acd7ad9753a94be41793265cf83b093d168 Mon Sep 17 00:00:00 2001 From: Quanah Gibson-Mount Date: Thu, 15 Apr 2010 22:08:56 +0000 Subject: [PATCH] ITS#6504 --- CHANGES | 1 + servers/slapd/backglue.c | 71 ++++++++++++++++++++++++++++++---------- 2 files changed, 54 insertions(+), 18 deletions(-) diff --git a/CHANGES b/CHANGES index 021b9fe8a1..908aea8032 100644 --- a/CHANGES +++ b/CHANGES @@ -8,6 +8,7 @@ OpenLDAP 2.4.22 Engineering Fixed slapd acl non-entry internal searches (ITS#6481) Fixed slapd certificateListValidate (ITS#6466) Fixed slapd empty URI parsing (ITS#6465) + Fixed slapd glued paged results (ITS#6504) Fixed slapd ignore controls with unrecognized flags (ITS#6480) Fixed slapd REP_ENTRY flag handling (ITS#5340) Fixed slapd sasl auxprop_lookup (ITS#6441) diff --git a/servers/slapd/backglue.c b/servers/slapd/backglue.c index e37176f5ad..f1ec215c1c 100644 --- a/servers/slapd/backglue.c +++ b/servers/slapd/backglue.c @@ -35,6 +35,7 @@ #define SLAPD_TOOLS #include "slap.h" +#include "lutil.h" #include "config.h" typedef struct gluenode { @@ -161,7 +162,8 @@ glue_op_response ( Operation *op, SlapReply *rs ) j = gs->nctrls; if (!j) { - newctrls = ch_malloc((i+1)*sizeof(LDAPControl *)); + newctrls = op->o_tmpalloc((i+1)*sizeof(LDAPControl *), + op->o_tmpmemctx); } else { /* Forget old pagedResults response if we're sending * a new one now @@ -178,25 +180,35 @@ glue_op_response ( Operation *op, SlapReply *rs ) if ( newpage ) { for ( k=0; kctrls[k]->ldctl_oid, - LDAP_CONTROL_PAGEDRESULTS )) { - gs->ctrls[k]->ldctl_oid = NULL; - ldap_control_free( gs->ctrls[k] ); - gs->ctrls[k] = gs->ctrls[--j]; - gs->ctrls[j] = NULL; - break; + LDAP_CONTROL_PAGEDRESULTS )) + { + op->o_tmpfree(gs->ctrls[k], op->o_tmpmemctx); + gs->ctrls[k] = gs->ctrls[--j]; + gs->ctrls[j] = NULL; + break; } } } } - newctrls = ch_realloc(gs->ctrls, - (j+i+1)*sizeof(LDAPControl *)); + newctrls = op->o_tmprealloc(gs->ctrls, + (j+i+1)*sizeof(LDAPControl *), op->o_tmpmemctx); } for (k=0; ksr_ctrls[k]; - if ( !BER_BVISNULL( &rs->sr_ctrls[k]->ldctl_value )) - ber_dupbv( &newctrls[j]->ldctl_value, - &rs->sr_ctrls[k]->ldctl_value ); + ber_len_t oidlen = strlen( rs->sr_ctrls[k]->ldctl_oid ); + newctrls[j] = op->o_tmpalloc(sizeof(LDAPControl) + oidlen + 1 + rs->sr_ctrls[k]->ldctl_value.bv_len + 1, + op->o_tmpmemctx); + newctrls[j]->ldctl_iscritical = rs->sr_ctrls[k]->ldctl_iscritical; + newctrls[j]->ldctl_oid = (char *)&newctrls[j][1]; + lutil_strcopy( newctrls[j]->ldctl_oid, rs->sr_ctrls[k]->ldctl_oid ); + if ( !BER_BVISNULL( &rs->sr_ctrls[k]->ldctl_value ) ) { + newctrls[j]->ldctl_value.bv_val = &newctrls[j]->ldctl_oid[oidlen + 1]; + newctrls[j]->ldctl_value.bv_len = rs->sr_ctrls[k]->ldctl_value.bv_len; + lutil_memcopy( newctrls[j]->ldctl_value.bv_val, + rs->sr_ctrls[k]->ldctl_value.bv_val, + rs->sr_ctrls[k]->ldctl_value.bv_len + 1 ); + } else { + BER_BVZERO( &newctrls[j]->ldctl_value ); + } } newctrls[j] = NULL; gs->nctrls = j; @@ -522,6 +534,31 @@ glue_op_search ( Operation *op, SlapReply *rs ) memset( ps->ps_cookieval.bv_val, 0, sizeof( PagedResultsCookie )); } + + + { + /* change the size of the page in the request + * that will be propagated */ + BerElementBuffer berbuf; + BerElement *ber = (BerElement *)&berbuf; + int size = ps->ps_size - rs->sr_nentries; + struct berval cookie = BER_BVC(""), value; + int c; + + for (c = 0; op->o_ctrls[c] != NULL; c++) { + if (strcmp(op->o_ctrls[c]->ldctl_oid, LDAP_CONTROL_PAGEDRESULTS) == 0) + break; + } + + ber_init2( ber, NULL, LBER_USE_DER ); + ber_printf( ber, "{iO}", size, &cookie ); + ber_flatten2( ber, &value, 0 ); + assert( op->o_ctrls[c]->ldctl_value.bv_len >= value.bv_len ); + op->o_ctrls[c]->ldctl_value.bv_len = value.bv_len; + lutil_memcopy( op->o_ctrls[c]->ldctl_value.bv_val, + value.bv_val, value.bv_len ); + ber_free_buf( ber ); + } } default: @@ -556,11 +593,9 @@ end_of_loop:; ber_bvarray_free(gs.refs); if (gs.ctrls) { for (i = gs.nctrls; --i >= 0; ) { - if (!BER_BVISNULL( &gs.ctrls[i]->ldctl_value )) - free(gs.ctrls[i]->ldctl_value.bv_val); - free(gs.ctrls[i]); + op->o_tmpfree(gs.ctrls[i], op->o_tmpmemctx); } - free(gs.ctrls); + op->o_tmpfree(gs.ctrls, op->o_tmpmemctx); } return rs->sr_err; } -- 2.39.5