mirror/openldap
2
0
Fork 0
mirror of https://git.openldap.org/openldap/openldap.git synced 2024-12-21 03:10:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

ITS#6787 release entry locks before sending entries

Browse Source
This commit is contained in:
Howard Chu 2011-01-13 01:11:08 +00:00
parent afa4a82747
commit 9f692a8168
4 changed files with 61 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
servers/slapd/back-monitor/cache.c
View File

@ -439,3 +439,11 @@ monitor_cache_destroy(
return 0;
}
int monitor_back_release(
Operation *op,
Entry *e,
int rw )
{
monitor_info_t *mi = ( monitor_info_t * )op->o_bd->be_private;
return monitor_cache_release( mi, e );
}

2
servers/slapd/back-monitor/init.c
View File

@ -2051,7 +2051,7 @@ monitor_back_initialize(
bi->bi_extended = 0;
bi->bi_entry_release_rw = 0;
bi->bi_entry_release_rw = monitor_back_release;
bi->bi_chk_referrals = 0;
bi->bi_operational = monitor_back_operational;

6
servers/slapd/back-monitor/proto-back-monitor.h
View File

@ -77,6 +77,12 @@ extern int
monitor_cache_destroy LDAP_P((
monitor_info_t *mi ));
extern int
monitor_back_release(
Operation *op,
Entry *e,
int rw );
/*
* connections
*/

75
servers/slapd/back-monitor/search.c
View File

@ -30,29 +30,42 @@
#include "back-monitor.h"
#include "proto-back-monitor.h"
static void
monitor_find_children(
Operation *op,
SlapReply *rs,
Entry *e_parent,
Entry **nonv,
Entry **vol
)
{
monitor_info_t *mi = ( monitor_info_t * )op->o_bd->be_private;
monitor_entry_t *mp;
mp = ( monitor_entry_t * )e_parent->e_private;
*nonv = mp->mp_children;
if ( MONITOR_HAS_VOLATILE_CH( mp ) ) {
monitor_entry_create( op, rs, NULL, e_parent, vol );
}
}
static int
monitor_send_children(
Operation *op,
SlapReply *rs,
Entry *e_parent,
Entry *e_nonvolatile,
Entry *e_ch,
int sub )
{
monitor_info_t *mi = ( monitor_info_t * )op->o_bd->be_private;
Entry *e,
*e_tmp,
*e_ch = NULL,
*e_nonvolatile = NULL;
*e_tmp;
monitor_entry_t *mp;
int rc,
nonvolatile = 0;
mp = ( monitor_entry_t * )e_parent->e_private;
e_nonvolatile = e = mp->mp_children;
if ( MONITOR_HAS_VOLATILE_CH( mp ) ) {
monitor_entry_create( op, rs, NULL, e_parent, &e_ch );
}
monitor_cache_release( mi, e_parent );
e = e_nonvolatile;
/* no volatile entries? */
if ( e_ch == NULL ) {
@ -85,6 +98,7 @@ monitor_send_children(
/* return entries */
for ( monitor_cache_lock( e ); e != NULL; ) {
Entry *sub_nv = NULL, *sub_ch = NULL;
monitor_entry_update( op, rs, e );
if ( e == e_nonvolatile )
@ -99,20 +113,23 @@ monitor_send_children(
goto freeout;
}
if ( sub )
monitor_find_children( op, rs, e, &sub_nv, &sub_ch );
rc = test_filter( op, e, op->oq_search.rs_filter );
if ( rc == LDAP_COMPARE_TRUE ) {
rs->sr_entry = e;
rs->sr_flags = 0;
rs->sr_flags = REP_ENTRY_MUSTRELEASE;
rc = send_search_entry( op, rs );
rs->sr_entry = NULL;
if ( rc ) {
monitor_cache_release( mi, e );
goto freeout;
}
} else {
monitor_cache_release( mi, e );
}
if ( sub ) {
rc = monitor_send_children( op, rs, e, sub );
rc = monitor_send_children( op, rs, sub_nv, sub_ch, sub );
if ( rc ) {
freeout:
/* FIXME: may leak generated children */
@ -134,16 +151,9 @@ freeout:
}
}
if ( e_tmp != NULL ) {
monitor_cache_lock( e_tmp );
}
if ( !sub ) {
/* otherwise the recursive call already released */
monitor_cache_release( mi, e );
}
e = e_tmp;
if ( e )
monitor_cache_lock( e );
}
return LDAP_SUCCESS;
@ -155,6 +165,7 @@ monitor_back_search( Operation *op, SlapReply *rs )
monitor_info_t *mi = ( monitor_info_t * )op->o_bd->be_private;
int rc = LDAP_SUCCESS;
Entry *e = NULL, *matched = NULL;
Entry *e_nv = NULL, *e_ch = NULL;
slap_mask_t mask;
Debug( LDAP_DEBUG_TRACE, "=> monitor_back_search\n", 0, 0, 0 );
@ -209,31 +220,37 @@ monitor_back_search( Operation *op, SlapReply *rs )
rc = test_filter( op, e, op->oq_search.rs_filter );
if ( rc == LDAP_COMPARE_TRUE ) {
rs->sr_entry = e;
rs->sr_flags = 0;
rs->sr_flags = REP_ENTRY_MUSTRELEASE;
send_search_entry( op, rs );
rs->sr_entry = NULL;
} else {
monitor_cache_release( mi, e );
}
rc = LDAP_SUCCESS;
monitor_cache_release( mi, e );
break;
case LDAP_SCOPE_ONELEVEL:
case LDAP_SCOPE_SUBORDINATE:
rc = monitor_send_children( op, rs, e,
monitor_find_children( op, rs, e, &e_nv, &e_ch );
monitor_cache_release( mi, e );
rc = monitor_send_children( op, rs, e_nv, e_ch,
op->oq_search.rs_scope == LDAP_SCOPE_SUBORDINATE );
break;
case LDAP_SCOPE_SUBTREE:
monitor_entry_update( op, rs, e );
monitor_find_children( op, rs, e, &e_nv, &e_ch );
rc = test_filter( op, e, op->oq_search.rs_filter );
if ( rc == LDAP_COMPARE_TRUE ) {
rs->sr_entry = e;
rs->sr_flags = 0;
rs->sr_flags = REP_ENTRY_MUSTRELEASE;
send_search_entry( op, rs );
rs->sr_entry = NULL;
} else {
monitor_cache_release( mi, e );
}
rc = monitor_send_children( op, rs, e, 1 );
rc = monitor_send_children( op, rs, e_nv, e_ch, 1 );
break;
default: