Diff for /servers/slapd/overlays/syncprov.c between versions 1.23 and 1.34

version 1.23, 2004/11/27 06:47:24 version 1.34, 2004/11/29 05:51:44
Line 65  typedef struct syncops { Line 65  typedef struct syncops {
         ldap_pvt_thread_mutex_t s_mutex;          ldap_pvt_thread_mutex_t s_mutex;
 } syncops;  } syncops;
   
 static int      sync_cid;  
   
 /* A received sync control */  /* A received sync control */
 typedef struct sync_control {  typedef struct sync_control {
         struct sync_cookie sr_state;          struct sync_cookie sr_state;
         int sr_rhint;          int sr_rhint;
 } sync_control;  } sync_control;
   
   #if 0 /* moved back to slap.h */
   #define o_sync  o_ctrlflag[slap_cids.sc_LDAPsync]
   #endif
 /* o_sync_mode uses data bits of o_sync */  /* o_sync_mode uses data bits of o_sync */
 #define o_sync  o_ctrlflag[sync_cid]  #define o_sync_mode     o_ctrlflag[slap_cids.sc_LDAPsync]
 #define o_sync_mode     o_ctrlflag[sync_cid]  
   
 #define SLAP_SYNC_NONE                                  (LDAP_SYNC_NONE<<SLAP_CONTROL_SHIFT)  #define SLAP_SYNC_NONE                                  (LDAP_SYNC_NONE<<SLAP_CONTROL_SHIFT)
 #define SLAP_SYNC_REFRESH                               (LDAP_SYNC_REFRESH_ONLY<<SLAP_CONTROL_SHIFT)  #define SLAP_SYNC_REFRESH                               (LDAP_SYNC_REFRESH_ONLY<<SLAP_CONTROL_SHIFT)
