upstream/openldap
1
0
Fork 0
mirror of https://git.openldap.org/openldap/openldap.git synced 2025-12-24 00:29:35 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix runq scheduling

Browse source
This commit is contained in:
Howard Chu 2005-10-02 12:26:02 +00:00
parent 52e8aaea3c
commit 190d6e768d
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
servers/slapd/overlays/syncprov.c
View file

@ -69,7 +69,7 @@ typedef struct syncops {
int s_inuse; /* reference count */
struct syncres *s_res;
struct syncres *s_restail;
void *s_qtask; /* task for playing psearch responses */
struct re_s *s_qtask; /* task for playing psearch responses */
ldap_pvt_thread_mutex_t s_mutex;
} syncops;
@ -900,12 +900,14 @@ syncprov_qresp( opcookie *opc, syncops *so, int mode )
if ( so->s_flags & PS_IS_DETACHED ) {
ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex );
if ( !so->s_qtask ) {
so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, 0,
so->s_qtask = ldap_pvt_runqueue_insert( &slapd_rq, 1,
syncprov_qtask, so, "syncprov_qtask",
so->s_op->o_conn->c_peer_name.bv_val );
} else {
if (!ldap_pvt_runqueue_isrunning( &slapd_rq, so->s_qtask )) {
so->s_qtask->interval.tv_sec = 0;
ldap_pvt_runqueue_resched( &slapd_rq, so->s_qtask, 0 );
so->s_qtask->interval.tv_sec = 1;
}
}
ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex );