Diff for /servers/slapd/overlays/syncprov.c between versions 1.56.2.40 and 1.147.2.3

version 1.56.2.40, 2007/01/02 21:44:08 version 1.147.2.3, 2006/10/19 20:06:55
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.56.2.39 2006/12/16 00:26:41 quanah Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.147.2.2 2006/08/17 23:50:32 kurt 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/>.
  *   *
  * Copyright 2004-2007 The OpenLDAP Foundation.   * Copyright 2004-2006 The OpenLDAP Foundation.
  * All rights reserved.   * All rights reserved.
  *   *
  * Redistribution and use in source and binary forms, with or without   * Redistribution and use in source and binary forms, with or without
Line 774  syncprov_sendresp( Operation *op, opcook Line 774  syncprov_sendresp( Operation *op, opcook
                         rs.sr_flags = REP_ENTRY_MUSTRELEASE;                          rs.sr_flags = REP_ENTRY_MUSTRELEASE;
                 if ( opc->sreference ) {                  if ( opc->sreference ) {
                         rs.sr_ref = get_entry_referrals( op, rs.sr_entry );                          rs.sr_ref = get_entry_referrals( op, rs.sr_entry );
                         send_search_reference( op, &rs );                          rs.sr_err = send_search_reference( op, &rs );
                         ber_bvarray_free( rs.sr_ref );                          ber_bvarray_free( rs.sr_ref );
                         if ( !rs.sr_entry )                          if ( !rs.sr_entry )
                                 *e = NULL;                                  *e = NULL;
Line 786  syncprov_sendresp( Operation *op, opcook Line 786  syncprov_sendresp( Operation *op, opcook
                 if ( rs.sr_entry->e_private )                  if ( rs.sr_entry->e_private )
                         rs.sr_flags = REP_ENTRY_MUSTRELEASE;                          rs.sr_flags = REP_ENTRY_MUSTRELEASE;
                 rs.sr_attrs = op->ors_attrs;                  rs.sr_attrs = op->ors_attrs;
                 send_search_entry( op, &rs );                  rs.sr_err = send_search_entry( op, &rs );
                 if ( !rs.sr_entry )                  if ( !rs.sr_entry )
                         *e = NULL;                          *e = NULL;
                 break;                  break;
Line 798  syncprov_sendresp( Operation *op, opcook Line 798  syncprov_sendresp( Operation *op, opcook
                 if ( opc->sreference ) {                  if ( opc->sreference ) {
                         struct berval bv = BER_BVNULL;                          struct berval bv = BER_BVNULL;
                         rs.sr_ref = &bv;                          rs.sr_ref = &bv;
                         send_search_reference( op, &rs );                          rs.sr_err = send_search_reference( op, &rs );
                 } else {                  } else {
                         send_search_entry( op, &rs );                          rs.sr_err = send_search_entry( op, &rs );
                 }                  }
                 break;                  break;
         default:          default:
Line 878  syncprov_qtask( void *ctx, void *arg ) Line 878  syncprov_qtask( void *ctx, void *arg )
         OperationBuffer opbuf;          OperationBuffer opbuf;
         Operation *op;          Operation *op;
         BackendDB be;          BackendDB be;
           int rc;
   
         op = (Operation *) &opbuf;          op = (Operation *) &opbuf;
         *op = *so->s_op;          *op = *so->s_op;
Line 898  syncprov_qtask( void *ctx, void *arg ) Line 899  syncprov_qtask( void *ctx, void *arg )
         op->o_private = NULL;          op->o_private = NULL;
         op->o_callback = NULL;          op->o_callback = NULL;
   
         (void)syncprov_qplay( op, on, so );          rc = syncprov_qplay( op, on, so );
   
         /* decrement use count... */          /* decrement use count... */
         syncprov_free_syncop( so );          syncprov_free_syncop( so );
   
         /* wait until we get explicitly scheduled again */          /* wait until we get explicitly scheduled again */
         ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex );          ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex );
         ldap_pvt_runqueue_stoptask( &slapd_rq, so->s_qtask );          ldap_pvt_runqueue_stoptask( &slapd_rq, rtask );
         ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 1 );          if ( rc == 0 ) {
                   ldap_pvt_runqueue_resched( &slapd_rq, rtask, 1 );
           } else {
                   /* bail out on any error */
                   ldap_pvt_runqueue_remove( &slapd_rq, rtask );
           }
         ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex );          ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex );
   
   #if 0   /* FIXME: connection_close isn't exported from slapd.
                    * should it be?
                    */
           if ( rc ) {
                   ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
                   if ( connection_state_closing( op->o_conn )) {
                           connection_close( op->o_conn );
                   }
                   ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
           }
   #endif
         return NULL;          return NULL;
 }  }
   
Line 1243  syncprov_op_cleanup( Operation *op, Slap Line 1260  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 )
         struct berval *csn )  
 {  {
           syncprov_info_t         *si = on->on_bi.bi_private;
         Modifications mod;          Modifications mod;
         Operation opm;          Operation opm;
         SlapReply rsm = { 0 };          SlapReply rsm = { 0 };
Line 1253  syncprov_checkpoint( Operation *op, Slap Line 1270  syncprov_checkpoint( Operation *op, Slap
         slap_callback cb = {0};          slap_callback cb = {0};
   
         /* If ctxcsn is empty, delete it */          /* If ctxcsn is empty, delete it */
         if ( BER_BVISEMPTY( csn )) {          if ( BER_BVISEMPTY( &si->si_ctxcsn )) {
                 mod.sml_values = NULL;                  mod.sml_values = NULL;
         } else {          } else {
                 mod.sml_values = bv;                  mod.sml_values = bv;
                 bv[1].bv_val = NULL;                  bv[1].bv_val = NULL;
                 bv[0] = *csn;                  bv[0] = si->si_ctxcsn;
         }          }
         mod.sml_nvalues = NULL;          mod.sml_nvalues = NULL;
         mod.sml_desc = slap_schema.si_ad_contextCSN;          mod.sml_desc = slap_schema.si_ad_contextCSN;
Line 1493  syncprov_op_response( Operation *op, Sla Line 1510  syncprov_op_response( Operation *op, Sla
         {          {
                 struct berval maxcsn = BER_BVNULL;                  struct berval maxcsn = BER_BVNULL;
                 char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];                  char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
                 int do_check = 0;  
   
                 /* Update our context CSN */                  /* Update our context CSN */
                 cbuf[0] = '\0';                  cbuf[0] = '\0';
Line 1516  syncprov_op_response( Operation *op, Sla Line 1532  syncprov_op_response( Operation *op, Sla
   
                 si->si_numops++;                  si->si_numops++;
                 if ( si->si_chkops || si->si_chktime ) {                  if ( si->si_chkops || si->si_chktime ) {
                           int do_check=0;
                         if ( si->si_chkops && si->si_numops >= si->si_chkops ) {                          if ( si->si_chkops && si->si_numops >= si->si_chkops ) {
                                 do_check = 1;                                  do_check = 1;
                                 si->si_numops = 0;                                  si->si_numops = 0;
Line 1525  syncprov_op_response( Operation *op, Sla Line 1542  syncprov_op_response( Operation *op, Sla
                                 do_check = 1;                                  do_check = 1;
                                 si->si_chklast = op->o_time;                                  si->si_chklast = op->o_time;
                         }                          }
                           if ( do_check ) {
                                   syncprov_checkpoint( op, rs, on );
                           }
                 }                  }
                 ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_unlock( &si->si_csn_mutex );
   
                 opc->sctxcsn.bv_len = maxcsn.bv_len;                  opc->sctxcsn.bv_len = maxcsn.bv_len;
                 opc->sctxcsn.bv_val = cbuf;                  opc->sctxcsn.bv_val = cbuf;
   
                 if ( do_check ) {  
                         syncprov_checkpoint( op, rs, on, &opc->sctxcsn );  
                 }  
   
                 /* Handle any persistent searches */                  /* Handle any persistent searches */
                 if ( si->si_ops ) {                  if ( si->si_ops ) {
                         switch(op->o_tag) {                          switch(op->o_tag) {
Line 2133  syncprov_operational( Line 2149  syncprov_operational(
                         if ( !a ) {                          if ( !a ) {
                                 for ( ap = &rs->sr_operational_attrs; *ap; ap=&(*ap)->a_next );                                  for ( ap = &rs->sr_operational_attrs; *ap; ap=&(*ap)->a_next );
   
                                 a = ch_malloc( sizeof(Attribute));                                  a = attr_alloc( slap_schema.si_ad_contextCSN );
                                 a->a_desc = slap_schema.si_ad_contextCSN;  
                                 a->a_vals = ch_malloc( 2 * sizeof(struct berval));                                  a->a_vals = ch_malloc( 2 * sizeof(struct berval));
                                 a->a_vals[1].bv_val = NULL;                                  a->a_vals[1].bv_val = NULL;
                                 a->a_nvals = a->a_vals;                                  a->a_nvals = a->a_vals;
                                 a->a_next = NULL;  
                                 a->a_flags = 0;  
                                 *ap = a;                                  *ap = a;
                         }                          }
   
Line 2459  syncprov_db_close( Line 2472  syncprov_db_close(
                 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;
                 syncprov_checkpoint( op, &rs, on, &si->si_ctxcsn );                  syncprov_checkpoint( op, &rs, on );
                 ldap_pvt_thread_pool_context_reset( thrctx );                  ldap_pvt_thread_pool_context_reset( thrctx );
         }          }
   
Line 2474  syncprov_db_init( Line 2487  syncprov_db_init(
         slap_overinst   *on = (slap_overinst *)be->bd_info;          slap_overinst   *on = (slap_overinst *)be->bd_info;
         syncprov_info_t *si;          syncprov_info_t *si;
   
         if ( SLAP_ISGLOBALOVERLAY( be ) ) {  
                 Debug( LDAP_DEBUG_ANY,  
                         "syncprov must be instantiated within a database.\n",  
                         0, 0, 0 );  
                 return 1;  
         }  
   
         si = ch_calloc(1, sizeof(syncprov_info_t));          si = ch_calloc(1, sizeof(syncprov_info_t));
         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 );

Removed from v.1.56.2.40  
changed lines
  Added in v.1.147.2.3


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