version 1.89, 2005/07/14 17:32:21
|
version 1.115, 2005/10/06 16:45:53
|
Line 1
|
Line 1
|
/* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.88 2005/07/10 08:20:21 hallvard Exp $ */ |
/* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.114 2005/10/04 00:29:25 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/>. |
* |
* |
Line 26
|
Line 26
|
#include "lutil.h" |
#include "lutil.h" |
#include "slap.h" |
#include "slap.h" |
#include "config.h" |
#include "config.h" |
|
#include "ldap_rq.h" |
|
|
/* A modify request on a particular entry */ |
/* A modify request on a particular entry */ |
typedef struct modinst { |
typedef struct modinst { |
Line 60 typedef struct syncops {
|
Line 61 typedef struct syncops {
|
int s_rid; |
int s_rid; |
struct berval s_filterstr; |
struct berval s_filterstr; |
int s_flags; /* search status */ |
int s_flags; /* search status */ |
|
#define PS_IS_REFRESHING 0x01 |
|
#define PS_IS_DETACHED 0x02 |
|
#define PS_WROTE_BASE 0x04 |
|
#define PS_FIND_BASE 0x08 |
|
|
int s_inuse; /* reference count */ |
int s_inuse; /* reference count */ |
struct syncres *s_res; |
struct syncres *s_res; |
struct syncres *s_restail; |
struct syncres *s_restail; |
|
struct re_s *s_qtask; /* task for playing psearch responses */ |
|
#define RUNQ_INTERVAL 36000 /* a long time */ |
ldap_pvt_thread_mutex_t s_mutex; |
ldap_pvt_thread_mutex_t s_mutex; |
} syncops; |
} syncops; |
|
|
Line 83 typedef struct sync_control {
|
Line 91 typedef struct sync_control {
|
#define SLAP_SYNC_PERSIST (LDAP_SYNC_RESERVED<<SLAP_CONTROL_SHIFT) |
#define SLAP_SYNC_PERSIST (LDAP_SYNC_RESERVED<<SLAP_CONTROL_SHIFT) |
#define SLAP_SYNC_REFRESH_AND_PERSIST (LDAP_SYNC_REFRESH_AND_PERSIST<<SLAP_CONTROL_SHIFT) |
#define SLAP_SYNC_REFRESH_AND_PERSIST (LDAP_SYNC_REFRESH_AND_PERSIST<<SLAP_CONTROL_SHIFT) |
|
|
#define PS_IS_REFRESHING 0x01 |
|
#define PS_IS_DETACHED 0x02 |
|
|
|
/* Record of which searches matched at premodify step */ |
/* Record of which searches matched at premodify step */ |
typedef struct syncmatches { |
typedef struct syncmatches { |
struct syncmatches *sm_next; |
struct syncmatches *sm_next; |
Line 116 typedef struct syncprov_info_t {
|
Line 121 typedef struct syncprov_info_t {
|
int si_chkops; /* checkpointing info */ |
int si_chkops; /* checkpointing info */ |
int si_chktime; |
int si_chktime; |
int si_numops; /* number of ops since last checkpoint */ |
int si_numops; /* number of ops since last checkpoint */ |
|
int si_nopres; /* Skip present phase */ |
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; |
Line 142 typedef struct fbase_cookie {
|
Line 148 typedef struct fbase_cookie {
|
int fscope; /* if TRUE then fdn is within the psearch scope */ |
int fscope; /* if TRUE then fdn is within the psearch scope */ |
} fbase_cookie; |
} fbase_cookie; |
|
|
static AttributeName csn_anlist[2]; |
static AttributeName csn_anlist[3]; |
static AttributeName uuid_anlist[2]; |
static AttributeName uuid_anlist[2]; |
|
|
/* Build a LDAPsync intermediate state control */ |
/* Build a LDAPsync intermediate state control */ |
Line 178 syncprov_state_ctrl(
|
Line 184 syncprov_state_ctrl(
|
} |
} |
} |
} |
|
|
|
/* FIXME: what if entryuuid is NULL or empty ? */ |
|
|
if ( send_cookie && cookie ) { |
if ( send_cookie && cookie ) { |
ber_printf( ber, "{eOON}", |
ber_printf( ber, "{eOON}", |
entry_sync_state, &entryuuid_bv, cookie ); |
entry_sync_state, &entryuuid_bv, cookie ); |
Line 357 findbase_cb( Operation *op, SlapReply *r
|
Line 365 findbase_cb( Operation *op, SlapReply *r
|
* Just store whatever we got. |
* Just store whatever we got. |
*/ |
*/ |
if ( fc->fss->s_eid == NOID ) { |
if ( fc->fss->s_eid == NOID ) { |
fc->fbase = 1; |
fc->fbase = 2; |
fc->fss->s_eid = rs->sr_entry->e_id; |
fc->fss->s_eid = rs->sr_entry->e_id; |
ber_dupbv( &fc->fss->s_base, &rs->sr_entry->e_nname ); |
ber_dupbv( &fc->fss->s_base, &rs->sr_entry->e_nname ); |
|
|
} else if ( rs->sr_entry->e_id == fc->fss->s_eid && |
} else if ( rs->sr_entry->e_id == fc->fss->s_eid && |
dn_match( &rs->sr_entry->e_nname, &fc->fss->s_base )) { |
dn_match( &rs->sr_entry->e_nname, &fc->fss->s_base )) { |
|
|
/* OK, the DN is the same and the entryID is the same. Now |
/* OK, the DN is the same and the entryID is the same. */ |
* see if the fdn resides in the scope. |
|
*/ |
|
fc->fbase = 1; |
fc->fbase = 1; |
switch ( fc->fss->s_op->ors_scope ) { |
|
case LDAP_SCOPE_BASE: |
|
fc->fscope = dn_match( fc->fdn, &rs->sr_entry->e_nname ); |
|
break; |
|
case LDAP_SCOPE_ONELEVEL: { |
|
struct berval pdn; |
|
dnParent( fc->fdn, &pdn ); |
|
fc->fscope = dn_match( &pdn, &rs->sr_entry->e_nname ); |
|
break; } |
|
case LDAP_SCOPE_SUBTREE: |
|
fc->fscope = dnIsSuffix( fc->fdn, &rs->sr_entry->e_nname ); |
|
break; |
|
#ifdef LDAP_SCOPE_SUBORDINATE |
|
case LDAP_SCOPE_SUBORDINATE: |
|
fc->fscope = dnIsSuffix( fc->fdn, &rs->sr_entry->e_nname ) && |
|
!dn_match( fc->fdn, &rs->sr_entry->e_nname ); |
|
break; |
|
#endif |
|
} |
|
} |
} |
} |
} |
if ( rs->sr_err != LDAP_SUCCESS ) { |
if ( rs->sr_err != LDAP_SUCCESS ) { |
Line 401 syncprov_findbase( Operation *op, fbase_
|
Line 388 syncprov_findbase( Operation *op, fbase_
|
opcookie *opc = op->o_callback->sc_private; |
opcookie *opc = op->o_callback->sc_private; |
slap_overinst *on = opc->son; |
slap_overinst *on = opc->son; |
|
|
slap_callback cb = {0}; |
/* Use basic parameters from syncrepl search, but use |
Operation fop; |
* current op's threadctx / tmpmemctx |
SlapReply frs = { REP_RESULT }; |
*/ |
int rc; |
ldap_pvt_thread_mutex_lock( &fc->fss->s_mutex ); |
|
if ( fc->fss->s_flags & PS_FIND_BASE ) { |
|
slap_callback cb = {0}; |
|
Operation fop; |
|
SlapReply frs = { REP_RESULT }; |
|
int rc; |
|
|
fop = *op; |
fc->fss->s_flags ^= PS_FIND_BASE; |
|
ldap_pvt_thread_mutex_unlock( &fc->fss->s_mutex ); |
|
|
cb.sc_response = findbase_cb; |
fop = *fc->fss->s_op; |
cb.sc_private = fc; |
|
|
|
fop.o_sync_mode &= SLAP_CONTROL_MASK; /* turn off sync mode */ |
fop.o_hdr = op->o_hdr; |
fop.o_managedsait = SLAP_CONTROL_CRITICAL; |
fop.o_bd = op->o_bd; |
fop.o_callback = &cb; |
fop.o_time = op->o_time; |
fop.o_tag = LDAP_REQ_SEARCH; |
fop.o_tincr = op->o_tincr; |
fop.ors_scope = LDAP_SCOPE_BASE; |
|
fop.ors_deref = fc->fss->s_op->ors_deref; |
|
fop.ors_limit = NULL; |
|
fop.ors_slimit = 1; |
|
fop.ors_tlimit = SLAP_NO_LIMIT; |
|
fop.ors_attrs = slap_anlist_no_attrs; |
|
fop.ors_attrsonly = 1; |
|
fop.ors_filter = fc->fss->s_op->ors_filter; |
|
fop.ors_filterstr = fc->fss->s_op->ors_filterstr; |
|
|
|
fop.o_req_ndn = fc->fss->s_op->o_req_ndn; |
cb.sc_response = findbase_cb; |
|
cb.sc_private = fc; |
|
|
fop.o_bd->bd_info = on->on_info->oi_orig; |
fop.o_sync_mode = 0; /* turn off sync mode */ |
rc = fop.o_bd->be_search( &fop, &frs ); |
fop.o_managedsait = SLAP_CONTROL_CRITICAL; |
fop.o_bd->bd_info = (BackendInfo *)on; |
fop.o_callback = &cb; |
|
fop.o_tag = LDAP_REQ_SEARCH; |
|
fop.ors_scope = LDAP_SCOPE_BASE; |
|
fop.ors_limit = NULL; |
|
fop.ors_slimit = 1; |
|
fop.ors_tlimit = SLAP_NO_LIMIT; |
|
fop.ors_attrs = slap_anlist_no_attrs; |
|
fop.ors_attrsonly = 1; |
|
|
if ( fc->fbase ) return LDAP_SUCCESS; |
fop.o_bd->bd_info = on->on_info->oi_orig; |
|
rc = fop.o_bd->be_search( &fop, &frs ); |
|
fop.o_bd->bd_info = (BackendInfo *)on; |
|
} else { |
|
ldap_pvt_thread_mutex_unlock( &fc->fss->s_mutex ); |
|
fc->fbase = 1; |
|
} |
|
|
|
/* After the first call, see if the fdn resides in the scope */ |
|
if ( fc->fbase == 1 ) { |
|
switch ( fc->fss->s_op->ors_scope ) { |
|
case LDAP_SCOPE_BASE: |
|
fc->fscope = dn_match( fc->fdn, &fc->fss->s_base ); |
|
break; |
|
case LDAP_SCOPE_ONELEVEL: { |
|
struct berval pdn; |
|
dnParent( fc->fdn, &pdn ); |
|
fc->fscope = dn_match( &pdn, &fc->fss->s_base ); |
|
break; } |
|
case LDAP_SCOPE_SUBTREE: |
|
fc->fscope = dnIsSuffix( fc->fdn, &fc->fss->s_base ); |
|
break; |
|
#ifdef LDAP_SCOPE_SUBORDINATE |
|
case LDAP_SCOPE_SUBORDINATE: |
|
fc->fscope = dnIsSuffix( fc->fdn, &fc->fss->s_base ) && |
|
!dn_match( fc->fdn, &fc->fss->s_base ); |
|
break; |
|
#endif |
|
} |
|
} |
|
|
|
if ( fc->fbase ) |
|
return LDAP_SUCCESS; |
|
|
/* If entryID has changed, then the base of this search has |
/* If entryID has changed, then the base of this search has |
* changed. Invalidate the psearch. |
* changed. Invalidate the psearch. |
Line 447 syncprov_findbase( Operation *op, fbase_
|
Line 470 syncprov_findbase( Operation *op, fbase_
|
* was not checkpointed at the previous shutdown. |
* was not checkpointed at the previous shutdown. |
* |
* |
* 2: when the current contextCSN is known and we have a sync cookie, we search |
* 2: when the current contextCSN is known and we have a sync cookie, we search |
* for one entry with CSN <= the cookie CSN. (Used to search for =.) If an |
* for one entry with CSN = the cookie CSN. If not found, try <= cookie CSN. |
* entry is found, the cookie CSN is valid, otherwise it is stale. |
* If an entry is found, the cookie CSN is valid, otherwise it is stale. |
* |
* |
* 3: during a refresh phase, we search for all entries with CSN <= the cookie |
* 3: during a refresh phase, we search for all entries with CSN <= the cookie |
* CSN, and generate Present records for them. We always collect this result |
* CSN, and generate Present records for them. We always collect this result |
Line 555 syncprov_findcsn( Operation *op, int mod
|
Line 578 syncprov_findcsn( Operation *op, int mod
|
int i, rc = LDAP_SUCCESS; |
int i, rc = LDAP_SUCCESS; |
fpres_cookie pcookie; |
fpres_cookie pcookie; |
sync_control *srs = NULL; |
sync_control *srs = NULL; |
|
int findcsn_retry = 1; |
|
|
if ( mode != FIND_MAXCSN ) { |
if ( mode != FIND_MAXCSN ) { |
srs = op->o_controls[slap_cids.sc_LDAPsync]; |
srs = op->o_controls[slap_cids.sc_LDAPsync]; |
Line 579 syncprov_findcsn( Operation *op, int mod
|
Line 603 syncprov_findcsn( Operation *op, int mod
|
fop.ors_filter = &cf; |
fop.ors_filter = &cf; |
fop.ors_filterstr.bv_val = buf; |
fop.ors_filterstr.bv_val = buf; |
|
|
|
again: |
switch( mode ) { |
switch( mode ) { |
case FIND_MAXCSN: |
case FIND_MAXCSN: |
cf.f_choice = LDAP_FILTER_GE; |
cf.f_choice = LDAP_FILTER_GE; |
Line 595 syncprov_findcsn( Operation *op, int mod
|
Line 620 syncprov_findcsn( Operation *op, int mod
|
maxcsn.bv_len = si->si_ctxcsn.bv_len; |
maxcsn.bv_len = si->si_ctxcsn.bv_len; |
break; |
break; |
case FIND_CSN: |
case FIND_CSN: |
cf.f_choice = LDAP_FILTER_LE; |
|
cf.f_av_value = srs->sr_state.ctxcsn; |
cf.f_av_value = srs->sr_state.ctxcsn; |
fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)", |
/* Look for exact match the first time */ |
cf.f_av_value.bv_val ); |
if ( findcsn_retry ) { |
|
cf.f_choice = LDAP_FILTER_EQUALITY; |
|
fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN=%s)", |
|
cf.f_av_value.bv_val ); |
|
/* On retry, look for <= */ |
|
} else { |
|
cf.f_choice = LDAP_FILTER_LE; |
|
fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)", |
|
cf.f_av_value.bv_val ); |
|
} |
fop.ors_attrsonly = 1; |
fop.ors_attrsonly = 1; |
fop.ors_attrs = slap_anlist_no_attrs; |
fop.ors_attrs = slap_anlist_no_attrs; |
fop.ors_slimit = 1; |
fop.ors_slimit = 1; |
Line 646 syncprov_findcsn( Operation *op, int mod
|
Line 679 syncprov_findcsn( Operation *op, int mod
|
break; |
break; |
case FIND_CSN: |
case FIND_CSN: |
/* If matching CSN was not found, invalidate the context. */ |
/* If matching CSN was not found, invalidate the context. */ |
if ( !cb.sc_private ) rc = LDAP_NO_SUCH_OBJECT; |
if ( !cb.sc_private ) { |
|
/* If we didn't find an exact match, then try for <= */ |
|
if ( findcsn_retry ) { |
|
findcsn_retry = 0; |
|
goto again; |
|
} |
|
rc = LDAP_NO_SUCH_OBJECT; |
|
} |
break; |
break; |
case FIND_PRESENT: |
case FIND_PRESENT: |
op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx ); |
op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx ); |
Line 657 syncprov_findcsn( Operation *op, int mod
|
Line 697 syncprov_findcsn( Operation *op, int mod
|
return rc; |
return rc; |
} |
} |
|
|
/* Queue a persistent search response */ |
static void |
static int |
syncprov_free_syncop( syncops *so ) |
syncprov_qresp( opcookie *opc, syncops *so, int mode ) |
|
{ |
{ |
syncres *sr; |
syncres *sr, *srnext; |
|
GroupAssertion *ga, *gnext; |
sr = ch_malloc(sizeof(syncres) + opc->suuid.bv_len + 1 + |
|
opc->sdn.bv_len + 1 + opc->sndn.bv_len + 1 + opc->sctxcsn.bv_len + 1 ); |
|
sr->s_next = NULL; |
|
sr->s_dn.bv_val = (char *)(sr + 1); |
|
sr->s_dn.bv_len = opc->sdn.bv_len; |
|
sr->s_mode = mode; |
|
sr->s_isreference = opc->sreference; |
|
sr->s_ndn.bv_val = lutil_strcopy( sr->s_dn.bv_val, opc->sdn.bv_val ); |
|
sr->s_ndn.bv_len = opc->sndn.bv_len; |
|
*(sr->s_ndn.bv_val++) = '\0'; |
|
sr->s_uuid.bv_val = lutil_strcopy( sr->s_ndn.bv_val, opc->sndn.bv_val ); |
|
sr->s_uuid.bv_len = opc->suuid.bv_len; |
|
*(sr->s_uuid.bv_val++) = '\0'; |
|
sr->s_csn.bv_val = lutil_strcopy( sr->s_uuid.bv_val, opc->suuid.bv_val ); |
|
sr->s_csn.bv_len = opc->sctxcsn.bv_len; |
|
strcpy( sr->s_csn.bv_val, opc->sctxcsn.bv_val ); |
|
|
|
if ( !so->s_res ) { |
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
so->s_res = sr; |
if ( --so->s_inuse > 0 ) { |
} else { |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
so->s_restail->s_next = sr; |
return; |
} |
} |
so->s_restail = sr; |
|
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
return LDAP_SUCCESS; |
if ( so->s_flags & PS_IS_DETACHED ) { |
} |
filter_free( so->s_op->ors_filter ); |
|
for ( ga = so->s_op->o_groups; ga; ga=gnext ) { |
/* Play back queued responses */ |
gnext = ga->ga_next; |
static int |
ch_free( ga ); |
syncprov_sendresp( Operation *op, opcookie *opc, syncops *so, Entry **e, int mode, int queue ); |
|
|
|
static int |
|
syncprov_qplay( Operation *op, slap_overinst *on, syncops *so ) |
|
{ |
|
syncres *sr, *srnext; |
|
Entry *e; |
|
opcookie opc; |
|
int rc; |
|
|
|
opc.son = on; |
|
op->o_bd->bd_info = (BackendInfo *)on->on_info; |
|
for (sr = so->s_res; sr; sr=srnext) { |
|
srnext = sr->s_next; |
|
opc.sdn = sr->s_dn; |
|
opc.sndn = sr->s_ndn; |
|
opc.suuid = sr->s_uuid; |
|
opc.sctxcsn = sr->s_csn; |
|
opc.sreference = sr->s_isreference; |
|
e = NULL; |
|
|
|
if ( sr->s_mode != LDAP_SYNC_DELETE ) { |
|
rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e ); |
|
if ( rc ) { |
|
ch_free( sr ); |
|
so->s_res = srnext; |
|
continue; |
|
} |
|
} |
|
rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode, 0 ); |
|
|
|
if ( e ) { |
|
be_entry_release_rw( op, e, 0 ); |
|
} |
} |
if ( rc ) |
ch_free( so->s_op ); |
break; |
} |
|
ch_free( so->s_base.bv_val ); |
|
for ( sr=so->s_res; sr; sr=srnext ) { |
|
srnext = sr->s_next; |
ch_free( sr ); |
ch_free( sr ); |
so->s_res = srnext; |
|
} |
} |
op->o_bd->bd_info = (BackendInfo *)on; |
ldap_pvt_thread_mutex_destroy( &so->s_mutex ); |
if ( !so->s_res ) |
ch_free( so ); |
so->s_restail = NULL; |
|
return rc; |
|
} |
} |
|
|
/* Send a persistent search response */ |
/* Send a persistent search response */ |
static int |
static int |
syncprov_sendresp( Operation *op, opcookie *opc, syncops *so, Entry **e, int mode, int queue ) |
syncprov_sendresp( Operation *op, opcookie *opc, syncops *so, Entry **e, int mode) |
{ |
{ |
slap_overinst *on = opc->son; |
slap_overinst *on = opc->son; |
|
|
Line 749 syncprov_sendresp( Operation *op, opcook
|
Line 737 syncprov_sendresp( Operation *op, opcook
|
struct berval cookie; |
struct berval cookie; |
Entry e_uuid = {0}; |
Entry e_uuid = {0}; |
Attribute a_uuid = {0}; |
Attribute a_uuid = {0}; |
Operation sop = *so->s_op; |
|
Opheader ohdr; |
|
|
|
if ( so->s_op->o_abandon ) |
if ( so->s_op->o_abandon ) |
return SLAPD_ABANDON; |
return SLAPD_ABANDON; |
|
|
ohdr = *sop.o_hdr; |
|
sop.o_hdr = &ohdr; |
|
sop.o_tmpmemctx = op->o_tmpmemctx; |
|
sop.o_bd = op->o_bd; |
|
sop.o_controls = op->o_controls; |
|
sop.o_private = op->o_private; |
|
|
|
/* If queueing is allowed */ |
|
if ( queue ) { |
|
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
|
/* If we're still in refresh mode, must queue */ |
|
if (so->s_flags & PS_IS_REFRESHING) { |
|
return syncprov_qresp( opc, so, mode ); |
|
} |
|
/* If connection is free but queue is non-empty, |
|
* try to flush the queue. |
|
*/ |
|
if ( so->s_res ) { |
|
rs.sr_err = syncprov_qplay( &sop, on, so ); |
|
} |
|
/* If the connection is busy, must queue */ |
|
if ( sop.o_conn->c_writewaiter || rs.sr_err == LDAP_BUSY ) { |
|
return syncprov_qresp( opc, so, mode ); |
|
} |
|
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
|
|
|
/* If syncprov_qplay returned any other error, bail out. */ |
|
if ( rs.sr_err ) { |
|
return rs.sr_err; |
|
} |
|
} else { |
|
/* Queueing not allowed and conn is busy, give up */ |
|
if ( sop.o_conn->c_writewaiter ) |
|
return LDAP_BUSY; |
|
} |
|
|
|
ctrls[1] = NULL; |
ctrls[1] = NULL; |
slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn, so->s_rid ); |
slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn, so->s_rid ); |
|
|
e_uuid.e_attrs = &a_uuid; |
e_uuid.e_attrs = &a_uuid; |
a_uuid.a_desc = slap_schema.si_ad_entryUUID; |
a_uuid.a_desc = slap_schema.si_ad_entryUUID; |
a_uuid.a_nvals = &opc->suuid; |
a_uuid.a_nvals = &opc->suuid; |
rs.sr_err = syncprov_state_ctrl( &sop, &rs, &e_uuid, |
rs.sr_err = syncprov_state_ctrl( op, &rs, &e_uuid, |
mode, ctrls, 0, 1, &cookie ); |
mode, ctrls, 0, 1, &cookie ); |
|
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
|
|
rs.sr_ctrls = ctrls; |
rs.sr_ctrls = ctrls; |
op->o_bd->bd_info = (BackendInfo *)on->on_info; |
op->o_bd->bd_info = (BackendInfo *)on->on_info; |
Line 808 syncprov_sendresp( Operation *op, opcook
|
Line 759 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; |
if ( opc->sreference ) { |
if ( opc->sreference ) { |
rs.sr_ref = get_entry_referrals( &sop, rs.sr_entry ); |
rs.sr_ref = get_entry_referrals( op, rs.sr_entry ); |
send_search_reference( &sop, &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 820 syncprov_sendresp( Operation *op, opcook
|
Line 771 syncprov_sendresp( Operation *op, opcook
|
rs.sr_entry = *e; |
rs.sr_entry = *e; |
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 = sop.ors_attrs; |
rs.sr_attrs = op->ors_attrs; |
send_search_entry( &sop, &rs ); |
send_search_entry( op, &rs ); |
if ( !rs.sr_entry ) |
if ( !rs.sr_entry ) |
*e = NULL; |
*e = NULL; |
break; |
break; |
Line 833 syncprov_sendresp( Operation *op, opcook
|
Line 784 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; |
send_search_reference( &sop, &rs ); |
send_search_reference( op, &rs ); |
} else { |
} else { |
send_search_entry( &sop, &rs ); |
send_search_entry( op, &rs ); |
} |
} |
break; |
break; |
default: |
default: |
assert(0); |
assert(0); |
} |
} |
op->o_tmpfree( rs.sr_ctrls[0], op->o_tmpmemctx ); |
/* In case someone else freed it already? */ |
op->o_private = sop.o_private; |
if ( rs.sr_ctrls ) { |
rs.sr_ctrls = NULL; |
op->o_tmpfree( rs.sr_ctrls[0], op->o_tmpmemctx ); |
/* Check queue again here; if we were hanging in a send and eventually |
rs.sr_ctrls = NULL; |
* recovered, there may be more to send now. But don't check if the |
} |
* original psearch has been abandoned. |
|
*/ |
return rs.sr_err; |
if ( so->s_op->o_abandon ) |
} |
return SLAPD_ABANDON; |
|
|
/* Play back queued responses */ |
|
static int |
|
syncprov_qplay( Operation *op, slap_overinst *on, syncops *so ) |
|
{ |
|
syncres *sr; |
|
Entry *e; |
|
opcookie opc; |
|
int rc; |
|
|
|
opc.son = on; |
|
op->o_bd->bd_info = (BackendInfo *)on->on_info; |
|
|
if ( rs.sr_err == LDAP_SUCCESS && queue && so->s_res ) { |
for (;;) { |
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
rs.sr_err = syncprov_qplay( &sop, on, so ); |
sr = so->s_res; |
|
if ( sr ) |
|
so->s_res = sr->s_next; |
|
if ( !so->s_res ) |
|
so->s_restail = NULL; |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
|
|
|
if ( !sr || so->s_op->o_abandon ) |
|
break; |
|
|
|
opc.sdn = sr->s_dn; |
|
opc.sndn = sr->s_ndn; |
|
opc.suuid = sr->s_uuid; |
|
opc.sctxcsn = sr->s_csn; |
|
opc.sreference = sr->s_isreference; |
|
e = NULL; |
|
|
|
if ( sr->s_mode != LDAP_SYNC_DELETE ) { |
|
rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e ); |
|
if ( rc ) { |
|
ch_free( sr ); |
|
continue; |
|
} |
|
} |
|
rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode ); |
|
|
|
if ( e ) { |
|
be_entry_release_rw( op, e, 0 ); |
|
} |
|
|
|
ch_free( sr ); |
|
|
|
if ( rc ) |
|
break; |
} |
} |
return rs.sr_err; |
op->o_bd->bd_info = (BackendInfo *)on; |
|
return rc; |
} |
} |
|
|
static void |
/* runqueue task for playing back queued responses */ |
syncprov_free_syncop( syncops *so ) |
static void * |
|
syncprov_qtask( void *ctx, void *arg ) |
{ |
{ |
syncres *sr, *srnext; |
struct re_s *rtask = arg; |
GroupAssertion *ga, *gnext; |
syncops *so = rtask->arg; |
|
slap_overinst *on = so->s_op->o_private; |
|
char opbuf[OPERATION_BUFFER_SIZE]; |
|
Operation *op; |
|
BackendDB be; |
|
|
|
op = (Operation *)opbuf; |
|
*op = *so->s_op; |
|
op->o_hdr = (Opheader *)(op+1); |
|
op->o_controls = (void **)(op->o_hdr+1); |
|
memset( op->o_controls, 0, SLAP_MAX_CIDS * sizeof(void *)); |
|
|
|
*op->o_hdr = *so->s_op->o_hdr; |
|
|
|
op->o_tmpmemctx = slap_sl_mem_create(SLAP_SLAB_SIZE, SLAP_SLAB_STACK, ctx); |
|
op->o_tmpmfuncs = &slap_sl_mfuncs; |
|
op->o_threadctx = ctx; |
|
|
|
/* syncprov_qplay expects a fake db */ |
|
be = *so->s_op->o_bd; |
|
be.be_flags |= SLAP_DBFLAG_OVERLAY; |
|
op->o_bd = &be; |
|
op->o_private = NULL; |
|
op->o_callback = NULL; |
|
|
|
syncprov_qplay( op, on, so ); |
|
|
|
/* decrement use count... */ |
|
syncprov_free_syncop( so ); |
|
|
|
/* wait until we get explicitly scheduled again */ |
|
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex ); |
|
ldap_pvt_runqueue_stoptask( &slapd_rq, so->s_qtask ); |
|
ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 1 ); |
|
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex ); |
|
|
|
return NULL; |
|
} |
|
|
|
/* Queue a persistent search response */ |
|
static int |
|
syncprov_qresp( opcookie *opc, syncops *so, int mode ) |
|
{ |
|
syncres *sr; |
|
|
|
sr = ch_malloc(sizeof(syncres) + opc->suuid.bv_len + 1 + |
|
opc->sdn.bv_len + 1 + opc->sndn.bv_len + 1 + opc->sctxcsn.bv_len + 1 ); |
|
sr->s_next = NULL; |
|
sr->s_dn.bv_val = (char *)(sr + 1); |
|
sr->s_dn.bv_len = opc->sdn.bv_len; |
|
sr->s_mode = mode; |
|
sr->s_isreference = opc->sreference; |
|
sr->s_ndn.bv_val = lutil_strcopy( sr->s_dn.bv_val, opc->sdn.bv_val ); |
|
sr->s_ndn.bv_len = opc->sndn.bv_len; |
|
*(sr->s_ndn.bv_val++) = '\0'; |
|
sr->s_uuid.bv_val = lutil_strcopy( sr->s_ndn.bv_val, opc->sndn.bv_val ); |
|
sr->s_uuid.bv_len = opc->suuid.bv_len; |
|
*(sr->s_uuid.bv_val++) = '\0'; |
|
sr->s_csn.bv_val = lutil_strcopy( sr->s_uuid.bv_val, opc->suuid.bv_val ); |
|
sr->s_csn.bv_len = opc->sctxcsn.bv_len; |
|
strcpy( sr->s_csn.bv_val, opc->sctxcsn.bv_val ); |
|
|
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
ldap_pvt_thread_mutex_lock( &so->s_mutex ); |
so->s_inuse--; |
if ( !so->s_res ) { |
if ( so->s_inuse > 0 ) { |
so->s_res = sr; |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
} else { |
return; |
so->s_restail->s_next = sr; |
|
} |
|
so->s_restail = sr; |
|
|
|
/* If the base of the psearch was modified, check it next time round */ |
|
if ( so->s_flags & PS_WROTE_BASE ) { |
|
so->s_flags ^= PS_WROTE_BASE; |
|
so->s_flags |= PS_FIND_BASE; |
} |
} |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
|
if ( so->s_flags & PS_IS_DETACHED ) { |
if ( so->s_flags & PS_IS_DETACHED ) { |
filter_free( so->s_op->ors_filter ); |
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex ); |
for ( ga = so->s_op->o_groups; ga; ga=gnext ) { |
if ( !so->s_qtask ) { |
gnext = ga->ga_next; |
so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, RUNQ_INTERVAL, |
ch_free( ga ); |
syncprov_qtask, so, "syncprov_qtask", |
|
so->s_op->o_conn->c_peer_name.bv_val ); |
|
++so->s_inuse; |
|
} 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; |
|
} |
} |
} |
ch_free( so->s_op ); |
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex ); |
} |
} |
ch_free( so->s_base.bv_val ); |
ldap_pvt_thread_mutex_unlock( &so->s_mutex ); |
for ( sr=so->s_res; sr; sr=srnext ) { |
return LDAP_SUCCESS; |
srnext = sr->s_next; |
|
ch_free( sr ); |
|
} |
|
ldap_pvt_thread_mutex_destroy( &so->s_mutex ); |
|
ch_free( so ); |
|
} |
} |
|
|
static int |
static int |
Line 995 syncprov_matchops( Operation *op, opcook
|
Line 1062 syncprov_matchops( Operation *op, opcook
|
e = op->ora_e; |
e = op->ora_e; |
} |
} |
|
|
if ( saveit ) { |
if ( saveit || op->o_tag == LDAP_REQ_ADD ) { |
ber_dupbv_x( &opc->sdn, &e->e_name, op->o_tmpmemctx ); |
ber_dupbv_x( &opc->sdn, &e->e_name, op->o_tmpmemctx ); |
ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx ); |
ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx ); |
opc->sreference = is_entry_referral( e ); |
opc->sreference = is_entry_referral( e ); |
} |
|
if ( saveit || op->o_tag == LDAP_REQ_ADD ) { |
|
a = attr_find( e->e_attrs, slap_schema.si_ad_entryUUID ); |
a = attr_find( e->e_attrs, slap_schema.si_ad_entryUUID ); |
if ( a ) |
if ( a ) |
ber_dupbv_x( &opc->suuid, &a->a_nvals[0], op->o_tmpmemctx ); |
ber_dupbv_x( &opc->suuid, &a->a_nvals[0], op->o_tmpmemctx ); |
|
} else if ( op->o_tag == LDAP_REQ_MODRDN && !saveit ) { |
|
op->o_tmpfree( opc->sndn.bv_val, op->o_tmpmemctx ); |
|
op->o_tmpfree( opc->sdn.bv_val, op->o_tmpmemctx ); |
|
ber_dupbv_x( &opc->sdn, &e->e_name, op->o_tmpmemctx ); |
|
ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx ); |
} |
} |
|
|
ldap_pvt_thread_mutex_lock( &si->si_ops_mutex ); |
ldap_pvt_thread_mutex_lock( &si->si_ops_mutex ); |
Line 1027 syncprov_matchops( Operation *op, opcook
|
Line 1097 syncprov_matchops( Operation *op, opcook
|
"search base has changed" ); |
"search base has changed" ); |
sprev->s_next = snext; |
sprev->s_next = snext; |
syncprov_drop_psearch( ss, 1 ); |
syncprov_drop_psearch( ss, 1 ); |
|
ss = sprev; |
continue; |
continue; |
} |
} |
|
|
|
|
/* If we're sending results now, look for this op in old matches */ |
/* If we're sending results now, look for this op in old matches */ |
if ( !saveit ) { |
if ( !saveit ) { |
syncmatches *old; |
syncmatches *old; |
|
|
|
/* Did we modify the search base? */ |
|
if ( dn_match( &op->o_req_ndn, &ss->s_base )) { |
|
ldap_pvt_thread_mutex_lock( &ss->s_mutex ); |
|
ss->s_flags |= PS_WROTE_BASE; |
|
ldap_pvt_thread_mutex_unlock( &ss->s_mutex ); |
|
} |
|
|
for ( sm=opc->smatches, old=(syncmatches *)&opc->smatches; sm; |
for ( sm=opc->smatches, old=(syncmatches *)&opc->smatches; sm; |
old=sm, sm=sm->sm_next ) { |
old=sm, sm=sm->sm_next ) { |
if ( sm->sm_op == ss ) { |
if ( sm->sm_op == ss ) { |
Line 1051 syncprov_matchops( Operation *op, opcook
|
Line 1131 syncprov_matchops( Operation *op, opcook
|
sm = op->o_tmpalloc( sizeof(syncmatches), op->o_tmpmemctx ); |
sm = op->o_tmpalloc( sizeof(syncmatches), op->o_tmpmemctx ); |
sm->sm_next = opc->smatches; |
sm->sm_next = opc->smatches; |
sm->sm_op = ss; |
sm->sm_op = ss; |
ss->s_inuse++; |
ldap_pvt_thread_mutex_lock( &ss->s_mutex ); |
|
++ss->s_inuse; |
|
ldap_pvt_thread_mutex_unlock( &ss->s_mutex ); |
opc->smatches = sm; |
opc->smatches = sm; |
} else { |
} else { |
/* if found send UPDATE else send ADD */ |
/* if found send UPDATE else send ADD */ |
ss->s_inuse++; |
syncprov_qresp( opc, ss, |
ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex ); |
found ? LDAP_SYNC_MODIFY : LDAP_SYNC_ADD ); |
syncprov_sendresp( op, opc, ss, &e, |
|
found ? LDAP_SYNC_MODIFY : LDAP_SYNC_ADD, 1 ); |
|
ldap_pvt_thread_mutex_lock( &si->si_ops_mutex ); |
|
ss->s_inuse--; |
|
} |
} |
} else if ( !saveit && found ) { |
} else if ( !saveit && found ) { |
/* send DELETE */ |
/* send DELETE */ |
ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex ); |
syncprov_qresp( opc, ss, LDAP_SYNC_DELETE ); |
syncprov_sendresp( op, opc, ss, NULL, LDAP_SYNC_DELETE, 1 ); |
|
ldap_pvt_thread_mutex_lock( &si->si_ops_mutex ); |
|
} |
} |
} |
} |
ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex ); |
ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex ); |
Line 1180 syncprov_add_slog( Operation *op, struct
|
Line 1256 syncprov_add_slog( Operation *op, struct
|
se->se_tag = op->o_tag; |
se->se_tag = op->o_tag; |
|
|
se->se_uuid.bv_val = (char *)(se+1); |
se->se_uuid.bv_val = (char *)(se+1); |
se->se_csn.bv_val = se->se_uuid.bv_val + opc->suuid.bv_len + 1; |
|
AC_MEMCPY( se->se_uuid.bv_val, opc->suuid.bv_val, opc->suuid.bv_len ); |
AC_MEMCPY( se->se_uuid.bv_val, opc->suuid.bv_val, opc->suuid.bv_len ); |
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; |
AC_MEMCPY( se->se_csn.bv_val, csn->bv_val, csn->bv_len ); |
AC_MEMCPY( se->se_csn.bv_val, csn->bv_val, csn->bv_len ); |
se->se_csn.bv_val[csn->bv_len] = '\0'; |
se->se_csn.bv_val[csn->bv_len] = '\0'; |
se->se_csn.bv_len = csn->bv_len; |
se->se_csn.bv_len = csn->bv_len; |
Line 1419 syncprov_op_response( Operation *op, Sla
|
Line 1495 syncprov_op_response( Operation *op, Sla
|
for ( sm = opc->smatches; sm; sm=sm->sm_next ) { |
for ( sm = opc->smatches; sm; sm=sm->sm_next ) { |
if ( sm->sm_op->s_op->o_abandon ) |
if ( sm->sm_op->s_op->o_abandon ) |
continue; |
continue; |
syncprov_sendresp( op, opc, sm->sm_op, NULL, |
syncprov_qresp( opc, sm->sm_op, LDAP_SYNC_DELETE ); |
LDAP_SYNC_DELETE, 1 ); |
|
} |
} |
break; |
break; |
} |
} |
Line 1592 typedef struct searchstate {
|
Line 1667 typedef struct searchstate {
|
slap_overinst *ss_on; |
slap_overinst *ss_on; |
syncops *ss_so; |
syncops *ss_so; |
int ss_present; |
int ss_present; |
|
struct berval ss_ctxcsn; |
|
char ss_csnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
} searchstate; |
} searchstate; |
|
|
static int |
static int |
Line 1606 syncprov_search_cleanup( Operation *op,
|
Line 1683 syncprov_search_cleanup( Operation *op,
|
} |
} |
|
|
static void |
static void |
syncprov_detach_op( Operation *op, syncops *so ) |
syncprov_detach_op( Operation *op, syncops *so, slap_overinst *on ) |
{ |
{ |
Operation *op2; |
Operation *op2; |
int i, alen = 0; |
int i, alen = 0; |
Line 1632 syncprov_detach_op( Operation *op, synco
|
Line 1709 syncprov_detach_op( Operation *op, synco
|
*op2->o_hdr = *op->o_hdr; |
*op2->o_hdr = *op->o_hdr; |
op2->o_tag = op->o_tag; |
op2->o_tag = op->o_tag; |
op2->o_time = op->o_time; |
op2->o_time = op->o_time; |
op2->o_bd = op->o_bd; |
op2->o_bd = on->on_info->oi_origdb; |
op2->o_request = op->o_request; |
op2->o_request = op->o_request; |
|
op2->o_private = on; |
|
|
if ( i ) { |
if ( i ) { |
op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1); |
op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1); |
Line 1672 syncprov_detach_op( Operation *op, synco
|
Line 1750 syncprov_detach_op( Operation *op, synco
|
g2->ga_next = op2->o_groups; |
g2->ga_next = op2->o_groups; |
op2->o_groups = g2; |
op2->o_groups = g2; |
} |
} |
|
/* Don't allow any further group caching */ |
|
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 ); |
ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex ); |
Line 1690 syncprov_search_response( Operation *op,
|
Line 1770 syncprov_search_response( Operation *op,
|
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 ) { |
|
Attribute *a; |
/* If we got a referral without a referral object, there's |
/* If we got a referral without a referral object, there's |
* something missing that we cannot replicate. Just ignore it. |
* something missing that we cannot replicate. Just ignore it. |
* The consumer will abort because we didn't send the expected |
* The consumer will abort because we didn't send the expected |
* control. |
* control. |
*/ |
*/ |
if ( !rs->sr_entry ) { |
if ( !rs->sr_entry ) { |
assert( rs->sr_entry ); |
assert( rs->sr_entry != NULL ); |
Debug( LDAP_DEBUG_ANY, "bogus referral in context\n",0,0,0 ); |
Debug( LDAP_DEBUG_ANY, "bogus referral in context\n",0,0,0 ); |
return SLAP_CB_CONTINUE; |
return SLAP_CB_CONTINUE; |
} |
} |
if ( !BER_BVISNULL( &srs->sr_state.ctxcsn )) { |
a = attr_find( rs->sr_entry->e_attrs, slap_schema.si_ad_entryCSN ); |
Attribute *a = attr_find( rs->sr_entry->e_attrs, |
if ( a ) { |
slap_schema.si_ad_entryCSN ); |
/* Make sure entry is less than the snaphot'd contextCSN */ |
|
if ( ber_bvcmp( &a->a_nvals[0], &ss->ss_ctxcsn ) > 0 ) |
|
return LDAP_SUCCESS; |
|
|
/* Don't send the ctx entry twice */ |
/* Don't send the ctx entry twice */ |
if ( a && bvmatch( &a->a_nvals[0], &srs->sr_state.ctxcsn ) ) |
if ( !BER_BVISNULL( &srs->sr_state.ctxcsn ) && |
|
bvmatch( &a->a_nvals[0], &srs->sr_state.ctxcsn ) ) |
return LDAP_SUCCESS; |
return LDAP_SUCCESS; |
} |
} |
rs->sr_ctrls = op->o_tmpalloc( sizeof(LDAPControl *)*2, |
rs->sr_ctrls = op->o_tmpalloc( sizeof(LDAPControl *)*2, |
Line 1716 syncprov_search_response( Operation *op,
|
Line 1800 syncprov_search_response( Operation *op,
|
} 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; |
|
|
slap_compose_sync_cookie( op, &cookie, |
slap_compose_sync_cookie( op, &cookie, &ss->ss_ctxcsn, |
&op->ors_filter->f_and->f_ava->aa_value, |
|
srs->sr_state.rid ); |
srs->sr_state.rid ); |
|
|
/* Is this a regular refresh? */ |
/* Is this a regular refresh? */ |
Line 1728 syncprov_search_response( Operation *op,
|
Line 1811 syncprov_search_response( Operation *op,
|
rs->sr_err = syncprov_done_ctrl( op, rs, rs->sr_ctrls, |
rs->sr_err = syncprov_done_ctrl( op, rs, rs->sr_ctrls, |
0, 1, &cookie, ss->ss_present ? LDAP_SYNC_REFRESH_PRESENTS : |
0, 1, &cookie, ss->ss_present ? LDAP_SYNC_REFRESH_PRESENTS : |
LDAP_SYNC_REFRESH_DELETES ); |
LDAP_SYNC_REFRESH_DELETES ); |
|
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
} else { |
} else { |
int locked = 0; |
|
/* It's RefreshAndPersist, transition to Persist phase */ |
/* It's RefreshAndPersist, transition to Persist phase */ |
syncprov_sendinfo( op, rs, ( ss->ss_present && rs->sr_nentries ) ? |
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 ); |
/* Flush any queued persist messages */ |
op->o_tmpfree( cookie.bv_val, op->o_tmpmemctx ); |
if ( ss->ss_so->s_res ) { |
|
ldap_pvt_thread_mutex_lock( &ss->ss_so->s_mutex ); |
/* Detach this Op from frontend control */ |
locked = 1; |
ldap_pvt_thread_mutex_lock( &ss->ss_so->s_mutex ); |
syncprov_qplay( op, on, ss->ss_so ); |
|
} |
|
|
|
/* Turn off the refreshing flag */ |
/* Turn off the refreshing flag */ |
ss->ss_so->s_flags ^= PS_IS_REFRESHING; |
ss->ss_so->s_flags ^= PS_IS_REFRESHING; |
if ( locked ) |
|
ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex ); |
|
|
|
/* Detach this Op from frontend control */ |
syncprov_detach_op( op, ss->ss_so, on ); |
syncprov_detach_op( op, ss->ss_so ); |
ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex ); |
|
|
return LDAP_SUCCESS; |
return LDAP_SUCCESS; |
} |
} |
Line 1762 syncprov_op_search( Operation *op, SlapR
|
Line 1841 syncprov_op_search( Operation *op, SlapR
|
slap_overinst *on = (slap_overinst *)op->o_bd->bd_info; |
slap_overinst *on = (slap_overinst *)op->o_bd->bd_info; |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
slap_callback *cb; |
slap_callback *cb; |
int gotstate = 0, nochange = 0, do_present = 1; |
int gotstate = 0, nochange = 0, do_present; |
Filter *fand, *fava; |
|
syncops *sop = NULL; |
syncops *sop = NULL; |
searchstate *ss; |
searchstate *ss; |
sync_control *srs; |
sync_control *srs; |
Line 1777 syncprov_op_search( Operation *op, SlapR
|
Line 1855 syncprov_op_search( Operation *op, SlapR
|
return rs->sr_err; |
return rs->sr_err; |
} |
} |
|
|
|
do_present = si->si_nopres ? 0 : 1; |
|
|
srs = op->o_controls[slap_cids.sc_LDAPsync]; |
srs = op->o_controls[slap_cids.sc_LDAPsync]; |
op->o_managedsait = SLAP_CONTROL_NONCRITICAL; |
op->o_managedsait = SLAP_CONTROL_NONCRITICAL; |
|
|
Line 1791 syncprov_op_search( Operation *op, SlapR
|
Line 1871 syncprov_op_search( Operation *op, SlapR
|
fc.fbase = 0; |
fc.fbase = 0; |
so.s_eid = NOID; |
so.s_eid = NOID; |
so.s_op = op; |
so.s_op = op; |
so.s_flags = PS_IS_REFRESHING; |
so.s_flags = PS_IS_REFRESHING | PS_FIND_BASE; |
/* 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; |
Line 1887 shortcut:
|
Line 1967 shortcut:
|
sop->s_filterstr= op->ors_filterstr; |
sop->s_filterstr= op->ors_filterstr; |
} |
} |
|
|
fand = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx ); |
/* If something changed, find the changes */ |
fand->f_choice = LDAP_FILTER_AND; |
if ( gotstate && !nochange ) { |
fand->f_next = NULL; |
Filter *fand, *fava; |
fava = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx ); |
|
fava->f_choice = LDAP_FILTER_LE; |
fand = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx ); |
fava->f_ava = op->o_tmpalloc( sizeof(AttributeAssertion), op->o_tmpmemctx ); |
fand->f_choice = LDAP_FILTER_AND; |
fava->f_ava->aa_desc = slap_schema.si_ad_entryCSN; |
fand->f_next = NULL; |
#ifdef LDAP_COMP_MATCH |
fava = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx ); |
fava->f_ava->aa_cf = NULL; |
fand->f_and = fava; |
#endif |
|
ber_dupbv_x( &fava->f_ava->aa_value, &ctxcsn, op->o_tmpmemctx ); |
|
fand->f_and = fava; |
|
if ( gotstate ) { |
|
fava->f_next = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx ); |
|
fava = fava->f_next; |
|
fava->f_choice = LDAP_FILTER_GE; |
fava->f_choice = LDAP_FILTER_GE; |
fava->f_ava = op->o_tmpalloc( sizeof(AttributeAssertion), op->o_tmpmemctx ); |
fava->f_ava = op->o_tmpalloc( sizeof(AttributeAssertion), op->o_tmpmemctx ); |
fava->f_ava->aa_desc = slap_schema.si_ad_entryCSN; |
fava->f_ava->aa_desc = slap_schema.si_ad_entryCSN; |
Line 1909 shortcut:
|
Line 1983 shortcut:
|
fava->f_ava->aa_cf = NULL; |
fava->f_ava->aa_cf = NULL; |
#endif |
#endif |
ber_dupbv_x( &fava->f_ava->aa_value, &srs->sr_state.ctxcsn, op->o_tmpmemctx ); |
ber_dupbv_x( &fava->f_ava->aa_value, &srs->sr_state.ctxcsn, op->o_tmpmemctx ); |
|
fava->f_next = op->ors_filter; |
|
op->ors_filter = fand; |
|
filter2bv_x( op, op->ors_filter, &op->ors_filterstr ); |
} |
} |
fava->f_next = op->ors_filter; |
|
op->ors_filter = fand; |
|
filter2bv_x( op, op->ors_filter, &op->ors_filterstr ); |
|
|
|
/* Let our callback add needed info to returned entries */ |
/* Let our callback add needed info to returned entries */ |
cb = op->o_tmpcalloc(1, sizeof(slap_callback)+sizeof(searchstate), op->o_tmpmemctx); |
cb = op->o_tmpcalloc(1, sizeof(slap_callback)+sizeof(searchstate), op->o_tmpmemctx); |
Line 1920 shortcut:
|
Line 1994 shortcut:
|
ss->ss_on = on; |
ss->ss_on = on; |
ss->ss_so = sop; |
ss->ss_so = sop; |
ss->ss_present = do_present; |
ss->ss_present = do_present; |
|
ss->ss_ctxcsn.bv_len = ctxcsn.bv_len; |
|
ss->ss_ctxcsn.bv_val = ss->ss_csnbuf; |
|
strcpy( ss->ss_ctxcsn.bv_val, ctxcsn.bv_val ); |
cb->sc_response = syncprov_search_response; |
cb->sc_response = syncprov_search_response; |
cb->sc_cleanup = syncprov_search_cleanup; |
cb->sc_cleanup = syncprov_search_cleanup; |
cb->sc_private = ss; |
cb->sc_private = ss; |
Line 1990 syncprov_operational(
|
Line 2067 syncprov_operational(
|
|
|
enum { |
enum { |
SP_CHKPT = 1, |
SP_CHKPT = 1, |
SP_SESSL |
SP_SESSL, |
|
SP_NOPRES |
}; |
}; |
|
|
static ConfigDriver sp_cf_gen; |
static ConfigDriver sp_cf_gen; |
Line 2000 static ConfigTable spcfg[] = {
|
Line 2078 static ConfigTable spcfg[] = {
|
sp_cf_gen, "( OLcfgOvAt:1.1 NAME 'olcSpCheckpoint' " |
sp_cf_gen, "( OLcfgOvAt:1.1 NAME 'olcSpCheckpoint' " |
"DESC 'ContextCSN checkpoint interval in ops and minutes' " |
"DESC 'ContextCSN checkpoint interval in ops and minutes' " |
"SYNTAX OMsDirectoryString SINGLE-VALUE )", NULL, NULL }, |
"SYNTAX OMsDirectoryString SINGLE-VALUE )", NULL, NULL }, |
{ "syncprov-sessionlog", "size", 2, 2, 0, ARG_INT|ARG_MAGIC|SP_SESSL, |
{ "syncprov-sessionlog", "ops", 2, 2, 0, ARG_INT|ARG_MAGIC|SP_SESSL, |
sp_cf_gen, "( OLcfgOvAt:1.2 NAME 'olcSpSessionlog' " |
sp_cf_gen, "( OLcfgOvAt:1.2 NAME 'olcSpSessionlog' " |
"DESC 'Session log size in ops' " |
"DESC 'Session log size in ops' " |
"SYNTAX OMsInteger SINGLE-VALUE )", NULL, NULL }, |
"SYNTAX OMsInteger SINGLE-VALUE )", NULL, NULL }, |
|
{ "syncprov-nopresent", NULL, 2, 2, 0, ARG_ON_OFF|ARG_MAGIC|SP_NOPRES, |
|
sp_cf_gen, "( OLcfgOvAt:1.3 NAME 'olcSpNoPresent' " |
|
"DESC 'Omit Present phase processing' " |
|
"SYNTAX OMsBoolean SINGLE-VALUE )", NULL, NULL }, |
{ NULL, NULL, 0, 0, 0, ARG_IGNORED } |
{ NULL, NULL, 0, 0, 0, ARG_IGNORED } |
}; |
}; |
|
|
Line 2012 static ConfigOCs spocs[] = {
|
Line 2094 static ConfigOCs spocs[] = {
|
"NAME 'olcSyncProvConfig' " |
"NAME 'olcSyncProvConfig' " |
"DESC 'SyncRepl Provider configuration' " |
"DESC 'SyncRepl Provider configuration' " |
"SUP olcOverlayConfig " |
"SUP olcOverlayConfig " |
"MAY ( olcSpCheckpoint $ olcSpSessionlog ) )", |
"MAY ( olcSpCheckpoint $ olcSpSessionlog $ olcSpNoPresent ) )", |
Cft_Overlay, spcfg }, |
Cft_Overlay, spcfg }, |
{ NULL, 0, NULL } |
{ NULL, 0, NULL } |
}; |
}; |
Line 2044 sp_cf_gen(ConfigArgs *c)
|
Line 2126 sp_cf_gen(ConfigArgs *c)
|
rc = 1; |
rc = 1; |
} |
} |
break; |
break; |
|
case SP_NOPRES: |
|
if ( si->si_nopres ) { |
|
c->value_int = 1; |
|
} else { |
|
rc = 1; |
|
} |
|
break; |
} |
} |
return rc; |
return rc; |
} else if ( c->op == LDAP_MOD_DELETE ) { |
} else if ( c->op == LDAP_MOD_DELETE ) { |
Line 2058 sp_cf_gen(ConfigArgs *c)
|
Line 2147 sp_cf_gen(ConfigArgs *c)
|
else |
else |
rc = LDAP_NO_SUCH_ATTRIBUTE; |
rc = LDAP_NO_SUCH_ATTRIBUTE; |
break; |
break; |
|
case SP_NOPRES: |
|
if ( si->si_nopres ) |
|
si->si_nopres = 0; |
|
else |
|
rc = LDAP_NO_SUCH_ATTRIBUTE; |
|
break; |
} |
} |
return rc; |
return rc; |
} |
} |
Line 2089 sp_cf_gen(ConfigArgs *c)
|
Line 2184 sp_cf_gen(ConfigArgs *c)
|
sl->sl_size = size; |
sl->sl_size = size; |
} |
} |
break; |
break; |
|
case SP_NOPRES: |
|
si->si_nopres = c->value_int; |
|
break; |
} |
} |
return rc; |
return rc; |
} |
} |
|
|
/* Cheating - we have no thread pool context for these functions, |
|
* so make one. |
|
*/ |
|
typedef struct thread_keys { |
|
void *key; |
|
void *data; |
|
ldap_pvt_thread_pool_keyfree_t *xfree; |
|
} thread_keys; |
|
|
|
#define MAXKEYS 32 |
|
/* A fake thread context */ |
|
static thread_keys thrctx[MAXKEYS]; |
|
|
|
/* ITS#3456 we cannot run this search on the main thread, must use a |
/* ITS#3456 we cannot run this search on the main thread, must use a |
* child thread in order to insure we have a big enough stack. |
* child thread in order to insure we have a big enough stack. |
*/ |
*/ |
Line 2137 syncprov_db_open(
|
Line 2222 syncprov_db_open(
|
Entry *e; |
Entry *e; |
Attribute *a; |
Attribute *a; |
int rc; |
int rc; |
|
void *thrctx = NULL; |
|
|
if ( slapMode & SLAP_TOOL_MODE ) { |
if ( slapMode & SLAP_TOOL_MODE ) { |
return 0; |
return 0; |
Line 2147 syncprov_db_open(
|
Line 2233 syncprov_db_open(
|
return rc; |
return rc; |
} |
} |
|
|
|
thrctx = ldap_pvt_thread_pool_context(); |
connection_fake_init( &conn, op, thrctx ); |
connection_fake_init( &conn, op, thrctx ); |
op->o_bd = be; |
op->o_bd = be; |
op->o_dn = be->be_rootdn; |
op->o_dn = be->be_rootdn; |
Line 2200 syncprov_db_open(
|
Line 2287 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 2212 syncprov_db_close(
|
Line 2300 syncprov_db_close(
|
{ |
{ |
slap_overinst *on = (slap_overinst *) be->bd_info; |
slap_overinst *on = (slap_overinst *) be->bd_info; |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private; |
int i; |
|
|
|
if ( slapMode & SLAP_TOOL_MODE ) { |
if ( slapMode & SLAP_TOOL_MODE ) { |
return 0; |
return 0; |
Line 2222 syncprov_db_close(
|
Line 2309 syncprov_db_close(
|
char opbuf[OPERATION_BUFFER_SIZE]; |
char opbuf[OPERATION_BUFFER_SIZE]; |
Operation *op = (Operation *)opbuf; |
Operation *op = (Operation *)opbuf; |
SlapReply rs = {REP_RESULT}; |
SlapReply rs = {REP_RESULT}; |
|
void *thrctx; |
|
|
|
thrctx = ldap_pvt_thread_pool_context(); |
connection_fake_init( &conn, op, thrctx ); |
connection_fake_init( &conn, op, thrctx ); |
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, &rs, on ); |
} |
ldap_pvt_thread_pool_context_reset( thrctx ); |
for ( i=0; thrctx[i].key; i++) { |
|
if ( thrctx[i].xfree ) |
|
thrctx[i].xfree( thrctx[i].key, thrctx[i].data ); |
|
thrctx[i].key = NULL; |
|
} |
} |
|
|
return 0; |
return 0; |
Line 2255 syncprov_db_init(
|
Line 2340 syncprov_db_init(
|
|
|
csn_anlist[0].an_desc = slap_schema.si_ad_entryCSN; |
csn_anlist[0].an_desc = slap_schema.si_ad_entryCSN; |
csn_anlist[0].an_name = slap_schema.si_ad_entryCSN->ad_cname; |
csn_anlist[0].an_name = slap_schema.si_ad_entryCSN->ad_cname; |
|
csn_anlist[1].an_desc = slap_schema.si_ad_entryUUID; |
|
csn_anlist[1].an_name = slap_schema.si_ad_entryUUID->ad_cname; |
|
|
uuid_anlist[0].an_desc = slap_schema.si_ad_entryUUID; |
uuid_anlist[0].an_desc = slap_schema.si_ad_entryUUID; |
uuid_anlist[0].an_name = slap_schema.si_ad_entryUUID->ad_cname; |
uuid_anlist[0].an_name = slap_schema.si_ad_entryUUID->ad_cname; |
Line 2286 static int syncprov_parseCtrl (
|
Line 2373 static int syncprov_parseCtrl (
|
LDAPControl *ctrl ) |
LDAPControl *ctrl ) |
{ |
{ |
ber_tag_t tag; |
ber_tag_t tag; |
BerElement *ber; |
BerElementBuffer berbuf; |
|
BerElement *ber = (BerElement *)&berbuf; |
ber_int_t mode; |
ber_int_t mode; |
ber_len_t len; |
ber_len_t len; |
struct berval cookie = BER_BVNULL; |
struct berval cookie = BER_BVNULL; |
Line 2320 static int syncprov_parseCtrl (
|
Line 2408 static int syncprov_parseCtrl (
|
* } |
* } |
*/ |
*/ |
|
|
ber = ber_init( &ctrl->ldctl_value ); |
ber_init2( ber, &ctrl->ldctl_value, 0 ); |
if( ber == NULL ) { |
|
rs->sr_text = "internal error"; |
|
return LDAP_OTHER; |
|
} |
|
|
|
if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) { |
if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) { |
rs->sr_text = "Sync control : mode decoding error"; |
rs->sr_text = "Sync control : mode decoding error"; |
Line 2346 static int syncprov_parseCtrl (
|
Line 2430 static int syncprov_parseCtrl (
|
tag = ber_peek_tag( ber, &len ); |
tag = ber_peek_tag( ber, &len ); |
|
|
if ( tag == LDAP_TAG_SYNC_COOKIE ) { |
if ( tag == LDAP_TAG_SYNC_COOKIE ) { |
if (( ber_scanf( ber, /*{*/ "o", &cookie )) == LBER_ERROR ) { |
if (( ber_scanf( ber, /*{*/ "m", &cookie )) == LBER_ERROR ) { |
rs->sr_text = "Sync control : cookie decoding error"; |
rs->sr_text = "Sync control : cookie decoding error"; |
return LDAP_PROTOCOL_ERROR; |
return LDAP_PROTOCOL_ERROR; |
} |
} |
Line 2364 static int syncprov_parseCtrl (
|
Line 2448 static int syncprov_parseCtrl (
|
sr = op->o_tmpcalloc( 1, sizeof(struct sync_control), op->o_tmpmemctx ); |
sr = op->o_tmpcalloc( 1, sizeof(struct sync_control), op->o_tmpmemctx ); |
sr->sr_rhint = rhint; |
sr->sr_rhint = rhint; |
if (!BER_BVISNULL(&cookie)) { |
if (!BER_BVISNULL(&cookie)) { |
ber_dupbv( &sr->sr_state.octet_str, &cookie ); |
ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx ); |
slap_parse_sync_cookie( &sr->sr_state ); |
slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx ); |
|
if ( sr->sr_state.rid == -1 ) { |
|
rs->sr_text = "Sync control : cookie parsing error"; |
|
return LDAP_PROTOCOL_ERROR; |
|
} |
} |
} |
|
|
op->o_controls[slap_cids.sc_LDAPsync] = sr; |
op->o_controls[slap_cids.sc_LDAPsync] = sr; |
|
|
(void) ber_free( ber, 1 ); |
|
|
|
op->o_sync = ctrl->ldctl_iscritical |
op->o_sync = ctrl->ldctl_iscritical |
? SLAP_CONTROL_CRITICAL |
? SLAP_CONTROL_CRITICAL |
: SLAP_CONTROL_NONCRITICAL; |
: SLAP_CONTROL_NONCRITICAL; |