mirror of
https://git.openldap.org/openldap/openldap.git
synced 2024-12-21 03:10:25 +08:00
ITS#3151 always reschedule consistency_check task
This commit is contained in:
parent
73fa8b7dd9
commit
88e2a06b5e
@ -1608,16 +1608,15 @@ consistency_check(
|
||||
}
|
||||
ldap_pvt_thread_mutex_unlock(&cm->remove_mutex);
|
||||
}
|
||||
/* If there were no queries, defer processing for a while */
|
||||
if ( pause ) {
|
||||
ldap_pvt_thread_mutex_lock( &syncrepl_rq.rq_mutex );
|
||||
cm->cc_paused = 1;
|
||||
if ( ldap_pvt_runqueue_isrunning( &syncrepl_rq, rtask )) {
|
||||
ldap_pvt_runqueue_stoptask( &syncrepl_rq, rtask );
|
||||
}
|
||||
ldap_pvt_runqueue_resched( &syncrepl_rq, rtask, 1 );
|
||||
ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
|
||||
ldap_pvt_thread_mutex_lock( &syncrepl_rq.rq_mutex );
|
||||
if ( ldap_pvt_runqueue_isrunning( &syncrepl_rq, rtask )) {
|
||||
ldap_pvt_runqueue_stoptask( &syncrepl_rq, rtask );
|
||||
}
|
||||
/* If there were no queries, defer processing for a while */
|
||||
cm->cc_paused = pause;
|
||||
ldap_pvt_runqueue_resched( &syncrepl_rq, rtask, pause );
|
||||
|
||||
ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user