From 53202e5711f32c80ec89d149da7de72b2a1fc953 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Fri, 4 Mar 2011 15:52:13 +0000
Subject: Added some extra functions to Bu::MiniCron to let you execute jobs
 that are in the queue immediately, with or without rescheduling, by id or
 name.

---
 src/minicron.cpp | 57 ++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 55 insertions(+), 2 deletions(-)

(limited to 'src/minicron.cpp')

diff --git a/src/minicron.cpp b/src/minicron.cpp
index 3375492..95cf66b 100644
--- a/src/minicron.cpp
+++ b/src/minicron.cpp
@@ -119,6 +119,58 @@ void Bu::MiniCron::removeJob( JobId jid )
 	}
 }
 
+void Bu::MiniCron::runJob( JobId jid, bool bReschedule )
+{
+	Bu::List<Job *> lJobs;
+	while( !hJobs.isEmpty() )
+	{
+		Job *pJob = hJobs.dequeue();
+		if( pJob->getId() == jid )
+		{
+			pJob->run( bReschedule );
+			if( !pJob->bContinue )
+			{
+				delete pJob;
+				break;
+			}
+			lJobs.append( pJob );
+			break;
+		}
+		lJobs.append( pJob );
+	}
+
+	for( Bu::List<Job *>::iterator i = lJobs.begin(); i; i++ )
+	{
+		hJobs.enqueue( *i );
+	}
+}
+
+void Bu::MiniCron::runJob( const Bu::String &sName, bool bReschedule )
+{
+	Bu::List<Job *> lJobs;
+	while( !hJobs.isEmpty() )
+	{
+		Job *pJob = hJobs.dequeue();
+		if( pJob->getName() == sName )
+		{
+			pJob->run( bReschedule );
+			if( !pJob->bContinue )
+			{
+				delete pJob;
+				break;
+			}
+			lJobs.append( pJob );
+			break;
+		}
+		lJobs.append( pJob );
+	}
+
+	for( Bu::List<Job *>::iterator i = lJobs.begin(); i; i++ )
+	{
+		hJobs.enqueue( *i );
+	}
+}
+
 Bu::MiniCron::JobInfoList Bu::MiniCron::getJobInfo()
 {
 	JobInfoList lRet;
@@ -148,10 +200,11 @@ Bu::MiniCron::Job::~Job()
 	pTimer = NULL;
 }
 
-void Bu::MiniCron::Job::run()
+void Bu::MiniCron::Job::run( bool bReschedule )
 {
 	iRunCount++;
-	tNextRun = pTimer->nextTime();
+	if( bReschedule )
+		tNextRun = pTimer->nextTime();
 	sigJob( *this );
 }
 
-- 
cgit v1.2.3