Diff for /servers/slapd/overlays/syncprov.c between versions 1.12 and 1.15

version 1.12, 2004/11/25 20:16:56 version 1.15, 2004/11/26 16:32:36
Line 19 Line 19
   
 #include "portable.h"  #include "portable.h"
   
 #define SLAPD_OVER_SYNCPROV     SLAPD_MOD_DYNAMIC  
   
 #ifdef SLAPD_OVER_SYNCPROV  #ifdef SLAPD_OVER_SYNCPROV
   
 #include <ac/string.h>  #include <ac/string.h>
 #include "lutil.h"  #include "lutil.h"
 #include "slap.h"  #include "slap.h"
   
   /* A queued result of a persistent search */
   typedef struct syncres {
           struct syncres *s_next;
           struct berval s_ndn;
           struct berval s_uuid;
           int result;
   } syncres;
   
 /* Record of a persistent search */  /* Record of a persistent search */
 typedef struct syncops {  typedef struct syncops {
         struct syncops *s_next;          struct syncops *s_next;
Line 35  typedef struct syncops { Line 41  typedef struct syncops {
         Operation       *s_op;          /* search op */          Operation       *s_op;          /* search op */
         Filter  *s_filter;          Filter  *s_filter;
         int             s_flags;        /* search status */          int             s_flags;        /* search status */
           struct syncres *s_res;
           struct syncres *s_restail;
           ldap_pvt_thread_mutex_t s_mutex;
 } syncops;  } syncops;
   
 static int      sync_cid;  static int      sync_cid;
Line 53  typedef struct syncprov_info_t { Line 62  typedef struct syncprov_info_t {
         int             si_gotcsn;      /* is our ctxcsn up to date? */          int             si_gotcsn;      /* is our ctxcsn up to date? */
         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;
           char            si_ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
 } syncprov_info_t;  } syncprov_info_t;
   
 typedef struct opcookie {  typedef struct opcookie {
Line 366  syncprov_findcsn( Operation *op, int mod Line 376  syncprov_findcsn( Operation *op, int mod
   
         if ( mode == FIND_CSN ) {          if ( mode == FIND_CSN ) {
                 if ( !si->si_gotcsn ) {                  if ( !si->si_gotcsn ) {
                         ber_dupbv( &si->si_ctxcsn, &fcookie.maxcsn );                          strcpy(si->si_ctxcsnbuf, fcookie.maxcsn.bv_val);
                           si->si_ctxcsn.bv_len = fcookie.maxcsn.bv_len;
                         si->si_gotcsn = 1;                          si->si_gotcsn = 1;
                         ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );                          ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
                         if ( fcookie.gotmatch ) return LDAP_SUCCESS;                          if ( fcookie.gotmatch ) return LDAP_SUCCESS;
Line 394  syncprov_sendresp( Operation *op, opcook Line 405  syncprov_sendresp( Operation *op, opcook
         Entry e_uuid = {0};          Entry e_uuid = {0};
         Attribute a_uuid = {0};          Attribute a_uuid = {0};
         Operation sop = *so->s_op;          Operation sop = *so->s_op;
           Opheader ohdr;
         syncrepl_state *srs = sop.o_controls[sync_cid];          syncrepl_state *srs = sop.o_controls[sync_cid];
   
           ohdr = *sop.o_hdr;
           sop.o_hdr = &ohdr;
         sop.o_tmpmemctx = op->o_tmpmemctx;          sop.o_tmpmemctx = op->o_tmpmemctx;
   
         ctrls[1] = NULL;          ctrls[1] = NULL;
Line 567  syncprov_op_response( Operation *op, Sla Line 581  syncprov_op_response( Operation *op, Sla
         {          {
                 struct berval maxcsn;                  struct berval maxcsn;
                 char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];                  char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
                 void *memctx = op->o_tmpmemctx;  
   
                 cbuf[0] = '\0';                  cbuf[0] = '\0';
                 ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );
                 op->o_tmpmemctx = NULL;  
                 slap_get_commit_csn( op, &maxcsn );                  slap_get_commit_csn( op, &maxcsn );
                 op->o_tmpmemctx = memctx;  
                 if ( maxcsn.bv_val ) {                  if ( maxcsn.bv_val ) {
                         strcpy( cbuf, maxcsn.bv_val );                          strcpy( cbuf, maxcsn.bv_val );
                         free( si->si_ctxcsn.bv_val );                          if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) {
                         si->si_ctxcsn = maxcsn;                                  strcpy( si->si_ctxcsnbuf, cbuf );
                                   si->si_ctxcsn.bv_len = maxcsn.bv_len;
                           }
                         si->si_gotcsn = 1;                          si->si_gotcsn = 1;
                 }                  }
                 ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
Line 789  syncprov_op_search( Operation *op, SlapR Line 802  syncprov_op_search( Operation *op, SlapR
         Filter *fand, *fava;          Filter *fand, *fava;
         syncops *sop = NULL;          syncops *sop = NULL;
         searchstate *ss;          searchstate *ss;
         syncrepl_state *srs = op->o_controls[sync_cid];          syncrepl_state *srs;
   
         if ( !(op->o_sync_mode & SLAP_SYNC_REFRESH) ) return SLAP_CB_CONTINUE;          if ( !(op->o_sync_mode & SLAP_SYNC_REFRESH) ) return SLAP_CB_CONTINUE;
   
Line 798  syncprov_op_search( Operation *op, SlapR Line 811  syncprov_op_search( Operation *op, SlapR
                 return rs->sr_err;                  return rs->sr_err;
         }          }
   
           srs = op->o_controls[sync_cid];
   
         /* 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 ) {
                 syncops so;                  syncops so;
Line 824  syncprov_op_search( Operation *op, SlapR Line 839  syncprov_op_search( Operation *op, SlapR
                 }                  }
                 sop = ch_malloc( sizeof( syncops ));                  sop = ch_malloc( sizeof( syncops ));
                 *sop = so;                  *sop = so;
                   ldap_pvt_thread_mutex_init( &sop->s_mutex );
                 ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );                  ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );
                 sop->s_next = si->si_ops;                  sop->s_next = si->si_ops;
                 si->si_ops = sop;                  si->si_ops = sop;
Line 859  syncprov_op_search( Operation *op, SlapR Line 875  syncprov_op_search( Operation *op, SlapR
                                         ctrls[1] = NULL;                                          ctrls[1] = NULL;
                                         slap_build_sync_done_ctrl( op, rs, ctrls, 0, 0,                                          slap_build_sync_done_ctrl( op, rs, ctrls, 0, 0,
                                                 NULL, LDAP_SYNC_REFRESH_DELETES );                                                  NULL, LDAP_SYNC_REFRESH_DELETES );
                                           rs->sr_ctrls = ctrls;
                                         rs->sr_err = LDAP_SUCCESS;                                          rs->sr_err = LDAP_SUCCESS;
                                         send_ldap_result( op, rs );                                          send_ldap_result( op, rs );
                                         return rs->sr_err;                                          return rs->sr_err;
Line 987  syncprov_db_init( Line 1004  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 );
           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;
         csn_anlist[0].an_name = slap_schema.si_ad_entryCSN->ad_cname;          csn_anlist[0].an_name = slap_schema.si_ad_entryCSN->ad_cname;

Removed from v.1.12  
changed lines
  Added in v.1.15


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