Diff for /servers/slapd/overlays/syncprov.c between versions 1.147.2.70 and 1.301

version 1.147.2.70, 2009/11/24 00:53:26 version 1.301, 2009/11/21 10:43:01
Line 1 Line 1
 /* $OpenLDAP$ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.300 2009/11/21 02:38:13 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 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 591  syncprov_findcsn( Operation *op, find_cs Line 584  syncprov_findcsn( Operation *op, find_cs
         slap_callback cb = {0};          slap_callback cb = {0};
         Operation fop;          Operation fop;
         SlapReply frs = { REP_RESULT };          SlapReply frs = { REP_RESULT };
         char buf[LDAP_LUTIL_CSNSTR_BUFSIZE + STRLENOF("(entryCSN<=)")];          char buf[LDAP_PVT_CSNSTR_BUFSIZE + STRLENOF("(entryCSN<=)")];
         char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];          char cbuf[LDAP_PVT_CSNSTR_BUFSIZE];
         struct berval maxcsn;          struct berval maxcsn;
         Filter cf;          Filter cf;
         AttributeAssertion eq = ATTRIBUTEASSERTION_INIT;          AttributeAssertion eq = ATTRIBUTEASSERTION_INIT;
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 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 ( opc.se ) {                          if ( sr->s_mode != LDAP_SYNC_DELETE ) {
                                 if ( !dec_mutexint( opc.se->e_private )) {                                  rc = overlay_entry_get_ov( op, &opc.sndn, NULL, NULL, 0, &e, on );
                                         opc.se->e_private = NULL;                                  if ( rc ) {
                                         entry_free ( opc.se );                                          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 ) {
                                   overlay_entry_release_ov( op, e, 0, on );
                           }
                 }                  }
   
                 ch_free( sr );                  ch_free( sr );
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 1341  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 1535  syncprov_playlog( Operation *op, SlapRep Line 1485  syncprov_playlog( Operation *op, SlapRep
         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];          char cbuf[LDAP_PVT_CSNSTR_BUFSIZE];
         BerVarray uuids;          BerVarray uuids;
         struct berval delcsn[2];          struct berval delcsn[2];
   
Line 1710  syncprov_op_response( Operation *op, Sla Line 1660  syncprov_op_response( Operation *op, Sla
         if ( rs->sr_err == LDAP_SUCCESS )          if ( rs->sr_err == LDAP_SUCCESS )
         {          {
                 struct berval maxcsn;                  struct berval maxcsn;
                 char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];                  char cbuf[LDAP_PVT_CSNSTR_BUFSIZE];
                 int do_check = 0, have_psearches, foundit, csn_changed = 0;                  int do_check = 0, have_psearches, foundit, csn_changed = 0;
   
                 ldap_pvt_thread_mutex_lock( &si->si_resp_mutex );                  ldap_pvt_thread_mutex_lock( &si->si_resp_mutex );
Line 1721  syncprov_op_response( Operation *op, Sla Line 1671  syncprov_op_response( Operation *op, Sla
                 maxcsn.bv_len = sizeof(cbuf);                  maxcsn.bv_len = sizeof(cbuf);
                 ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );                  ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );
   
                 slap_get_commit_csn( op, &maxcsn, &foundit );  
                 if ( BER_BVISEMPTY( &maxcsn ) && SLAP_GLUE_SUBORDINATE( op->o_bd )) {                  if ( BER_BVISEMPTY( &maxcsn ) && SLAP_GLUE_SUBORDINATE( op->o_bd )) {
                         /* syncrepl queues the CSN values in the db where                          /* syncrepl queues the CSN values in the db where
                          * it is configured , not where the changes are made.                           * it is configured , not where the changes are made.
Line 2473  syncprov_op_search( Operation *op, SlapR Line 2422  syncprov_op_search( Operation *op, SlapR
                                                 changed = SS_CHANGED;                                                  changed = SS_CHANGED;
                                         else if ( newer > 0 ) {                                          else if ( newer > 0 ) {
                                         /* our state is older, tell consumer nothing */                                          /* our state is older, tell consumer nothing */
                                                 rs->sr_err = LDAP_SUCCESS;  
 bailout:  
                                                 if ( sop ) {                                                  if ( sop ) {
                                                         syncops **sp = &si->si_ops;                                                          syncops **sp = &si->si_ops;
                                                                                                                   
Line 2485  bailout: Line 2432  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 2539  no_change:  if ( !(op->o_sync_mode & SLA Line 2487  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 2561  no_change:  if ( !(op->o_sync_mode & SLA Line 2508  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 2860  sp_cf_gen(ConfigArgs *c) Line 2808  sp_cf_gen(ConfigArgs *c)
                 }                  }
                 sl = si->si_logs;                  sl = si->si_logs;
                 if ( !sl ) {                  if ( !sl ) {
                         sl = ch_malloc( sizeof( sessionlog ) + LDAP_LUTIL_CSNSTR_BUFSIZE );                          sl = ch_malloc( sizeof( sessionlog ) + LDAP_PVT_CSNSTR_BUFSIZE );
                         sl->sl_mincsn.bv_val = (char *)(sl+1);                          sl->sl_mincsn.bv_val = (char *)(sl+1);
                         sl->sl_mincsn.bv_len = 0;                          sl->sl_mincsn.bv_len = 0;
                         sl->sl_num = 0;                          sl->sl_num = 0;
Line 2966  syncprov_db_open( Line 2914  syncprov_db_open(
   
         /* Didn't find a contextCSN, should we generate one? */          /* Didn't find a contextCSN, should we generate one? */
         if ( !si->si_ctxcsn ) {          if ( !si->si_ctxcsn ) {
                 char csnbuf[ LDAP_LUTIL_CSNSTR_BUFSIZE ];                  char csnbuf[ LDAP_PVT_CSNSTR_BUFSIZE ];
                 struct berval csn;                  struct berval csn;
   
                 if ( SLAP_SYNC_SHADOW( op->o_bd )) {                  if ( SLAP_SYNC_SHADOW( op->o_bd )) {

Removed from v.1.147.2.70  
changed lines
  Added in v.1.301


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