Diff for /servers/slapd/overlays/syncprov.c between versions 1.58 and 1.63

version 1.58, 2004/12/31 11:02:35 version 1.63, 2005/01/12 01:32:48
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.57 2004/12/12 06:00:58 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.62 2005/01/12 00:49:00 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/>.
  *   *
  * Copyright 2004 The OpenLDAP Foundation.   * Copyright 2004-2005 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 84  typedef struct sync_control { Line 84  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 525  findmax_cb( Operation *op, SlapReply *rs Line 526  findmax_cb( Operation *op, SlapReply *rs
                 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 );
   
                 if ( a && ber_bvcmp( &a->a_vals[0], maxcsn )) {                  if ( a && ber_bvcmp( &a->a_vals[0], maxcsn ) > 0 ) {
                         maxcsn->bv_len = a->a_vals[0].bv_len;                          maxcsn->bv_len = a->a_vals[0].bv_len;
                         strcpy( maxcsn->bv_val, a->a_vals[0].bv_val );                          strcpy( maxcsn->bv_val, a->a_vals[0].bv_val );
                 }                  }
Line 644  syncprov_findcsn( Operation *op, int mod Line 645  syncprov_findcsn( Operation *op, int mod
                 fop.ors_slimit = SLAP_NO_LIMIT;                  fop.ors_slimit = SLAP_NO_LIMIT;
                 cb.sc_private = &maxcsn;                  cb.sc_private = &maxcsn;
                 cb.sc_response = findmax_cb;                  cb.sc_response = findmax_cb;
                   strcpy( cbuf, si->si_ctxcsn.bv_val );
                 maxcsn.bv_val = cbuf;                  maxcsn.bv_val = cbuf;
                 maxcsn.bv_len = 0;                  maxcsn.bv_len = si->si_ctxcsn.bv_len;
                 break;                  break;
         case FIND_CSN:          case FIND_CSN:
                 cf.f_choice = LDAP_FILTER_LE;                  cf.f_choice = LDAP_FILTER_LE;
Line 696  syncprov_findcsn( Operation *op, int mod Line 698  syncprov_findcsn( Operation *op, int mod
   
         switch( mode ) {          switch( mode ) {
         case FIND_MAXCSN:          case FIND_MAXCSN:
                 if ( maxcsn.bv_len ) {                  strcpy( si->si_ctxcsnbuf, maxcsn.bv_val );
                         strcpy( si->si_ctxcsnbuf, maxcsn.bv_val );                  si->si_ctxcsn.bv_len = maxcsn.bv_len;
                         si->si_ctxcsn.bv_len = maxcsn.bv_len;  
                 }  
                 break;                  break;
         case FIND_CSN:          case FIND_CSN:
                 /* If matching CSN was not found, invalidate the context. */                  /* If matching CSN was not found, invalidate the context. */
Line 829  syncprov_free_syncop( syncops *so ) Line 829  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 847  syncprov_free_syncop( syncops *so ) Line 849  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 882  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 );
                 }                  }
                 /* 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 1585  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 1611  syncprov_search_response( Operation *op, Line 1611  syncprov_search_response( Operation *op,
                 if ( 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 ( 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,

Removed from v.1.58  
changed lines
  Added in v.1.63


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