Diff for /servers/slapd/overlays/syncprov.c between versions 1.147.2.6 and 1.147.2.7

version 1.147.2.6, 2007/02/16 01:53:39 version 1.147.2.7, 2007/08/31 23:14:06
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.147.2.5 2007/02/15 00:44:18 kurt Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.195 2007/08/28 22:27:47 ando 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 659  again: Line 659  again:
                 } else {                  } else {
                         cf.f_choice = LDAP_FILTER_LE;                          cf.f_choice = LDAP_FILTER_LE;
                         fop.ors_limit = &fc_limits;                          fop.ors_limit = &fc_limits;
                           memset( &fc_limits, 0, sizeof( fc_limits ));
                         fc_limits.lms_s_unchecked = 1;                          fc_limits.lms_s_unchecked = 1;
                         fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)",                          fop.ors_filterstr.bv_len = sprintf( buf, "(entryCSN<=%s)",
                                 cf.f_av_value.bv_val );                                  cf.f_av_value.bv_val );
Line 896  syncprov_qtask( void *ctx, void *arg ) Line 897  syncprov_qtask( void *ctx, void *arg )
         BackendDB be;          BackendDB be;
         int rc;          int rc;
   
         op = (Operation *) &opbuf;          op = &opbuf.ob_op;
         *op = *so->s_op;          *op = *so->s_op;
         op->o_hdr = (Opheader *)(op+1);          op->o_hdr = &opbuf.ob_hdr;
         op->o_controls = (void **)(op->o_hdr+1);          op->o_controls = opbuf.ob_controls;
         memset( op->o_controls, 0, SLAP_MAX_CIDS * sizeof(void *));          memset( op->o_controls, 0, sizeof(opbuf.ob_controls) );
   
         *op->o_hdr = *so->s_op->o_hdr;          *op->o_hdr = *so->s_op->o_hdr;
   
