Diff for /servers/slapd/overlays/syncprov.c between versions 1.112 and 1.113

version 1.112, 2005/10/03 02:49:35 version 1.113, 2005/10/03 20:59:25
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.111 2005/10/02 10:28:50 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.112 2005/10/03 02:49:35 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/>.
  *   *
Line 697  again: Line 697  again:
         return rc;          return rc;
 }  }
   
   static void
   syncprov_free_syncop( syncops *so )
   {
           syncres *sr, *srnext;
           GroupAssertion *ga, *gnext;
   
           ldap_pvt_thread_mutex_lock( &so->s_mutex );
           if ( --so->s_inuse > 0 ) {
                   ldap_pvt_thread_mutex_unlock( &so->s_mutex );
                   return;
           }
           ldap_pvt_thread_mutex_unlock( &so->s_mutex );
           if ( so->s_flags & PS_IS_DETACHED ) {
                   filter_free( so->s_op->ors_filter );
                   for ( ga = so->s_op->o_groups; ga; ga=gnext ) {
                           gnext = ga->ga_next;
                           ch_free( ga );
                   }
                   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 );
   }
   
 /* Send a persistent search response */  /* Send a persistent search response */
 static int  static int
 syncprov_sendresp( Operation *op, opcookie *opc, syncops *so, Entry **e, int mode)  syncprov_sendresp( Operation *op, opcookie *opc, syncops *so, Entry **e, int mode)
Line 762  syncprov_sendresp( Operation *op, opcook Line 791  syncprov_sendresp( Operation *op, opcook
         default:          default:
                 assert(0);                  assert(0);
         }          }
         op->o_tmpfree( rs.sr_ctrls[0], op->o_tmpmemctx );          /* In case someone else freed it already? */
         rs.sr_ctrls = NULL;          if ( rs.sr_ctrls ) {
                   op->o_tmpfree( rs.sr_ctrls[0], op->o_tmpmemctx );
                   rs.sr_ctrls = NULL;
           }
   
         return rs.sr_err;          return rs.sr_err;
 }  }
Line 789  syncprov_qplay( Operation *op, slap_over Line 821  syncprov_qplay( Operation *op, slap_over
                         so->s_restail = NULL;                          so->s_restail = NULL;
                 ldap_pvt_thread_mutex_unlock( &so->s_mutex );                  ldap_pvt_thread_mutex_unlock( &so->s_mutex );
   
                 if ( !sr )                  if ( !sr || so->s_op->o_abandon )
                         break;                          break;
   
                 if ( !so->s_op->o_abandon ) {                  opc.sdn = sr->s_dn;
                         opc.sdn = sr->s_dn;                  opc.sndn = sr->s_ndn;
                         opc.sndn = sr->s_ndn;                  opc.suuid = sr->s_uuid;
                         opc.suuid = sr->s_uuid;                  opc.sctxcsn = sr->s_csn;
                         opc.sctxcsn = sr->s_csn;                  opc.sreference = sr->s_isreference;
                         opc.sreference = sr->s_isreference;                  e = NULL;
                         e = NULL;  
                   if ( sr->s_mode != LDAP_SYNC_DELETE ) {
                         if ( sr->s_mode != LDAP_SYNC_DELETE ) {                          rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e );
                                 rc = be_entry_get_rw( op, &opc.sndn, NULL, NULL, 0, &e );                          if ( rc ) {
                                 if ( rc ) {                                  ch_free( sr );
                                         ch_free( sr );                                  continue;
                                         continue;  
                                 }  
                         }                          }
                         rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode );                  }
                   rc = syncprov_sendresp( op, &opc, so, &e, sr->s_mode );
   
                         if ( e ) {                  if ( e ) {
                                 be_entry_release_rw( op, e, 0 );                          be_entry_release_rw( op, e, 0 );
                         }  
                         if ( rc )  
                                 break;  
                 }                  }
   
                 ch_free( sr );                  ch_free( sr );
   
                   if ( rc )
                           break;
         }          }
         op->o_bd->bd_info = (BackendInfo *)on;          op->o_bd->bd_info = (BackendInfo *)on;
         return rc;          return rc;
Line 854  syncprov_qtask( void *ctx, void *arg ) Line 885  syncprov_qtask( void *ctx, void *arg )
   
         syncprov_qplay( op, on, so );          syncprov_qplay( op, on, so );
   
           /* decrement use count... */
           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, so->s_qtask );
