X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fctxcsn.c;h=c93fa5c83c1e1d082d3e17c87e1f40b25d2e93c5;hb=24db207196a453a4f9acdce08593c7e0ed53ce4c;hp=90e16f6b3ec31e5c90395debae03ec851d17ae1e;hpb=a1830a3cd09a6e1383c0199bea30669f9bdb01b2;p=openldap diff --git a/servers/slapd/ctxcsn.c b/servers/slapd/ctxcsn.c index 90e16f6b3e..c93fa5c83c 100644 --- a/servers/slapd/ctxcsn.c +++ b/servers/slapd/ctxcsn.c @@ -2,7 +2,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 2003-2005 The OpenLDAP Foundation. + * Copyright 2003-2007 The OpenLDAP Foundation. * Portions Copyright 2003 IBM Corporation. * All rights reserved. * @@ -28,12 +28,12 @@ const struct berval slap_ldapsync_bv = BER_BVC("ldapsync"); const struct berval slap_ldapsync_cn_bv = BER_BVC("cn=ldapsync"); +int slap_serverID; void slap_get_commit_csn( Operation *op, - struct berval *maxcsn, - struct berval *curcsn + struct berval *maxcsn ) { struct slap_csn_entry *csne, *committed_csne = NULL; @@ -46,7 +46,6 @@ slap_get_commit_csn( 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; } @@ -130,7 +129,7 @@ slap_create_context_csn_entry( struct berval bv; - e = (Entry *) ch_calloc( 1, sizeof( Entry )); + e = entry_alloc(); attr_merge( e, slap_schema.si_ad_objectClass, ocbva, NULL ); @@ -166,7 +165,7 @@ slap_queue_csn( ldap_pvt_thread_mutex_lock( op->o_bd->be_pcl_mutexp ); ber_dupbv( &pending->ce_csn, csn ); - ber_dupbv_x( &op->o_csn, &pending->ce_csn, op->o_tmpmemctx ); + ber_bvreplace_x( &op->o_csn, &pending->ce_csn, op->o_tmpmemctx ); pending->ce_connid = op->o_connid; pending->ce_opid = op->o_opid; pending->ce_state = SLAP_CSN_PENDING; @@ -183,13 +182,10 @@ slap_get_csn( { if ( csn == NULL ) return LDAP_OTHER; -#ifndef HAVE_GMTIME_R + /* gmtime doesn't always need a mutex, but lutil_csnstr does */ ldap_pvt_thread_mutex_lock( &gmtime_mutex ); -#endif - csn->bv_len = lutil_csnstr( csn->bv_val, csn->bv_len, 0, 0 ); -#ifndef HAVE_GMTIME_R + csn->bv_len = lutil_csnstr( csn->bv_val, csn->bv_len, slap_serverID, 0 ); ldap_pvt_thread_mutex_unlock( &gmtime_mutex ); -#endif if ( manage_ctxcsn ) slap_queue_csn( op, csn );