--- servers/slapd/ctxcsn.c 2004/12/06 22:17:58 1.30 +++ servers/slapd/ctxcsn.c 2004/12/07 23:46:14 1.31 @@ -1,5 +1,5 @@ /* ctxcsn.c -- Context CSN Management Routines */ -/* $OpenLDAP: pkg/ldap/servers/slapd/ctxcsn.c,v 1.29 2004/11/26 08:40:22 hyc Exp $ */ +/* $OpenLDAP: pkg/ldap/servers/slapd/ctxcsn.c,v 1.30 2004/12/06 22:17:58 hyc Exp $ */ /* This work is part of OpenLDAP Software . * * Copyright 2003-2004 The OpenLDAP Foundation. @@ -30,18 +30,24 @@ const struct berval slap_ldapsync_bv = B const struct berval slap_ldapsync_cn_bv = BER_BVC("cn=ldapsync"); void -slap_get_commit_csn( Operation *op, struct berval *csn ) +slap_get_commit_csn( + Operation *op, + struct berval *maxcsn, + struct berval *curcsn +) { struct slap_csn_entry *csne, *committed_csne = NULL; int i = 0; - csn->bv_val = NULL; - csn->bv_len = 0; + if ( maxcsn ) { + BER_BVZERO( maxcsn ); + } ldap_pvt_thread_mutex_lock( op->o_bd->be_pcl_mutexp ); LDAP_TAILQ_FOREACH( csne, op->o_bd->be_pending_csn_list, ce_csn_link ) { if ( csne->ce_opid == op->o_opid && csne->ce_connid == op->o_connid ) { + if ( curcsn ) *curcsn = csne->ce_csn; csne->ce_state = SLAP_CSN_COMMIT; break; } @@ -52,7 +58,7 @@ slap_get_commit_csn( Operation *op, stru if ( csne->ce_state == SLAP_CSN_PENDING ) break; } - if ( committed_csne ) ber_dupbv_x( csn, &committed_csne->ce_csn, op->o_tmpmemctx ); + if ( committed_csne && maxcsn ) *maxcsn = committed_csne->ce_csn; ldap_pvt_thread_mutex_unlock( op->o_bd->be_pcl_mutexp ); }