Diff for /servers/slapd/overlays/syncprov.c between versions 1.207 and 1.214

version 1.207, 2007/11/01 23:25:11 version 1.214, 2008/02/10 01:10:28
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.206 2007/10/08 16:13:29 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.213 2008/01/07 23:20:14 kurt 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-2007 The OpenLDAP Foundation.   * Copyright 2004-2008 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 1566  syncprov_op_response( Operation *op, Sla Line 1566  syncprov_op_response( Operation *op, Sla
                 char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];                  char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
                 int do_check = 0, have_psearches;                  int do_check = 0, have_psearches;
   
                   /* Don't do any processing for consumer contextCSN updates */
                   if ( SLAP_SYNC_SHADOW( op->o_bd ) && 
                           op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) {
                           return SLAP_CB_CONTINUE;
                   }
   
                 /* Update our context CSN */                  /* Update our context CSN */
                 cbuf[0] = '\0';                  cbuf[0] = '\0';
                 ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );                  ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );
Line 1592  syncprov_op_response( Operation *op, Sla Line 1598  syncprov_op_response( Operation *op, Sla
                         }                          }
                 }                  }
   
                 /* Don't do any processing for consumer contextCSN updates */  
                 if ( SLAP_SYNC_SHADOW( op->o_bd ) &&   
                         op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) {  
                         ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock );  
                         return SLAP_CB_CONTINUE;  
                 }  
   
                 si->si_numops++;                  si->si_numops++;
                 if ( si->si_chkops || si->si_chktime ) {                  if ( si->si_chkops || si->si_chktime ) {
                         if ( si->si_chkops && si->si_numops >= si->si_chkops ) {                          if ( si->si_chkops && si->si_numops >= si->si_chkops ) {
Line 1607  syncprov_op_response( Operation *op, Sla Line 1606  syncprov_op_response( Operation *op, Sla
                         }                          }
                         if ( si->si_chktime &&                          if ( si->si_chktime &&
                                 (op->o_time - si->si_chklast >= si->si_chktime )) {                                  (op->o_time - si->si_chklast >= si->si_chktime )) {
                                 do_check = 1;                                  if ( si->si_chklast ) {
                                 si->si_chklast = op->o_time;                                          do_check = 1;
                                           si->si_chklast = op->o_time;
                                   } else {
                                           si->si_chklast = 1;
                                   }
                         }                          }
                 }                  }
                 ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock );                  ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock );
Line 2064  syncprov_op_search( Operation *op, SlapR Line 2067  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, changed = 0, do_present;          int gotstate = 0, changed = 0, do_present = 0;
         syncops *sop = NULL;          syncops *sop = NULL;
         searchstate *ss;          searchstate *ss;
         sync_control *srs;          sync_control *srs;
Line 2079  syncprov_op_search( Operation *op, SlapR Line 2082  syncprov_op_search( Operation *op, SlapR
                 return rs->sr_err;                  return rs->sr_err;
         }          }
   
         do_present = si->si_nopres ? 0 : SS_PRESENT;  
   
         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 2148  syncprov_op_search( Operation *op, SlapR Line 2149  syncprov_op_search( Operation *op, SlapR
                 if ( !numcsns )                  if ( !numcsns )
                         goto no_change;                          goto no_change;
   
                   if ( !si->si_nopres )
                           do_present = SS_PRESENT;
   
                 /* If there are SIDs we don't recognize in the cookie, drop them */                  /* If there are SIDs we don't recognize in the cookie, drop them */
                 for (i=0; i<srs->sr_state.numcsns; ) {                  for (i=0; i<srs->sr_state.numcsns; ) {
                         for (j=0; j<numcsns; j++) {                          for (j=0; j<numcsns; j++) {
Line 2191  syncprov_op_search( Operation *op, SlapR Line 2195  syncprov_op_search( Operation *op, SlapR
                                         break;                                          break;
                         }                          }
                         if ( !changed ) {                          if ( !changed ) {
                                   do_present = 0;
 no_change:              if ( !(op->o_sync_mode & SLAP_SYNC_PERSIST) ) {  no_change:              if ( !(op->o_sync_mode & SLAP_SYNC_PERSIST) ) {
                                         LDAPControl     *ctrls[2];                                          LDAPControl     *ctrls[2];
   
Line 2319  syncprov_operational( Line 2324  syncprov_operational(
         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;
   
           /* This prevents generating unnecessarily; frontend will strip
            * any statically stored copy.
            */
           if ( op->o_sync != SLAP_CONTROL_NONE )
                   return SLAP_CB_CONTINUE;
   
         if ( rs->sr_entry &&          if ( rs->sr_entry &&
                 dn_match( &rs->sr_entry->e_nname, op->o_bd->be_nsuffix )) {                  dn_match( &rs->sr_entry->e_nname, op->o_bd->be_nsuffix )) {
   
Line 2838  static int syncprov_parseCtrl ( Line 2849  static int syncprov_parseCtrl (
         sr->sr_rhint = rhint;          sr->sr_rhint = rhint;
         if (!BER_BVISNULL(&cookie)) {          if (!BER_BVISNULL(&cookie)) {
                 ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx );                  ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx );
                   /* If parse fails, pretend no cookie was sent */
                 if ( slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx ) ||                  if ( slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx ) ||
                         sr->sr_state.rid == -1 ) {                          sr->sr_state.rid == -1 ) {
                         rs->sr_text = "Sync control : cookie parsing error";                          if ( sr->sr_state.ctxcsn ) {
                         return LDAP_PROTOCOL_ERROR;                                  ber_bvarray_free_x( sr->sr_state.ctxcsn, op->o_tmpmemctx );
                                   sr->sr_state.ctxcsn = NULL;
                           }
                           sr->sr_state.numcsns = 0;
                 }                  }
         }          }
   

Removed from v.1.207  
changed lines
  Added in v.1.214


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