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

version 1.147.2.30, 2008/07/08 20:33:51 version 1.237, 2008/05/28 00:45:18
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.147.2.29 2008/05/29 22:57:32 quanah 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 497  findmax_cb( Operation *op, SlapReply *rs Line 497  findmax_cb( Operation *op, SlapReply *rs
                 Attribute *a = attr_find( rs->sr_entry->e_attrs,                  Attribute *a = attr_find( rs->sr_entry->e_attrs,
                         slap_schema.si_ad_entryCSN );                          slap_schema.si_ad_entryCSN );
   
                 if ( a && ber_bvcmp( &a->a_vals[0], maxcsn ) > 0 &&                  if ( a && ber_bvcmp( &a->a_vals[0], maxcsn ) > 0 ) {
                         slap_parse_csn_sid( &a->a_vals[0] ) == slap_serverID ) {  
                         maxcsn->bv_len = a->a_vals[0].bv_len;                          maxcsn->bv_len = a->a_vals[0].bv_len;
                         strcpy( maxcsn->bv_val, a->a_vals[0].bv_val );                          strcpy( maxcsn->bv_val, a->a_vals[0].bv_val );
                 }                  }
Line 588  syncprov_findcsn( Operation *op, find_cs Line 587  syncprov_findcsn( Operation *op, find_cs
         sync_control *srs = NULL;          sync_control *srs = NULL;
         struct slap_limits_set fc_limits;          struct slap_limits_set fc_limits;
         int i, rc = LDAP_SUCCESS, findcsn_retry = 1;          int i, rc = LDAP_SUCCESS, findcsn_retry = 1;
         int maxid;          int maxid = 0;
   
         if ( mode != FIND_MAXCSN ) {          if ( mode != FIND_MAXCSN ) {
                 srs = op->o_controls[slap_cids.sc_LDAPsync];                  srs = op->o_controls[slap_cids.sc_LDAPsync];
Line 614  again: Line 613  again:
         switch( mode ) {          switch( mode ) {
         case FIND_MAXCSN:          case FIND_MAXCSN:
                 cf.f_choice = LDAP_FILTER_GE;                  cf.f_choice = LDAP_FILTER_GE;
                 /* If there are multiple CSNs, use the one with our serverID */                  cf.f_av_value = si->si_ctxcsn[0];
                 for ( i=0; i<si->si_numcsns; i++) {                  /* If there are multiple CSNs, use the largest */
                         if ( slap_serverID == si->si_sids[i] ) {                  for ( i=1; i<si->si_numcsns; i++) {
                           if ( ber_bvcmp( &cf.f_av_value, &si->si_ctxcsn[i] ) < 0 ) {
                                   cf.f_av_value = si->si_ctxcsn[i];
                                 maxid = i;                                  maxid = i;
                                 break;  
                         }                          }
                 }                  }
                 if ( i == si->si_numcsns ) {  
                         /* No match: this is multimaster, and none of the content in the DB  
                          * originated locally. Treat like no CSN.  
                          */  
                         return LDAP_NO_SUCH_OBJECT;  
                 }  
                 cf.f_av_value = si->si_ctxcsn[maxid];  
                 fop.ors_filterstr.bv_len = snprintf( buf, sizeof( buf ),                  fop.ors_filterstr.bv_len = snprintf( buf, sizeof( buf ),
                         "(entryCSN>=%s)", cf.f_av_value.bv_val );                          "(entryCSN>=%s)", cf.f_av_value.bv_val );
                 if ( fop.ors_filterstr.bv_len < 0 || fop.ors_filterstr.bv_len >= sizeof( buf ) ) {                  if ( fop.ors_filterstr.bv_len < 0 || fop.ors_filterstr.bv_len >= sizeof( buf ) ) {
Line 1181  syncprov_matchops( Operation *op, opcook Line 1174  syncprov_matchops( Operation *op, opcook
                 sprev = ss, ss=snext)                  sprev = ss, ss=snext)
         {          {
                 Operation op2;                  Operation op2;
                 Opheader oh;  
                 syncmatches *sm;                  syncmatches *sm;
                 int found = 0;                  int found = 0;
   
Line 1231  syncprov_matchops( Operation *op, opcook Line 1223  syncprov_matchops( Operation *op, opcook
   
                 if ( fc.fscope ) {                  if ( fc.fscope ) {
                         op2 = *ss->s_op;                          op2 = *ss->s_op;
                         oh = *op->o_hdr;                          op2.o_hdr = op->o_hdr;
                         oh.oh_conn = ss->s_op->o_conn;  
                         oh.oh_connid = ss->s_op->o_connid;  
                         op2.o_hdr = &oh;  
                         op2.o_extra = op->o_extra;                          op2.o_extra = op->o_extra;
                 }                  }
   
Line 1607  syncprov_op_response( Operation *op, Sla Line 1596  syncprov_op_response( Operation *op, Sla
                 cbuf[0] = '\0';                  cbuf[0] = '\0';
                 ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );                  ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );
                 slap_get_commit_csn( op, &maxcsn );                  slap_get_commit_csn( op, &maxcsn );
                 if ( BER_BVISNULL( &maxcsn ) && SLAP_GLUE_SUBORDINATE( op->o_bd )) {  
                         /* syncrepl queues the CSN values in the db where  
                          * it is configured , not where the changes are made.  
                          * So look for a value in the glue db if we didn't  
                          * find any in this db.  
                          */  
                         BackendDB *be = op->o_bd;  
                         op->o_bd = select_backend( &be->be_nsuffix[0], 1);  
                         slap_get_commit_csn( op, &maxcsn );  
                         op->o_bd = be;  
                 }  
                 if ( !BER_BVISNULL( &maxcsn ) ) {                  if ( !BER_BVISNULL( &maxcsn ) ) {
                         int i, sid;                          int i, sid;
                         strcpy( cbuf, maxcsn.bv_val );                          strcpy( cbuf, maxcsn.bv_val );
Line 2118  syncprov_search_response( Operation *op, Line 2096  syncprov_search_response( Operation *op,
                         if ( op->o_abandon ) {                          if ( op->o_abandon ) {
                                 ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );                                  ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
                                 ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex );                                  ldap_pvt_thread_mutex_unlock( &ss->ss_so->s_mutex );
                                 /* syncprov_ab_cleanup will free this syncop */                                  syncprov_free_syncop( ss->ss_so );
                                 return SLAPD_ABANDON;                                  return SLAPD_ABANDON;
   
                         } else {                          } else {

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


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