Line 1030  syncprov_drop_psearch( syncops *so, int Line 1031  syncprov_drop_psearch( syncops *so, int
                         ldap_pvt_thread_mutex_lock( &so->s_op->o_conn->c_mutex );                          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_executing--;
                 so->s_op->o_conn->c_n_ops_completed++;                  so->s_op->o_conn->c_n_ops_completed++;
                 LDAP_STAILQ_REMOVE( &so->s_op->o_conn->c_ops, so->s_op, slap_op,                  LDAP_STAILQ_REMOVE( &so->s_op->o_conn->c_ops, so->s_op, Operation,
                         o_next );                          o_next );
                 if ( lock )                  if ( lock )
                         ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );                          ldap_pvt_thread_mutex_unlock( &so->s_op->o_conn->c_mutex );
Line 1284  syncprov_op_cleanup( Operation *op, Slap Line 1285  syncprov_op_cleanup( Operation *op, Slap
 static void  static void
 syncprov_checkpoint( Operation *op, SlapReply *rs, slap_overinst *on )  syncprov_checkpoint( Operation *op, SlapReply *rs, slap_overinst *on )
 {  {
     syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;          syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
         Modifications mod;          Modifications mod;
         Operation opm;          Operation opm;
         SlapReply rsm = { 0 };          SlapReply rsm = { 0 };
Line 1307  syncprov_checkpoint( Operation *op, Slap Line 1308  syncprov_checkpoint( Operation *op, Slap
         opm.o_req_ndn = op->o_bd->be_nsuffix[0];          opm.o_req_ndn = op->o_bd->be_nsuffix[0];
         opm.o_bd->bd_info = on->on_info->oi_orig;          opm.o_bd->bd_info = on->on_info->oi_orig;
         opm.o_managedsait = SLAP_CONTROL_NONCRITICAL;          opm.o_managedsait = SLAP_CONTROL_NONCRITICAL;
           opm.o_no_schema_check = 1;
         opm.o_bd->be_modify( &opm, &rsm );          opm.o_bd->be_modify( &opm, &rsm );
         if ( mod.sml_next != NULL ) {          if ( mod.sml_next != NULL ) {
                 slap_mods_free( mod.sml_next, 1 );                  slap_mods_free( mod.sml_next, 1 );
         }          }
           opm.orm_no_opattrs = 0;
 }  }
   
 static void  static void
Line 1810  syncprov_search_cleanup( Operation *op, Line 1813  syncprov_search_cleanup( Operation *op,
         return 0;          return 0;
 }  }
   
   typedef struct SyncOperationBuffer {
           Operation               sob_op;
           Opheader                sob_hdr;
           AttributeName   sob_extra;      /* not always present */
           /* Further data allocated here */
   } SyncOperationBuffer;
   
 static void  static void
 syncprov_detach_op( Operation *op, syncops *so, slap_overinst *on )  syncprov_detach_op( Operation *op, syncops *so, slap_overinst *on )
 {  {
           SyncOperationBuffer *sopbuf2;
         Operation *op2;          Operation *op2;
         int i, alen = 0;          int i, alen = 0;
         size_t size;          size_t size;
Line 1824  syncprov_detach_op( Operation *op, synco Line 1835  syncprov_detach_op( Operation *op, synco
                 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 */
         size = sizeof(Operation) + sizeof(Opheader) +          size = offsetof( SyncOperationBuffer, sob_extra ) +
                 (i ? ( (i+1) * sizeof(AttributeName) + alen) : 0) +                  (i ? ( (i+1) * sizeof(AttributeName) + alen) : 0) +
                 op->o_req_dn.bv_len + 1 +                  op->o_req_dn.bv_len + 1 +
                 op->o_req_ndn.bv_len + 1 +                  op->o_req_ndn.bv_len + 1 +
                 op->o_ndn.bv_len + 1 +                  op->o_ndn.bv_len + 1 +
                 so->s_filterstr.bv_len + 1;                  so->s_filterstr.bv_len + 1;
         op2 = (Operation *)ch_calloc( 1, size );          sopbuf2 = ch_calloc( 1, size );
         op2->o_hdr = (Opheader *)(op2+1);          op2 = &sopbuf2->sob_op;
           op2->o_hdr = &sopbuf2->sob_hdr;
   
         /* Copy the fields we care about explicitly, leave the rest alone */          /* Copy the fields we care about explicitly, leave the rest alone */
         *op2->o_hdr = *op->o_hdr;          *op2->o_hdr = *op->o_hdr;
Line 1841  syncprov_detach_op( Operation *op, synco Line 1853  syncprov_detach_op( Operation *op, synco
         op2->o_request = op->o_request;          op2->o_request = op->o_request;
         op2->o_private = on;          op2->o_private = on;
   
           ptr = (char *) sopbuf2 + offsetof( SyncOperationBuffer, sob_extra );
         if ( i ) {          if ( i ) {
                 op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1);                  op2->ors_attrs = (AttributeName *) ptr;
                 ptr = (char *)(op2->ors_attrs+i+1);                  ptr = (char *) &op2->ors_attrs[i+1];
                 for (i=0; !BER_BVISNULL( &op->ors_attrs[i].an_name ); 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;
                 }                  }
                 BER_BVZERO( &op2->ors_attrs[i].an_name );                  BER_BVZERO( &op2->ors_attrs[i].an_name );
         } else {  
                 ptr = (char *)(op2->o_hdr + 1);  
         }          }
   
         op2->o_authz = op->o_authz;          op2->o_authz = op->o_authz;
         op2->o_ndn.bv_val = ptr;          op2->o_ndn.bv_val = ptr;
         ptr = lutil_strcopy(ptr, op->o_ndn.bv_val) + 1;          ptr = lutil_strcopy(ptr, op->o_ndn.bv_val) + 1;
Line 2296  syncprov_operational( Line 2308  syncprov_operational(
                                                 a = attr_find( rs->sr_entry->e_attrs,                                                  a = attr_find( rs->sr_entry->e_attrs,
                                                         slap_schema.si_ad_contextCSN );                                                          slap_schema.si_ad_contextCSN );
                                         }                                          }
                                         free( a->a_vals );                                          if ( a->a_nvals != a->a_vals ) {
                                                   ber_bvarray_free( a->a_nvals );
                                           }
                                           a->a_nvals = NULL;
                                           ber_bvarray_free( a->a_vals );
                                           a->a_vals = NULL;
                                 }                                  }
                                 ber_bvarray_dup_x( &a->a_vals, si->si_ctxcsn, NULL );                                  ber_bvarray_dup_x( &a->a_vals, si->si_ctxcsn, NULL );
                                 a->a_nvals = a->a_vals;                                  ber_bvarray_dup_x( &a->a_nvals, si->si_ctxcsn, NULL );
                         }                          }
                         ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock );                          ldap_pvt_thread_rdwr_runlock( &si->si_csn_rwlock );
                 }                  }
Line 2358  sp_cf_gen(ConfigArgs *c) Line 2375  sp_cf_gen(ConfigArgs *c)
                 case SP_CHKPT:                  case SP_CHKPT:
                         if ( si->si_chkops || si->si_chktime ) {                          if ( si->si_chkops || si->si_chktime ) {
                                 struct berval bv;                                  struct berval bv;
                                 bv.bv_len = sprintf( c->msg, "%d %d",                                  bv.bv_len = sprintf( c->cr_msg, "%d %d",
                                         si->si_chkops, si->si_chktime );                                          si->si_chkops, si->si_chktime );
                                 bv.bv_val = c->msg;                                  bv.bv_val = c->cr_msg;
                                 value_add_one( &c->rvalue_vals, &bv );                                  value_add_one( &c->rvalue_vals, &bv );
                         } else {                          } else {
                                 rc = 1;                                  rc = 1;
Line 2419  sp_cf_gen(ConfigArgs *c) Line 2436  sp_cf_gen(ConfigArgs *c)
         switch ( c->type ) {          switch ( c->type ) {
         case SP_CHKPT:          case SP_CHKPT:
                 if ( lutil_atoi( &si->si_chkops, c->argv[1] ) != 0 ) {                  if ( lutil_atoi( &si->si_chkops, c->argv[1] ) != 0 ) {
                         snprintf( c->msg, sizeof( c->msg ), "%s unable to parse checkpoint ops # \"%s\"",                          snprintf( c->cr_msg, sizeof( c->cr_msg ), "%s unable to parse checkpoint ops # \"%s\"",
                                 c->argv[0], c->argv[1] );                                  c->argv[0], c->argv[1] );
                         Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,                          Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,
                                 "%s: %s\n", c->log, c->msg, 0 );                                  "%s: %s\n", c->log, c->cr_msg, 0 );
                         return ARG_BAD_CONF;                          return ARG_BAD_CONF;
                 }                  }
                 if ( si->si_chkops <= 0 ) {                  if ( si->si_chkops <= 0 ) {
                         snprintf( c->msg, sizeof( c->msg ), "%s invalid checkpoint ops # \"%d\"",                          snprintf( c->cr_msg, sizeof( c->cr_msg ), "%s invalid checkpoint ops # \"%d\"",
                                 c->argv[0], si->si_chkops );                                  c->argv[0], si->si_chkops );
                         Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,                          Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,
                                 "%s: %s\n", c->log, c->msg, 0 );                                  "%s: %s\n", c->log, c->cr_msg, 0 );
                         return ARG_BAD_CONF;                          return ARG_BAD_CONF;
                 }                  }
                 if ( lutil_atoi( &si->si_chktime, c->argv[2] ) != 0 ) {                  if ( lutil_atoi( &si->si_chktime, c->argv[2] ) != 0 ) {
                         snprintf( c->msg, sizeof( c->msg ), "%s unable to parse checkpoint time \"%s\"",                          snprintf( c->cr_msg, sizeof( c->cr_msg ), "%s unable to parse checkpoint time \"%s\"",
                                 c->argv[0], c->argv[1] );                                  c->argv[0], c->argv[1] );
                         Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,                          Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,
                                 "%s: %s\n", c->log, c->msg, 0 );                                  "%s: %s\n", c->log, c->cr_msg, 0 );
                         return ARG_BAD_CONF;                          return ARG_BAD_CONF;
                 }                  }
                 if ( si->si_chktime <= 0 ) {                  if ( si->si_chktime <= 0 ) {
                         snprintf( c->msg, sizeof( c->msg ), "%s invalid checkpoint time \"%d\"",                          snprintf( c->cr_msg, sizeof( c->cr_msg ), "%s invalid checkpoint time \"%d\"",
                                 c->argv[0], si->si_chkops );                                  c->argv[0], si->si_chkops );
                         Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,                          Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,
                                 "%s: %s\n", c->log, c->msg, 0 );                                  "%s: %s\n", c->log, c->cr_msg, 0 );
                         return ARG_BAD_CONF;                          return ARG_BAD_CONF;
                 }                  }
                 si->si_chktime *= 60;                  si->si_chktime *= 60;
