Diff for /servers/slapd/overlays/syncprov.c between versions 1.22 and 1.29

version 1.22, 2004/11/27 06:29:10 version 1.29, 2004/11/27 14:08:25
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;
Line 147  syncprov_state_ctrl( Line 150  syncprov_state_ctrl(
         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 471  syncprov_findbase( Operation *op, fbase_ Line 474  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 556  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 569  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 585  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_tlimit = SLAP_NO_LIMIT;          fop.ors_tlimit = SLAP_NO_LIMIT;
Line 659  syncprov_findcsn( Operation *op, int mod Line 604  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 700  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 710  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;
 }  }
   
   static void
   syncprov_free_syncop( syncops *so )
   {
           syncres *sr, *srnext;
   
           ldap_pvt_thread_mutex_lock( &so->s_mutex );
           so->s_inuse--;
           if ( so->s_inuse > 0 ) {
                   ldap_pvt_thread_mutex_unlock( &so->s_mutex );
                   return;
           }
           ldap_pvt_thread_mutex_unlock( &so->s_mutex );
           filter_free( so->s_op->ors_filter );
           ch_free( so->s_op );
           ch_free( so->s_base.bv_val );
           for ( sr=so->s_res; sr; sr=srnext ) {
                   srnext = sr->s_next;
                   ch_free( sr );
           }
           ldap_pvt_thread_mutex_destroy( &so->s_mutex );
           ch_free( so );
   }
   
   static int
   syncprov_drop_psearch( syncops *so )
   {
           ldap_pvt_thread_mutex_lock( &so->s_op->o_conn->c_mutex );
           so->s_op->o_conn->c_n_ops_executing--;
           so->s_op->o_conn->c_n_ops_completed++;
           ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );
           syncprov_free_syncop( so );
   }
   
   static int
   syncprov_op_abandon( Operation *op, SlapReply *rs )
   {
           slap_overinst           *on = (slap_overinst *)op->o_bd->bd_info;
           syncprov_info_t         *si = on->on_bi.bi_private;
           syncops *so, *soprev;
   
           ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );
           for ( so=si->si_ops, soprev = (syncops *)&si->si_ops; so;
                   soprev=so, so=so->s_next ) {
                   if ( so->s_op->o_connid == op->o_connid &&
                           so->s_op->o_msgid == op->orn_msgid ) {
                                   so->s_op->o_abandon = 1;
                                   soprev->s_next = so->s_next;
                                   break;
                   }
           }
           ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );
           if ( so ) {
                   /* Is this really a Cancel exop? */
                   if ( op->o_tag != LDAP_REQ_ABANDON ) {
                           rs->sr_err = LDAP_CANCELLED;
                           send_ldap_result( so->s_op, rs );
                   }
                   syncprov_drop_psearch( so );
           }
           return SLAP_CB_CONTINUE;
   }
   
 /* Find which persistent searches are affected by this operation */  /* Find which persistent searches are affected by this operation */
 static void  static void
 syncprov_matchops( Operation *op, opcookie *opc, int saveit )  syncprov_matchops( Operation *op, opcookie *opc, int saveit )
