version 1.56.2.51, 2008/07/09 20:53:13
|
version 1.144, 2006/01/23 21:23:00
|
Line 1
|
Line 1
|
/* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.56.2.50 2008/05/14 00:49:04 quanah Exp $ */ |
/* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.143 2006/01/23 19:53:52 hyc 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/>. |
* |
* |
* Copyright 2004-2008 The OpenLDAP Foundation. |
* Copyright 2004-2006 The OpenLDAP Foundation. |
* All rights reserved. |
* All rights reserved. |
* |
* |
* Redistribution and use in source and binary forms, with or without |
* Redistribution and use in source and binary forms, with or without |
Line 65 typedef struct syncops {
|
Line 65 typedef struct syncops {
|
#define PS_IS_DETACHED 0x02 |
#define PS_IS_DETACHED 0x02 |
#define PS_WROTE_BASE 0x04 |
#define PS_WROTE_BASE 0x04 |
#define PS_FIND_BASE 0x08 |
#define PS_FIND_BASE 0x08 |
#define PS_FIX_FILTER 0x10 |
|
|
|
int s_inuse; /* reference count */ |
int s_inuse; /* reference count */ |
struct syncres *s_res; |
struct syncres *s_res; |
Line 127 typedef struct syncprov_info_t {
|
Line 126 typedef struct syncprov_info_t {
|
time_t si_chklast; /* time of last checkpoint */ |
time_t si_chklast; /* time of last checkpoint */ |
Avlnode *si_mods; /* entries being modified */ |
Avlnode *si_mods; /* entries being modified */ |
sessionlog *si_logs; |
sessionlog *si_logs; |
ldap_pvt_thread_rdwr_t si_csn_rwlock; |
ldap_pvt_thread_mutex_t si_csn_mutex; |
ldap_pvt_thread_mutex_t si_ops_mutex; |
ldap_pvt_thread_mutex_t si_ops_mutex; |
ldap_pvt_thread_mutex_t si_mods_mutex; |
ldap_pvt_thread_mutex_t si_mods_mutex; |
char si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
char si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
Line 401 syncprov_findbase( Operation *op, fbase_
|
Line 400 syncprov_findbase( Operation *op, fbase_
|
slap_callback cb = {0}; |
slap_callback cb = {0}; |
Operation fop; |
Operation fop; |
SlapReply frs = { REP_RESULT }; |
SlapReply frs = { REP_RESULT }; |
BackendInfo *bi; |
|
int rc; |
int rc; |
|
|
fc->fss->s_flags ^= PS_FIND_BASE; |
fc->fss->s_flags ^= PS_FIND_BASE; |
Line 413 syncprov_findbase( Operation *op, fbase_
|
Line 411 syncprov_findbase( Operation *op, fbase_
|
fop.o_bd = op->o_bd; |
fop.o_bd = op->o_bd; |
fop.o_time = op->o_time; |
fop.o_time = op->o_time; |
fop.o_tincr = op->o_tincr; |
fop.o_tincr = op->o_tincr; |
bi = op->o_bd->bd_info; |
|
|
|
cb.sc_response = findbase_cb; |
cb.sc_response = findbase_cb; |
cb.sc_private = fc; |
cb.sc_private = fc; |
Line 431 syncprov_findbase( Operation *op, fbase_
|
Line 428 syncprov_findbase( Operation *op, fbase_
|
fop.ors_filter = &generic_filter; |
fop.ors_filter = &generic_filter; |
fop.ors_filterstr = generic_filterstr; |
fop.ors_filterstr = generic_filterstr; |
|
|
rc = overlay_op_walk( &fop, &frs, op_search, on->on_info, on ); |
fop.o_bd->bd_info = on->on_info->oi_orig; |
op->o_bd->bd_info = bi; |
rc = fop.o_bd->be_search( &fop, &frs ); |
|
fop.o_bd->bd_info = (BackendInfo *)on; |
} else { |
} else { |
ldap_pvt_thread_mutex_unlock( &fc->fss->s_mutex ); |
ldap_pvt_thread_mutex_unlock( &fc->fss->s_mutex ); |
fc->fbase = 1; |
fc->fbase = 1; |
Line 581 syncprov_findcsn( Operation *op, find_cs
|
Line 579 syncprov_findcsn( Operation *op, find_cs
|
char buf[LDAP_LUTIL_CSNSTR_BUFSIZE + STRLENOF("(entryCSN<=)")]; |
char buf[LDAP_LUTIL_CSNSTR_BUFSIZE + STRLENOF("(entryCSN<=)")]; |
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
struct berval maxcsn; |
struct berval maxcsn; |
Filter cf; |
Filter cf, af; |
#ifdef LDAP_COMP_MATCH |
#ifdef LDAP_COMP_MATCH |
AttributeAssertion eq = { NULL, BER_BVNULL, NULL }; |
AttributeAssertion eq = { NULL, BER_BVNULL, NULL }; |
#else |
#else |
Line 642 again:
|
Line 640 again:
|
} else { |
} else { |
cf.f_choice = LDAP_FILTER_LE; |
cf.f_choice = LDAP_FILTER_LE; |
fop.ors_limit = &fc_limits; |
fop.ors_limit = &fc_limits; |
memset( &fc_limits, 0, sizeof( fc_limits )); |
|
fc_limits.lms_s_unchecked = 1; |
fc_limits.lms_s_unchecked = 1; |
fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)", |
fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)", |
cf.f_av_value.bv_val ); |
cf.f_av_value.bv_val ); |
Line 654 again:
|
Line 651 again:
|
cb.sc_response = findcsn_cb; |
cb.sc_response = findcsn_cb; |
break; |
break; |
case FIND_PRESENT: |
case FIND_PRESENT: |
fop.ors_filter = op->ors_filter; |
af.f_choice = LDAP_FILTER_AND; |
fop.ors_filterstr = op->ors_filterstr; |
af.f_next = NULL; |
|
af.f_and = &cf; |
|
cf.f_choice = LDAP_FILTER_LE; |
|
cf.f_av_value = srs->sr_state.ctxcsn; |
|
cf.f_next = op->ors_filter; |
|
fop.ors_filter = ⁡ |
|
filter2bv_x( &fop, fop.ors_filter, &fop.ors_filterstr ); |
fop.ors_attrsonly = 0; |
fop.ors_attrsonly = 0; |
fop.ors_attrs = uuid_anlist; |
fop.ors_attrs = uuid_anlist; |
fop.ors_slimit = SLAP_NO_LIMIT; |
fop.ors_slimit = SLAP_NO_LIMIT; |
Line 699 again:
|
Line 702 again:
|
break; |
break; |
case FIND_PRESENT: |
case FIND_PRESENT: |
op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx ); |
op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx ); |
|
op->o_tmpfree( fop.ors_filterstr.bv_val, op->o_tmpmemctx ); |
break; |
break; |
} |
} |
|
|
Line 769 syncprov_sendresp( Operation *op, opcook
|
Line 773 syncprov_sendresp( Operation *op, opcook
|
rs.sr_flags = REP_ENTRY_MUSTRELEASE; |
rs.sr_flags = REP_ENTRY_MUSTRELEASE; |
if ( opc->sreference ) { |
if ( opc->sreference ) { |
rs.sr_ref = get_entry_referrals( op, rs.sr_entry ); |
rs.sr_ref = get_entry_referrals( op, rs.sr_entry ); |
rs.sr_err = send_search_reference( op, &rs ); |
send_search_reference( op, &rs ); |
ber_bvarray_free( rs.sr_ref ); |
ber_bvarray_free( rs.sr_ref ); |
if ( !rs.sr_entry ) |
if ( !rs.sr_entry ) |
*e = NULL; |
*e = NULL; |
Line 781 syncprov_sendresp( Operation *op, opcook
|
Line 785 syncprov_sendresp( Operation *op, opcook
|
if ( rs.sr_entry->e_private ) |
if ( rs.sr_entry->e_private ) |
rs.sr_flags = REP_ENTRY_MUSTRELEASE; |
rs.sr_flags = REP_ENTRY_MUSTRELEASE; |
rs.sr_attrs = op->ors_attrs; |
rs.sr_attrs = op->ors_attrs; |
rs.sr_err = send_search_entry( op, &rs ); |
send_search_entry( op, &rs ); |
if ( !rs.sr_entry ) |
if ( !rs.sr_entry ) |
*e = NULL; |
*e = NULL; |
break; |
break; |
Line 793 syncprov_sendresp( Operation *op, opcook
|
Line 797 syncprov_sendresp( Operation *op, opcook
|
if ( opc->sreference ) { |
if ( opc->sreference ) { |
struct berval bv = BER_BVNULL; |
struct berval bv = BER_BVNULL; |
rs.sr_ref = &bv; |
rs.sr_ref = &bv; |
rs.sr_err = send_search_reference( op, &rs ); |
send_search_reference( op, &rs ); |
} else { |
} else { |
rs.sr_err = send_search_entry( op, &rs ); |
send_search_entry( op, &rs ); |
} |
} |
break; |
break; |
default: |
default: |
Line 820 syncprov_qplay( Operation *op, slap_over
|
Line 824 syncprov_qplay( Operation *op, slap_over
|
int rc = 0; |
int rc = 0; |
|
|
opc.son = on; |
opc.son = on; |
|
op->o_bd->bd_info = (BackendInfo *)on->on_info; |
|
|
for (;;) { |
for (;;) { |
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
Line 841 syncprov_qplay( Operation *op, slap_over
|
Line 846 syncprov_qplay( Operation *op, slap_over
|
e = NULL; |
e = NULL; |
|
|
if ( sr->s_mode != LDAP_SYNC_DELETE ) { |
if ( sr->s_mode != LDAP_SYNC_DELETE ) { |
rc = overlay_entry_get_ov( op, &opc.sndn, NULL, NULL, 0, &e, on ); |
rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e ); |
if ( rc ) { |
if ( rc ) { |
Debug( LDAP_DEBUG_SYNC, "syncprov_qplay: failed to get %s, " |
|
"error (%d), ignoring...\n", opc.sndn.bv_val, rc, 0 ); |
|
ch_free( sr ); |
ch_free( sr ); |
rc = 0; |
|
continue; |
continue; |
} |
} |
} |
} |
rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode ); |
rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode ); |
|
|
if ( e ) { |
if ( e ) { |
overlay_entry_release_ov( op, e, 0, on ); |
be_entry_release_rw( op, e, 0 ); |
} |
} |
|
|
ch_free( sr ); |
ch_free( sr ); |
Line 861 syncprov_qplay( Operation *op, slap_over
|
Line 863 syncprov_qplay( Operation *op, slap_over
|
if ( rc ) |
if ( rc ) |
break; |
break; |
} |
} |
|
op->o_bd->bd_info = (BackendInfo *)on; |
return rc; |
return rc; |
} |
} |
|
|
Line 874 syncprov_qtask( void *ctx, void *arg )
|
Line 877 syncprov_qtask( void *ctx, void *arg )
|
OperationBuffer opbuf; |
OperationBuffer opbuf; |
Operation *op; |
Operation *op; |
BackendDB be; |
BackendDB be; |
int rc; |
|
|
|
op = (Operation *) &opbuf; |
op = (Operation *) &opbuf; |
*op = *so->s_op; |
*op = *so->s_op; |
Line 895 syncprov_qtask( void *ctx, void *arg )
|
Line 897 syncprov_qtask( void *ctx, void *arg )
|
op->o_private = NULL; |
op->o_private = NULL; |
op->o_callback = NULL; |
op->o_callback = NULL; |
|
|
rc = syncprov_qplay( op, on, so ); |
(void)syncprov_qplay( op, on, so ); |
|
|
/* decrement use count... */ |
/* decrement use count... */ |
syncprov_free_syncop( so ); |
syncprov_free_syncop( so ); |
|
|
/* wait until we get explicitly scheduled again */ |
/* wait until we get explicitly scheduled again */ |
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex ); |
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex ); |
ldap_pvt_runqueue_stoptask( &slapd_rq, rtask ); |
ldap_pvt_runqueue_stoptask( &slapd_rq, so->s_qtask ); |
if ( rc == 0 ) { |
ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 1 ); |
ldap_pvt_runqueue_resched( &slapd_rq, rtask, 1 ); |
|
} else { |
|
/* bail out on any error */ |
|
ldap_pvt_runqueue_remove( &slapd_rq, rtask ); |
|
} |
|
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex ); |
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex ); |
|
|
return NULL; |
return NULL; |
} |
} |
|
|
/* Start the task to play back queued psearch responses */ |
|
static void |
|
syncprov_qstart( syncops *so ) |
|
{ |
|
int wake=0; |
|
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex ); |
|
if ( !so->s_qtask ) { |
|
so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, RUNQ_INTERVAL, |
|
syncprov_qtask, so, "syncprov_qtask", |
|
so->s_op->o_conn->c_peer_name.bv_val ); |
|
++so->s_inuse; |
|
wake = 1; |
|
} else { |
|
if (!ldap_pvt_runqueue_isrunning( &slapd_rq, so->s_qtask ) && |
|
!so->s_qtask->next_sched.tv_sec ) { |
|
so->s_qtask->interval.tv_sec = 0; |
|
ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 0 ); |
|
so->s_qtask->interval.tv_sec = RUNQ_INTERVAL; |
|
++so->s_inuse; |
|
wake = 1; |
|
} |
|
} |
|
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex ); |
|
if ( wake ) |
|
slap_wake_listener(); |
|
} |
|
|
|
/* Queue a persistent search response */ |
/* Queue a persistent search response */ |
static int |
static int |
syncprov_qresp( opcookie *opc, syncops *so, int mode ) |
syncprov_qresp( opcookie *opc, syncops *so, int mode ) |
Line 979 syncprov_qresp( opcookie *opc, syncops *
|
Line 949 syncprov_qresp( opcookie *opc, syncops *
|
so->s_flags |= PS_FIND_BASE; |
so->s_flags |= PS_FIND_BASE; |
} |
} |
if ( so->s_flags & PS_IS_DETACHED ) { |
if ( so->s_flags & PS_IS_DETACHED ) { |
syncprov_qstart( so ); |
int wake=0; |
|
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex ); |
|
if ( !so->s_qtask ) { |
|
so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, RUNQ_INTERVAL, |
|
syncprov_qtask, so, "syncprov_qtask", |
|
so->s_op->o_conn->c_peer_name.bv_val ); |
|
++so->s_inuse; |
|
wake = 1; |
|
} else { |
|
if (!ldap_pvt_runqueue_isrunning( &slapd_rq, so->s_qtask ) && |
|
!so->s_qtask->next_sched.tv_sec ) { |
|
so->s_qtask->interval.tv_sec = 0; |
|
ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 0 ); |
|
so->s_qtask->interval.tv_sec = RUNQ_INTERVAL; |
|
++so->s_inuse; |
|
wake = 1; |
|
} |
|
} |
|
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex ); |
|
if ( wake ) |
|
slap_wake_listener(); |
} |
} |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
return LDAP_SUCCESS; |
return LDAP_SUCCESS; |
Line 1060 syncprov_matchops( Operation *op, opcook
|
Line 1050 syncprov_matchops( Operation *op, opcook
|
|
|
fbase_cookie fc; |
fbase_cookie fc; |
syncops *ss, *sprev, *snext; |
syncops *ss, *sprev, *snext; |
Entry *e = NULL; |
Entry *e; |
Attribute *a; |
Attribute *a; |
int rc; |
int rc; |
struct berval newdn; |
struct berval newdn; |
int freefdn = 0; |
int freefdn = 0; |
BackendDB *b0 = op->o_bd, db; |
|
|
|
fc.fdn = &op->o_req_ndn; |
fc.fdn = &op->o_req_ndn; |
/* compute new DN */ |
/* compute new DN */ |
Line 1078 syncprov_matchops( Operation *op, opcook
|
Line 1067 syncprov_matchops( Operation *op, opcook
|
freefdn = 1; |
freefdn = 1; |
} |
} |
if ( op->o_tag != LDAP_REQ_ADD ) { |
if ( op->o_tag != LDAP_REQ_ADD ) { |
if ( !SLAP_ISOVERLAY( op->o_bd )) { |
op->o_bd->bd_info = (BackendInfo *)on->on_info; |
db = *op->o_bd; |
rc = be_entry_get_rw( op, fc.fdn, NULL, NULL, 0, &e ); |
op->o_bd = &db; |
|
} |
|
rc = overlay_entry_get_ov( op, fc.fdn, NULL, NULL, 0, &e, on ); |
|
/* If we're sending responses now, make a copy and unlock the DB */ |
/* If we're sending responses now, make a copy and unlock the DB */ |
if ( e && !saveit ) { |
if ( e && !saveit ) { |
Entry *e2 = entry_dup( e ); |
Entry *e2 = entry_dup( e ); |
overlay_entry_release_ov( op, e, 0, on ); |
be_entry_release_rw( op, e, 0 ); |
e = e2; |
e = e2; |
} |
} |
if ( rc ) { |
op->o_bd->bd_info = (BackendInfo *)on; |
op->o_bd = b0; |
if ( rc ) return; |
return; |
|
} |
|
} else { |
} else { |
e = op->ora_e; |
e = op->ora_e; |
} |
} |
Line 1190 syncprov_matchops( Operation *op, opcook
|
Line 1174 syncprov_matchops( Operation *op, opcook
|
if ( freefdn ) { |
if ( freefdn ) { |
op->o_tmpfree( fc.fdn->bv_val, op->o_tmpmemctx ); |
op->o_tmpfree( fc.fdn->bv_val, op->o_tmpmemctx ); |
} |
} |
op->o_bd = b0; |
|
} |
} |
|
|
static int |
static int |
Line 1252 syncprov_checkpoint( Operation *op, Slap
|
Line 1235 syncprov_checkpoint( Operation *op, Slap
|
struct berval bv[2]; |
struct berval bv[2]; |
slap_callback cb = {0}; |
slap_callback cb = {0}; |
|
|
/* If ctxcsn is empty, delete it */ |
mod.sml_values = bv; |
if ( BER_BVISEMPTY( &si->si_ctxcsn )) { |
bv[1].bv_val = NULL; |
mod.sml_values = NULL; |
bv[0] = si->si_ctxcsn; |
} else { |
|
mod.sml_values = bv; |
|
bv[1].bv_val = NULL; |
|
bv[0] = si->si_ctxcsn; |
|
} |
|
mod.sml_nvalues = NULL; |
mod.sml_nvalues = NULL; |
mod.sml_desc = slap_schema.si_ad_contextCSN; |
mod.sml_desc = slap_schema.si_ad_contextCSN; |
mod.sml_op = LDAP_MOD_REPLACE; |
mod.sml_op = LDAP_MOD_REPLACE; |
Line 1284 syncprov_checkpoint( Operation *op, Slap
|
Line 1262 syncprov_checkpoint( Operation *op, Slap
|
} |
} |
|
|
static void |
static void |
syncprov_add_slog( Operation *op ) |
syncprov_add_slog( Operation *op, struct berval *csn ) |
{ |
{ |
opcookie *opc = op->o_callback->sc_private; |
opcookie *opc = op->o_callback->sc_private; |
slap_overinst *on = opc->son; |
slap_overinst *on = opc->son; |
Line 1296 syncprov_add_slog( Operation *op )
|
Line 1274 syncprov_add_slog( Operation *op )
|
{ |
{ |
/* Allocate a record. UUIDs are not NUL-terminated. */ |
/* Allocate a record. UUIDs are not NUL-terminated. */ |
se = ch_malloc( sizeof( slog_entry ) + opc->suuid.bv_len + |
se = ch_malloc( sizeof( slog_entry ) + opc->suuid.bv_len + |
op->o_csn.bv_len + 1 ); |
csn->bv_len + 1 ); |
se->se_next = NULL; |
se->se_next = NULL; |
se->se_tag = op->o_tag; |
se->se_tag = op->o_tag; |
|
|
Line 1305 syncprov_add_slog( Operation *op )
|
Line 1283 syncprov_add_slog( Operation *op )
|
se->se_uuid.bv_len = opc->suuid.bv_len; |
se->se_uuid.bv_len = opc->suuid.bv_len; |
|
|
se->se_csn.bv_val = se->se_uuid.bv_val + opc->suuid.bv_len; |
se->se_csn.bv_val = se->se_uuid.bv_val + opc->suuid.bv_len; |
AC_MEMCPY( se->se_csn.bv_val, op->o_csn.bv_val, op->o_csn.bv_len ); |
AC_MEMCPY( se->se_csn.bv_val, csn->bv_val, csn->bv_len ); |
se->se_csn.bv_val[op->o_csn.bv_len] = '\0'; |
se->se_csn.bv_val[csn->bv_len] = '\0'; |
se->se_csn.bv_len = op->o_csn.bv_len; |
se->se_csn.bv_len = csn->bv_len; |
|
|
ldap_pvt_thread_mutex_lock( &sl->sl_mutex ); |
ldap_pvt_thread_mutex_lock( &sl->sl_mutex ); |
if ( sl->sl_head ) { |
if ( sl->sl_head ) { |
Line 1324 syncprov_add_slog( Operation *op )
|
Line 1302 syncprov_add_slog( Operation *op )
|
sl->sl_mincsn.bv_len = se->se_csn.bv_len; |
sl->sl_mincsn.bv_len = se->se_csn.bv_len; |
ch_free( se ); |
ch_free( se ); |
sl->sl_num--; |
sl->sl_num--; |
|
if ( !sl->sl_head ) { |
|
sl->sl_tail = NULL; |
|
} |
} |
} |
ldap_pvt_thread_mutex_unlock( &sl->sl_mutex ); |
ldap_pvt_thread_mutex_unlock( &sl->sl_mutex ); |
} |
} |
Line 1342 playlog_cb( Operation *op, SlapReply *rs
|
Line 1323 playlog_cb( Operation *op, SlapReply *rs
|
/* enter with sl->sl_mutex locked, release before returning */ |
/* enter with sl->sl_mutex locked, release before returning */ |
static void |
static void |
syncprov_playlog( Operation *op, SlapReply *rs, sessionlog *sl, |
syncprov_playlog( Operation *op, SlapReply *rs, sessionlog *sl, |
sync_control *srs, struct berval *ctxcsn ) |
struct berval *oldcsn, struct berval *ctxcsn ) |
{ |
{ |
slap_overinst *on = (slap_overinst *)op->o_bd->bd_info; |
slap_overinst *on = (slap_overinst *)op->o_bd->bd_info; |
slog_entry *se; |
slog_entry *se; |
int i, j, ndel, num, nmods, mmods; |
int i, j, ndel, num, nmods, mmods; |
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
|
BerVarray uuids; |
BerVarray uuids; |
struct berval delcsn; |
|
|
|
if ( !sl->sl_num ) { |
if ( !sl->sl_num ) { |
ldap_pvt_thread_mutex_unlock( &sl->sl_mutex ); |
ldap_pvt_thread_mutex_unlock( &sl->sl_mutex ); |
Line 1362 syncprov_playlog( Operation *op, SlapRep
|
Line 1341 syncprov_playlog( Operation *op, SlapRep
|
|
|
uuids = op->o_tmpalloc( (num+1) * sizeof( struct berval ) + |
uuids = op->o_tmpalloc( (num+1) * sizeof( struct berval ) + |
num * UUID_LEN, op->o_tmpmemctx ); |
num * UUID_LEN, op->o_tmpmemctx ); |
uuids[0].bv_val = (char *)(uuids + num + 1); |
|
|
|
delcsn.bv_len = 0; |
uuids[0].bv_val = (char *)(uuids + num + 1); |
delcsn.bv_val = cbuf; |
|
|
|
/* Make a copy of the relevant UUIDs. Put the Deletes up front |
/* Make a copy of the relevant UUIDs. Put the Deletes up front |
* and everything else at the end. Do this first so we can |
* and everything else at the end. Do this first so we can |
* unlock the list mutex. |
* unlock the list mutex. |
*/ |
*/ |
Debug( LDAP_DEBUG_SYNC, "srs csn %s\n", srs->sr_state.ctxcsn.bv_val, 0, 0 ); |
|
for ( se=sl->sl_head; se; se=se->se_next ) { |
for ( se=sl->sl_head; se; se=se->se_next ) { |
Debug( LDAP_DEBUG_SYNC, "log csn %s\n", se->se_csn.bv_val, 0, 0 ); |
if ( ber_bvcmp( &se->se_csn, oldcsn ) < 0 ) continue; |
ndel = ber_bvcmp( &se->se_csn, &srs->sr_state.ctxcsn ); |
if ( ber_bvcmp( &se->se_csn, ctxcsn ) > 0 ) break; |
if ( ndel <= 0 ) { |
|
Debug( LDAP_DEBUG_SYNC, "cmp %d, too old\n", ndel, 0, 0 ); |
|
continue; |
|
} |
|
ndel = ber_bvcmp( &se->se_csn, ctxcsn ); |
|
if ( ndel > 0 ) { |
|
Debug( LDAP_DEBUG_SYNC, "cmp %d, too new\n", ndel, 0, 0 ); |
|
break; |
|
} |
|
if ( se->se_tag == LDAP_REQ_DELETE ) { |
if ( se->se_tag == LDAP_REQ_DELETE ) { |
j = i; |
j = i; |
i++; |
i++; |
AC_MEMCPY( cbuf, se->se_csn.bv_val, se->se_csn.bv_len ); |
|
delcsn.bv_len = se->se_csn.bv_len; |
|
delcsn.bv_val[delcsn.bv_len] = '\0'; |
|
} else { |
} else { |
nmods++; |
nmods++; |
j = num - nmods; |
j = num - nmods; |
Line 1481 syncprov_playlog( Operation *op, SlapRep
|
Line 1445 syncprov_playlog( Operation *op, SlapRep
|
fop.o_bd->bd_info = (BackendInfo *)on; |
fop.o_bd->bd_info = (BackendInfo *)on; |
} |
} |
if ( ndel ) { |
if ( ndel ) { |
struct berval cookie; |
|
|
|
slap_compose_sync_cookie( op, &cookie, &delcsn, srs->sr_state.rid ); |
|
uuids[ndel].bv_val = NULL; |
uuids[ndel].bv_val = NULL; |
syncprov_sendinfo( op, rs, LDAP_TAG_SYNC_ID_SET, &cookie, 0, uuids, 1 ); |
syncprov_sendinfo( op, rs, LDAP_TAG_SYNC_ID_SET, NULL, 0, uuids, 1 ); |
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
|
} |
} |
op->o_tmpfree( uuids, op->o_tmpmemctx ); |
|
} |
} |
|
|
static int |
static int |
Line 1501 syncprov_op_response( Operation *op, Sla
|
Line 1460 syncprov_op_response( Operation *op, Sla
|
|
|
if ( rs->sr_err == LDAP_SUCCESS ) |
if ( rs->sr_err == LDAP_SUCCESS ) |
{ |
{ |
struct berval maxcsn = BER_BVNULL; |
struct berval maxcsn = BER_BVNULL, curcsn = BER_BVNULL; |
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
int do_check = 0, have_psearches; |
|
|
|
/* Update our context CSN */ |
/* Update our context CSN */ |
cbuf[0] = '\0'; |
cbuf[0] = '\0'; |
ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_lock( &si->si_csn_mutex ); |
slap_get_commit_csn( op, &maxcsn ); |
slap_get_commit_csn( op, &maxcsn, &curcsn ); |
if ( !BER_BVISNULL( &maxcsn ) ) { |
if ( !BER_BVISNULL( &maxcsn ) ) { |
strcpy( cbuf, maxcsn.bv_val ); |
strcpy( cbuf, maxcsn.bv_val ); |
if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) { |
if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) { |
Line 1520 syncprov_op_response( Operation *op, Sla
|
Line 1478 syncprov_op_response( Operation *op, Sla
|
/* Don't do any processing for consumer contextCSN updates */ |
/* Don't do any processing for consumer contextCSN updates */ |
if ( SLAP_SYNC_SHADOW( op->o_bd ) && |
if ( SLAP_SYNC_SHADOW( op->o_bd ) && |
op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) { |
op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) { |
ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex ); |
return SLAP_CB_CONTINUE; |
return SLAP_CB_CONTINUE; |
} |
} |
|
|
si->si_numops++; |
si->si_numops++; |
if ( si->si_chkops || si->si_chktime ) { |
if ( si->si_chkops || si->si_chktime ) { |
|
int do_check=0; |
if ( si->si_chkops && si->si_numops >= si->si_chkops ) { |
if ( si->si_chkops && si->si_numops >= si->si_chkops ) { |
do_check = 1; |
do_check = 1; |
si->si_numops = 0; |
si->si_numops = 0; |
Line 1535 syncprov_op_response( Operation *op, Sla
|
Line 1494 syncprov_op_response( Operation *op, Sla
|
do_check = 1; |
do_check = 1; |
si->si_chklast = op->o_time; |
si->si_chklast = op->o_time; |
} |
} |
|
if ( do_check ) { |
|
syncprov_checkpoint( op, rs, on ); |
|
} |
} |
} |
ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex ); |
|
|
if ( do_check ) { |
|
ldap_pvt_thread_rdwr_rlock( &si->si_csn_rwlock ); |
|
syncprov_checkpoint( op, rs, on ); |
|
ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock ); |
|
} |
|
|
|
opc->sctxcsn.bv_len = maxcsn.bv_len; |
opc->sctxcsn.bv_len = maxcsn.bv_len; |
opc->sctxcsn.bv_val = cbuf; |
opc->sctxcsn.bv_val = cbuf; |
|
|
/* Handle any persistent searches */ |
/* Handle any persistent searches */ |
ldap_pvt_thread_mutex_lock( &si->si_ops_mutex ); |
if ( si->si_ops ) { |
have_psearches = ( si->si_ops != NULL ); |
|
ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex ); |
|
if ( have_psearches ) { |
|
switch(op->o_tag) { |
switch(op->o_tag) { |
case LDAP_REQ_ADD: |
case LDAP_REQ_ADD: |
case LDAP_REQ_MODIFY: |
case LDAP_REQ_MODIFY: |
Line 1574 syncprov_op_response( Operation *op, Sla
|
Line 1527 syncprov_op_response( Operation *op, Sla
|
|
|
/* Add any log records */ |
/* Add any log records */ |
if ( si->si_logs && op->o_tag != LDAP_REQ_ADD ) { |
if ( si->si_logs && op->o_tag != LDAP_REQ_ADD ) { |
syncprov_add_slog( op ); |
syncprov_add_slog( op, &curcsn ); |
} |
} |
|
|
} |
} |
Line 1609 syncprov_op_compare( Operation *op, Slap
|
Line 1562 syncprov_op_compare( Operation *op, Slap
|
a.a_vals = bv; |
a.a_vals = bv; |
a.a_nvals = a.a_vals; |
a.a_nvals = a.a_vals; |
|
|
ldap_pvt_thread_rdwr_rlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_lock( &si->si_csn_mutex ); |
|
|
rs->sr_err = access_allowed( op, &e, op->oq_compare.rs_ava->aa_desc, |
rs->sr_err = access_allowed( op, &e, op->oq_compare.rs_ava->aa_desc, |
&op->oq_compare.rs_ava->aa_value, ACL_COMPARE, NULL ); |
&op->oq_compare.rs_ava->aa_value, ACL_COMPARE, NULL ); |
Line 1638 syncprov_op_compare( Operation *op, Slap
|
Line 1591 syncprov_op_compare( Operation *op, Slap
|
|
|
return_results:; |
return_results:; |
|
|
ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex ); |
|
|
send_ldap_result( op, rs ); |
send_ldap_result( op, rs ); |
|
|
Line 1656 syncprov_op_mod( Operation *op, SlapRepl
|
Line 1609 syncprov_op_mod( Operation *op, SlapRepl
|
{ |
{ |
slap_overinst *on = (slap_overinst *)op->o_bd->bd_info; |
slap_overinst *on = (slap_overinst *)op->o_bd->bd_info; |
syncprov_info_t *si = on->on_bi.bi_private; |
syncprov_info_t *si = on->on_bi.bi_private; |
slap_callback *cb; |
|
opcookie *opc; |
|
int have_psearches, cbsize; |
|
|
|
ldap_pvt_thread_mutex_lock( &si->si_ops_mutex ); |
slap_callback *cb = op->o_tmpcalloc(1, sizeof(slap_callback)+ |
have_psearches = ( si->si_ops != NULL ); |
sizeof(opcookie) + |
ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex ); |
(si->si_ops ? sizeof(modinst) : 0 ), |
|
op->o_tmpmemctx); |
cbsize = sizeof(slap_callback) + sizeof(opcookie) + |
opcookie *opc = (opcookie *)(cb+1); |
(have_psearches ? sizeof(modinst) : 0 ); |
|
|
|
cb = op->o_tmpcalloc(1, cbsize, op->o_tmpmemctx); |
|
opc = (opcookie *)(cb+1); |
|
opc->son = on; |
opc->son = on; |
cb->sc_response = syncprov_op_response; |
cb->sc_response = syncprov_op_response; |
cb->sc_cleanup = syncprov_op_cleanup; |
cb->sc_cleanup = syncprov_op_cleanup; |
Line 1679 syncprov_op_mod( Operation *op, SlapRepl
|
Line 1625 syncprov_op_mod( Operation *op, SlapRepl
|
/* If there are active persistent searches, lock this operation. |
/* If there are active persistent searches, lock this operation. |
* See seqmod.c for the locking logic on its own. |
* See seqmod.c for the locking logic on its own. |
*/ |
*/ |
if ( have_psearches ) { |
if ( si->si_ops ) { |
modtarget *mt, mtdummy; |
modtarget *mt, mtdummy; |
modinst *mi; |
modinst *mi; |
|
|
Line 1726 syncprov_op_mod( Operation *op, SlapRepl
|
Line 1672 syncprov_op_mod( Operation *op, SlapRepl
|
} |
} |
} |
} |
|
|
if (( have_psearches || si->si_logs ) && op->o_tag != LDAP_REQ_ADD ) |
if (( si->si_ops || si->si_logs ) && op->o_tag != LDAP_REQ_ADD ) |
syncprov_matchops( op, opc, 1 ); |
syncprov_matchops( op, opc, 1 ); |
|
|
return SLAP_CB_CONTINUE; |
return SLAP_CB_CONTINUE; |
Line 1816 syncprov_detach_op( Operation *op, synco
|
Line 1762 syncprov_detach_op( Operation *op, synco
|
op2->ors_filterstr.bv_val = ptr; |
op2->ors_filterstr.bv_val = ptr; |
strcpy( ptr, so->s_filterstr.bv_val ); |
strcpy( ptr, so->s_filterstr.bv_val ); |
op2->ors_filterstr.bv_len = so->s_filterstr.bv_len; |
op2->ors_filterstr.bv_len = so->s_filterstr.bv_len; |
|
op2->ors_filter = filter_dup( op->ors_filter, NULL ); |
/* Skip the AND/GE clause that we stuck on in front */ |
|
if ( so->s_flags & PS_FIX_FILTER ) { |
|
op2->ors_filter = op->ors_filter->f_and->f_next; |
|
so->s_flags ^= PS_FIX_FILTER; |
|
} else { |
|
op2->ors_filter = op->ors_filter; |
|
} |
|
op2->ors_filter = filter_dup( op2->ors_filter, NULL ); |
|
so->s_op = op2; |
so->s_op = op2; |
|
|
/* Copy any cached group ACLs individually */ |
/* Copy any cached group ACLs individually */ |
Line 1840 syncprov_detach_op( Operation *op, synco
|
Line 1778 syncprov_detach_op( Operation *op, synco
|
op2->o_do_not_cache = 1; |
op2->o_do_not_cache = 1; |
|
|
/* Add op2 to conn so abandon will find us */ |
/* Add op2 to conn so abandon will find us */ |
|
ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex ); |
op->o_conn->c_n_ops_executing++; |
op->o_conn->c_n_ops_executing++; |
op->o_conn->c_n_ops_completed--; |
op->o_conn->c_n_ops_completed--; |
LDAP_STAILQ_INSERT_TAIL( &op->o_conn->c_ops, op2, o_next ); |
LDAP_STAILQ_INSERT_TAIL( &op->o_conn->c_ops, op2, o_next ); |
so->s_flags |= PS_IS_DETACHED; |
so->s_flags |= PS_IS_DETACHED; |
|
ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex ); |
/* Prevent anyone else from trying to send a result for this op */ |
|
op->o_abandon = 1; |
|
} |
} |
|
|
static int |
static int |
Line 1854 syncprov_search_response( Operation *op,
|
Line 1791 syncprov_search_response( Operation *op,
|
{ |
{ |
searchstate *ss = op->o_callback->sc_private; |
searchstate *ss = op->o_callback->sc_private; |
slap_overinst *on = ss->ss_on; |
slap_overinst *on = ss->ss_on; |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
|
sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync]; |
sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync]; |
|
|
if ( rs->sr_type == REP_SEARCH || rs->sr_type == REP_SEARCHREF ) { |
if ( rs->sr_type == REP_SEARCH || rs->sr_type == REP_SEARCHREF ) { |
Line 1874 syncprov_search_response( Operation *op,
|
Line 1810 syncprov_search_response( Operation *op,
|
a = attr_find( rs->sr_operational_attrs, slap_schema.si_ad_entryCSN ); |
a = attr_find( rs->sr_operational_attrs, slap_schema.si_ad_entryCSN ); |
} |
} |
if ( a ) { |
if ( a ) { |
/* If not a persistent search */ |
|
/* Make sure entry is less than the snapshot'd contextCSN */ |
/* Make sure entry is less than the snapshot'd contextCSN */ |
if ( !ss->ss_so && ber_bvcmp( &a->a_nvals[0], &ss->ss_ctxcsn ) > 0 ) { |
if ( ber_bvcmp( &a->a_nvals[0], &ss->ss_ctxcsn ) > 0 ) |
Debug( LDAP_DEBUG_SYNC, "Entry %s CSN %s greater than snapshot %s\n", |
|
rs->sr_entry->e_name.bv_val, |
|
a->a_nvals[0].bv_val, |
|
ss->ss_ctxcsn.bv_val ); |
|
return LDAP_SUCCESS; |
return LDAP_SUCCESS; |
} |
|
|
|
/* Don't send the ctx entry twice */ |
/* Don't send the ctx entry twice */ |
if ( !BER_BVISNULL( &srs->sr_state.ctxcsn ) && |
if ( !BER_BVISNULL( &srs->sr_state.ctxcsn ) && |
bvmatch( &a->a_nvals[0], &srs->sr_state.ctxcsn ) ) { |
bvmatch( &a->a_nvals[0], &srs->sr_state.ctxcsn ) ) |
Debug( LDAP_DEBUG_SYNC, "Entry %s CSN %s matches ctx %s\n", |
|
rs->sr_entry->e_name.bv_val, |
|
a->a_nvals[0].bv_val, |
|
srs->sr_state.ctxcsn.bv_val ); |
|
return LDAP_SUCCESS; |
return LDAP_SUCCESS; |
} |
|
} |
} |
rs->sr_ctrls = op->o_tmpalloc( sizeof(LDAPControl *)*2, |
rs->sr_ctrls = op->o_tmpalloc( sizeof(LDAPControl *)*2, |
op->o_tmpmemctx ); |
op->o_tmpmemctx ); |
rs->sr_ctrls[1] = NULL; |
rs->sr_ctrls[1] = NULL; |
/* If we're in delta-sync mode, always send a cookie */ |
rs->sr_err = syncprov_state_ctrl( op, rs, rs->sr_entry, |
if ( si->si_nopres && si->si_usehint && a ) { |
LDAP_SYNC_ADD, rs->sr_ctrls, 0, 0, NULL ); |
struct berval cookie; |
|
slap_compose_sync_cookie( op, &cookie, a->a_nvals, srs->sr_state.rid ); |
|
rs->sr_err = syncprov_state_ctrl( op, rs, rs->sr_entry, |
|
LDAP_SYNC_ADD, rs->sr_ctrls, 0, 1, &cookie ); |
|
} else { |
|
rs->sr_err = syncprov_state_ctrl( op, rs, rs->sr_entry, |
|
LDAP_SYNC_ADD, rs->sr_ctrls, 0, 0, NULL ); |
|
} |
|
} else if ( rs->sr_type == REP_RESULT && rs->sr_err == LDAP_SUCCESS ) { |
} else if ( rs->sr_type == REP_RESULT && rs->sr_err == LDAP_SUCCESS ) { |
struct berval cookie; |
struct berval cookie; |
|
|
Line 1924 syncprov_search_response( Operation *op,
|
Line 1841 syncprov_search_response( Operation *op,
|
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
} else { |
} else { |
/* It's RefreshAndPersist, transition to Persist phase */ |
/* It's RefreshAndPersist, transition to Persist phase */ |
syncprov_sendinfo( op, rs, ss->ss_present ? |
syncprov_sendinfo( op, rs, ( ss->ss_present && rs->sr_nentries ) ? |
LDAP_TAG_SYNC_REFRESH_PRESENT : LDAP_TAG_SYNC_REFRESH_DELETE, |
LDAP_TAG_SYNC_REFRESH_PRESENT : LDAP_TAG_SYNC_REFRESH_DELETE, |
&cookie, 1, NULL, 0 ); |
&cookie, 1, NULL, 0 ); |
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
|
|
/* Detach this Op from frontend control */ |
/* Detach this Op from frontend control */ |
ldap_pvt_thread_mutex_lock( &ss->ss_so->s_mutex ); |
ldap_pvt_thread_mutex_lock( &ss->ss_so->s_mutex ); |
ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex ); |
|
|
|
/* But not if this connection was closed along the way */ |
|
if ( op->o_abandon ) { |
|
ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex ); |
|
ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex ); |
|
/* syncprov_ab_cleanup will free this syncop */ |
|
return SLAPD_ABANDON; |
|
|
|
} else { |
|
/* Turn off the refreshing flag */ |
|
ss->ss_so->s_flags ^= PS_IS_REFRESHING; |
|
|
|
syncprov_detach_op( op, ss->ss_so, on ); |
|
|
|
ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex ); |
/* Turn off the refreshing flag */ |
|
ss->ss_so->s_flags ^= PS_IS_REFRESHING; |
|
|
/* If there are queued responses, fire them off */ |
syncprov_detach_op( op, ss->ss_so, on ); |
if ( ss->ss_so->s_res ) |
|
syncprov_qstart( ss->ss_so ); |
|
} |
|
ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex ); |
ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex ); |
|
|
return LDAP_SUCCESS; |
return LDAP_SUCCESS; |
Line 2001 syncprov_op_search( Operation *op, SlapR
|
Line 1902 syncprov_op_search( Operation *op, SlapR
|
/* syncprov_findbase expects to be called as a callback... */ |
/* syncprov_findbase expects to be called as a callback... */ |
sc.sc_private = &opc; |
sc.sc_private = &opc; |
opc.son = on; |
opc.son = on; |
ldap_pvt_thread_mutex_init( &so.s_mutex ); |
|
cb = op->o_callback; |
cb = op->o_callback; |
op->o_callback = ≻ |
op->o_callback = ≻ |
rs->sr_err = syncprov_findbase( op, &fc ); |
rs->sr_err = syncprov_findbase( op, &fc ); |
op->o_callback = cb; |
op->o_callback = cb; |
ldap_pvt_thread_mutex_destroy( &so.s_mutex ); |
|
|
|
if ( rs->sr_err != LDAP_SUCCESS ) { |
if ( rs->sr_err != LDAP_SUCCESS ) { |
send_ldap_result( op, rs ); |
send_ldap_result( op, rs ); |
Line 2025 syncprov_op_search( Operation *op, SlapR
|
Line 1924 syncprov_op_search( Operation *op, SlapR
|
} |
} |
|
|
/* snapshot the ctxcsn */ |
/* snapshot the ctxcsn */ |
ldap_pvt_thread_rdwr_rlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_lock( &si->si_csn_mutex ); |
strcpy( csnbuf, si->si_ctxcsnbuf ); |
strcpy( csnbuf, si->si_ctxcsnbuf ); |
ctxcsn.bv_len = si->si_ctxcsn.bv_len; |
ctxcsn.bv_len = si->si_ctxcsn.bv_len; |
ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex ); |
ctxcsn.bv_val = csnbuf; |
ctxcsn.bv_val = csnbuf; |
|
|
/* If we have a cookie, handle the PRESENT lookups */ |
/* If we have a cookie, handle the PRESENT lookups */ |
Line 2059 syncprov_op_search( Operation *op, SlapR
|
Line 1958 syncprov_op_search( Operation *op, SlapR
|
sl=si->si_logs; |
sl=si->si_logs; |
if ( sl ) { |
if ( sl ) { |
ldap_pvt_thread_mutex_lock( &sl->sl_mutex ); |
ldap_pvt_thread_mutex_lock( &sl->sl_mutex ); |
/* Are there any log entries, and is the consumer state |
if ( ber_bvcmp( &srs->sr_state.ctxcsn, &sl->sl_mincsn ) >= 0 ) { |
* present in the session log? |
|
*/ |
|
if ( sl->sl_num > 0 && ber_bvcmp( &srs->sr_state.ctxcsn, &sl->sl_mincsn ) >= 0 ) { |
|
do_present = 0; |
do_present = 0; |
/* mutex is unlocked in playlog */ |
/* mutex is unlocked in playlog */ |
syncprov_playlog( op, rs, sl, srs, &ctxcsn ); |
syncprov_playlog( op, rs, sl, &srs->sr_state.ctxcsn, &ctxcsn ); |
} else { |
} else { |
ldap_pvt_thread_mutex_unlock( &sl->sl_mutex ); |
ldap_pvt_thread_mutex_unlock( &sl->sl_mutex ); |
} |
} |
Line 2116 shortcut:
|
Line 2012 shortcut:
|
fava->f_next = op->ors_filter; |
fava->f_next = op->ors_filter; |
op->ors_filter = fand; |
op->ors_filter = fand; |
filter2bv_x( op, op->ors_filter, &op->ors_filterstr ); |
filter2bv_x( op, op->ors_filter, &op->ors_filterstr ); |
if ( sop ) |
|
sop->s_flags |= PS_FIX_FILTER; |
|
} |
} |
|
|
/* Let our callback add needed info to returned entries */ |
/* Let our callback add needed info to returned entries */ |
Line 2185 syncprov_operational(
|
Line 2079 syncprov_operational(
|
*ap = a; |
*ap = a; |
} |
} |
|
|
ldap_pvt_thread_rdwr_rlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_lock( &si->si_csn_mutex ); |
if ( !ap ) { |
if ( !ap ) { |
strcpy( a->a_vals[0].bv_val, si->si_ctxcsnbuf ); |
strcpy( a->a_vals[0].bv_val, si->si_ctxcsnbuf ); |
} else { |
} else { |
ber_dupbv( &a->a_vals[0], &si->si_ctxcsn ); |
ber_dupbv( &a->a_vals[0], &si->si_ctxcsn ); |
} |
} |
ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex ); |
} |
} |
} |
} |
return SLAP_CB_CONTINUE; |
return SLAP_CB_CONTINUE; |
Line 2309 sp_cf_gen(ConfigArgs *c)
|
Line 2203 sp_cf_gen(ConfigArgs *c)
|
switch ( c->type ) { |
switch ( c->type ) { |
case SP_CHKPT: |
case SP_CHKPT: |
if ( lutil_atoi( &si->si_chkops, c->argv[1] ) != 0 ) { |
if ( lutil_atoi( &si->si_chkops, c->argv[1] ) != 0 ) { |
snprintf( c->msg, sizeof( c->msg ), "%s unable to parse checkpoint ops # \"%s\"", |
sprintf( c->msg, "%s unable to parse checkpoint ops # \"%s\"", |
c->argv[0], c->argv[1] ); |
c->argv[0], c->argv[1] ); |
Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE, |
Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 ); |
"%s: %s\n", c->log, c->msg, 0 ); |
|
return ARG_BAD_CONF; |
return ARG_BAD_CONF; |
} |
} |
if ( si->si_chkops <= 0 ) { |
if ( si->si_chkops <= 0 ) { |
snprintf( c->msg, sizeof( c->msg ), "%s invalid checkpoint ops # \"%d\"", |
sprintf( c->msg, "%s invalid checkpoint ops # \"%d\"", |
c->argv[0], si->si_chkops ); |
c->argv[0], si->si_chkops ); |
Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE, |
Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 ); |
"%s: %s\n", c->log, c->msg, 0 ); |
|
return ARG_BAD_CONF; |
return ARG_BAD_CONF; |
} |
} |
if ( lutil_atoi( &si->si_chktime, c->argv[2] ) != 0 ) { |
if ( lutil_atoi( &si->si_chktime, c->argv[2] ) != 0 ) { |
snprintf( c->msg, sizeof( c->msg ), "%s unable to parse checkpoint time \"%s\"", |
sprintf( c->msg, "%s unable to parse checkpoint time \"%s\"", |
c->argv[0], c->argv[1] ); |
c->argv[0], c->argv[1] ); |
Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE, |
Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 ); |
"%s: %s\n", c->log, c->msg, 0 ); |
|
return ARG_BAD_CONF; |
return ARG_BAD_CONF; |
} |
} |
if ( si->si_chktime <= 0 ) { |
if ( si->si_chktime <= 0 ) { |
snprintf( c->msg, sizeof( c->msg ), "%s invalid checkpoint time \"%d\"", |
sprintf( c->msg, "%s invalid checkpoint time \"%d\"", |
c->argv[0], si->si_chkops ); |
c->argv[0], si->si_chkops ); |
Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE, |
Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 ); |
"%s: %s\n", c->log, c->msg, 0 ); |
|
return ARG_BAD_CONF; |
return ARG_BAD_CONF; |
} |
} |
si->si_chktime *= 60; |
si->si_chktime *= 60; |
Line 2343 sp_cf_gen(ConfigArgs *c)
|
Line 2233 sp_cf_gen(ConfigArgs *c)
|
int size = c->value_int; |
int size = c->value_int; |
|
|
if ( size < 0 ) { |
if ( size < 0 ) { |
snprintf( c->msg, sizeof( c->msg ), "%s size %d is negative", |
sprintf( c->msg, "%s size %d is negative", |
c->argv[0], size ); |
c->argv[0], size ); |
Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE, |
Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 ); |
"%s: %s\n", c->log, c->msg, 0 ); |
|
return ARG_BAD_CONF; |
return ARG_BAD_CONF; |
} |
} |
sl = si->si_logs; |
sl = si->si_logs; |
Line 2400 syncprov_db_open(
|
Line 2289 syncprov_db_open(
|
OperationBuffer opbuf = { 0 }; |
OperationBuffer opbuf = { 0 }; |
char ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
char ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
Operation *op = (Operation *) &opbuf; |
Operation *op = (Operation *) &opbuf; |
Entry *e = NULL; |
Entry *e; |
Attribute *a; |
Attribute *a; |
int rc; |
int rc; |
void *thrctx = NULL; |
void *thrctx = NULL; |
|
|
if ( !SLAP_LASTMOD( be )) { |
|
Debug( LDAP_DEBUG_ANY, |
|
"syncprov_db_open: invalid config, lastmod must be enabled\n", 0, 0, 0 ); |
|
return -1; |
|
} |
|
|
|
if ( slapMode & SLAP_TOOL_MODE ) { |
if ( slapMode & SLAP_TOOL_MODE ) { |
return 0; |
return 0; |
} |
} |
Line 2428 syncprov_db_open(
|
Line 2311 syncprov_db_open(
|
|
|
ctxcsnbuf[0] = '\0'; |
ctxcsnbuf[0] = '\0'; |
|
|
rc = overlay_entry_get_ov( op, be->be_nsuffix, NULL, |
op->o_bd->bd_info = on->on_info->oi_orig; |
slap_schema.si_ad_contextCSN, 0, &e, on ); |
rc = be_entry_get_rw( op, be->be_nsuffix, NULL, |
|
slap_schema.si_ad_contextCSN, 0, &e ); |
|
|
if ( e ) { |
if ( e ) { |
ldap_pvt_thread_t tid; |
ldap_pvt_thread_t tid; |
Line 2444 syncprov_db_open(
|
Line 2328 syncprov_db_open(
|
si->si_ctxcsnbuf[si->si_ctxcsn.bv_len] = '\0'; |
si->si_ctxcsnbuf[si->si_ctxcsn.bv_len] = '\0'; |
strcpy( ctxcsnbuf, si->si_ctxcsnbuf ); |
strcpy( ctxcsnbuf, si->si_ctxcsnbuf ); |
} |
} |
overlay_entry_release_ov( op, e, 0, on ); |
be_entry_release_rw( op, e, 0 ); |
if ( !BER_BVISEMPTY( &si->si_ctxcsn ) ) { |
if ( !BER_BVISEMPTY( &si->si_ctxcsn ) ) { |
|
op->o_bd->bd_info = (BackendInfo *)on; |
op->o_req_dn = be->be_suffix[0]; |
op->o_req_dn = be->be_suffix[0]; |
op->o_req_ndn = be->be_nsuffix[0]; |
op->o_req_ndn = be->be_nsuffix[0]; |
op->ors_scope = LDAP_SCOPE_SUBTREE; |
op->ors_scope = LDAP_SCOPE_SUBTREE; |
ldap_pvt_thread_create( &tid, 0, syncprov_db_otask, op ); |
ldap_pvt_thread_create( &tid, 0, syncprov_db_otask, op ); |
ldap_pvt_thread_join( tid, NULL ); |
ldap_pvt_thread_join( tid, NULL ); |
} |
} |
} |
} else if ( SLAP_SYNC_SHADOW( op->o_bd )) { |
|
/* If we're also a consumer, and we didn't find the context entry, |
if ( BER_BVISEMPTY( &si->si_ctxcsn ) ) { |
|
if ( SLAP_SYNC_SHADOW( op->o_bd )) { |
|
/* If we're also a consumer, and we didn't get a contextCSN, |
|
* then don't generate anything, wait for our provider to send it |
* then don't generate anything, wait for our provider to send it |
* to us. |
* to us. |
*/ |
*/ |
goto out; |
goto out; |
} |
} |
|
|
|
if ( BER_BVISEMPTY( &si->si_ctxcsn ) ) { |
si->si_ctxcsn.bv_len = sizeof( si->si_ctxcsnbuf ); |
si->si_ctxcsn.bv_len = sizeof( si->si_ctxcsnbuf ); |
slap_get_csn( op, &si->si_ctxcsn, 0 ); |
slap_get_csn( op, &si->si_ctxcsn, 0 ); |
} |
} |
Line 2475 syncprov_db_open(
|
Line 2359 syncprov_db_open(
|
|
|
out: |
out: |
op->o_bd->bd_info = (BackendInfo *)on; |
op->o_bd->bd_info = (BackendInfo *)on; |
|
ldap_pvt_thread_pool_context_reset( thrctx ); |
return 0; |
return 0; |
} |
} |
|
|
Line 2492 syncprov_db_close(
|
Line 2377 syncprov_db_close(
|
return 0; |
return 0; |
} |
} |
if ( si->si_numops ) { |
if ( si->si_numops ) { |
Connection conn = {0}; |
Connection conn; |
OperationBuffer opbuf; |
OperationBuffer opbuf; |
Operation *op = (Operation *) &opbuf; |
Operation *op = (Operation *) &opbuf; |
SlapReply rs = {REP_RESULT}; |
SlapReply rs = {REP_RESULT}; |
Line 2504 syncprov_db_close(
|
Line 2389 syncprov_db_close(
|
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, &rs, on ); |
|
ldap_pvt_thread_pool_context_reset( thrctx ); |
} |
} |
|
|
return 0; |
return 0; |
Line 2517 syncprov_db_init(
|
Line 2403 syncprov_db_init(
|
slap_overinst *on = (slap_overinst *)be->bd_info; |
slap_overinst *on = (slap_overinst *)be->bd_info; |
syncprov_info_t *si; |
syncprov_info_t *si; |
|
|
if ( SLAP_ISGLOBALOVERLAY( be ) ) { |
|
Debug( LDAP_DEBUG_ANY, |
|
"syncprov must be instantiated within a database.\n", |
|
0, 0, 0 ); |
|
return 1; |
|
} |
|
|
|
si = ch_calloc(1, sizeof(syncprov_info_t)); |
si = ch_calloc(1, sizeof(syncprov_info_t)); |
on->on_bi.bi_private = si; |
on->on_bi.bi_private = si; |
ldap_pvt_thread_rdwr_init( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_init( &si->si_csn_mutex ); |
ldap_pvt_thread_mutex_init( &si->si_ops_mutex ); |
ldap_pvt_thread_mutex_init( &si->si_ops_mutex ); |
ldap_pvt_thread_mutex_init( &si->si_mods_mutex ); |
ldap_pvt_thread_mutex_init( &si->si_mods_mutex ); |
si->si_ctxcsn.bv_val = si->si_ctxcsnbuf; |
si->si_ctxcsn.bv_val = si->si_ctxcsnbuf; |
Line 2564 syncprov_db_destroy(
|
Line 2443 syncprov_db_destroy(
|
} |
} |
ldap_pvt_thread_mutex_destroy( &si->si_mods_mutex ); |
ldap_pvt_thread_mutex_destroy( &si->si_mods_mutex ); |
ldap_pvt_thread_mutex_destroy( &si->si_ops_mutex ); |
ldap_pvt_thread_mutex_destroy( &si->si_ops_mutex ); |
ldap_pvt_thread_rdwr_destroy( &si->si_csn_rwlock ); |
ldap_pvt_thread_mutex_destroy( &si->si_csn_mutex ); |
ch_free( si ); |
ch_free( si ); |
} |
} |
|
|
Line 2654 static int syncprov_parseCtrl (
|
Line 2533 static int syncprov_parseCtrl (
|
sr->sr_rhint = rhint; |
sr->sr_rhint = rhint; |
if (!BER_BVISNULL(&cookie)) { |
if (!BER_BVISNULL(&cookie)) { |
ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx ); |
ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx ); |
if ( slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx ) || |
slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx ); |
sr->sr_state.rid == -1 ) { |
if ( sr->sr_state.rid == -1 ) { |
rs->sr_text = "Sync control : cookie parsing error"; |
rs->sr_text = "Sync control : cookie parsing error"; |
return LDAP_PROTOCOL_ERROR; |
return LDAP_PROTOCOL_ERROR; |
} |
} |