Diff for /servers/slapd/overlays/syncprov.c between versions 1.56.2.4 and 1.62

version 1.56.2.4, 2005/01/28 17:29:50 version 1.62, 2005/01/12 00:49:00
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.56.2.3 2005/01/20 18:04:04 kurt Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.61 2005/01/11 04:00:59 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 100  typedef struct slog_entry { Line 101  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 607  syncprov_findcsn( Operation *op, int mod Line 610  syncprov_findcsn( Operation *op, int mod
         AttributeAssertion eq;          AttributeAssertion eq;
         int i, rc = LDAP_SUCCESS;          int i, rc = LDAP_SUCCESS;
         fpres_cookie pcookie;          fpres_cookie pcookie;
         sync_control *srs = NULL;          sync_control *srs;
   
         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 648  syncprov_findcsn( Operation *op, int mod Line 651  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 662  syncprov_findcsn( Operation *op, int mod Line 665  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 768  syncprov_sendresp( Operation *op, opcook Line 771  syncprov_sendresp( Operation *op, opcook
         }          }
   
         ctrls[1] = NULL;          ctrls[1] = NULL;
         slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn, so->s_rid );          slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn,
                   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 856  syncprov_drop_psearch( syncops *so, int Line 860  syncprov_drop_psearch( syncops *so, int
                         ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );                          ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );
         }          }
         syncprov_free_syncop( so );          syncprov_free_syncop( so );
   
         return 0;  
 }  }
   
 static int  static int
Line 884  syncprov_op_abandon( Operation *op, Slap Line 886  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 );
                 }                  }
                 syncprov_drop_psearch( so, 0 );                  /* Our cloned searches have no ctrls set.
                    * 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 923  syncprov_matchops( Operation *op, opcook Line 930  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 1050  syncprov_op_cleanup( Operation *op, Slap Line 1061  syncprov_op_cleanup( Operation *op, Slap
                 op->o_tmpfree( opc->sdn.bv_val, op->o_tmpmemctx );                  op->o_tmpfree( opc->sdn.bv_val, op->o_tmpmemctx );
         op->o_callback = cb->sc_next;          op->o_callback = cb->sc_next;
         op->o_tmpfree(cb, op->o_tmpmemctx);          op->o_tmpfree(cb, op->o_tmpmemctx);
   
         return 0;  
 }  }
   
 static void  static void
Line 1093  syncprov_add_slog( Operation *op, struct Line 1102  syncprov_add_slog( Operation *op, struct
         sessionlog *sl;          sessionlog *sl;
         slog_entry *se;          slog_entry *se;
   
         sl = si->si_logs;          for ( sl = si->si_logs; sl; sl=sl->sl_next ) {
         {  
                 /* 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 1294  syncprov_op_response( Operation *op, Sla Line 1302  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 1612  syncprov_search_response( Operation *op, Line 1613  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 ( !BER_BVISNULL( &srs->sr_state.ctxcsn )) {                  if ( srs->sr_state.ctxcsn ) {
                         Attribute *a = attr_find( rs->sr_entry->e_attrs,                          Attribute *a = attr_find( rs->sr_entry->e_attrs,
                                 slap_schema.si_ad_entryCSN );                                  slap_schema.si_ad_entryCSN );
                                                   
                         /* 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 1630  syncprov_search_response( Operation *op, Line 1631  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.rid );                          srs->sr_state.sid, srs->sr_state.rid );
   
                 /* Is this a regular refresh? */                  /* Is this a regular refresh? */
                 if ( !ss->ss_so ) {                  if ( !ss->ss_so ) {
Line 1750  syncprov_op_search( Operation *op, SlapR Line 1751  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 1767  syncprov_op_search( Operation *op, SlapR Line 1769  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 ( !BER_BVISNULL( &srs->sr_state.ctxcsn )) {          if ( 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 1791  syncprov_op_search( Operation *op, SlapR Line 1793  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? */
                 sl=si->si_logs;                  for ( sl=si->si_logs; sl; sl=sl->sl_next )
                           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 1845  shortcut: Line 1848  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 1949  syncprov_db_config( Line 1952  syncprov_db_config(
   
         } else if ( strcasecmp( argv[0], "syncprov-sessionlog" ) == 0 ) {          } else if ( strcasecmp( argv[0], "syncprov-sessionlog" ) == 0 ) {
                 sessionlog *sl;                  sessionlog *sl;
                 int size;                  int sid, size;
                 if ( argc != 2 ) {                  if ( argc != 3 ) {
                         fprintf( stderr, "%s: line %d: wrong number of arguments in "                          fprintf( stderr, "%s: line %d: wrong number of arguments in "
                                 "\"syncprov-sessionlog <size>\"\n", fname, lineno );                                  "\"syncprov-sessionlog <sid> <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[1] );                  size = atoi( argv[2] );
                 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;
                 }                  }
                 sl = si->si_logs;                  for ( sl = si->si_logs; sl; sl=sl->sl_next ) {
                           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 2012  syncprov_db_open( Line 2029  syncprov_db_open(
         Attribute *a;          Attribute *a;
         int rc;          int rc;
   
         rc = overlay_register_control( be, LDAP_CONTROL_SYNC );  
         if ( rc ) {  
                 return rc;  
         }  
   
         connection_fake_init( &conn, op, thrctx );          connection_fake_init( &conn, op, thrctx );
         op->o_bd = be;          op->o_bd = be;
         op->o_dn = be->be_rootdn;          op->o_dn = be->be_rootdn;
Line 2222  static int syncprov_parseCtrl ( Line 2234  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_dupbv( &sr->sr_state.octet_str, &cookie );                  ber_bvarray_add( &sr->sr_state.octet_str, &cookie );
                 slap_parse_sync_cookie( &sr->sr_state );                  slap_parse_sync_cookie( &sr->sr_state );
         }          }
   

Removed from v.1.56.2.4  
changed lines
  Added in v.1.62


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