Diff for /servers/slapd/overlays/syncprov.c between versions 1.35 and 1.42

version 1.35, 2004/11/29 09:27:38 version 1.42, 2004/12/07 09:05:24
Line 1 Line 1
   /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.41 2004/12/07 01:58:33 hyc Exp $ */
 /* syncprov.c - syncrepl provider */  /* syncprov.c - syncrepl provider */
 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.  /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *   *
Line 101  typedef struct syncprov_info_t { Line 102  typedef struct syncprov_info_t {
         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_rdwr_t  si_mods_rwlock;          ldap_pvt_thread_mutex_t si_mods_mutex;
         char            si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];          char            si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
 } syncprov_info_t;  } syncprov_info_t;
   
Line 478  syncprov_findbase( Operation *op, fbase_ Line 479  syncprov_findbase( Operation *op, fbase_
 }  }
   
 /* syncprov_findcsn:  /* syncprov_findcsn:
  *   This function has two different purposes, but they both use a search   *   This function has three different purposes, but they all 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 known and we have a sync cookie, we search   * 1: at startup time, after a contextCSN has been read from the database,
    * we search for all entries with CSN >= contextCSN in case the contextCSN
    * was not checkpointed at the previous shutdown.
    *
    * 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.   * entry is found, the cookie CSN is valid, otherwise it is stale.
  *   *
  * 2: during a refresh phase, we search for all entries with CSN <= the cookie   * 3: during a refresh phase, we search for all entries with CSN <= the cookie
  * CSN, and generate Present records for them. We always collect this result   * CSN, and generate Present records for them. We always collect this result
  * 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_MAXCSN     1
 #define FIND_PRESENT    2  #define FIND_CSN        2
   #define FIND_PRESENT    3
   
   static int
   findmax_cb( Operation *op, SlapReply *rs )
   {
           if ( rs->sr_type == REP_SEARCH && rs->sr_err == LDAP_SUCCESS ) {
                   struct berval *maxcsn = op->o_callback->sc_private;
                   Attribute *a = attr_find( rs->sr_entry->e_attrs,
                           slap_schema.si_ad_entryCSN );
   
                   if ( a && ber_bvcmp( &a->a_vals[0], maxcsn )) {
                           maxcsn->bv_len = a->a_vals[0].bv_len;
                           strcpy( maxcsn->bv_val, a->a_vals[0].bv_val );
                   }
           }
           return LDAP_SUCCESS;
   }
   
 static int  static int
 findcsn_cb( Operation *op, SlapReply *rs )  findcsn_cb( Operation *op, SlapReply *rs )
Line 504  findcsn_cb( Operation *op, SlapReply *rs Line 526  findcsn_cb( Operation *op, SlapReply *rs
   
 /* Build a list of entryUUIDs for sending in a SyncID set */  /* Build a list of entryUUIDs for sending in a SyncID set */
   
   #define UUID_LEN        16
   
 typedef struct fpres_cookie {  typedef struct fpres_cookie {
         int num;          int num;
         BerVarray uuids;          BerVarray uuids;
           char *last;
 } fpres_cookie;  } fpres_cookie;
   
 static int  static int