Line 905  syncprov_qresp( opcookie *opc, syncops * Line 939  syncprov_qresp( opcookie *opc, syncops *
                         so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, RUNQ_INTERVAL,                          so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, RUNQ_INTERVAL,
                                 syncprov_qtask, so, "syncprov_qtask",                                  syncprov_qtask, so, "syncprov_qtask",
                                 so->s_op->o_conn->c_peer_name.bv_val );                                  so->s_op->o_conn->c_peer_name.bv_val );
                           ++so->s_inuse;
                 } else {                  } else {
                         if (!ldap_pvt_runqueue_isrunning( &slapd_rq, so->s_qtask ) &&                          if (!ldap_pvt_runqueue_isrunning( &slapd_rq, so->s_qtask ) &&
                                 !so->s_qtask->next_sched.tv_sec ) {                                  !so->s_qtask->next_sched.tv_sec ) {
                                 so->s_qtask->interval.tv_sec = 0;                                  so->s_qtask->interval.tv_sec = 0;
                                 ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 0 );                                  ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 0 );
                                 so->s_qtask->interval.tv_sec = RUNQ_INTERVAL;                                  so->s_qtask->interval.tv_sec = RUNQ_INTERVAL;
                                   ++so->s_inuse;
                         }                          }
                 }                  }
                 ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex );                  ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex );
Line 919  syncprov_qresp( opcookie *opc, syncops * Line 955  syncprov_qresp( opcookie *opc, syncops *
         return LDAP_SUCCESS;          return LDAP_SUCCESS;
 }  }
   
 static void  
 syncprov_free_syncop( syncops *so )  
 {  
         syncres *sr, *srnext;  
         GroupAssertion *ga, *gnext;  
   
         ldap_pvt_thread_mutex_lock( &so->s_mutex );  
         so->s_inuse--;  
         if ( so->s_inuse > 0 ) {  
                 ldap_pvt_thread_mutex_unlock( &so->s_mutex );  
                 return;  
         }  
         ldap_pvt_thread_mutex_unlock( &so->s_mutex );  
         if ( so->s_flags & PS_IS_DETACHED ) {  
                 filter_free( so->s_op->ors_filter );  
                 for ( ga = so->s_op->o_groups; ga; ga=gnext ) {  
                         gnext = ga->ga_next;  
                         ch_free( ga );  
                 }  
                 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  static int
 syncprov_drop_psearch( syncops *so, int lock )  syncprov_drop_psearch( syncops *so, int lock )
 {  {
Line 1124  syncprov_matchops( Operation *op, opcook Line 1130  syncprov_matchops( Operation *op, opcook
                                 sm = op->o_tmpalloc( sizeof(syncmatches), op->o_tmpmemctx );                                  sm = op->o_tmpalloc( sizeof(syncmatches), op->o_tmpmemctx );
                                 sm->sm_next = opc->smatches;                                  sm->sm_next = opc->smatches;
                                 sm->sm_op = ss;                                  sm->sm_op = ss;
                                 ss->s_inuse++;                                  ldap_pvt_thread_mutex_lock( &ss->s_mutex );
                                   ++ss->s_inuse;
                                   ldap_pvt_thread_mutex_unlock( &ss->s_mutex );
                                 opc->smatches = sm;                                  opc->smatches = sm;
                         } else {                          } else {
                                 /* if found send UPDATE else send ADD */                                  /* if found send UPDATE else send ADD */
                                 ss->s_inuse++;  
                                 syncprov_qresp( opc, ss,                                  syncprov_qresp( opc, ss,
                                         found ? LDAP_SYNC_MODIFY : LDAP_SYNC_ADD );                                          found ? LDAP_SYNC_MODIFY : LDAP_SYNC_ADD );
                                 ss->s_inuse--;  
                         }                          }
                 } else if ( !saveit && found ) {                  } else if ( !saveit && found ) {
                         /* send DELETE */                          /* send DELETE */
Line 1811  syncprov_search_response( Operation *op, Line 1817  syncprov_search_response( Operation *op,
                                 &cookie, 1, NULL, 0 );                                  &cookie, 1, NULL, 0 );
                         /* Flush any queued persist messages */                          /* Flush any queued persist messages */
                         if ( ss->ss_so->s_res ) {                          if ( ss->ss_so->s_res ) {
                                   slap_callback *sc = op->o_callback;
                                   op->o_callback = NULL;
                                 syncprov_qplay( op, on, ss->ss_so );                                  syncprov_qplay( op, on, ss->ss_so );
                                   op->o_callback = sc;
                         }                          }
   
                         /* Detach this Op from frontend control */                          /* Detach this Op from frontend control */

Removed from v.1.112  
changed lines
  Added in v.1.113


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