Line 788  syncprov_matchops( Operation *op, opcook Line 785  syncprov_matchops( Operation *op, opcook
         syncprov_info_t         *si = on->on_bi.bi_private;          syncprov_info_t         *si = on->on_bi.bi_private;
   
         fbase_cookie fc;          fbase_cookie fc;
         syncops *ss;          syncops *ss, *sprev, *snext;
         Entry *e;          Entry *e;
         Attribute *a;          Attribute *a;
         int rc;          int rc;
Line 824  syncprov_matchops( Operation *op, opcook Line 821  syncprov_matchops( Operation *op, opcook
         }          }
   
         ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );          ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );
         for (ss = si->si_ops; ss; ss=ss->s_next)          for (ss = si->si_ops, sprev = (syncops *)&si->si_ops; ss;
                   sprev = ss, ss=snext)
         {          {
                 syncmatches *sm;                  syncmatches *sm;
                 int found = 0;                  int found = 0;
   
                   snext = ss->s_next;
                 /* validate base */                  /* validate base */
                 fc.fss = ss;                  fc.fss = ss;
                 fc.fbase = 0;                  fc.fbase = 0;
                 fc.fscope = 0;                  fc.fscope = 0;
   
                   /* If the base of the search is missing, signal a refresh */
                 rc = syncprov_findbase( op, &fc );                  rc = syncprov_findbase( op, &fc );
                 if ( rc != LDAP_SUCCESS ) continue;                  if ( rc != LDAP_SUCCESS ) {
                           SlapReply rs = {REP_RESULT};
                           send_ldap_error( ss->s_op, &rs, LDAP_SYNC_REFRESH_REQUIRED,
                                   "search base has changed" );
                           sprev->s_next = snext;
                           syncprov_drop_psearch( ss );
                           continue;
                   }
   
                 /* If we're sending results now, look for this op in old matches */                  /* If we're sending results now, look for this op in old matches */
                 if ( !saveit ) {                  if ( !saveit ) {
Line 877  syncprov_matchops( Operation *op, opcook Line 885  syncprov_matchops( Operation *op, opcook
         }          }
 }  }
   
 static void  
 syncprov_free_syncop( syncops *so )  
 {  
         syncres *sr, *srnext;  
   
         ldap_pvt_thread_mutex_lock( &so->s_mutex );  
         so->s_inuse--;  
         if ( so->s_inuse > 0 ) {  
                 ldap_pvt_thread_mutex_unlock( &so->s_mutex );  
                 return;  
         }  
         ldap_pvt_thread_mutex_unlock( &so->s_mutex );  
         filter_free( so->s_op->ors_filter );  
         ch_free( so->s_op );  
         ch_free( so->s_base.bv_val );  
         for ( sr=so->s_res; sr; sr=srnext ) {  
                 srnext = sr->s_next;  
                 ch_free( sr );  
         }  
         ldap_pvt_thread_mutex_destroy( &so->s_mutex );  
         ch_free( so );  
 }  
   
 static int  static int
 syncprov_op_cleanup( Operation *op, SlapReply *rs )  syncprov_op_cleanup( Operation *op, SlapReply *rs )
 {  {
Line 920  syncprov_op_cleanup( Operation *op, Slap Line 905  syncprov_op_cleanup( Operation *op, Slap
         mtdummy.mt_op = op;          mtdummy.mt_op = op;
         ldap_pvt_thread_mutex_lock( &si->si_mods_mutex );          ldap_pvt_thread_mutex_lock( &si->si_mods_mutex );
         mt = avl_find( si->si_mods, &mtdummy, sp_avl_cmp );          mt = avl_find( si->si_mods, &mtdummy, sp_avl_cmp );
           ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );
         if ( mt ) {          if ( mt ) {
                 modinst *mi = mt->mt_mods;                  modinst *mi = mt->mt_mods;
                                   
Line 930  syncprov_op_cleanup( Operation *op, Slap Line 916  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_mutex_lock( &si->si_mods_mutex );
                         avl_delete( &si->si_mods, mt, sp_avl_cmp );                          avl_delete( &si->si_mods, mt, sp_avl_cmp );
                           ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );
                         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 );  
         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 958  syncprov_op_response( Operation *op, Sla Line 975  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 1000  syncprov_op_response( Operation *op, Sla Line 1033  syncprov_op_response( Operation *op, Sla
         return SLAP_CB_CONTINUE;          return SLAP_CB_CONTINUE;
 }  }
   
 static int  /* We don't use a subentry to store the context CSN any more.
 syncprov_op_abandon( Operation *op, SlapReply *rs )   * We expose the current context CSN as an operational attribute
 {   * of the suffix entry.
         slap_overinst           *on = (slap_overinst *)op->o_bd->bd_info;  
         syncprov_info_t         *si = on->on_bi.bi_private;  
         syncops *so, *soprev;  
   
         ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );  
         for ( so=si->si_ops, soprev = (syncops *)&si->si_ops; so;  
                 soprev=so, so=so->s_next ) {  
                 if ( so->s_op->o_connid == op->o_connid &&  
                         so->s_op->o_msgid == op->orn_msgid ) {  
                                 so->s_op->o_abandon = 1;  
                                 soprev->s_next = so->s_next;  
                                 break;  
                 }  
         }  
         ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );  
         if ( so ) {  
                 ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );  
                 op->o_conn->c_n_ops_executing--;  
                 op->o_conn->c_n_ops_completed++;  
                 ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );  
                 /* Is this really a Cancel exop? */  
                 if ( op->o_tag != LDAP_REQ_ABANDON ) {  
                         rs->sr_err = LDAP_CANCELLED;  
                         send_ldap_result( so->s_op, rs );  
                 }  
                 syncprov_free_syncop( so );  
         }  
         return SLAP_CB_CONTINUE;  
 }  
   
 #if 0  
 /* We don't use a subentry to store the context CSN any more. But  
  * we ought to expose the current context CSN as an operational attribute  
  * 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 1045  syncprov_op_compare( Operation *op, Slap Line 1044  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 1095  return_results:; Line 1100  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 1177  typedef struct searchstate { Line 1181  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 1194  syncprov_detach_op( Operation *op, synco Line 1200  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 1211  syncprov_detach_op( Operation *op, synco Line 1217  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 1249  syncprov_search_response( Operation *op, Line 1254  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;
Line 1358  syncprov_op_search( Operation *op, SlapR Line 1363  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 1428  syncprov_op_search( Operation *op, SlapR Line 1433  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;
Line 1440  syncprov_op_search( Operation *op, SlapR Line 1446  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 1466  syncprov_op_search( Operation *op, SlapR Line 1460  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 1492  shortcut: Line 1488  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 1508  shortcut: Line 1506  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 1537  syncprov_db_config( Line 1581  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 *free;
   } thread_keys;
   
   /* A fake thread context */
   static thread_keys thrctx[8];
   
   /* 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 );
           }
           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].free )
                           thrctx[i].free( thrctx[i].key, thrctx[i].data );
           }
   
       return 0;
   }
   
 static int  static int
 syncprov_db_init(  syncprov_db_init(
         BackendDB *be          BackendDB *be
Line 1549  syncprov_db_init( Line 1682  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_mutex_init( &si->si_mods_mutex );
         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 1569  syncprov_db_destroy( Line 1703  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_mutex_destroy( &si->si_mods_mutex );
                 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 1600  static int syncprov_parseCtrl ( Line 1735  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 1665  static int syncprov_parseCtrl ( Line 1800  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 1692  syncprov_init() Line 1827  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 1702  syncprov_init() Line 1837  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.22  
changed lines
  Added in v.1.29


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