Diff for /servers/slapd/overlays/syncprov.c between versions 1.187 and 1.192

version 1.187, 2007/05/14 19:25:48 version 1.192, 2007/07/20 13:16:36
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.186 2007/04/20 20:32:58 kurt Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.191 2007/07/18 19:02:14 hallvard 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 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 1312  syncprov_checkpoint( Operation *op, Slap Line 1313  syncprov_checkpoint( Operation *op, Slap
         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 1811  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 1825  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 1842  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 2508  syncprov_db_open( Line 2519  syncprov_db_open(
         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 2531  syncprov_db_open( Line 2542  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 2603  syncprov_db_close( Line 2615  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 2773  static int syncprov_parseCtrl ( Line 2786  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.187  
changed lines
  Added in v.1.192


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