Diff for /servers/slapd/overlays/syncprov.c between versions 1.147.2.76 and 1.306

version 1.147.2.76, 2010/12/12 00:47:22 version 1.306, 2009/11/23 21:13:42
Line 1 Line 1
 /* $OpenLDAP$ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.305 2009/11/22 16:43:48 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 931  syncprov_qplay( Operation *op, syncops * Line 931  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 945  syncprov_qplay( Operation *op, syncops * Line 945  syncprov_qplay( Operation *op, syncops *
   
                         rc = syncprov_sendresp( op, &opc, so, sr->s_mode );                          rc = syncprov_sendresp( op, &opc, so, sr->s_mode );
   
                 }                          if ( opc.se ) {
                 if ( sr->s_e ) {                                  if ( !dec_mutexint( opc.se->e_private )) {
                         if ( !dec_mutexint( sr->s_e->e_private )) {                                          opc.se->e_private = NULL;
                                 sr->s_e->e_private = NULL;                                          entry_free ( opc.se );
                                 entry_free ( sr->s_e );                                  }
                         }                          }
                 }                  }
   
Line 1301  syncprov_matchops( Operation *op, opcook Line 1301  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;
                         ldap_pvt_thread_mutex_lock( &ss->s_mutex );                          rc = test_filter( &op2, e, ss->s_op->ors_filter );
                         if (ss->s_flags & PS_FIX_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 1421  syncprov_checkpoint( Operation *op, Slap Line 1413  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 1442  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 1459  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 2472  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_err = LDAP_SUCCESS;
                                                 rs->sr_text = "consumer state is newer than provider!";  
 bailout:  bailout:
                                                 if ( sop ) {                                                  if ( sop ) {
                                                         syncops **sp = &si->si_ops;                                                          syncops **sp = &si->si_ops;
Line 2573  no_change:  if ( !(op->o_sync_mode & SLA Line 2561  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 {

Removed from v.1.147.2.76  
changed lines
  Added in v.1.306


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