Diff for /servers/slapd/overlays/syncprov.c between versions 1.61 and 1.66

version 1.61, 2005/01/11 04:00:59 version 1.66, 2005/01/14 03:26:59
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.60 2005/01/08 08:59:53 ando Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.65 2005/01/13 20:14:52 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 56  typedef struct syncops { Line 56  typedef struct syncops {
         struct berval   s_base;         /* ndn of search base */          struct berval   s_base;         /* ndn of search base */
         ID              s_eid;          /* entryID of search base */          ID              s_eid;          /* entryID of search base */
         Operation       *s_op;          /* search op */          Operation       *s_op;          /* search op */
         int             s_sid;  
         int             s_rid;          int             s_rid;
         struct berval s_filterstr;          struct berval s_filterstr;
         int             s_flags;        /* search status */          int             s_flags;        /* search status */
Line 84  typedef struct sync_control { Line 83  typedef struct sync_control {
 #define SLAP_SYNC_REFRESH_AND_PERSIST   (LDAP_SYNC_REFRESH_AND_PERSIST<<SLAP_CONTROL_SHIFT)  #define SLAP_SYNC_REFRESH_AND_PERSIST   (LDAP_SYNC_REFRESH_AND_PERSIST<<SLAP_CONTROL_SHIFT)
   
 #define PS_IS_REFRESHING        0x01  #define PS_IS_REFRESHING        0x01
   #define PS_IS_DETACHED          0x02
   
 /* Record of which searches matched at premodify step */  /* Record of which searches matched at premodify step */
 typedef struct syncmatches {  typedef struct syncmatches {
Line 100  typedef struct slog_entry { Line 100  typedef struct slog_entry {
 } slog_entry;  } slog_entry;
   
 typedef struct sessionlog {  typedef struct sessionlog {
         struct sessionlog *sl_next;  
         int             sl_sid;  
         struct berval   sl_mincsn;          struct berval   sl_mincsn;
         int             sl_num;          int             sl_num;
         int             sl_size;          int             sl_size;
Line 614  syncprov_findcsn( Operation *op, int mod Line 612  syncprov_findcsn( Operation *op, int mod
         if ( mode != FIND_MAXCSN ) {          if ( mode != FIND_MAXCSN ) {
                 srs = op->o_controls[slap_cids.sc_LDAPsync];                  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 650  syncprov_findcsn( Operation *op, int mod Line 648  syncprov_findcsn( Operation *op, int mod
                 break;                  break;
         case FIND_CSN:          case FIND_CSN:
                 cf.f_choice = LDAP_FILTER_LE;                  cf.f_choice = LDAP_FILTER_LE;
                 cf.f_av_value = *srs->sr_state.ctxcsn;                  cf.f_av_value = srs->sr_state.ctxcsn;
                 fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)",                  fbuf.bv_len = sprintf( buf, "(entryCSN<=%s)",
                         cf.f_av_value.bv_val );                          cf.f_av_value.bv_val );
                 fop.ors_attrsonly = 1;                  fop.ors_attrsonly = 1;
Line 664  syncprov_findcsn( Operation *op, int mod Line 662  syncprov_findcsn( Operation *op, int mod
                 af.f_next = NULL;                  af.f_next = NULL;
                 af.f_and = &cf;                  af.f_and = &cf;
                 cf.f_choice = LDAP_FILTER_LE;                  cf.f_choice = LDAP_FILTER_LE;
                 cf.f_av_value = *srs->sr_state.ctxcsn;                  cf.f_av_value = srs->sr_state.ctxcsn;
                 cf.f_next = op->ors_filter;                  cf.f_next = op->ors_filter;
                 fop.ors_filter = &af;                  fop.ors_filter = &af;
                 filter2bv_x( &fop, fop.ors_filter, &fop.ors_filterstr );                  filter2bv_x( &fop, fop.ors_filter, &fop.ors_filterstr );
Line 770  syncprov_sendresp( Operation *op, opcook Line 768  syncprov_sendresp( Operation *op, opcook
         }          }
   
         ctrls[1] = NULL;          ctrls[1] = NULL;
         slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn,          slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn, so->s_rid );
                 so->s_sid, so->s_rid );  
   
         e_uuid.e_attrs = &a_uuid;          e_uuid.e_attrs = &a_uuid;
         a_uuid.a_desc = slap_schema.si_ad_entryUUID;          a_uuid.a_desc = slap_schema.si_ad_entryUUID;
Line 828  syncprov_free_syncop( syncops *so ) Line 825  syncprov_free_syncop( syncops *so )
                 return;                  return;
         }          }
         ldap_pvt_thread_mutex_unlock( &so->s_mutex );          ldap_pvt_thread_mutex_unlock( &so->s_mutex );
         filter_free( so->s_op->ors_filter );          if ( so->s_flags & PS_IS_DETACHED ) {
         for ( ga = so->s_op->o_groups; ga; ga=gnext ) {                  filter_free( so->s_op->ors_filter );
                 gnext = ga->ga_next;                  for ( ga = so->s_op->o_groups; ga; ga=gnext ) {
                 ch_free( ga );                          gnext = ga->ga_next;
                           ch_free( ga );
                   }
                   ch_free( so->s_op );
         }          }
         ch_free( so->s_op );  
         ch_free( so->s_base.bv_val );          ch_free( so->s_base.bv_val );
         for ( sr=so->s_res; sr; sr=srnext ) {          for ( sr=so->s_res; sr; sr=srnext ) {
                 srnext = sr->s_next;                  srnext = sr->s_next;
Line 846  syncprov_free_syncop( syncops *so ) Line 845  syncprov_free_syncop( syncops *so )
 static int  static int
 syncprov_drop_psearch( syncops *so, int lock )  syncprov_drop_psearch( syncops *so, int lock )
 {  {
         if ( lock )          if ( so->s_flags & PS_IS_DETACHED ) {
                 ldap_pvt_thread_mutex_lock( &so->s_op->o_conn->c_mutex );                  if ( lock )
         so->s_op->o_conn->c_n_ops_executing--;                          ldap_pvt_thread_mutex_lock( &so->s_op->o_conn->c_mutex );
         so->s_op->o_conn->c_n_ops_completed++;                  so->s_op->o_conn->c_n_ops_executing--;
         LDAP_STAILQ_REMOVE( &so->s_op->o_conn->c_ops, so->s_op, slap_op,                  so->s_op->o_conn->c_n_ops_completed++;
                 o_next );                  LDAP_STAILQ_REMOVE( &so->s_op->o_conn->c_ops, so->s_op, slap_op,
         if ( lock )                          o_next );
                 ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );                  if ( lock )
                           ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );
           }
         syncprov_free_syncop( so );          syncprov_free_syncop( so );
 }  }
   
Line 881  syncprov_op_abandon( Operation *op, Slap Line 882  syncprov_op_abandon( Operation *op, Slap
                         rs->sr_err = LDAP_CANCELLED;                          rs->sr_err = LDAP_CANCELLED;
                         send_ldap_result( so->s_op, rs );                          send_ldap_result( so->s_op, rs );
                 }                  }
                 /* Our cloned searches have no ctrls set.                  syncprov_drop_psearch( so, 0 );
                  * we don't want to muck with real search ops  
                  * from the frontend.  
                  */  
                 if ( ! so->s_op->o_sync )  
                         syncprov_drop_psearch( so, 0 );  
         }          }
         return SLAP_CB_CONTINUE;          return SLAP_CB_CONTINUE;
 }  }
Line 925  syncprov_matchops( Operation *op, opcook Line 921  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 1097  syncprov_add_slog( Operation *op, struct Line 1089  syncprov_add_slog( Operation *op, struct
         sessionlog *sl;          sessionlog *sl;
         slog_entry *se;          slog_entry *se;
   
         for ( sl = si->si_logs; sl; sl=sl->sl_next ) {          sl = si->si_logs;
           {
                 /* Allocate a record. UUIDs are not NUL-terminated. */                  /* Allocate a record. UUIDs are not NUL-terminated. */
                 se = ch_malloc( sizeof( slog_entry ) + opc->suuid.bv_len +                   se = ch_malloc( sizeof( slog_entry ) + opc->suuid.bv_len + 
                         csn->bv_len + 1 );                          csn->bv_len + 1 );
Line 1297  syncprov_op_response( Operation *op, Sla Line 1290  syncprov_op_response( Operation *op, Sla
                         }                          }
                 }                  }
   
                   /* Don't do any processing for consumer contextCSN updates */
                   if ( SLAP_SYNC_SHADOW( op->o_bd ) && 
                           op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) {
                           ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
                           return SLAP_CB_CONTINUE;
                   }
   
                 si->si_numops++;                  si->si_numops++;
                 if ( si->si_chkops || si->si_chktime ) {                  if ( si->si_chkops || si->si_chktime ) {
                         int do_check=0;                          int do_check=0;
Line 1584  syncprov_detach_op( Operation *op, synco Line 1584  syncprov_detach_op( Operation *op, synco
         op->o_conn->c_n_ops_executing++;          op->o_conn->c_n_ops_executing++;
         op->o_conn->c_n_ops_completed--;          op->o_conn->c_n_ops_completed--;
         LDAP_STAILQ_INSERT_TAIL( &op->o_conn->c_ops, op2, o_next );          LDAP_STAILQ_INSERT_TAIL( &op->o_conn->c_ops, op2, o_next );
           so->s_flags |= PS_IS_DETACHED;
         ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );          ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
 }  }
   
Line 1607  syncprov_search_response( Operation *op, Line 1608  syncprov_search_response( Operation *op,
                         Debug( LDAP_DEBUG_ANY, "bogus referral in context\n",0,0,0 );                          Debug( LDAP_DEBUG_ANY, "bogus referral in context\n",0,0,0 );
                         return SLAP_CB_CONTINUE;                          return SLAP_CB_CONTINUE;
                 }                  }
                 if ( srs->sr_state.ctxcsn ) {                  if ( !BER_BVISNULL( &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 );
                                                   
                         /* Don't send the ctx entry twice */                          /* Don't send the ctx entry twice */
                         if ( a && bvmatch( &a->a_nvals[0], srs->sr_state.ctxcsn ) )                          if ( a && bvmatch( &a->a_nvals[0], &srs->sr_state.ctxcsn ) )
                                 return LDAP_SUCCESS;                                  return LDAP_SUCCESS;
                 }                  }
                 rs->sr_ctrls = op->o_tmpalloc( sizeof(LDAPControl *)*2,                  rs->sr_ctrls = op->o_tmpalloc( sizeof(LDAPControl *)*2,
Line 1625  syncprov_search_response( Operation *op, Line 1626  syncprov_search_response( Operation *op,
   
                 slap_compose_sync_cookie( op, &cookie,                  slap_compose_sync_cookie( op, &cookie,
                         &op->ors_filter->f_and->f_ava->aa_value,                          &op->ors_filter->f_and->f_ava->aa_value,
                         srs->sr_state.sid, srs->sr_state.rid );                          srs->sr_state.rid );
   
                 /* Is this a regular refresh? */                  /* Is this a regular refresh? */
                 if ( !ss->ss_so ) {                  if ( !ss->ss_so ) {
Line 1745  syncprov_op_search( Operation *op, SlapR Line 1746  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_init( &sop->s_mutex );
                 sop->s_sid = srs->sr_state.sid;  
                 sop->s_rid = srs->sr_state.rid;                  sop->s_rid = srs->sr_state.rid;
                 sop->s_inuse = 1;                  sop->s_inuse = 1;
   
Line 1763  syncprov_op_search( Operation *op, SlapR Line 1763  syncprov_op_search( Operation *op, SlapR
         ctxcsn.bv_val = csnbuf;          ctxcsn.bv_val = csnbuf;
                   
         /* If we have a cookie, handle the PRESENT lookups */          /* If we have a cookie, handle the PRESENT lookups */
         if ( srs->sr_state.ctxcsn ) {          if ( !BER_BVISNULL( &srs->sr_state.ctxcsn )) {
                 sessionlog *sl;                  sessionlog *sl;
   
                 /* The cookie was validated when it was parsed, just use it */                  /* The cookie was validated when it was parsed, just use it */
   
                 /* If just Refreshing and nothing has changed, shortcut it */                  /* If just Refreshing and nothing has changed, shortcut it */
                 if ( bvmatch( srs->sr_state.ctxcsn, &ctxcsn )) {                  if ( bvmatch( &srs->sr_state.ctxcsn, &ctxcsn )) {
                         nochange = 1;                          nochange = 1;
                         if ( !(op->o_sync_mode & SLAP_SYNC_PERSIST) ) {                          if ( !(op->o_sync_mode & SLAP_SYNC_PERSIST) ) {
                                 LDAPControl     *ctrls[2];                                  LDAPControl     *ctrls[2];
Line 1787  syncprov_op_search( Operation *op, SlapR Line 1787  syncprov_op_search( Operation *op, SlapR
                         goto shortcut;                          goto shortcut;
                 }                  }
                 /* Do we have a sessionlog for this search? */                  /* Do we have a sessionlog for this search? */
                 for ( sl=si->si_logs; sl; sl=sl->sl_next )                  sl=si->si_logs;
                         if ( sl->sl_sid == srs->sr_state.sid ) break;  
                 if ( sl ) {                  if ( sl ) {
                         ldap_pvt_thread_mutex_lock( &sl->sl_mutex );                          ldap_pvt_thread_mutex_lock( &sl->sl_mutex );
                         if ( ber_bvcmp( srs->sr_state.ctxcsn, &sl->sl_mincsn ) >= 0 ) {                          if ( ber_bvcmp( &srs->sr_state.ctxcsn, &sl->sl_mincsn ) >= 0 ) {
                                 do_present = 0;                                  do_present = 0;
                                 /* mutex is unlocked in playlog */                                  /* mutex is unlocked in playlog */
                                 syncprov_playlog( op, rs, sl, srs->sr_state.ctxcsn, &ctxcsn );                                  syncprov_playlog( op, rs, sl, &srs->sr_state.ctxcsn, &ctxcsn );
                         } else {                          } else {
                                 ldap_pvt_thread_mutex_unlock( &sl->sl_mutex );                                  ldap_pvt_thread_mutex_unlock( &sl->sl_mutex );
                         }                          }
Line 1842  shortcut: Line 1841  shortcut:
                 fava->f_choice = LDAP_FILTER_GE;                  fava->f_choice = LDAP_FILTER_GE;
                 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;
                 ber_dupbv_x( &fava->f_ava->aa_value, srs->sr_state.ctxcsn, op->o_tmpmemctx );                  ber_dupbv_x( &fava->f_ava->aa_value, &srs->sr_state.ctxcsn, op->o_tmpmemctx );
         }          }
         fava->f_next = op->ors_filter;          fava->f_next = op->ors_filter;
         op->ors_filter = fand;          op->ors_filter = fand;
Line 1946  syncprov_db_config( Line 1945  syncprov_db_config(
   
         } else if ( strcasecmp( argv[0], "syncprov-sessionlog" ) == 0 ) {          } else if ( strcasecmp( argv[0], "syncprov-sessionlog" ) == 0 ) {
                 sessionlog *sl;                  sessionlog *sl;
                 int sid, size;                  int size;
                 if ( argc != 3 ) {                  if ( argc != 2 ) {
                         fprintf( stderr, "%s: line %d: wrong number of arguments in "                          fprintf( stderr, "%s: line %d: wrong number of arguments in "
                                 "\"syncprov-sessionlog <sid> <size>\"\n", fname, lineno );                                  "\"syncprov-sessionlog <size>\"\n", fname, lineno );
                         return -1;  
                 }  
                 sid = atoi( argv[1] );  
                 if ( sid < 0 || sid > 999 ) {  
                         fprintf( stderr,  
                                 "%s: line %d: session log id %d is out of range [0..999]\n",  
                                 fname, lineno, sid );  
                         return -1;                          return -1;
                 }                  }
                 size = atoi( argv[2] );                  size = atoi( argv[1] );
                 if ( size < 0 ) {                  if ( size < 0 ) {
                         fprintf( stderr,                          fprintf( stderr,
                                 "%s: line %d: session log size %d is negative\n",                                  "%s: line %d: session log size %d is negative\n",
                                 fname, lineno, size );                                  fname, lineno, size );
                         return -1;                          return -1;
                 }                  }
                 for ( sl = si->si_logs; sl; sl=sl->sl_next ) {                  sl = si->si_logs;
                         if ( sl->sl_sid == sid ) {  
                                 sl->sl_size = size;  
                                 break;  
                         }  
                 }  
                 if ( !sl ) {                  if ( !sl ) {
                         sl = ch_malloc( sizeof( sessionlog ) + LDAP_LUTIL_CSNSTR_BUFSIZE );                          sl = ch_malloc( sizeof( sessionlog ) + LDAP_LUTIL_CSNSTR_BUFSIZE );
                         sl->sl_mincsn.bv_val = (char *)(sl+1);                          sl->sl_mincsn.bv_val = (char *)(sl+1);
                         sl->sl_mincsn.bv_len = 0;                          sl->sl_mincsn.bv_len = 0;
                         sl->sl_sid = sid;  
                         sl->sl_size = size;  
                         sl->sl_num = 0;                          sl->sl_num = 0;
                         sl->sl_head = sl->sl_tail = NULL;                          sl->sl_head = sl->sl_tail = NULL;
                         sl->sl_next = si->si_logs;  
                         ldap_pvt_thread_mutex_init( &sl->sl_mutex );                          ldap_pvt_thread_mutex_init( &sl->sl_mutex );
                         si->si_logs = sl;                          si->si_logs = sl;
                 }                  }
                   sl->sl_size = size;
                 return 0;                  return 0;
         }          }
   
Line 2228  static int syncprov_parseCtrl ( Line 2213  static int syncprov_parseCtrl (
         sr = op->o_tmpcalloc( 1, sizeof(struct sync_control), op->o_tmpmemctx );          sr = op->o_tmpcalloc( 1, sizeof(struct sync_control), op->o_tmpmemctx );
         sr->sr_rhint = rhint;          sr->sr_rhint = rhint;
         if (!BER_BVISNULL(&cookie)) {          if (!BER_BVISNULL(&cookie)) {
                 ber_bvarray_add( &sr->sr_state.octet_str, &cookie );                  ber_dupbv( &sr->sr_state.octet_str, &cookie );
                 slap_parse_sync_cookie( &sr->sr_state );                  slap_parse_sync_cookie( &sr->sr_state );
         }          }
   

Removed from v.1.61  
changed lines
  Added in v.1.66


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