[BACK]Return to syncprov.c CVS log [TXT] [DIR] Up to [OpenLDAP] / servers / slapd / overlays

Diff for /servers/slapd/overlays/syncprov.c between versions 1.18 and 1.19

version 1.18, 2004/11/26 23:57:38 version 1.19, 2004/11/27 00:26:12
Line 263  syncprov_state_ctrl_from_slog( Line 263  syncprov_state_ctrl_from_slog(
         return LDAP_SUCCESS;          return LDAP_SUCCESS;
 }  }
   
 int  static int
 syncprov_sendinfo(  syncprov_sendinfo(
         Operation       *op,          Operation       *op,
         SlapReply       *rs,          SlapReply       *rs,
Line 908  syncprov_op_response( Operation *op, Sla Line 908  syncprov_op_response( Operation *op, Sla
         return SLAP_CB_CONTINUE;          return SLAP_CB_CONTINUE;
 }  }
   
   static void
   syncprov_free_syncop( syncops *so )
   {
           syncres *sr, *srnext;
   
           filter_free( so->s_op->ors_filter );
           ch_free( so->s_op );
           ch_free( so->s_base.bv_val );
           for ( sr=so->s_res; sr; sr=srnext ) {
                   srnext = sr->s_next;
                   ch_free( sr );
           }
           ldap_pvt_thread_mutex_destroy( &so->s_mutex );
           ch_free( so );
   }
   
   static int
   syncprov_op_abandon( Operation *op, SlapReply *rs )
   {
           slap_overinst           *on = (slap_overinst *)op->o_bd->bd_info;
           syncprov_info_t         *si = on->on_bi.bi_private;
           syncops *so, *soprev;
   
           ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );
           for ( so=si->si_ops, soprev = (syncops *)&si->si_ops; so;
                   soprev=so, so=so->s_next ) {
                   if ( so->s_op->o_connid == op->o_connid &&
                           so->s_op->o_msgid == op->orn_msgid ) {
                                   soprev->s_next = so->s_next;
                                   break;
                   }
           }
           ldap_pvt_thread_mutex_unlock( &si->si_ops_mutex );
           if ( so ) {
                   ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
                   op->o_conn->c_n_ops_executing--;
                   op->o_conn->c_n_ops_completed++;
                   ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
                   /* Is this really a Cancel exop? */
                   if ( op->o_tag != LDAP_REQ_ABANDON ) {
                           rs->sr_err = LDAP_CANCELLED;
                           send_ldap_result( so->s_op, rs );
                   }
                   syncprov_free_syncop( so );
           }
           return SLAP_CB_CONTINUE;
   }
   
 #if 0  #if 0
 static int  static int
 syncprov_op_compare( Operation *op, SlapReply *rs )  syncprov_op_compare( Operation *op, SlapReply *rs )
Line 1070  syncprov_detach_op( Operation *op, synco Line 1118  syncprov_detach_op( Operation *op, synco
         /* Increment number of ops so that idletimeout ignores us */          /* Increment number of ops so that idletimeout ignores us */
         ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );          ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
         op->o_conn->c_n_ops_executing++;          op->o_conn->c_n_ops_executing++;
           op->o_conn->c_n_ops_completed--;
         ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );          ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
 }  }
   
Line 1533  syncprov_init() Line 1582  syncprov_init()
         syncprov.on_bi.bi_db_config = syncprov_db_config;          syncprov.on_bi.bi_db_config = syncprov_db_config;
         syncprov.on_bi.bi_db_destroy = syncprov_db_destroy;          syncprov.on_bi.bi_db_destroy = syncprov_db_destroy;
   
           syncprov.on_bi.bi_op_abandon = syncprov_op_abandon;
           syncprov.on_bi.bi_op_cancel = syncprov_op_abandon;
   
         syncprov.on_bi.bi_op_add = syncprov_op_mod;          syncprov.on_bi.bi_op_add = syncprov_op_mod;
 #if 0  #if 0
         syncprov.on_bi.bi_op_compare = syncprov_op_compare;          syncprov.on_bi.bi_op_compare = syncprov_op_compare;
Removed from v.1.18  
changed lines
  Added in v.1.19

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