Diff for /servers/slapd/overlays/syncprov.c between versions 1.91 and 1.97

version 1.91, 2005/08/02 06:43:27 version 1.97, 2005/08/15 03:36:56
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.90 2005/07/18 04:22:36 hallvard Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.96 2005/08/14 22:04: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 447  syncprov_findbase( Operation *op, fbase_ Line 447  syncprov_findbase( Operation *op, fbase_
  * was not checkpointed at the previous shutdown.   * was not checkpointed at the previous shutdown.
  *   *
  * 2: when the current contextCSN is known and we have a sync cookie, we search   * 2: when the current contextCSN is known and we have a sync cookie, we search
  * for one entry with CSN <= the cookie CSN. (Used to search for =.) If an   * for one entry with CSN = the cookie CSN. If not found, try <= cookie CSN.
  * entry is found, the cookie CSN is valid, otherwise it is stale.   * If an entry is found, the cookie CSN is valid, otherwise it is stale.
  *   *
  * 3: during a refresh phase, we search for all entries with CSN <= the cookie   * 3: during a refresh phase, we search for all entries with CSN <= the cookie
  * CSN, and generate Present records for them. We always collect this result   * CSN, and generate Present records for them. We always collect this result
Line 555  syncprov_findcsn( Operation *op, int mod Line 555  syncprov_findcsn( Operation *op, int mod
         int i, rc = LDAP_SUCCESS;          int i, rc = LDAP_SUCCESS;
         fpres_cookie pcookie;          fpres_cookie pcookie;
         sync_control *srs = NULL;          sync_control *srs = NULL;
           int findcsn_retry = 1;
   
         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 579  syncprov_findcsn( Operation *op, int mod Line 580  syncprov_findcsn( Operation *op, int mod
         fop.ors_filter = &cf;          fop.ors_filter = &cf;
         fop.ors_filterstr.bv_val = buf;          fop.ors_filterstr.bv_val = buf;
   
   again:
         switch( mode ) {          switch( mode ) {
         case FIND_MAXCSN:          case FIND_MAXCSN:
                 cf.f_choice = LDAP_FILTER_GE;                  cf.f_choice = LDAP_FILTER_GE;
Line 595  syncprov_findcsn( Operation *op, int mod Line 597  syncprov_findcsn( Operation *op, int mod
                 maxcsn.bv_len = si->si_ctxcsn.bv_len;                  maxcsn.bv_len = si->si_ctxcsn.bv_len;
                 break;                  break;
         case FIND_CSN:          case FIND_CSN:
                 cf.f_choice = LDAP_FILTER_LE;  
                 cf.f_av_value = srs->sr_state.ctxcsn;                  cf.f_av_value = srs->sr_state.ctxcsn;
                 fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)",                  /* Look for exact match the first time */
                         cf.f_av_value.bv_val );                  if ( findcsn_retry ) {
                           cf.f_choice = LDAP_FILTER_EQUALITY;
                           fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN=%s)",
                                   cf.f_av_value.bv_val );
                   /* On retry, look for <= */
                   } else {
                           cf.f_choice = LDAP_FILTER_LE;
                           fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)",
                                   cf.f_av_value.bv_val );
                   }
                 fop.ors_attrsonly = 1;                  fop.ors_attrsonly = 1;
                 fop.ors_attrs = slap_anlist_no_attrs;                  fop.ors_attrs = slap_anlist_no_attrs;
                 fop.ors_slimit = 1;                  fop.ors_slimit = 1;
Line 646  syncprov_findcsn( Operation *op, int mod Line 656  syncprov_findcsn( Operation *op, int mod
                 break;                  break;
         case FIND_CSN:          case FIND_CSN:
                 /* If matching CSN was not found, invalidate the context. */                  /* If matching CSN was not found, invalidate the context. */
                 if ( !cb.sc_private ) rc = LDAP_NO_SUCH_OBJECT;                  if ( !cb.sc_private ) {
                           /* If we didn't find an exact match, then try for <= */
                           if ( findcsn_retry ) {
                                   findcsn_retry = 0;
                                   goto again;
                           }
                           rc = LDAP_NO_SUCH_OBJECT;
                   }
                 break;                  break;
         case FIND_PRESENT:          case FIND_PRESENT:
                 op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx );                  op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx );
Line 2000  static ConfigTable spcfg[] = { Line 2017  static ConfigTable spcfg[] = {
                 sp_cf_gen, "( OLcfgOvAt:1.1 NAME 'olcSpCheckpoint' "                  sp_cf_gen, "( OLcfgOvAt:1.1 NAME 'olcSpCheckpoint' "
                         "DESC 'ContextCSN checkpoint interval in ops and minutes' "                          "DESC 'ContextCSN checkpoint interval in ops and minutes' "
                         "SYNTAX OMsDirectoryString SINGLE-VALUE )", NULL, NULL },                          "SYNTAX OMsDirectoryString SINGLE-VALUE )", NULL, NULL },
         { "syncprov-sessionlog", "size", 2, 2, 0, ARG_INT|ARG_MAGIC|SP_SESSL,          { "syncprov-sessionlog", "ops", 2, 2, 0, ARG_INT|ARG_MAGIC|SP_SESSL,
                 sp_cf_gen, "( OLcfgOvAt:1.2 NAME 'olcSpSessionlog' "                  sp_cf_gen, "( OLcfgOvAt:1.2 NAME 'olcSpSessionlog' "
                         "DESC 'Session log size in ops' "                          "DESC 'Session log size in ops' "
                         "SYNTAX OMsInteger SINGLE-VALUE )", NULL, NULL },                          "SYNTAX OMsInteger SINGLE-VALUE )", NULL, NULL },
Line 2286  static int syncprov_parseCtrl ( Line 2303  static int syncprov_parseCtrl (
         LDAPControl *ctrl )          LDAPControl *ctrl )
 {  {
         ber_tag_t tag;          ber_tag_t tag;
         BerElement *ber;          BerElementBuffer berbuf;
           BerElement *ber = (BerElement *)&berbuf;
         ber_int_t mode;          ber_int_t mode;
         ber_len_t len;          ber_len_t len;
         struct berval cookie = BER_BVNULL;          struct berval cookie = BER_BVNULL;
Line 2320  static int syncprov_parseCtrl ( Line 2338  static int syncprov_parseCtrl (
          *      }           *      }
          */           */
   
         ber = ber_init( &ctrl->ldctl_value );          ber_init2( ber, &ctrl->ldctl_value, 0 );
         if( ber == NULL ) {  
                 rs->sr_text = "internal error";  
                 return LDAP_OTHER;  
         }  
   
         if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) {          if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) {
                 rs->sr_text = "Sync control : mode decoding error";                  rs->sr_text = "Sync control : mode decoding error";
Line 2346  static int syncprov_parseCtrl ( Line 2360  static int syncprov_parseCtrl (
         tag = ber_peek_tag( ber, &len );          tag = ber_peek_tag( ber, &len );
   
         if ( tag == LDAP_TAG_SYNC_COOKIE ) {          if ( tag == LDAP_TAG_SYNC_COOKIE ) {
                 if (( ber_scanf( ber, /*{*/ "o", &cookie )) == LBER_ERROR ) {                  if (( ber_scanf( ber, /*{*/ "m", &cookie )) == LBER_ERROR ) {
                         rs->sr_text = "Sync control : cookie decoding error";                          rs->sr_text = "Sync control : cookie decoding error";
                         return LDAP_PROTOCOL_ERROR;                          return LDAP_PROTOCOL_ERROR;
                 }                  }
Line 2364  static int syncprov_parseCtrl ( Line 2378  static int syncprov_parseCtrl (
         sr = op->o_tmpcalloc( 1, sizeof(struct sync_control), op->o_tmpmemctx );          sr = op->o_tmpcalloc( 1, sizeof(struct sync_control), op->o_tmpmemctx );
         sr->sr_rhint = rhint;          sr->sr_rhint = rhint;
         if (!BER_BVISNULL(&cookie)) {          if (!BER_BVISNULL(&cookie)) {
                 ber_dupbv( &sr->sr_state.octet_str, &cookie );                  ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx );
                 slap_parse_sync_cookie( &sr->sr_state );                  slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx );
                   if ( sr->sr_state.rid == -1 ) {
                           rs->sr_text = "Sync control : cookie parsing error";
                           return LDAP_PROTOCOL_ERROR;
                   }
         }          }
   
         op->o_controls[slap_cids.sc_LDAPsync] = sr;          op->o_controls[slap_cids.sc_LDAPsync] = sr;
   
         (void) ber_free( ber, 1 );  
   
         op->o_sync = ctrl->ldctl_iscritical          op->o_sync = ctrl->ldctl_iscritical
                 ? SLAP_CONTROL_CRITICAL                  ? SLAP_CONTROL_CRITICAL
                 : SLAP_CONTROL_NONCRITICAL;                  : SLAP_CONTROL_NONCRITICAL;

Removed from v.1.91  
changed lines
  Added in v.1.97


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