Diff for /servers/slapd/overlays/syncprov.c between versions 1.147.2.77 and 1.302

version 1.147.2.77, 2010/12/12 03:54:10 version 1.302, 2009/11/21 10:54:59
Line 1 Line 1
 /* $OpenLDAP$ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.301 2009/11/21 10:43:01 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-2010 The OpenLDAP Foundation.   * Copyright 2004-2009 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 48  typedef struct modtarget { Line 48  typedef struct modtarget {
 /* A queued result of a persistent search */  /* A queued result of a persistent search */
 typedef struct syncres {  typedef struct syncres {
         struct syncres *s_next;          struct syncres *s_next;
         Entry *s_e;  
         struct berval s_dn;          struct berval s_dn;
         struct berval s_ndn;          struct berval s_ndn;
         struct berval s_uuid;          struct berval s_uuid;
Line 146  typedef struct opcookie { Line 145  typedef struct opcookie {
         slap_overinst *son;          slap_overinst *son;
         syncmatches *smatches;          syncmatches *smatches;
         modtarget *smt;          modtarget *smt;
         Entry *se;  
         struct berval sdn;      /* DN of entry, for deletes */          struct berval sdn;      /* DN of entry, for deletes */
         struct berval sndn;          struct berval sndn;
         struct berval suuid;    /* UUID of entry */          struct berval suuid;    /* UUID of entry */
Line 156  typedef struct opcookie { Line 154  typedef struct opcookie {
         short sreference;       /* Is the entry a reference? */          short sreference;       /* Is the entry a reference? */
 } opcookie;  } opcookie;
   
 typedef struct mutexint {  
         ldap_pvt_thread_mutex_t mi_mutex;  
         int mi_int;  
 } mutexint;  
   
 typedef struct fbase_cookie {  typedef struct fbase_cookie {
         struct berval *fdn;     /* DN of a modified entry, for scope testing */          struct berval *fdn;     /* DN of a modified entry, for scope testing */
         syncops *fss;   /* persistent search we're testing against */          syncops *fss;   /* persistent search we're testing against */
Line 746  again: Line 739  again:
         return rc;          return rc;
 }  }
   
 /* Should find a place to cache these */  
 static mutexint *get_mutexint()  
 {  
         mutexint *mi = ch_malloc( sizeof( mutexint ));  
         ldap_pvt_thread_mutex_init( &mi->mi_mutex );  
         mi->mi_int = 1;  
         return mi;  
 }  
   
 static void inc_mutexint( mutexint *mi )  
 {  
         ldap_pvt_thread_mutex_lock( &mi->mi_mutex );  
         mi->mi_int++;  
         ldap_pvt_thread_mutex_unlock( &mi->mi_mutex );  
 }  
   
 /* return resulting counter */  
 static int dec_mutexint( mutexint *mi )  
 {  
         int i;  
         ldap_pvt_thread_mutex_lock( &mi->mi_mutex );  
         i = --mi->mi_int;  
         ldap_pvt_thread_mutex_unlock( &mi->mi_mutex );  
         if ( !i ) {  
                 ldap_pvt_thread_mutex_destroy( &mi->mi_mutex );  
                 ch_free( mi );  
         }  
         return i;  
 }  
   
 static void  static void
 syncprov_free_syncop( syncops *so )  syncprov_free_syncop( syncops *so )
 {  {
Line 799  syncprov_free_syncop( syncops *so ) Line 762  syncprov_free_syncop( syncops *so )
         ch_free( so->s_base.bv_val );          ch_free( so->s_base.bv_val );
         for ( sr=so->s_res; sr; sr=srnext ) {          for ( sr=so->s_res; sr; sr=srnext ) {
                 srnext = sr->s_next;                  srnext = sr->s_next;
                 if ( sr->s_e ) {  
                         if ( !dec_mutexint( sr->s_e->e_private )) {  
                                 sr->s_e->e_private = NULL;  
                                 entry_free( sr->s_e );  
                         }  
                 }  
                 ch_free( sr );                  ch_free( sr );
         }          }
         ldap_pvt_thread_mutex_destroy( &so->s_mutex );          ldap_pvt_thread_mutex_destroy( &so->s_mutex );
Line 813  syncprov_free_syncop( syncops *so ) Line 770  syncprov_free_syncop( syncops *so )
   
 /* Send a persistent search response */  /* Send a persistent search response */
 static int  static int
 syncprov_sendresp( Operation *op, opcookie *opc, syncops *so, int mode )  syncprov_sendresp( Operation *op, opcookie *opc, syncops *so,
           Entry **e, int mode )
 {  {
         slap_overinst *on = opc->son;          slap_overinst *on = opc->son;
   
Line 853  syncprov_sendresp( Operation *op, opcook Line 811  syncprov_sendresp( Operation *op, opcook
         }          }
   
         rs.sr_ctrls = ctrls;          rs.sr_ctrls = ctrls;
         rs.sr_entry = &e_uuid;          op->o_bd->bd_info = (BackendInfo *)on->on_info;
         if ( mode == LDAP_SYNC_ADD || mode == LDAP_SYNC_MODIFY ) {  
                 e_uuid = *opc->se;  
                 e_uuid.e_private = NULL;  
         }  
   
         switch( mode ) {          switch( mode ) {
         case LDAP_SYNC_ADD:          case LDAP_SYNC_ADD:
                   rs.sr_entry = *e;
                   if ( rs.sr_entry->e_private )
                           rs.sr_flags = REP_ENTRY_MUSTRELEASE;
                 if ( opc->sreference && so->s_op->o_managedsait <= SLAP_CONTROL_IGNORED ) {                  if ( opc->sreference && so->s_op->o_managedsait <= SLAP_CONTROL_IGNORED ) {
                         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 );                          rs.sr_err = send_search_reference( op, &rs );
                         ber_bvarray_free( rs.sr_ref );                          ber_bvarray_free( rs.sr_ref );
                           if ( !rs.sr_entry )
                                   *e = NULL;
                         break;                          break;
                 }                  }
                 /* fallthru */                  /* fallthru */
         case LDAP_SYNC_MODIFY:          case LDAP_SYNC_MODIFY:
                   rs.sr_entry = *e;
                   if ( rs.sr_entry->e_private )
                           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 );                  rs.sr_err = send_search_entry( op, &rs );
                   if ( !rs.sr_entry )
                           *e = NULL;
                 break;                  break;
         case LDAP_SYNC_DELETE:          case LDAP_SYNC_DELETE:
                 e_uuid.e_attrs = NULL;                  e_uuid.e_attrs = NULL;
                 e_uuid.e_name = opc->sdn;                  e_uuid.e_name = opc->sdn;
                 e_uuid.e_nname = opc->sndn;                  e_uuid.e_nname = opc->sndn;
                   rs.sr_entry = &e_uuid;
                 if ( opc->sreference && so->s_op->o_managedsait <= SLAP_CONTROL_IGNORED ) {                  if ( opc->sreference && so->s_op->o_managedsait <= SLAP_CONTROL_IGNORED ) {
                         struct berval bv = BER_BVNULL;                          struct berval bv = BER_BVNULL;
                         rs.sr_ref = &bv;                          rs.sr_ref = &bv;
Line 931  syncprov_qplay( Operation *op, syncops * Line 895  syncprov_qplay( Operation *op, syncops *
                 ldap_pvt_thread_mutex_unlock( &so->s_mutex );                  ldap_pvt_thread_mutex_unlock( &so->s_mutex );
   
                 if ( sr->s_mode == LDAP_SYNC_NEW_COOKIE ) {                  if ( sr->s_mode == LDAP_SYNC_NEW_COOKIE ) {
                         SlapReply rs = { REP_INTERMEDIATE };                      SlapReply rs = { REP_INTERMEDIATE };
   
                         rc = syncprov_sendinfo( op, &rs, LDAP_TAG_SYNC_NEW_COOKIE,                      rc = syncprov_sendinfo( op, &rs, LDAP_TAG_SYNC_NEW_COOKIE,
                                 &sr->s_csn, 0, NULL, 0 );                                  &sr->s_csn, 0, NULL, 0 );
                 } else {                  } else {
                         opc.sdn = sr->s_dn;                          opc.sdn = sr->s_dn;
Line 941  syncprov_qplay( Operation *op, syncops * Line 905  syncprov_qplay( Operation *op, syncops *
                         opc.suuid = sr->s_uuid;                          opc.suuid = sr->s_uuid;
                         opc.sctxcsn = sr->s_csn;                          opc.sctxcsn = sr->s_csn;
                         opc.sreference = sr->s_isreference;                          opc.sreference = sr->s_isreference;
                         opc.se = sr->s_e;                          e = NULL;
   
                         rc = syncprov_sendresp( op, &opc, so, sr->s_mode );                          if ( sr->s_mode != LDAP_SYNC_DELETE ) {
                                   rc = overlay_entry_get_ov( op, &opc.sndn, NULL, NULL, 0, &e, on );
                                   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 );
                                           rc = 0;
                                           continue;
                                   }
                           }
                           rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode );
   
                 }                          if ( e ) {
                 if ( sr->s_e ) {                                  overlay_entry_release_ov( op, e, 0, on );
                         if ( !dec_mutexint( sr->s_e->e_private )) {  
                                 sr->s_e->e_private = NULL;  
                                 entry_free ( sr->s_e );  
                         }                          }
                 }                  }
   
Line 1043  syncprov_qresp( opcookie *opc, syncops * Line 1014  syncprov_qresp( opcookie *opc, syncops *
                 srsize += cookie.bv_len + 1;                  srsize += cookie.bv_len + 1;
         sr = ch_malloc( srsize );          sr = ch_malloc( srsize );
         sr->s_next = NULL;          sr->s_next = NULL;
         sr->s_e = opc->se;  
         /* bump refcount on this entry */  
         if ( opc->se )  
                 inc_mutexint( opc->se->e_private );  
         sr->s_dn.bv_val = (char *)(sr + 1);          sr->s_dn.bv_val = (char *)(sr + 1);
         sr->s_dn.bv_len = opc->sdn.bv_len;          sr->s_dn.bv_len = opc->sdn.bv_len;
         sr->s_mode = mode;          sr->s_mode = mode;
Line 1190  syncprov_matchops( Operation *op, opcook Line 1157  syncprov_matchops( Operation *op, opcook
                 rc = overlay_entry_get_ov( op, fc.fdn, NULL, NULL, 0, &e, on );                  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 ) {
                         if ( !opc->se ) {                          Entry *e2 = entry_dup( e );
                                 opc->se = entry_dup( e );  
                                 opc->se->e_private = get_mutexint();  
                         }  
                         overlay_entry_release_ov( op, e, 0, on );                          overlay_entry_release_ov( op, e, 0, on );
                         e = opc->se;                          e = e2;
                 }                  }
                 if ( rc ) {                  if ( rc ) {
                         op->o_bd = b0;                          op->o_bd = b0;
Line 1203  syncprov_matchops( Operation *op, opcook Line 1167  syncprov_matchops( Operation *op, opcook
                 }                  }
         } else {          } else {
                 e = op->ora_e;                  e = op->ora_e;
                 if ( !saveit ) {  
                         if ( !opc->se ) {  
                                 opc->se = entry_dup( e );  
                                 opc->se->e_private = get_mutexint();  
                         }  
                         e = opc->se;  
                 }  
         }          }
   
         if ( saveit || op->o_tag == LDAP_REQ_ADD ) {          if ( saveit || op->o_tag == LDAP_REQ_ADD ) {
Line 1270  syncprov_matchops( Operation *op, opcook Line 1227  syncprov_matchops( Operation *op, opcook
                         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;
Line 1293  syncprov_matchops( Operation *op, opcook Line 1251  syncprov_matchops( Operation *op, opcook
                 }                  }
   
                 if ( fc.fscope ) {                  if ( fc.fscope ) {
                         ldap_pvt_thread_mutex_lock( &ss->s_mutex );  
                         op2 = *ss->s_op;                          op2 = *ss->s_op;
                         oh = *op->o_hdr;                          oh = *op->o_hdr;
                         oh.oh_conn = ss->s_op->o_conn;                          oh.oh_conn = ss->s_op->o_conn;
Line 1302  syncprov_matchops( Operation *op, opcook Line 1259  syncprov_matchops( Operation *op, opcook
                         op2.o_hdr = &oh;                          op2.o_hdr = &oh;
                         op2.o_extra = op->o_extra;                          op2.o_extra = op->o_extra;
                         op2.o_callback = NULL;                          op2.o_callback = NULL;
                         if (ss->s_flags & PS_FIX_FILTER) {                          rc = test_filter( &op2, e, ss->s_op->ors_filter );
                                 /* Skip the AND/GE clause that we stuck on in front. We  
                                    would lose deletes/mods that happen during the refresh  
                                    phase otherwise (ITS#6555) */  
                                 op2.ors_filter = ss->s_op->ors_filter->f_and->f_next;  
                         }  
                         ldap_pvt_thread_mutex_unlock( &ss->s_mutex );  
                         rc = test_filter( &op2, e, op2.ors_filter );  
                 }                  }
   
                 Debug( LDAP_DEBUG_TRACE, "syncprov_matchops: sid %03x fscope %d rc %d\n",                  Debug( LDAP_DEBUG_TRACE, "syncprov_matchops: sid %03x fscope %d rc %d\n",
Line 1349  syncprov_matchops( Operation *op, opcook Line 1299  syncprov_matchops( Operation *op, opcook
                 if ( !SLAP_ISOVERLAY( op->o_bd )) {                  if ( !SLAP_ISOVERLAY( op->o_bd )) {
                         op->o_bd = &db;                          op->o_bd = &db;
                 }                  }
                 if ( saveit )                  overlay_entry_release_ov( op, e, 0, on );
                         overlay_entry_release_ov( op, e, 0, on );  
                 op->o_bd = b0;                  op->o_bd = b0;
         }          }
         if ( opc->se && !saveit ) {  
                 if ( !dec_mutexint( opc->se->e_private )) {  
                         opc->se->e_private = NULL;  
                         entry_free( opc->se );  
                         opc->se = NULL;  
                 }  
         }  
         if ( freefdn ) {          if ( freefdn ) {
                 op->o_tmpfree( fc.fdn->bv_val, op->o_tmpmemctx );                  op->o_tmpfree( fc.fdn->bv_val, op->o_tmpmemctx );
         }          }
Line 1421  syncprov_checkpoint( Operation *op, Slap Line 1363  syncprov_checkpoint( Operation *op, Slap
         SlapReply rsm = { 0 };          SlapReply rsm = { 0 };
         slap_callback cb = {0};          slap_callback cb = {0};
         BackendDB be;          BackendDB be;
         BackendInfo *bi;  
   
 #ifdef CHECK_CSN  #ifdef CHECK_CSN
         Syntax *syn = slap_schema.si_ad_contextCSN->ad_type->sat_syntax;          Syntax *syn = slap_schema.si_ad_contextCSN->ad_type->sat_syntax;
Line 1451  syncprov_checkpoint( Operation *op, Slap Line 1392  syncprov_checkpoint( Operation *op, Slap
         }          }
         opm.o_req_dn = si->si_contextdn;          opm.o_req_dn = si->si_contextdn;
         opm.o_req_ndn = si->si_contextdn;          opm.o_req_ndn = si->si_contextdn;
         bi = opm.o_bd->bd_info;  
         opm.o_bd->bd_info = on->on_info->oi_orig;          opm.o_bd->bd_info = on->on_info->oi_orig;
         opm.o_managedsait = SLAP_CONTROL_NONCRITICAL;          opm.o_managedsait = SLAP_CONTROL_NONCRITICAL;
         opm.o_no_schema_check = 1;          opm.o_no_schema_check = 1;
Line 1469  syncprov_checkpoint( Operation *op, Slap Line 1409  syncprov_checkpoint( Operation *op, Slap
                 if ( e == opm.ora_e )                  if ( e == opm.ora_e )
                         be_entry_release_w( &opm, opm.ora_e );                          be_entry_release_w( &opm, opm.ora_e );
         }          }
         opm.o_bd->bd_info = bi;  
   
         if ( mod.sml_next != NULL ) {          if ( mod.sml_next != NULL ) {
                 slap_mods_free( mod.sml_next, 1 );                  slap_mods_free( mod.sml_next, 1 );
Line 2483  syncprov_op_search( Operation *op, SlapR Line 2422  syncprov_op_search( Operation *op, SlapR
                                         if ( newer < 0 )                                          if ( newer < 0 )
                                                 changed = SS_CHANGED;                                                  changed = SS_CHANGED;
                                         else if ( newer > 0 ) {                                          else if ( newer > 0 ) {
                                         /* our state is older, complain to consumer */                                          /* our state is older, tell consumer nothing */
                                                 rs->sr_err = LDAP_UNWILLING_TO_PERFORM;  
                                                 rs->sr_text = "consumer state is newer than provider!";  
 bailout:  
                                                 if ( sop ) {                                                  if ( sop ) {
                                                         syncops **sp = &si->si_ops;                                                          syncops **sp = &si->si_ops;
                                                                                                                   
Line 2497  bailout: Line 2433  bailout:
                                                         ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );                                                          ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );
                                                         ch_free( sop );                                                          ch_free( sop );
                                                 }                                                  }
                                                   rs->sr_err = LDAP_SUCCESS;
                                                 rs->sr_ctrls = NULL;                                                  rs->sr_ctrls = NULL;
                                                 send_ldap_result( op, rs );                                                  send_ldap_result( op, rs );
                                                 return rs->sr_err;                                                  return rs->sr_err;
Line 2551  no_change:  if ( !(op->o_sync_mode & SLA Line 2488  no_change:  if ( !(op->o_sync_mode & SLA
                                         ber_bvarray_free_x( ctxcsn, op->o_tmpmemctx );                                          ber_bvarray_free_x( ctxcsn, op->o_tmpmemctx );
                                 if ( sids )                                  if ( sids )
                                         op->o_tmpfree( sids, op->o_tmpmemctx );                                          op->o_tmpfree( sids, op->o_tmpmemctx );
                                 rs->sr_err = LDAP_SYNC_REFRESH_REQUIRED;                                  send_ldap_error( op, rs, LDAP_SYNC_REFRESH_REQUIRED, "sync cookie is stale" );
                                 rs->sr_text = "sync cookie is stale";                                  return rs->sr_err;
                                 goto bailout;  
                         }                          }
                         if ( srs->sr_state.ctxcsn ) {                          if ( srs->sr_state.ctxcsn ) {
                                 ber_bvarray_free_x( srs->sr_state.ctxcsn, op->o_tmpmemctx );                                  ber_bvarray_free_x( srs->sr_state.ctxcsn, op->o_tmpmemctx );
Line 2573  no_change:  if ( !(op->o_sync_mode & SLA Line 2509  no_change:  if ( !(op->o_sync_mode & SLA
                                         ber_bvarray_free_x( ctxcsn, op->o_tmpmemctx );                                          ber_bvarray_free_x( ctxcsn, op->o_tmpmemctx );
                                 if ( sids )                                  if ( sids )
                                         op->o_tmpfree( sids, op->o_tmpmemctx );                                          op->o_tmpfree( sids, op->o_tmpmemctx );
                                 goto bailout;                                  send_ldap_result( op, rs );
                                   return rs->sr_err;
                         }                          }
                 }                  }
         } else {          } else {
Line 2606  shortcut: Line 2543  shortcut:
 #endif  #endif
                 ber_dupbv_x( &fava->f_ava->aa_value, &mincsn, op->o_tmpmemctx );                  ber_dupbv_x( &fava->f_ava->aa_value, &mincsn, op->o_tmpmemctx );
                 fava->f_next = op->ors_filter;                  fava->f_next = op->ors_filter;
                 if ( sop )  
                         ldap_pvt_thread_mutex_lock( &sop->s_mutex );  
                 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 ) {                  if ( sop )
                         sop->s_flags |= PS_FIX_FILTER;                          sop->s_flags |= PS_FIX_FILTER;
                         ldap_pvt_thread_mutex_unlock( &sop->s_mutex );  
                 }  
         }          }
   
         /* Let our callback add needed info to returned entries */          /* Let our callback add needed info to returned entries */

Removed from v.1.147.2.77  
changed lines
  Added in v.1.302


______________
© Copyright 1998-2020, OpenLDAP Foundation, info@OpenLDAP.org