Line 2453  sp_cf_gen(ConfigArgs *c) Line 2470  sp_cf_gen(ConfigArgs *c)
                 int size = c->value_int;                  int size = c->value_int;
   
                 if ( size < 0 ) {                  if ( size < 0 ) {
                         snprintf( c->msg, sizeof( c->msg ), "%s size %d is negative",                          snprintf( c->cr_msg, sizeof( c->cr_msg ), "%s size %d is negative",
                                 c->argv[0], size );                                  c->argv[0], size );
                         Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,                          Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_NONE,
                                 "%s: %s\n", c->log, c->msg, 0 );                                  "%s: %s\n", c->log, c->cr_msg, 0 );
                         return ARG_BAD_CONF;                          return ARG_BAD_CONF;
                 }                  }
                 sl = si->si_logs;                  sl = si->si_logs;
Line 2500  syncprov_db_otask( Line 2517  syncprov_db_otask(
  */   */
 static int  static int
 syncprov_db_open(  syncprov_db_open(
     BackendDB *be          BackendDB *be,
           ConfigReply *cr
 )  )
 {  {
         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 = { 0 };          Connection conn = { 0 };
         OperationBuffer opbuf = { 0 };          OperationBuffer opbuf;
         Operation *op = (Operation *) &opbuf;          Operation *op;
         Entry *e = NULL;          Entry *e = NULL;
         Attribute *a;          Attribute *a;
         int rc;          int rc;
Line 2530  syncprov_db_open( Line 2548  syncprov_db_open(
         }          }
   
         thrctx = ldap_pvt_thread_pool_context();          thrctx = ldap_pvt_thread_pool_context();
         connection_fake_init( &conn, op, thrctx );          connection_fake_init( &conn, &opbuf, thrctx );
           op = &opbuf.ob_op;
         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;
Line 2592  out: Line 2611  out:
  */   */
 static int  static int
 syncprov_db_close(  syncprov_db_close(
     BackendDB *be          BackendDB *be,
           ConfigReply *cr
 )  )
 {  {
     slap_overinst   *on = (slap_overinst *) be->bd_info;      slap_overinst   *on = (slap_overinst *) be->bd_info;
Line 2602  syncprov_db_close( Line 2622  syncprov_db_close(
                 return 0;                  return 0;
         }          }
         if ( si->si_numops ) {          if ( si->si_numops ) {
                 Connection conn;                  Connection conn = {0};
                 OperationBuffer opbuf;                  OperationBuffer opbuf;
                 Operation *op = (Operation *) &opbuf;                  Operation *op;
                 SlapReply rs = {REP_RESULT};                  SlapReply rs = {REP_RESULT};
                 void *thrctx;                  void *thrctx;
   
                 thrctx = ldap_pvt_thread_pool_context();                  thrctx = ldap_pvt_thread_pool_context();
                 connection_fake_init( &conn, op, thrctx );                  connection_fake_init( &conn, &opbuf, thrctx );
                   op = &opbuf.ob_op;
                 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;
Line 2621  syncprov_db_close( Line 2642  syncprov_db_close(
   
 static int  static int
 syncprov_db_init(  syncprov_db_init(
         BackendDB *be          BackendDB *be,
           ConfigReply *cr
 )  )
 {  {
         slap_overinst   *on = (slap_overinst *)be->bd_info;          slap_overinst   *on = (slap_overinst *)be->bd_info;
Line 2653  syncprov_db_init( Line 2675  syncprov_db_init(
   
 static int  static int
 syncprov_db_destroy(  syncprov_db_destroy(
         BackendDB *be          BackendDB *be,
           ConfigReply *cr
 )  )
 {  {
         slap_overinst   *on = (slap_overinst *)be->bd_info;          slap_overinst   *on = (slap_overinst *)be->bd_info;
Line 2708  static int syncprov_parseCtrl ( Line 2731  static int syncprov_parseCtrl (
                 return LDAP_PROTOCOL_ERROR;                  return LDAP_PROTOCOL_ERROR;
         }          }
   
           if ( BER_BVISNULL( &ctrl->ldctl_value ) ) {
                   rs->sr_text = "Sync control value is absent";
                   return LDAP_PROTOCOL_ERROR;
           }
   
         if ( BER_BVISEMPTY( &ctrl->ldctl_value ) ) {          if ( BER_BVISEMPTY( &ctrl->ldctl_value ) ) {
                 rs->sr_text = "Sync control value is empty (or absent)";                  rs->sr_text = "Sync control value is empty";
                 return LDAP_PROTOCOL_ERROR;                  return LDAP_PROTOCOL_ERROR;
         }          }
   
Line 2767  static int syncprov_parseCtrl ( Line 2795  static int syncprov_parseCtrl (
         sr->sr_rhint = rhint;          sr->sr_rhint = rhint;
         if (!BER_BVISNULL(&cookie)) {          if (!BER_BVISNULL(&cookie)) {
                 ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx );                  ber_dupbv_x( &sr->sr_state.octet_str, &cookie, op->o_tmpmemctx );
                 slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx );                  if ( slap_parse_sync_cookie( &sr->sr_state, op->o_tmpmemctx ) ||
                 if ( sr->sr_state.rid == -1 ) {                          sr->sr_state.rid == -1 ) {
                         rs->sr_text = "Sync control : cookie parsing error";                          rs->sr_text = "Sync control : cookie parsing error";
                         return LDAP_PROTOCOL_ERROR;                          return LDAP_PROTOCOL_ERROR;
                 }                  }

Removed from v.1.147.2.6  
changed lines
  Added in v.1.147.2.7


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