Line 517  findpres_cb( Operation *op, SlapReply *r Line 542  findpres_cb( Operation *op, SlapReply *r
         int ret = SLAP_CB_CONTINUE;          int ret = SLAP_CB_CONTINUE;
   
         if ( rs->sr_type == REP_SEARCH ) {          if ( rs->sr_type == REP_SEARCH ) {
                 ret = slap_build_syncUUID_set( op, &pc->uuids, rs->sr_entry );                  Attribute *a = attr_find( rs->sr_entry->e_attrs,
                 if ( ret > 0 ) {                          slap_schema.si_ad_entryUUID );
                   if ( a ) {
                           pc->uuids[pc->num].bv_val = pc->last;
                           AC_MEMCPY( pc->uuids[pc->num].bv_val, a->a_nvals[0].bv_val,
                                   pc->uuids[pc->num].bv_len );
                         pc->num++;                          pc->num++;
                         ret = LDAP_SUCCESS;                          pc->last = pc->uuids[pc->num].bv_val;
                         if ( pc->num == SLAP_SYNCUUID_SET_SIZE ) {                          pc->uuids[pc->num].bv_val = NULL;
                                 ret = syncprov_sendinfo( op, rs, LDAP_TAG_SYNC_ID_SET, NULL,                  }
                                         0, pc->uuids, 0 );                  ret = LDAP_SUCCESS;
                                 ber_bvarray_free_x( pc->uuids, op->o_tmpmemctx );                  if ( pc->num == SLAP_SYNCUUID_SET_SIZE ) {
                                 pc->uuids = NULL;                          ret = syncprov_sendinfo( op, rs, LDAP_TAG_SYNC_ID_SET, NULL,
                                 pc->num = 0;                                  0, pc->uuids, 0 );
                         }                          pc->uuids[pc->num].bv_val = pc->last;
                 } else {                          pc->num = 0;
                         ret = LDAP_OTHER;                          pc->last = pc->uuids[0].bv_val;
                 }                  }
   
         } else if ( rs->sr_type == REP_RESULT ) {          } else if ( rs->sr_type == REP_RESULT ) {
                 ret = rs->sr_err;                  ret = rs->sr_err;
                 if ( pc->num ) {                  if ( pc->num ) {
                         ret = syncprov_sendinfo( op, rs, LDAP_TAG_SYNC_ID_SET, NULL,                          ret = syncprov_sendinfo( op, rs, LDAP_TAG_SYNC_ID_SET, NULL,
                                 0, pc->uuids, 0 );                                  0, pc->uuids, 0 );
                         ber_bvarray_free_x( pc->uuids, op->o_tmpmemctx );                          pc->uuids[pc->num].bv_val = pc->last;
                         pc->uuids = NULL;  
                         pc->num = 0;                          pc->num = 0;
                           pc->last = pc->uuids[0].bv_val;
                 }                  }
         }          }
         return ret;          return ret;
 }  }
   
   
 static int  static int
 syncprov_findcsn( Operation *op, int mode )  syncprov_findcsn( Operation *op, int mode )
 {  {
Line 556  syncprov_findcsn( Operation *op, int mod Line 585  syncprov_findcsn( Operation *op, int mod
         SlapReply frs = { REP_RESULT };          SlapReply frs = { REP_RESULT };
         char buf[LDAP_LUTIL_CSNSTR_BUFSIZE + STRLENOF("(entryCSN<=)")];          char buf[LDAP_LUTIL_CSNSTR_BUFSIZE + STRLENOF("(entryCSN<=)")];
         char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];          char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
         struct berval fbuf;          struct berval fbuf, maxcsn;
         Filter cf;          Filter cf;
         AttributeAssertion eq;          AttributeAssertion eq;
         int rc;          int i, rc = LDAP_SUCCESS;
         fpres_cookie pcookie;          fpres_cookie pcookie;
         int locked = 0;          sync_control *srs;
         sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync];  
   
         if ( srs->sr_state.ctxcsn->bv_len >= LDAP_LUTIL_CSNSTR_BUFSIZE ) {          if ( mode != FIND_MAXCSN ) {
                 return LDAP_OTHER;                  srs = op->o_controls[slap_cids.sc_LDAPsync];
   
                   if ( srs->sr_state.ctxcsn->bv_len >= LDAP_LUTIL_CSNSTR_BUFSIZE ) {
                           return LDAP_OTHER;
                   }
         }          }
   
         fop = *op;          fop = *op;
         fop.o_sync_mode &= SLAP_CONTROL_MASK;   /* turn off sync_mode */          fop.o_sync_mode &= SLAP_CONTROL_MASK;   /* turn off sync_mode */
   
         fbuf.bv_val = buf;          fbuf.bv_val = buf;
         if ( mode == FIND_CSN ) {          cf.f_ava = &eq;
           cf.f_av_desc = slap_schema.si_ad_entryCSN;
           cf.f_next = NULL;
   
           switch( mode ) {
           case FIND_MAXCSN:
                   cf.f_choice = LDAP_FILTER_GE;
                   cf.f_av_value = si->si_ctxcsn;
                   fbuf.bv_len = sprintf( buf, "(entryCSN>=%s)",
                           cf.f_av_value.bv_val );
                   fop.ors_attrsonly = 0;
                   fop.ors_attrs = csn_anlist;
                   fop.ors_slimit = SLAP_NO_LIMIT;
                   cb.sc_private = &maxcsn;
                   cb.sc_response = findmax_cb;
                   maxcsn.bv_val = cbuf;
                   maxcsn.bv_len = 0;
                   break;
           case FIND_CSN:
                   cf.f_choice = LDAP_FILTER_LE;
                   cf.f_av_value = *srs->sr_state.ctxcsn;
                   fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)",
                           cf.f_av_value.bv_val );
                 fop.ors_attrsonly = 1;                  fop.ors_attrsonly = 1;
                 fop.ors_attrs = slap_anlist_no_attrs;                  fop.ors_attrs = slap_anlist_no_attrs;
                 fop.ors_slimit = 1;                  fop.ors_slimit = 1;
                 cb.sc_private = NULL;                  cb.sc_private = NULL;
                 cb.sc_response = findcsn_cb;                  cb.sc_response = findcsn_cb;
                   break;
         } else if ( mode == FIND_PRESENT ) {          case FIND_PRESENT:
                   cf.f_choice = LDAP_FILTER_LE;
                   cf.f_av_value = *srs->sr_state.ctxcsn;
                   fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)",
                           cf.f_av_value.bv_val );
                 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 588  syncprov_findcsn( Operation *op, int mod Line 646  syncprov_findcsn( Operation *op, int mod
                 cb.sc_private = &pcookie;                  cb.sc_private = &pcookie;
                 cb.sc_response = findpres_cb;                  cb.sc_response = findpres_cb;
                 pcookie.num = 0;                  pcookie.num = 0;
                 pcookie.uuids = NULL;  
         }  
         cf.f_choice = LDAP_FILTER_LE;  
         cf.f_ava = &eq;  
         cf.f_av_desc = slap_schema.si_ad_entryCSN;  
         cf.f_av_value = *srs->sr_state.ctxcsn;  
         cf.f_next = NULL;  
         fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)",  
                 srs->sr_state.ctxcsn->bv_val );  
   
                   /* preallocate storage for a full set */
                   pcookie.uuids = op->o_tmpalloc( (SLAP_SYNCUUID_SET_SIZE+1) *
                           sizeof(struct berval) + SLAP_SYNCUUID_SET_SIZE * UUID_LEN,
                           op->o_tmpmemctx );
                   pcookie.last = (char *)(pcookie.uuids + SLAP_SYNCUUID_SET_SIZE+1);
                   pcookie.uuids[0].bv_val = pcookie.last;
                   pcookie.uuids[0].bv_len = UUID_LEN;
                   for (i=1; i<SLAP_SYNCUUID_SET_SIZE; i++) {
                           pcookie.uuids[i].bv_val = pcookie.uuids[i-1].bv_val + UUID_LEN;
                           pcookie.uuids[i].bv_len = UUID_LEN;
                   }
                   break;
           }
         fop.o_callback = &cb;          fop.o_callback = &cb;
         fop.ors_limit = NULL;          fop.ors_limit = NULL;
         fop.ors_tlimit = SLAP_NO_LIMIT;          fop.ors_tlimit = SLAP_NO_LIMIT;
