version 1.322, 2010/12/30 22:34:56
|
version 1.323, 2010/12/30 22:43:12
|
Line 1
|
Line 1
|
/* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.321 2010/12/20 09:57:07 hallvard Exp $ */ |
/* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.322 2010/12/30 22:34:56 hallvard Exp $ */ |
/* syncprov.c - syncrepl provider */ |
/* syncprov.c - syncrepl provider */ |
/* This work is part of OpenLDAP Software <http://www.openldap.org/>. |
/* This work is part of OpenLDAP Software <http://www.openldap.org/>. |
* |
* |
Line 1418 syncprov_op_cleanup( Operation *op, Slap
|
Line 1418 syncprov_op_cleanup( Operation *op, Slap
|
} |
} |
|
|
static void |
static void |
syncprov_checkpoint( Operation *op, SlapReply *rs, slap_overinst *on ) |
syncprov_checkpoint( Operation *op, slap_overinst *on ) |
{ |
{ |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
Modifications mod; |
Modifications mod; |
Line 1893 syncprov_op_response( Operation *op, Sla
|
Line 1893 syncprov_op_response( Operation *op, Sla
|
|
|
if ( do_check ) { |
if ( do_check ) { |
ldap_pvt_thread_rdwr_rlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_rdwr_rlock( &si->si_csn_rwlock ); |
syncprov_checkpoint( op, rs, on ); |
syncprov_checkpoint( op, on ); |
ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock ); |
} |
} |
|
|
Line 3085 syncprov_db_close(
|
Line 3085 syncprov_db_close(
|
Connection conn = {0}; |
Connection conn = {0}; |
OperationBuffer opbuf; |
OperationBuffer opbuf; |
Operation *op; |
Operation *op; |
SlapReply rs = {REP_RESULT}; |
|
void *thrctx; |
void *thrctx; |
|
|
thrctx = ldap_pvt_thread_pool_context(); |
thrctx = ldap_pvt_thread_pool_context(); |
Line 3094 syncprov_db_close(
|
Line 3093 syncprov_db_close(
|
op->o_bd = be; |
op->o_bd = be; |
op->o_dn = be->be_rootdn; |
op->o_dn = be->be_rootdn; |
op->o_ndn = be->be_rootndn; |
op->o_ndn = be->be_rootndn; |
syncprov_checkpoint( op, &rs, on ); |
syncprov_checkpoint( op, on ); |
} |
} |
|
|
#ifdef SLAP_CONFIG_DELETE |
#ifdef SLAP_CONFIG_DELETE |