From 35d1bd68b955ec9a4c94fbb33765d08a8e8128ae Mon Sep 17 00:00:00 2001
From: Jong Hyuk Choi <jongchoi@openldap.org>
Date: Wed, 7 May 2003 23:52:08 +0000
Subject: [PATCH] runqueue restructuring

---
 include/ldap_rq.h        |  6 ++++--
 libraries/libldap_r/rq.c |  6 ++++--
 servers/slapd/backend.c  |  2 +-
 servers/slapd/daemon.c   | 33 +++++++++++++++------------------
 servers/slapd/syncrepl.c |  2 +-
 5 files changed, 25 insertions(+), 24 deletions(-)

diff --git a/include/ldap_rq.h b/include/ldap_rq.h
index 3344f902e1..db83a8da1d 100644
--- a/include/ldap_rq.h
+++ b/include/ldap_rq.h
@@ -7,7 +7,8 @@ typedef struct re_s {
 	struct timeval interval;
 	LDAP_STAILQ_ENTRY(re_s) tnext; /* it includes running */
 	LDAP_STAILQ_ENTRY(re_s) rnext;
-	void *private;
+	ldap_pvt_thread_start_t *routine;
+	void *arg;
 } re_t;
 
 typedef struct runqueue_s {
@@ -20,7 +21,8 @@ LDAP_F( void )
 ldap_pvt_runqueue_insert(
 	struct runqueue_s* rq,
 	time_t interval,
-	void *private
+	ldap_pvt_thread_start_t* routine,
+	void *arg
 );
 
 LDAP_F( void )
diff --git a/libraries/libldap_r/rq.c b/libraries/libldap_r/rq.c
index 4cf59c1992..f1fe099361 100644
--- a/libraries/libldap_r/rq.c
+++ b/libraries/libldap_r/rq.c
@@ -20,7 +20,8 @@ void
 ldap_pvt_runqueue_insert(
 	struct runqueue_s* rq,
 	time_t interval,
-	void *private
+	ldap_pvt_thread_start_t *routine,
+	void *arg
 )
 {
 	struct re_s* entry;
@@ -30,7 +31,8 @@ ldap_pvt_runqueue_insert(
 	entry->interval.tv_usec = 0;
 	entry->next_sched.tv_sec = time( NULL );
 	entry->next_sched.tv_usec = 0;
-	entry->private = private;
+	entry->routine = routine;
+	entry->arg = arg;
 	LDAP_STAILQ_INSERT_HEAD( &rq->task_list, entry, tnext );
 }
 
diff --git a/servers/slapd/backend.c b/servers/slapd/backend.c
index 0075e9921c..d2350bb44b 100644
--- a/servers/slapd/backend.c
+++ b/servers/slapd/backend.c
@@ -365,7 +365,7 @@ int backend_startup(Backend *be)
 			syncinfo_t *si = ( syncinfo_t * ) backendDB[i].syncinfo;
 			ldap_pvt_thread_mutex_lock( &syncrepl_rq.rq_mutex );
 			ldap_pvt_runqueue_insert( &syncrepl_rq, si->interval,
-							(void *) &backendDB[i] );
+							do_syncrepl, (void *) &backendDB[i] );
 			ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
 		}
 #endif
diff --git a/servers/slapd/daemon.c b/servers/slapd/daemon.c
index 571b8979d2..a94349897f 100644
--- a/servers/slapd/daemon.c
+++ b/servers/slapd/daemon.c
@@ -1297,12 +1297,25 @@ slapd_daemon_task(
 		at = ldap_pvt_thread_pool_backload(&connection_pool);
 
 #ifdef LDAP_SYNCREPL
-		/* cat is of struct timeval containing the earliest schedule */
 		ldap_pvt_thread_mutex_lock( &syncrepl_rq.rq_mutex );
 		rtask = ldap_pvt_runqueue_next_sched( &syncrepl_rq, &cat );
+		while ( cat && cat->tv_sec && cat->tv_sec <= now ) {
+			if ( ldap_pvt_runqueue_isrunning( &syncrepl_rq, rtask )) {
+				ldap_pvt_runqueue_resched( &syncrepl_rq, rtask );
+			} else {
+				ldap_pvt_runqueue_runtask( &syncrepl_rq, rtask );
+				ldap_pvt_runqueue_resched( &syncrepl_rq, rtask );
+				ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
+				ldap_pvt_thread_pool_submit( &connection_pool,
+											rtask->routine, (void *) rtask );
+			}
+			rtask = ldap_pvt_runqueue_next_sched( &syncrepl_rq, &cat );
+		}
+		rtask = ldap_pvt_runqueue_next_sched( &syncrepl_rq, &cat );
 		ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
+
 		if ( cat != NULL ) {
-			diff.tv_sec = cat->tv_sec - slap_get_time();
+			diff.tv_sec = difftime( cat->tv_sec, now );
 			if ( diff.tv_sec == 0 )
 				diff.tv_sec = tdelta;
 		}
@@ -1386,22 +1399,6 @@ slapd_daemon_task(
 			    0, 0, 0 );
 #endif
 
-#ifdef LDAP_SYNCREPL
-			ldap_pvt_thread_mutex_lock( &syncrepl_rq.rq_mutex );
-			rtask = ldap_pvt_runqueue_next_sched( &syncrepl_rq, &cat );
-			if ( ldap_pvt_runqueue_isrunning( &syncrepl_rq, rtask )) {
-				ldap_pvt_runqueue_resched( &syncrepl_rq, rtask );
-				ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
-			} else if ( cat && cat->tv_sec && cat->tv_sec <= slap_get_time() ) {
-				ldap_pvt_runqueue_runtask( &syncrepl_rq, rtask );
-				ldap_pvt_runqueue_resched( &syncrepl_rq, rtask );
-				ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
-				ldap_pvt_thread_pool_submit( &connection_pool,
-								do_syncrepl, (void *) rtask );
-			} else {
-				ldap_pvt_thread_mutex_unlock( &syncrepl_rq.rq_mutex );
-			}
-#endif
 			ldap_pvt_thread_yield();
 			continue;
 
diff --git a/servers/slapd/syncrepl.c b/servers/slapd/syncrepl.c
index 261287c5eb..3794f00cd2 100644
--- a/servers/slapd/syncrepl.c
+++ b/servers/slapd/syncrepl.c
@@ -119,7 +119,7 @@ do_syncrepl(
 	void	*arg )
 {
 	struct re_s* rtask = arg;
-	Backend *be = rtask->private;
+	Backend *be = rtask->arg;
 	syncinfo_t *si = ( syncinfo_t * ) be->syncinfo;
 
 	SlapReply	rs = {REP_RESULT};
-- 
2.39.5