Line 605  syncprov_findcsn( Operation *op, int mod Line 667  syncprov_findcsn( Operation *op, int mod
         fop.ors_filterstr = fbuf;          fop.ors_filterstr = fbuf;
   
         fop.o_bd->bd_info = on->on_info->oi_orig;          fop.o_bd->bd_info = on->on_info->oi_orig;
         rc = fop.o_bd->be_search( &fop, &frs );          fop.o_bd->be_search( &fop, &frs );
         fop.o_bd->bd_info = (BackendInfo *)on;          fop.o_bd->bd_info = (BackendInfo *)on;
   
         if ( mode == FIND_CSN ) {          switch( mode ) {
                 if ( cb.sc_private ) return LDAP_SUCCESS;          case FIND_MAXCSN:
         } else if ( mode == FIND_PRESENT ) {                  if ( maxcsn.bv_len ) {
                 return LDAP_SUCCESS;                          strcpy( si->si_ctxcsnbuf, maxcsn.bv_val );
                           si->si_ctxcsn.bv_len = maxcsn.bv_len;
                   }
                   break;
           case FIND_CSN:
                   /* If matching CSN was not found, invalidate the context. */
                   if ( !cb.sc_private ) rc = LDAP_NO_SUCH_OBJECT;
                   break;
           case FIND_PRESENT:
                   op->o_tmpfree( pcookie.uuids, op->o_tmpmemctx );
                   break;
         }          }
   
         /* If matching CSN was not found, invalidate the context. */          return rc;
         return LDAP_NO_SUCH_OBJECT;  
 }  }
   
 /* Queue a persistent search response if still in Refresh stage */  /* Queue a persistent search response if still in Refresh stage */
