X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;ds=sidebyside;f=servers%2Fslapd%2Fabandon.c;h=95df80c2a59acc708742e04a7f7d029c6d032478;hb=61312e7989b6b0cf97b859caf4b43fa7e70741c8;hp=78fa52904e60cd4eb39e6362cb4eef9b17874d58;hpb=2f5e17d056f5c8d0722419841eedc67c05993595;p=openldap diff --git a/servers/slapd/abandon.c b/servers/slapd/abandon.c index 78fa52904e..95df80c2a5 100644 --- a/servers/slapd/abandon.c +++ b/servers/slapd/abandon.c @@ -2,7 +2,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 1998-2004 The OpenLDAP Foundation. + * Copyright 1998-2005 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -75,27 +75,29 @@ do_abandon( Operation *op, SlapReply *rs ) LDAP_STAILQ_FOREACH( o, &op->o_conn->c_ops, o_next ) { if ( o->o_msgid == id ) { o->o_abandon = 1; - goto done; + break; } } - LDAP_STAILQ_FOREACH( o, &op->o_conn->c_pending_ops, o_next ) { - if ( o->o_msgid == id ) { - LDAP_STAILQ_REMOVE( &op->o_conn->c_pending_ops, - o, slap_op, o_next ); - LDAP_STAILQ_NEXT(o, o_next) = NULL; - op->o_conn->c_n_ops_pending--; - slap_op_free( o ); - goto done; + if ( o ) { + op->orn_msgid = id; + + op->o_bd = frontendDB; + rs->sr_err = frontendDB->be_abandon( op, rs ); + + } else { + LDAP_STAILQ_FOREACH( o, &op->o_conn->c_pending_ops, o_next ) { + if ( o->o_msgid == id ) { + LDAP_STAILQ_REMOVE( &op->o_conn->c_pending_ops, + o, slap_op, o_next ); + LDAP_STAILQ_NEXT(o, o_next) = NULL; + op->o_conn->c_n_ops_pending--; + slap_op_free( o ); + break; + } } } -done: - op->orn_msgid = id; - - op->o_bd = frontendDB; - rs->sr_err = frontendDB->be_abandon( op, rs ); - ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex ); Debug( LDAP_DEBUG_TRACE, "do_abandon: op=%ld %sfound\n", @@ -106,10 +108,7 @@ done: int fe_op_abandon( Operation *op, SlapReply *rs ) { - int i; - - for ( i = 0; i < nbackends; i++ ) { - op->o_bd = &backends[i]; + LDAP_STAILQ_FOREACH( op->o_bd, &backendDB, be_next ) { if ( op->o_bd->be_abandon ) { (void)op->o_bd->be_abandon( op, rs ); }