int si_refreshDelete;
int si_refreshPresent;
int si_refreshDone;
- int si_refreshCount;
- time_t si_refreshBeg;
- time_t si_refreshEnd;
- OpExtra *si_refreshTxn;
int si_syncdata;
int si_logstate;
int si_lazyCommit;
}
si->si_refreshDone = 0;
- si->si_refreshBeg = slap_get_time();
- si->si_refreshCount = 0;
- si->si_refreshTxn = NULL;
- Debug( LDAP_DEBUG_ANY, "do_syncrep1: %s starting refresh\n",
+ Debug( LDAP_DEBUG_SYNC, "do_syncrep1: %s starting refresh\n",
si->si_ridtxt, 0, 0 );
rc = ldap_sync_search( si, op->o_tmpmemctx );
{
rc = syncrepl_updateCookie( si, op, &syncCookie, 1 );
}
- if ( si->si_refreshCount ) {
- LDAP_SLIST_REMOVE( &op->o_extra, si->si_refreshTxn, OpExtra, oe_next );
- op->o_bd->bd_info->bi_op_txn( op, SLAP_TXN_COMMIT, &si->si_refreshTxn );
- si->si_refreshCount = 0;
- si->si_refreshTxn = NULL;
- }
- si->si_refreshEnd = slap_get_time();
if ( err == LDAP_SUCCESS
&& si->si_logstate == SYNCLOG_FALLBACK ) {
si->si_logstate = SYNCLOG_LOGGING;
{
si->si_refreshDone = 1;
}
+ ber_scanf( ber, /*"{"*/ "}" );
if ( si->si_refreshDone ) {
- if ( si->si_refreshCount ) {
- LDAP_SLIST_REMOVE( &op->o_extra, si->si_refreshTxn, OpExtra, oe_next );
- op->o_bd->bd_info->bi_op_txn( op, SLAP_TXN_COMMIT, &si->si_refreshTxn );
- si->si_refreshCount = 0;
- si->si_refreshTxn = NULL;
- }
- si->si_refreshEnd = slap_get_time();
- Debug( LDAP_DEBUG_ANY, "do_syncrep1: %s finished refresh\n",
- si->si_ridtxt, 0, 0 );
+ Debug( LDAP_DEBUG_SYNC, "do_syncrep1: %s finished refresh\n",
+ si->si_ridtxt, 0, 0 );
}
- ber_scanf( ber, /*"{"*/ "}" );
if ( abs(si->si_type) == LDAP_SYNC_REFRESH_AND_PERSIST &&
si->si_refreshDone )
tout_p = &tout;
if ( ldap_pvt_thread_pool_pausing( &connection_pool )) {
slap_sync_cookie_free( &syncCookie, 0 );
slap_sync_cookie_free( &syncCookie_req, 0 );
- if ( si->si_refreshCount ) {
- LDAP_SLIST_REMOVE( &op->o_extra, si->si_refreshTxn, OpExtra, oe_next );
- op->o_bd->bd_info->bi_op_txn( op, SLAP_TXN_COMMIT, &si->si_refreshTxn );
- si->si_refreshCount = 0;
- si->si_refreshTxn = NULL;
- }
return SYNC_PAUSED;
}
}