Line 918  syncprov_op_cleanup( Operation *op, Slap Line 989  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_rdwr_rlock( &si->si_mods_rwlock );          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_rdwr_runlock( &si->si_mods_rwlock );          ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );
         if ( mt ) {          if ( mt ) {
                 modinst *mi = mt->mt_mods;                  modinst *mi = mt->mt_mods;
   
Line 931  syncprov_op_cleanup( Operation *op, Slap Line 1002  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 );                          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_rdwr_wunlock( &si->si_mods_rwlock );                          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 );
Line 1154  syncprov_op_mod( Operation *op, SlapRepl Line 1225  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_rdwr_wlock( &si->si_mods_rwlock );                  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 );
                 if ( mt ) {                  if ( mt ) {
                         ldap_pvt_thread_mutex_lock( &mt->mt_mutex );                          ldap_pvt_thread_mutex_lock( &mt->mt_mutex );
                         ldap_pvt_thread_rdwr_wunlock( &si->si_mods_rwlock );                          ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );
                         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 1167  syncprov_op_mod( Operation *op, SlapRepl Line 1238  syncprov_op_mod( Operation *op, SlapRepl
                                 ldap_pvt_thread_yield();                                  ldap_pvt_thread_yield();
                                 ldap_pvt_thread_mutex_lock( &mt->mt_mutex );                                  ldap_pvt_thread_mutex_lock( &mt->mt_mutex );
                         }                          }
                           ldap_pvt_thread_mutex_unlock( &mt->mt_mutex );
                 } else {                  } else {
                         /* Record that we're modifying this entry now */                          /* Record that we're modifying this entry now */
                         mt = ch_malloc( sizeof(modtarget) );                          mt = ch_malloc( sizeof(modtarget) );
Line 1175  syncprov_op_mod( Operation *op, SlapRepl Line 1247  syncprov_op_mod( Operation *op, SlapRepl
                         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_rdwr_wunlock( &si->si_mods_rwlock );                          ldap_pvt_thread_mutex_unlock( &si->si_mods_mutex );
                 }                  }
   
                 if ( op->o_tag != LDAP_REQ_ADD )                  if ( op->o_tag != LDAP_REQ_ADD )
Line 1202  typedef struct searchstate { Line 1274  typedef struct searchstate {
 static int  static int
 syncprov_search_cleanup( Operation *op, SlapReply *rs )  syncprov_search_cleanup( Operation *op, SlapReply *rs )
 {  {
 #if 0  
         if ( rs->sr_ctrls ) {          if ( rs->sr_ctrls ) {
                 free( rs->sr_ctrls[0] );                  op->o_tmpfree( rs->sr_ctrls[0], op->o_tmpmemctx );
                 op->o_tmpfree( rs->sr_ctrls, op->o_tmpmemctx );                  op->o_tmpfree( rs->sr_ctrls, op->o_tmpmemctx );
                 rs->sr_ctrls = NULL;                  rs->sr_ctrls = NULL;
         }          }
 #endif  
         return 0;          return 0;
 }  }
   
Line 1578  syncprov_operational( Line 1648  syncprov_operational(
                         ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );                          ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
                 }                  }
         }          }
         return LDAP_SUCCESS;          return SLAP_CB_CONTINUE;
 }  }
   
 static int  static int