Line 94  typedef struct syncmatches { Line 94  typedef struct syncmatches {
 typedef struct syncprov_info_t {  typedef struct syncprov_info_t {
         syncops         *si_ops;          syncops         *si_ops;
         struct berval   si_ctxcsn;      /* ldapsync context */          struct berval   si_ctxcsn;      /* ldapsync context */
         int             si_gotcsn;      /* is our ctxcsn up to date? */          int             si_chkops;      /* checkpointing info */
           int             si_chktime;
           int             si_numops;      /* number of ops since last checkpoint */
           time_t  si_chklast;     /* time of last checkpoint */
         Avlnode *si_mods;       /* entries being modified */          Avlnode *si_mods;       /* entries being modified */
         ldap_pvt_thread_mutex_t si_csn_mutex;          ldap_pvt_thread_mutex_t si_csn_mutex;
         ldap_pvt_thread_mutex_t si_ops_mutex;          ldap_pvt_thread_mutex_t si_ops_mutex;
         ldap_pvt_thread_mutex_t si_mods_mutex;          ldap_pvt_thread_rdwr_t  si_mods_rwlock;
         char            si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];          char            si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
 } syncprov_info_t;  } syncprov_info_t;
   
Line 128  syncprov_state_ctrl( Line 131  syncprov_state_ctrl(
         Operation       *op,          Operation       *op,
         SlapReply       *rs,          SlapReply       *rs,
         Entry           *e,          Entry           *e,
         int                     entry_sync_state,          int             entry_sync_state,
         LDAPControl     **ctrls,          LDAPControl     **ctrls,
         int                     num_ctrls,          int             num_ctrls,
         int                     send_cookie,          int             send_cookie,
         struct berval   *cookie)          struct berval   *cookie )
 {  {
         Attribute* a;          Attribute* a;
         int ret;          int ret;
Line 142  syncprov_state_ctrl( Line 145  syncprov_state_ctrl(
         BerElementBuffer berbuf;          BerElementBuffer berbuf;
         BerElement *ber = (BerElement *)&berbuf;          BerElement *ber = (BerElement *)&berbuf;
   
         struct berval entryuuid_bv      = BER_BVNULL;          struct berval   entryuuid_bv = BER_BVNULL;
   
         ber_init2( ber, 0, LBER_USE_DER );          ber_init2( ber, 0, LBER_USE_DER );
         ber_set_option( ber, LBER_OPT_BER_MEMCTX, &op->o_tmpmemctx );          ber_set_option( ber, LBER_OPT_BER_MEMCTX, &op->o_tmpmemctx );
   
         ctrls[num_ctrls] = slap_sl_malloc ( sizeof ( LDAPControl ), op->o_tmpmemctx );          ctrls[num_ctrls] = op->o_tmpalloc( sizeof ( LDAPControl ), op->o_tmpmemctx );
   
         for ( a = e->e_attrs; a != NULL; a = a->a_next ) {          for ( a = e->e_attrs; a != NULL; a = a->a_next ) {
                 AttributeDescription *desc = a->a_desc;                  AttributeDescription *desc = a->a_desc;
Line 200  syncprov_done_ctrl( Line 203  syncprov_done_ctrl(
         ber_init2( ber, NULL, LBER_USE_DER );          ber_init2( ber, NULL, LBER_USE_DER );
         ber_set_option( ber, LBER_OPT_BER_MEMCTX, &op->o_tmpmemctx );          ber_set_option( ber, LBER_OPT_BER_MEMCTX, &op->o_tmpmemctx );
   
         ctrls[num_ctrls] = ch_malloc ( sizeof ( LDAPControl ) );          ctrls[num_ctrls] = op->o_tmpalloc( sizeof ( LDAPControl ), op->o_tmpmemctx );
   
         ber_printf( ber, "{" );          ber_printf( ber, "{" );
         if ( send_cookie && cookie ) {          if ( send_cookie && cookie ) {
Line 209  syncprov_done_ctrl( Line 212  syncprov_done_ctrl(
         if ( refreshDeletes == LDAP_SYNC_REFRESH_DELETES ) {          if ( refreshDeletes == LDAP_SYNC_REFRESH_DELETES ) {
                 ber_printf( ber, "b", refreshDeletes );                  ber_printf( ber, "b", refreshDeletes );
         }          }
         ber_printf( ber, "N}" );                  ber_printf( ber, "N}" );
   
         ctrls[num_ctrls]->ldctl_oid = LDAP_CONTROL_SYNC_DONE;          ctrls[num_ctrls]->ldctl_oid = LDAP_CONTROL_SYNC_DONE;
         ctrls[num_ctrls]->ldctl_iscritical = (op->o_sync == SLAP_CONTROL_CRITICAL);          ctrls[num_ctrls]->ldctl_iscritical = (op->o_sync == SLAP_CONTROL_CRITICAL);
Line 424  findbase_cb( Operation *op, SlapReply *r Line 427  findbase_cb( Operation *op, SlapReply *r
                         }                          }
                 }                  }
         }          }
           if ( rs->sr_err != LDAP_SUCCESS ) {
                   Debug( LDAP_DEBUG_ANY, "findbase failed! %d\n", rs->sr_err,0,0 );
           }
         return LDAP_SUCCESS;          return LDAP_SUCCESS;
 }  }
   
Line 449  syncprov_findbase( Operation *op, fbase_ Line 455  syncprov_findbase( Operation *op, fbase_
         fop.o_tag = LDAP_REQ_SEARCH;          fop.o_tag = LDAP_REQ_SEARCH;
         fop.ors_scope = LDAP_SCOPE_BASE;          fop.ors_scope = LDAP_SCOPE_BASE;
         fop.ors_deref = fc->fss->s_op->ors_deref;          fop.ors_deref = fc->fss->s_op->ors_deref;
           fop.ors_limit = NULL;
         fop.ors_slimit = 1;          fop.ors_slimit = 1;
         fop.ors_tlimit = SLAP_NO_LIMIT;          fop.ors_tlimit = SLAP_NO_LIMIT;
         fop.ors_attrs = slap_anlist_no_attrs;          fop.ors_attrs = slap_anlist_no_attrs;
Line 471  syncprov_findbase( Operation *op, fbase_ Line 478  syncprov_findbase( Operation *op, fbase_
 }  }
   
 /* syncprov_findcsn:  /* syncprov_findcsn:
  *   This function has three different purposes, but they all use a search   *   This function has two different purposes, but they both use a search
  * that filters on entryCSN so they're combined here.   * that filters on entryCSN so they're combined here.
  * 1: when the current contextCSN is unknown (i.e., at server start time)   * 1: when the current contextCSN is known and we have a sync cookie, we search
  * and a syncrepl search has arrived with a cookie, we search for all entries  
  * with CSN >= the cookie CSN, and store the maximum as our contextCSN. Also,  
  * we expect to find the cookie CSN in the search results, and note if we did  
  * or not. If not, we assume the cookie is stale. (This may be too restrictive,  
  * notice case 2.)  
  *  
  * 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. (Used to search for =.) If an
  * entry is found, the cookie CSN is valid, otherwise it is stale. Case 1 is   * entry is found, the cookie CSN is valid, otherwise it is stale.
  * considered a special case of case 2, and both are generally called the  
  * "find CSN" task.  
  *   *
  * 3: during a refresh phase, we search for all entries with CSN <= the cookie   * 2: 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
  * in SyncID sets, even if there's only one match.   * in SyncID sets, even if there's only one match.
  */   */
 #define FIND_CSN        1  #define FIND_CSN        1
 #define FIND_PRESENT    2  #define FIND_PRESENT    2
   
 typedef struct fcsn_cookie {  
         struct berval maxcsn;  
         int gotmatch;  
 } fcsn_cookie;  
   
 static int  static int
 findcsn_cb( Operation *op, SlapReply *rs )  findcsn_cb( Operation *op, SlapReply *rs )
 {  {
         slap_callback *sc = op->o_callback;          slap_callback *sc = op->o_callback;
   
         if ( rs->sr_type == REP_SEARCH && rs->sr_err == LDAP_SUCCESS ) {          if ( rs->sr_type == REP_SEARCH && rs->sr_err == LDAP_SUCCESS ) {
                 /* If the private pointer is set, it points to an fcsn_cookie                  sc->sc_private = (void *)1;
                  * and we want to record the maxcsn and match state.  
                  */  
                 if ( sc->sc_private ) {  
                         int i;  
                         fcsn_cookie *fc = sc->sc_private;  
                         sync_control *srs = op->o_controls[sync_cid];  
                         Attribute *a = attr_find(rs->sr_entry->e_attrs,  
                                 slap_schema.si_ad_entryCSN );  
                         i = ber_bvcmp( &a->a_vals[0], srs->sr_state.ctxcsn );  
                         if ( i == 0 ) fc->gotmatch = 1;  
                         i = ber_bvcmp( &a->a_vals[0], &fc->maxcsn );  
                         if ( i > 0 ) {  
                                 fc->maxcsn.bv_len = a->a_vals[0].bv_len;  
                                 strcpy(fc->maxcsn.bv_val, a->a_vals[0].bv_val );  
                         }  
                 } else {  
                 /* Otherwise, if the private pointer is not set, we just  
                  * want to know if any entry matched the filter.  
                  */  
                         sc->sc_private = (void *)1;  
                 }  
         }          }
         return LDAP_SUCCESS;          return LDAP_SUCCESS;
 }  }
Line 588  syncprov_findcsn( Operation *op, int mod Line 560  syncprov_findcsn( Operation *op, int mod
         Filter cf;          Filter cf;
         AttributeAssertion eq;          AttributeAssertion eq;
         int rc;          int rc;
         fcsn_cookie fcookie;  
         fpres_cookie pcookie;          fpres_cookie pcookie;
         int locked = 0;          int locked = 0;
         sync_control *srs = op->o_controls[sync_cid];          sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync];
   
         if ( srs->sr_state.ctxcsn->bv_len >= LDAP_LUTIL_CSNSTR_BUFSIZE ) {          if ( srs->sr_state.ctxcsn->bv_len >= LDAP_LUTIL_CSNSTR_BUFSIZE ) {
                 return LDAP_OTHER;                  return LDAP_OTHER;
Line 602  syncprov_findcsn( Operation *op, int mod Line 573  syncprov_findcsn( Operation *op, int mod
   
         fbuf.bv_val = buf;          fbuf.bv_val = buf;
         if ( mode == FIND_CSN ) {          if ( mode == FIND_CSN ) {
                 if ( !si->si_gotcsn ) {                  fop.ors_attrsonly = 1;
                         /* If we don't know the current ctxcsn, find it */                  fop.ors_attrs = slap_anlist_no_attrs;
                         ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );                  fop.ors_slimit = 1;
                         locked = 1;                  cb.sc_private = NULL;
                 }  
                 if ( !si->si_gotcsn ) {  
                         cf.f_choice = LDAP_FILTER_GE;  
                         fop.ors_attrsonly = 0;  
                         fop.ors_attrs = csn_anlist;  
                         fop.ors_slimit = SLAP_NO_LIMIT;  
                         cb.sc_private = &fcookie;  
                         fcookie.maxcsn.bv_val = cbuf;  
                         fcookie.maxcsn.bv_len = 0;  
                         fcookie.gotmatch = 0;  
                         fbuf.bv_len = sprintf( buf, "(entryCSN>=%s)", srs->sr_state.ctxcsn->bv_val );  
                 } else {  
                         if ( locked ) {  
                                 ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );  
                                 locked = 0;  
                         }  
                         cf.f_choice = LDAP_FILTER_LE;  
                         fop.ors_attrsonly = 1;  
                         fop.ors_attrs = slap_anlist_no_attrs;  
                         fop.ors_slimit = 1;  
                         cb.sc_private = NULL;  
                         fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)", srs->sr_state.ctxcsn->bv_val );  
                 }  
                 cb.sc_response = findcsn_cb;                  cb.sc_response = findcsn_cb;
   
         } else if ( mode == FIND_PRESENT ) {          } else if ( mode == FIND_PRESENT ) {
                 cf.f_choice = LDAP_FILTER_LE;  
                 fop.ors_attrsonly = 0;                  fop.ors_attrsonly = 0;
                 fop.ors_attrs = uuid_anlist;                  fop.ors_attrs = uuid_anlist;
                 fop.ors_slimit = SLAP_NO_LIMIT;                  fop.ors_slimit = SLAP_NO_LIMIT;
Line 642  syncprov_findcsn( Operation *op, int mod Line 589  syncprov_findcsn( Operation *op, int mod
                 cb.sc_response = findpres_cb;                  cb.sc_response = findpres_cb;
                 pcookie.num = 0;                  pcookie.num = 0;
                 pcookie.uuids = NULL;                  pcookie.uuids = NULL;
                 fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)", srs->sr_state.ctxcsn->bv_val );  
         }          }
           cf.f_choice = LDAP_FILTER_LE;
         cf.f_ava = &eq;          cf.f_ava = &eq;
         cf.f_av_desc = slap_schema.si_ad_entryCSN;          cf.f_av_desc = slap_schema.si_ad_entryCSN;
         cf.f_av_value = *srs->sr_state.ctxcsn;          cf.f_av_value = *srs->sr_state.ctxcsn;
         cf.f_next = NULL;          cf.f_next = NULL;
           fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)",
                   srs->sr_state.ctxcsn->bv_val );
   
         fop.o_callback = &cb;          fop.o_callback = &cb;
           fop.ors_limit = NULL;
         fop.ors_tlimit = SLAP_NO_LIMIT;          fop.ors_tlimit = SLAP_NO_LIMIT;
         fop.ors_filter = &cf;          fop.ors_filter = &cf;
         fop.ors_filterstr = fbuf;          fop.ors_filterstr = fbuf;
Line 659  syncprov_findcsn( Operation *op, int mod Line 609  syncprov_findcsn( Operation *op, int mod
         fop.o_bd->bd_info = (BackendInfo *)on;          fop.o_bd->bd_info = (BackendInfo *)on;
   
         if ( mode == FIND_CSN ) {          if ( mode == FIND_CSN ) {
                 if ( !si->si_gotcsn ) {                  if ( cb.sc_private ) return LDAP_SUCCESS;
                         strcpy(si->si_ctxcsnbuf, fcookie.maxcsn.bv_val);  
                         si->si_ctxcsn.bv_len = fcookie.maxcsn.bv_len;  
                         si->si_gotcsn = 1;  
                         ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );  
                         if ( fcookie.gotmatch ) return LDAP_SUCCESS;  
                           
                 } else {  
                         if ( cb.sc_private ) return LDAP_SUCCESS;  
                 }  
         } else if ( mode == FIND_PRESENT ) {          } else if ( mode == FIND_PRESENT ) {
                 return LDAP_SUCCESS;                  return LDAP_SUCCESS;
         }          }
Line 764  syncprov_sendresp( Operation *op, opcook Line 705  syncprov_sendresp( Operation *op, opcook
                 e_uuid.e_nname = opc->sndn;                  e_uuid.e_nname = opc->sndn;
                 rs.sr_entry = &e_uuid;                  rs.sr_entry = &e_uuid;
                 if ( opc->sreference ) {                  if ( opc->sreference ) {
                         struct berval bv;                          struct berval bv = BER_BVNULL;
                         bv.bv_val = NULL;  
                         bv.bv_len = 0;  
                         rs.sr_ref = &bv;                          rs.sr_ref = &bv;
                         send_search_reference( &sop, &rs );                          send_search_reference( &sop, &rs );
                 } else {                  } else {
Line 776  syncprov_sendresp( Operation *op, opcook Line 715  syncprov_sendresp( Operation *op, opcook
         default:          default:
                 assert(0);                  assert(0);
         }          }
         free( rs.sr_ctrls[0] );          op->o_tmpfree( rs.sr_ctrls[0], op->o_tmpmemctx );
           rs.sr_ctrls = NULL;
         return rs.sr_err;          return rs.sr_err;
 }  }
   
Line 855  syncprov_matchops( Operation *op, opcook Line 795  syncprov_matchops( Operation *op, opcook
         Attribute *a;          Attribute *a;
         int rc;          int rc;
         struct berval newdn;          struct berval newdn;
           int freefdn = 0;
   
         fc.fdn = &op->o_req_ndn;          fc.fdn = &op->o_req_ndn;
         /* compute new DN */          /* compute new DN */
Line 864  syncprov_matchops( Operation *op, opcook Line 805  syncprov_matchops( Operation *op, opcook
                 else dnParent( fc.fdn, &pdn );                  else dnParent( fc.fdn, &pdn );
                 build_new_dn( &newdn, &pdn, &op->orr_nnewrdn, op->o_tmpmemctx );                  build_new_dn( &newdn, &pdn, &op->orr_nnewrdn, op->o_tmpmemctx );
                 fc.fdn = &newdn;                  fc.fdn = &newdn;
                   freefdn = 1;
         }          }
         if ( op->o_tag != LDAP_REQ_ADD ) {          if ( op->o_tag != LDAP_REQ_ADD ) {
                 op->o_bd->bd_info = (BackendInfo *)on->on_info;                  op->o_bd->bd_info = (BackendInfo *)on->on_info;
Line 874  syncprov_matchops( Operation *op, opcook Line 816  syncprov_matchops( Operation *op, opcook
                 e = op->ora_e;                  e = op->ora_e;
         }          }
   
           /* Never replicate these */
           if ( is_entry_syncConsumerSubentry( e )) {
                   goto done;
           }
         if ( saveit ) {          if ( saveit ) {
                 ber_dupbv_x( &opc->sdn, &e->e_name, op->o_tmpmemctx );                  ber_dupbv_x( &opc->sdn, &e->e_name, op->o_tmpmemctx );
                 ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx );                  ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx );
Line 943  syncprov_matchops( Operation *op, opcook Line 889  syncprov_matchops( Operation *op, opcook
                 }                  }
         }          }
         ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );          ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );
   done:
         if ( op->o_tag != LDAP_REQ_ADD ) {          if ( op->o_tag != LDAP_REQ_ADD ) {
                 op->o_bd->bd_info = (BackendInfo *)on->on_info;                  op->o_bd->bd_info = (BackendInfo *)on->on_info;
                 be_entry_release_r( op, e );                  be_entry_release_r( op, e );
                 op->o_bd->bd_info = (BackendInfo *)on;                  op->o_bd->bd_info = (BackendInfo *)on;
         }          }
           if ( freefdn ) {
                   op->o_tmpfree( fc.fdn->bv_val, op->o_tmpmemctx );
           }
 }  }
   
 static int  static int
Line 968  syncprov_op_cleanup( Operation *op, Slap Line 918  syncprov_op_cleanup( Operation *op, Slap
   
         /* Remove op from lock table */          /* Remove op from lock table */
         mtdummy.mt_op = op;          mtdummy.mt_op = op;
         ldap_pvt_thread_mutex_lock( &si->si_mods_mutex );          ldap_pvt_thread_rdwr_rlock( &si->si_mods_rwlock );
         mt = avl_find( si->si_mods, &mtdummy, sp_avl_cmp );          mt = avl_find( si->si_mods, &mtdummy, sp_avl_cmp );
           ldap_pvt_thread_rdwr_runlock( &si->si_mods_rwlock );
         if ( mt ) {          if ( mt ) {
                 modinst *mi = mt->mt_mods;                  modinst *mi = mt->mt_mods;
                   
                 /* If there are more, promote the next one */                  /* If there are more, promote the next one */
                 ldap_pvt_thread_mutex_lock( &mt->mt_mutex );                  ldap_pvt_thread_mutex_lock( &mt->mt_mutex );
                 if ( mi->mi_next ) {                  if ( mi->mi_next ) {
Line 980  syncprov_op_cleanup( Operation *op, Slap Line 931  syncprov_op_cleanup( Operation *op, Slap
                         mt->mt_op = mt->mt_mods->mi_op;                          mt->mt_op = mt->mt_mods->mi_op;
                         ldap_pvt_thread_mutex_unlock( &mt->mt_mutex );                          ldap_pvt_thread_mutex_unlock( &mt->mt_mutex );
                 } else {                  } else {
                           ldap_pvt_thread_rdwr_wlock( &si->si_mods_rwlock );
                         avl_delete( &si->si_mods, mt, sp_avl_cmp );                          avl_delete( &si->si_mods, mt, sp_avl_cmp );
                           ldap_pvt_thread_rdwr_wunlock( &si->si_mods_rwlock );
                         ldap_pvt_thread_mutex_unlock( &mt->mt_mutex );                          ldap_pvt_thread_mutex_unlock( &mt->mt_mutex );
                         ldap_pvt_thread_mutex_destroy( &mt->mt_mutex );                          ldap_pvt_thread_mutex_destroy( &mt->mt_mutex );
                         ch_free( mt );                          ch_free( mt );
                 }                  }
         }          }
         ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );          if ( !BER_BVISNULL( &opc->suuid ))
                   op->o_tmpfree( opc->suuid.bv_val, op->o_tmpmemctx );
           if ( !BER_BVISNULL( &opc->sndn ))
                   op->o_tmpfree( opc->sndn.bv_val, op->o_tmpmemctx );
           if ( !BER_BVISNULL( &opc->sdn ))
                   op->o_tmpfree( opc->sdn.bv_val, op->o_tmpmemctx );
         op->o_callback = cb->sc_next;          op->o_callback = cb->sc_next;
         op->o_tmpfree(cb, op->o_tmpmemctx);          op->o_tmpfree(cb, op->o_tmpmemctx);
 }  }
   
   static void
   syncprov_checkpoint( Operation *op, SlapReply *rs, slap_overinst *on )
   {
           syncprov_info_t         *si = on->on_bi.bi_private;
           Modifications mod;
           Operation opm;
           struct berval bv[2];
           BackendInfo *orig;
           slap_callback cb = {0};
   
           mod.sml_values = bv;
           bv[1].bv_val = NULL;
           bv[0] = si->si_ctxcsn;
           mod.sml_nvalues = NULL;
           mod.sml_desc = slap_schema.si_ad_contextCSN;
           mod.sml_op = LDAP_MOD_REPLACE;
           mod.sml_next = NULL;
   
           cb.sc_response = slap_null_cb;
           opm = *op;
           opm.o_tag = LDAP_REQ_MODIFY;
           opm.o_callback = &cb;
           opm.orm_modlist = &mod;
           opm.o_req_dn = op->o_bd->be_suffix[0];
           opm.o_req_ndn = op->o_bd->be_nsuffix[0];
           orig = opm.o_bd->bd_info;
           opm.o_bd->bd_info = on->on_info->oi_orig;
           opm.o_bd->be_modify( &opm, rs );
   }
   
 static int  static int
 syncprov_op_response( Operation *op, SlapReply *rs )  syncprov_op_response( Operation *op, SlapReply *rs )
 {  {
Line 1008  syncprov_op_response( Operation *op, Sla Line 996  syncprov_op_response( Operation *op, Sla
                 cbuf[0] = '\0';                  cbuf[0] = '\0';
                 ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );
                 slap_get_commit_csn( op, &maxcsn );                  slap_get_commit_csn( op, &maxcsn );
                 if ( maxcsn.bv_val ) {                  if ( !BER_BVISNULL( &maxcsn ) ) {
                         strcpy( cbuf, maxcsn.bv_val );                          strcpy( cbuf, maxcsn.bv_val );
                         if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) {                          if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) {
                                 strcpy( si->si_ctxcsnbuf, cbuf );                                  strcpy( si->si_ctxcsnbuf, cbuf );
                                 si->si_ctxcsn.bv_len = maxcsn.bv_len;                                  si->si_ctxcsn.bv_len = maxcsn.bv_len;
                         }                          }
                         si->si_gotcsn = 1;                  }
   
                   si->si_numops++;
                   if ( si->si_chkops || si->si_chktime ) {
                           int do_check=0;
                           if ( si->si_chkops && si->si_numops >= si->si_chkops ) {
                                   do_check = 1;
                                   si->si_numops = 0;
                           }
                           if ( si->si_chktime &&
                                   (op->o_time - si->si_chklast >= si->si_chktime )) {
                                   do_check = 1;
                                   si->si_chklast = op->o_time;
                           }
                           if ( do_check ) {
                                   syncprov_checkpoint( op, rs, on );
                           }
                 }                  }
                 ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
   
Line 1050  syncprov_op_response( Operation *op, Sla Line 1054  syncprov_op_response( Operation *op, Sla
         return SLAP_CB_CONTINUE;          return SLAP_CB_CONTINUE;
 }  }
   
 #if 0  /* We don't use a subentry to store the context CSN any more.
 /* We don't use a subentry to store the context CSN any more. But   * We expose the current context CSN as an operational attribute
  * we ought to expose the current context CSN as an operational attribute   * of the suffix entry.
  * somewhere, like on the suffix entry.  
  */   */
 static int  static int
 syncprov_op_compare( Operation *op, SlapReply *rs )  syncprov_op_compare( Operation *op, SlapReply *rs )
Line 1062  syncprov_op_compare( Operation *op, Slap Line 1065  syncprov_op_compare( Operation *op, Slap
         syncprov_info_t         *si = on->on_bi.bi_private;          syncprov_info_t         *si = on->on_bi.bi_private;
         int rc = SLAP_CB_CONTINUE;          int rc = SLAP_CB_CONTINUE;
   
         if ( dn_match( &op->o_req_ndn, &si->si_e->e_nname ) )          if ( dn_match( &op->o_req_ndn, op->o_bd->be_nsuffix ) &&
                   op->oq_compare.rs_ava->aa_desc == slap_schema.si_ad_contextCSN )
         {          {
                 Attribute *a;                  Entry e = {0};
                   Attribute a = {0};
                   struct berval bv[2];
   
                   e.e_name = op->o_bd->be_suffix[0];
                   e.e_nname = op->o_bd->be_nsuffix[0];
   
                   BER_BVZERO( &bv[1] );
                   bv[0] = si->si_ctxcsn;
   
                   a.a_desc = slap_schema.si_ad_contextCSN;
                   a.a_vals = bv;
                   a.a_nvals = a.a_vals;
   
                   ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );
   
                 ldap_pvt_thread_mutex_lock( &si->si_e_mutex );                  rs->sr_err = access_allowed( op, &e, op->oq_compare.rs_ava->aa_desc,
                           &op->oq_compare.rs_ava->aa_value, ACL_COMPARE, NULL );
                   if ( ! rs->sr_err ) {
                           rs->sr_err = LDAP_INSUFFICIENT_ACCESS;
                           goto return_results;
                   }
   
                 if ( get_assert( op ) &&                  if ( get_assert( op ) &&
                         ( test_filter( op, si->si_e, get_assertion( op ) ) != LDAP_COMPARE_TRUE ) )                          ( test_filter( op, &e, get_assertion( op ) ) != LDAP_COMPARE_TRUE ) )
                 {                  {
                         rs->sr_err = LDAP_ASSERTION_FAILED;                          rs->sr_err = LDAP_ASSERTION_FAILED;
                         goto return_results;                          goto return_results;
                 }                  }
   
                 rs->sr_err = access_allowed( op, si->si_e, op->oq_compare.rs_ava->aa_desc,  
                         &op->oq_compare.rs_ava->aa_value, ACL_COMPARE, NULL );  
                 if ( ! rs->sr_err ) {  
                         rs->sr_err = LDAP_INSUFFICIENT_ACCESS;  
                         goto return_results;  
                 }  
   
                 rs->sr_err = LDAP_NO_SUCH_ATTRIBUTE;                  rs->sr_err = LDAP_COMPARE_FALSE;
   
                 for ( a = attr_find( si->si_e->e_attrs, op->oq_compare.rs_ava->aa_desc );                  if ( value_find_ex( op->oq_compare.rs_ava->aa_desc,
                         a != NULL;                          SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH |
                         a = attr_find( a->a_next, op->oq_compare.rs_ava->aa_desc ) )                                  SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH,
                                   a.a_nvals, &op->oq_compare.rs_ava->aa_value, op->o_tmpmemctx ) == 0 )
                 {                  {
                         rs->sr_err = LDAP_COMPARE_FALSE;                          rs->sr_err = LDAP_COMPARE_TRUE;
   
                         if ( value_find_ex( op->oq_compare.rs_ava->aa_desc,  
                                 SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH |  
                                         SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH,  
                                 a->a_nvals, &op->oq_compare.rs_ava->aa_value, op->o_tmpmemctx ) == 0 )  
                         {  
                                 rs->sr_err = LDAP_COMPARE_TRUE;  
                                 break;  
                         }  
                 }                  }
   
 return_results:;  return_results:;
   
                 ldap_pvt_thread_mutex_unlock( &si->si_e_mutex );                  ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
   
                 send_ldap_result( op, rs );                  send_ldap_result( op, rs );
   
Line 1112  return_results:; Line 1121  return_results:;
                 rc = rs->sr_err;                  rc = rs->sr_err;
         }          }
   
         return SLAP_CB_CONTINUE;          return rc;
 }  }
 #endif  
           
 static int  static int
 syncprov_op_mod( Operation *op, SlapReply *rs )  syncprov_op_mod( Operation *op, SlapReply *rs )
 {  {
Line 1146  syncprov_op_mod( Operation *op, SlapRepl Line 1154  syncprov_op_mod( Operation *op, SlapRepl
   
                 /* See if we're already modifying this entry... */                  /* See if we're already modifying this entry... */
                 mtdummy.mt_op = op;                  mtdummy.mt_op = op;
                 ldap_pvt_thread_mutex_lock( &si->si_mods_mutex );                  ldap_pvt_thread_rdwr_wlock( &si->si_mods_rwlock );
                 mt = avl_find( si->si_mods, &mtdummy, sp_avl_cmp );                  mt = avl_find( si->si_mods, &mtdummy, sp_avl_cmp );
                 if ( mt ) {                  if ( mt ) {
                         ldap_pvt_thread_mutex_lock( &mt->mt_mutex );                          ldap_pvt_thread_mutex_lock( &mt->mt_mutex );
                         ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );                          ldap_pvt_thread_rdwr_wunlock( &si->si_mods_rwlock );
                         mt->mt_tail->mi_next = mi;                          mt->mt_tail->mi_next = mi;
                         mt->mt_tail = mi;                          mt->mt_tail = mi;
                         /* wait for this op to get to head of list */                          /* wait for this op to get to head of list */
Line 1161  syncprov_op_mod( Operation *op, SlapRepl Line 1169  syncprov_op_mod( Operation *op, SlapRepl
                         }                          }
                 } else {                  } else {
                         /* Record that we're modifying this entry now */                          /* Record that we're modifying this entry now */
                         mt = malloc( sizeof(modtarget) );                          mt = ch_malloc( sizeof(modtarget) );
                         mt->mt_mods = mi;                          mt->mt_mods = mi;
                         mt->mt_tail = mi;                          mt->mt_tail = mi;
                         mt->mt_op = mi->mi_op;                          mt->mt_op = mi->mi_op;
                         ldap_pvt_thread_mutex_init( &mt->mt_mutex );                          ldap_pvt_thread_mutex_init( &mt->mt_mutex );
                         avl_insert( &si->si_mods, mt, sp_avl_cmp, avl_dup_error );                          avl_insert( &si->si_mods, mt, sp_avl_cmp, avl_dup_error );
                         ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );                          ldap_pvt_thread_rdwr_wunlock( &si->si_mods_rwlock );
                 }                  }
   
                 if ( op->o_tag != LDAP_REQ_ADD )                  if ( op->o_tag != LDAP_REQ_ADD )
Line 1194  typedef struct searchstate { Line 1202  typedef struct searchstate {
 static int  static int
 syncprov_search_cleanup( Operation *op, SlapReply *rs )  syncprov_search_cleanup( Operation *op, SlapReply *rs )
 {  {
         searchstate *ss = op->o_callback->sc_private;  #if 0
         if ( rs->sr_ctrls ) {          if ( rs->sr_ctrls ) {
                 free( rs->sr_ctrls[0] );                  free( rs->sr_ctrls[0] );
                 op->o_tmpfree( rs->sr_ctrls, op->o_tmpmemctx );                  op->o_tmpfree( rs->sr_ctrls, op->o_tmpmemctx );
                   rs->sr_ctrls = NULL;
         }          }
   #endif
         return 0;          return 0;
 }  }
   
Line 1211  syncprov_detach_op( Operation *op, synco Line 1221  syncprov_detach_op( Operation *op, synco
         char *ptr;          char *ptr;
   
         /* count the search attrs */          /* count the search attrs */
         for (i=0; op->ors_attrs && op->ors_attrs[i].an_name.bv_val; i++) {          for (i=0; op->ors_attrs && !BER_BVISNULL( &op->ors_attrs[i].an_name ); i++) {
                 alen += op->ors_attrs[i].an_name.bv_len + 1;                  alen += op->ors_attrs[i].an_name.bv_len + 1;
         }          }
         /* Make a new copy of the operation */          /* Make a new copy of the operation */
Line 1228  syncprov_detach_op( Operation *op, synco Line 1238  syncprov_detach_op( Operation *op, synco
         if ( i ) {          if ( i ) {
                 op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1);                  op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1);
                 ptr = (char *)(op2->ors_attrs+i+1);                  ptr = (char *)(op2->ors_attrs+i+1);
                 for (i=0; op->ors_attrs[i].an_name.bv_val; i++) {                  for (i=0; !BER_BVISNULL( &op->ors_attrs[i].an_name ); i++) {
                         op2->ors_attrs[i] = op->ors_attrs[i];                          op2->ors_attrs[i] = op->ors_attrs[i];
                         op2->ors_attrs[i].an_name.bv_val = ptr;                          op2->ors_attrs[i].an_name.bv_val = ptr;
                         ptr = lutil_strcopy( ptr, op->ors_attrs[i].an_name.bv_val ) + 1;                          ptr = lutil_strcopy( ptr, op->ors_attrs[i].an_name.bv_val ) + 1;
                 }                  }
                 op2->ors_attrs[i].an_name.bv_val = NULL;                  BER_BVZERO( &op2->ors_attrs[i].an_name );
                 op2->ors_attrs[i].an_name.bv_len = 0;  
         } else {          } else {
                 ptr = (char *)(op2->o_hdr + 1);                  ptr = (char *)(op2->o_hdr + 1);
         }          }
Line 1266  syncprov_search_response( Operation *op, Line 1275  syncprov_search_response( Operation *op,
         searchstate *ss = op->o_callback->sc_private;          searchstate *ss = op->o_callback->sc_private;
         slap_overinst *on = ss->ss_on;          slap_overinst *on = ss->ss_on;
         syncprov_info_t         *si = on->on_bi.bi_private;          syncprov_info_t         *si = on->on_bi.bi_private;
         sync_control *srs = op->o_controls[sync_cid];          sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync];
   
         if ( rs->sr_type == REP_SEARCH || rs->sr_type == REP_SEARCHREF ) {          if ( rs->sr_type == REP_SEARCH || rs->sr_type == REP_SEARCHREF ) {
                 int i;                  int i;
                   /* If we got a referral without a referral object, there's
                    * something missing that we cannot replicate. Just ignore it.
                    * The consumer will abort because we didn't send the expected
                    * control.
                    */
                   if ( !rs->sr_entry ) {
                           assert( rs->sr_entry );
                           Debug( LDAP_DEBUG_ANY, "bogus referral in context\n",0,0,0 );
                           return SLAP_CB_CONTINUE;
                   }
                 if ( srs->sr_state.ctxcsn ) {                  if ( srs->sr_state.ctxcsn ) {
                         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 );
Line 1320  syncprov_search_response( Operation *op, Line 1339  syncprov_search_response( Operation *op,
                                         opc.sctxcsn = sr->s_csn;                                          opc.sctxcsn = sr->s_csn;
                                         opc.sreference = sr->s_isreference;                                          opc.sreference = sr->s_isreference;
                                         e = NULL;                                          e = NULL;
                                           
                                         if ( sr->s_mode != LDAP_SYNC_DELETE ) {                                          if ( sr->s_mode != LDAP_SYNC_DELETE ) {
                                                 op->o_bd->bd_info = (BackendInfo *)on->on_info;                                                  op->o_bd->bd_info = (BackendInfo *)on->on_info;
                                                 rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e );                                                  rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e );
Line 1375  syncprov_op_search( Operation *op, SlapR Line 1394  syncprov_op_search( Operation *op, SlapR
                 return rs->sr_err;                  return rs->sr_err;
         }          }
   
         srs = op->o_controls[sync_cid];          srs = op->o_controls[slap_cids.sc_LDAPsync];
   
         /* If this is a persistent search, set it up right away */          /* If this is a persistent search, set it up right away */
         if ( op->o_sync_mode & SLAP_SYNC_PERSIST ) {          if ( op->o_sync_mode & SLAP_SYNC_PERSIST ) {
Line 1445  syncprov_op_search( Operation *op, SlapR Line 1464  syncprov_op_search( Operation *op, SlapR
                                         rs->sr_ctrls = ctrls;                                          rs->sr_ctrls = ctrls;
                                         rs->sr_err = LDAP_SUCCESS;                                          rs->sr_err = LDAP_SUCCESS;
                                         send_ldap_result( op, rs );                                          send_ldap_result( op, rs );
                                           rs->sr_ctrls = NULL;
                                         return rs->sr_err;                                          return rs->sr_err;
                                 }                                  }
                                 goto shortcut;                                  goto shortcut;
                         } else                           } else
                         /* If context has changed, check for Present UUIDs */                          /* If context has changed, check for Present UUIDs */
                         if ( syncprov_findcsn( op, FIND_PRESENT ) != LDAP_SUCCESS ) {                          if ( syncprov_findcsn( op, FIND_PRESENT ) != LDAP_SUCCESS ) {
                                 send_ldap_result( op, rs );                                  send_ldap_result( op, rs );
Line 1457  syncprov_op_search( Operation *op, SlapR Line 1477  syncprov_op_search( Operation *op, SlapR
                 }                  }
         }          }
   
         /* If we didn't get a cookie and we don't know our contextcsn, try to  
          * find it anyway.  
          */  
         if ( !gotstate && !si->si_gotcsn ) {  
                 struct berval bv = BER_BVC("1"), *old;  
                   
                 old = srs->sr_state.ctxcsn;  
                 srs->sr_state.ctxcsn = &bv;  
                 syncprov_findcsn( op, FIND_CSN );  
                 srs->sr_state.ctxcsn = old;  
         }  
   
         /* Append CSN range to search filter, save original filter          /* Append CSN range to search filter, save original filter
          * for persistent search evaluation           * for persistent search evaluation
          */           */
Line 1483  syncprov_op_search( Operation *op, SlapR Line 1491  syncprov_op_search( Operation *op, SlapR
         fava->f_choice = LDAP_FILTER_LE;          fava->f_choice = LDAP_FILTER_LE;
         fava->f_ava = op->o_tmpalloc( sizeof(AttributeAssertion), op->o_tmpmemctx );          fava->f_ava = op->o_tmpalloc( sizeof(AttributeAssertion), op->o_tmpmemctx );
         fava->f_ava->aa_desc = slap_schema.si_ad_entryCSN;          fava->f_ava->aa_desc = slap_schema.si_ad_entryCSN;
           ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );
         ber_dupbv_x( &fava->f_ava->aa_value, &si->si_ctxcsn, op->o_tmpmemctx );          ber_dupbv_x( &fava->f_ava->aa_value, &si->si_ctxcsn, op->o_tmpmemctx );
           ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
         fand->f_and = fava;          fand->f_and = fava;
         if ( gotstate ) {          if ( gotstate ) {
                 fava->f_next = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx );                  fava->f_next = op->o_tmpalloc( sizeof(Filter), op->o_tmpmemctx );
Line 1509  shortcut: Line 1519  shortcut:
         cb->sc_next = op->o_callback;          cb->sc_next = op->o_callback;
         op->o_callback = cb;          op->o_callback = cb;
   
   #if 0   /* I don't think we need to shortcircuit back-bdb any more */
         op->o_sync_mode &= SLAP_CONTROL_MASK;          op->o_sync_mode &= SLAP_CONTROL_MASK;
   #endif
   
         /* If this is a persistent search and no changes were reported during          /* If this is a persistent search and no changes were reported during
          * the refresh phase, just invoke the response callback to transition           * the refresh phase, just invoke the response callback to transition
Line 1525  shortcut: Line 1537  shortcut:
 }  }
   
 static int  static int
   syncprov_operational(
           Operation *op,
           SlapReply *rs )
   {
           slap_overinst           *on = (slap_overinst *)op->o_bd->bd_info;
           syncprov_info_t         *si = (syncprov_info_t *)on->on_bi.bi_private;
   
           if ( rs->sr_entry &&
                   dn_match( &rs->sr_entry->e_nname, op->o_bd->be_nsuffix )) {
   
                   if ( SLAP_OPATTRS( rs->sr_attr_flags ) ||
                           ad_inlist( slap_schema.si_ad_contextCSN, rs->sr_attrs )) {
                           Attribute *a, **ap = NULL;
   
                           for ( a=rs->sr_entry->e_attrs; a; a=a->a_next ) {
                                   if ( a->a_desc == slap_schema.si_ad_contextCSN )
                                           break;
                           }
   
                           if ( !a ) {
                                   for ( ap = &rs->sr_operational_attrs; *ap; ap=&(*ap)->a_next );
   
                                   a = ch_malloc( sizeof(Attribute));
                                   a->a_desc = slap_schema.si_ad_contextCSN;
                                   a->a_vals = ch_malloc( 2 * sizeof(struct berval));
                                   a->a_vals[1].bv_val = NULL;
                                   a->a_nvals = a->a_vals;
                                   a->a_next = NULL;
                                   a->a_flags = 0;
                                   *ap = a;
                           }
   
                           ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );
                           if ( !ap ) {
                                   strcpy( a->a_vals[0].bv_val, si->si_ctxcsnbuf );
                           } else {
                                   ber_dupbv( &a->a_vals[0], &si->si_ctxcsn );
                           }
                           ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
                   }
           }
           return LDAP_SUCCESS;
   }
   
   static int
 syncprov_db_config(  syncprov_db_config(
         BackendDB       *be,          BackendDB       *be,
         const char      *fname,          const char      *fname,
Line 1554  syncprov_db_config( Line 1611  syncprov_db_config(
         return SLAP_CONF_UNKNOWN;          return SLAP_CONF_UNKNOWN;
 }  }
   
   /* Cheating - we have no thread pool context for these functions,
    * so make one.
    */
   typedef struct thread_keys {
           void *key;
           void *data;
           ldap_pvt_thread_pool_keyfree_t *xfree;
   } thread_keys;
   
   #define MAXKEYS 32
   /* A fake thread context */
   static thread_keys thrctx[MAXKEYS];
   
   /* Read any existing contextCSN from the underlying db.
    * Then search for any entries newer than that. If no value exists,
    * just generate it. Cache whatever result.
    */
   static int
   syncprov_db_open(
       BackendDB *be
   )
   {
           slap_overinst   *on = (slap_overinst *) be->bd_info;
           syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
   
           char opbuf[OPERATION_BUFFER_SIZE];
           Operation *op = (Operation *)opbuf;
           Entry *e;
           Attribute *a;
           int rc;
   
           memset(opbuf, 0, sizeof(opbuf));
           op->o_hdr = (Opheader *)(op+1);
           op->o_bd = be;
           op->o_dn = be->be_rootdn;
           op->o_ndn = be->be_rootndn;
           op->o_threadctx = thrctx;
           op->o_tmpmfuncs = &ch_mfuncs;
   
           op->o_bd->bd_info = on->on_info->oi_orig;
           rc = be_entry_get_rw( op, be->be_nsuffix, NULL,
                   slap_schema.si_ad_contextCSN, 0, &e );
   
           if ( e ) {
                   a = attr_find( e->e_attrs, slap_schema.si_ad_contextCSN );
                   if ( a ) {
                           si->si_ctxcsn.bv_len = a->a_nvals[0].bv_len;
                           if ( si->si_ctxcsn.bv_len >= sizeof(si->si_ctxcsnbuf ))
                                   si->si_ctxcsn.bv_len = sizeof(si->si_ctxcsnbuf)-1;
                           strncpy( si->si_ctxcsnbuf, a->a_nvals[0].bv_val,
                                   si->si_ctxcsn.bv_len );
                           si->si_ctxcsnbuf[si->si_ctxcsn.bv_len] = '\0';
                   }
                   be_entry_release_r( op, e );
           }
   
           if ( BER_BVISEMPTY( &si->si_ctxcsn ) ) {
                   slap_get_csn( op, si->si_ctxcsnbuf, sizeof(si->si_ctxcsnbuf),
                                   &si->si_ctxcsn, 0 );
           }
   
           op->o_bd->bd_info = (BackendInfo *)on;
           return 0;
   }
   
   /* Write the current contextCSN into the underlying db.
    */
   static int
   syncprov_db_close(
       BackendDB *be
   )
   {
       slap_overinst   *on = (slap_overinst *) be->bd_info;
       syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
           int i;
   
           if ( si->si_numops ) {
                   Connection conn;
                   char opbuf[OPERATION_BUFFER_SIZE];
                   Operation *op = (Operation *)opbuf;
                   SlapReply rs = {REP_RESULT};
   
                   connection_fake_init( &conn, op, thrctx );
                   op->o_bd = be;
                   op->o_dn = be->be_rootdn;
                   op->o_ndn = be->be_rootndn;
                   syncprov_checkpoint( op, &rs, on );
           }
           for ( i=0; thrctx[i].key; i++) {
                   if ( thrctx[i].xfree )
                           thrctx[i].xfree( thrctx[i].key, thrctx[i].data );
                   thrctx[i].key = NULL;
           }
   
       return 0;
   }
   
 static int  static int
 syncprov_db_init(  syncprov_db_init(
         BackendDB *be          BackendDB *be
Line 1566  syncprov_db_init( Line 1720  syncprov_db_init(
         on->on_bi.bi_private = si;          on->on_bi.bi_private = si;
         ldap_pvt_thread_mutex_init( &si->si_csn_mutex );          ldap_pvt_thread_mutex_init( &si->si_csn_mutex );
         ldap_pvt_thread_mutex_init( &si->si_ops_mutex );          ldap_pvt_thread_mutex_init( &si->si_ops_mutex );
           ldap_pvt_thread_rdwr_init( &si->si_mods_rwlock );
         si->si_ctxcsn.bv_val = si->si_ctxcsnbuf;          si->si_ctxcsn.bv_val = si->si_ctxcsnbuf;
   
         csn_anlist[0].an_desc = slap_schema.si_ad_entryCSN;          csn_anlist[0].an_desc = slap_schema.si_ad_entryCSN;
Line 1586  syncprov_db_destroy( Line 1741  syncprov_db_destroy(
         syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;          syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
   
         if ( si ) {          if ( si ) {
                   ldap_pvt_thread_rdwr_destroy( &si->si_mods_rwlock );
                 ldap_pvt_thread_mutex_destroy( &si->si_ops_mutex );                  ldap_pvt_thread_mutex_destroy( &si->si_ops_mutex );
                 ldap_pvt_thread_mutex_destroy( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_destroy( &si->si_csn_mutex );
                 ch_free( si );                  ch_free( si );
Line 1617  static int syncprov_parseCtrl ( Line 1773  static int syncprov_parseCtrl (
                 return LDAP_PROTOCOL_ERROR;                  return LDAP_PROTOCOL_ERROR;
         }          }
   
         if ( ctrl->ldctl_value.bv_len == 0 ) {          if ( BER_BVISEMPTY( &ctrl->ldctl_value ) ) {
                 rs->sr_text = "Sync control value is empty (or absent)";                  rs->sr_text = "Sync control value is empty (or absent)";
                 return LDAP_PROTOCOL_ERROR;                  return LDAP_PROTOCOL_ERROR;
         }          }
Line 1682  static int syncprov_parseCtrl ( Line 1838  static int syncprov_parseCtrl (
                 slap_parse_sync_cookie( &sr->sr_state );                  slap_parse_sync_cookie( &sr->sr_state );
         }          }
   
         op->o_controls[sync_cid] = sr;          op->o_controls[slap_cids.sc_LDAPsync] = sr;
   
         (void) ber_free( ber, 1 );          (void) ber_free( ber, 1 );
   
Line 1709  syncprov_init() Line 1865  syncprov_init()
   
         rc = register_supported_control( LDAP_CONTROL_SYNC,          rc = register_supported_control( LDAP_CONTROL_SYNC,
                 SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,                  SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,
                 syncprov_parseCtrl, &sync_cid );                  syncprov_parseCtrl, &slap_cids.sc_LDAPsync );
         if ( rc != LDAP_SUCCESS ) {          if ( rc != LDAP_SUCCESS ) {
                 fprintf( stderr, "Failed to register control %d\n", rc );                  fprintf( stderr, "Failed to register control %d\n", rc );
                 return rc;                  return rc;
Line 1719  syncprov_init() Line 1875  syncprov_init()
         syncprov.on_bi.bi_db_init = syncprov_db_init;          syncprov.on_bi.bi_db_init = syncprov_db_init;
         syncprov.on_bi.bi_db_config = syncprov_db_config;          syncprov.on_bi.bi_db_config = syncprov_db_config;
         syncprov.on_bi.bi_db_destroy = syncprov_db_destroy;          syncprov.on_bi.bi_db_destroy = syncprov_db_destroy;
           syncprov.on_bi.bi_db_open = syncprov_db_open;
           syncprov.on_bi.bi_db_close = syncprov_db_close;
   
         syncprov.on_bi.bi_op_abandon = syncprov_op_abandon;          syncprov.on_bi.bi_op_abandon = syncprov_op_abandon;
         syncprov.on_bi.bi_op_cancel = syncprov_op_abandon;          syncprov.on_bi.bi_op_cancel = syncprov_op_abandon;
   
         syncprov.on_bi.bi_op_add = syncprov_op_mod;          syncprov.on_bi.bi_op_add = syncprov_op_mod;
 #if 0  
         syncprov.on_bi.bi_op_compare = syncprov_op_compare;          syncprov.on_bi.bi_op_compare = syncprov_op_compare;
 #endif  
         syncprov.on_bi.bi_op_delete = syncprov_op_mod;          syncprov.on_bi.bi_op_delete = syncprov_op_mod;
         syncprov.on_bi.bi_op_modify = syncprov_op_mod;          syncprov.on_bi.bi_op_modify = syncprov_op_mod;
         syncprov.on_bi.bi_op_modrdn = syncprov_op_mod;          syncprov.on_bi.bi_op_modrdn = syncprov_op_mod;
         syncprov.on_bi.bi_op_search = syncprov_op_search;          syncprov.on_bi.bi_op_search = syncprov_op_search;
         syncprov.on_bi.bi_extended = syncprov_op_extended;          syncprov.on_bi.bi_extended = syncprov_op_extended;
           syncprov.on_bi.bi_operational = syncprov_operational;
   
 #if 0  #if 0
         syncprov.on_response = syncprov_response;          syncprov.on_response = syncprov_response;

Removed from v.1.23  
changed lines
  Added in v.1.34


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