Diff for /servers/slapd/overlays/syncprov.c between versions 1.234 and 1.237

version 1.234, 2008/05/08 23:51:26 version 1.237, 2008/05/28 00:45:18
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.233 2008/05/06 01:03:47 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.236 2008/05/13 19:57:19 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 404  syncprov_findbase( Operation *op, fbase_ Line 404  syncprov_findbase( Operation *op, fbase_
                 slap_callback cb = {0};                  slap_callback cb = {0};
                 Operation fop;                  Operation fop;
                 SlapReply frs = { REP_RESULT };                  SlapReply frs = { REP_RESULT };
                 BackendInfo *bi;  
                 int rc;                  int rc;
   
                 fc->fss->s_flags ^= PS_FIND_BASE;                  fc->fss->s_flags ^= PS_FIND_BASE;
Line 412  syncprov_findbase( Operation *op, fbase_ Line 411  syncprov_findbase( Operation *op, fbase_
   
                 fop = *fc->fss->s_op;                  fop = *fc->fss->s_op;
   
                   fop.o_bd = fop.o_bd->bd_self;
                 fop.o_hdr = op->o_hdr;                  fop.o_hdr = op->o_hdr;
                 fop.o_bd = op->o_bd;  
                 fop.o_time = op->o_time;                  fop.o_time = op->o_time;
                 fop.o_tincr = op->o_tincr;                  fop.o_tincr = op->o_tincr;
                 bi = op->o_bd->bd_info;  
   
                 cb.sc_response = findbase_cb;                  cb.sc_response = findbase_cb;
                 cb.sc_private = fc;                  cb.sc_private = fc;
Line 434  syncprov_findbase( Operation *op, fbase_ Line 432  syncprov_findbase( Operation *op, fbase_
                 fop.ors_filter = &generic_filter;                  fop.ors_filter = &generic_filter;
                 fop.ors_filterstr = generic_filterstr;                  fop.ors_filterstr = generic_filterstr;
   
                 rc = overlay_op_walk( &fop, &frs, op_search, on->on_info, on );                  rc = fop.o_bd->be_search( &fop, &frs );
                 op->o_bd->bd_info = bi;  
         } else {          } else {
                 ldap_pvt_thread_mutex_unlock( &fc->fss->s_mutex );                  ldap_pvt_thread_mutex_unlock( &fc->fss->s_mutex );
                 fc->fbase = 1;                  fc->fbase = 1;
Line 1224  syncprov_matchops( Operation *op, opcook Line 1221  syncprov_matchops( Operation *op, opcook
                         }                          }
                 }                  }
   
                 if ( fc.fscope )                  if ( fc.fscope ) {
                         op2 = *ss->s_op;                          op2 = *ss->s_op;
                           op2.o_hdr = op->o_hdr;
                           op2.o_extra = op->o_extra;
                   }
   
                 /* check if current o_req_dn is in scope and matches filter */                  /* check if current o_req_dn is in scope and matches filter */
                 if ( fc.fscope && test_filter( &op2, e, ss->s_op->ors_filter ) ==                  if ( fc.fscope && test_filter( &op2, e, ss->s_op->ors_filter ) ==
Line 1616  syncprov_op_response( Operation *op, Sla Line 1616  syncprov_op_response( Operation *op, Sla
                                         sizeof(int));                                          sizeof(int));
                                 si->si_sids[i] = sid;                                  si->si_sids[i] = sid;
                         }                          }
                   } else {
                           /* internal ops that aren't meant to be replicated */
                           ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock );
                           return SLAP_CB_CONTINUE;
                 }                  }
   
                 /* Don't do any processing for consumer contextCSN updates */                  /* Don't do any processing for consumer contextCSN updates */

Removed from v.1.234  
changed lines
  Added in v.1.237


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