Line 1633  syncprov_db_open( Line 1703  syncprov_db_open(
         slap_overinst   *on = (slap_overinst *) be->bd_info;          slap_overinst   *on = (slap_overinst *) be->bd_info;
         syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;          syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
   
           Connection conn;
         char opbuf[OPERATION_BUFFER_SIZE];          char opbuf[OPERATION_BUFFER_SIZE];
           char ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
         Operation *op = (Operation *)opbuf;          Operation *op = (Operation *)opbuf;
         Entry *e;          Entry *e;
         Attribute *a;          Attribute *a;
         int rc;          int rc;
   
         memset(opbuf, 0, sizeof(opbuf));          connection_fake_init( &conn, op, thrctx );
         op->o_hdr = (Opheader *)(op+1);  
         op->o_bd = be;          op->o_bd = be;
         op->o_dn = be->be_rootdn;          op->o_dn = be->be_rootdn;
         op->o_ndn = be->be_rootndn;          op->o_ndn = be->be_rootndn;
         op->o_threadctx = thrctx;  
         op->o_tmpmfuncs = &ch_mfuncs;          ctxcsnbuf[0] = '\0';
   
         op->o_bd->bd_info = on->on_info->oi_orig;          op->o_bd->bd_info = on->on_info->oi_orig;
         rc = be_entry_get_rw( op, be->be_nsuffix, NULL,          rc = be_entry_get_rw( op, be->be_nsuffix, NULL,
Line 1660  syncprov_db_open( Line 1731  syncprov_db_open(
                         strncpy( si->si_ctxcsnbuf, a->a_nvals[0].bv_val,                          strncpy( si->si_ctxcsnbuf, a->a_nvals[0].bv_val,
                                 si->si_ctxcsn.bv_len );                                  si->si_ctxcsn.bv_len );
                         si->si_ctxcsnbuf[si->si_ctxcsn.bv_len] = '\0';                          si->si_ctxcsnbuf[si->si_ctxcsn.bv_len] = '\0';
                           strcpy( ctxcsnbuf, si->si_ctxcsnbuf );
                 }                  }
                 be_entry_release_r( op, e );                  be_entry_release_r( op, e );
                   op->o_bd->bd_info = (BackendInfo *)on;
                   op->o_req_dn = be->be_suffix[0];
                   op->o_req_ndn = be->be_nsuffix[0];
                   op->ors_scope = LDAP_SCOPE_SUBTREE;
                   syncprov_findcsn( op, FIND_MAXCSN );
         }          }
   
         if ( BER_BVISEMPTY( &si->si_ctxcsn ) ) {          if ( BER_BVISEMPTY( &si->si_ctxcsn ) ) {
Line 1669  syncprov_db_open( Line 1746  syncprov_db_open(
                                 &si->si_ctxcsn, 0 );                                  &si->si_ctxcsn, 0 );
         }          }
   
           /* If our ctxcsn is different from what was read from the root
            * entry, write the new value out.
            */
           if ( strcmp( si->si_ctxcsnbuf, ctxcsnbuf )) {
                   SlapReply rs = {REP_RESULT};
                   syncprov_checkpoint( op, &rs, on );
           }
   
         op->o_bd->bd_info = (BackendInfo *)on;          op->o_bd->bd_info = (BackendInfo *)on;
         return 0;          return 0;
 }  }
Line 1717  syncprov_db_init( Line 1802  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 );          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 1738  syncprov_db_destroy( Line 1823  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_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 );

Removed from v.1.35  
changed lines
  Added in v.1.42


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