From 4a3582ec10235efea2a2973773e6c33b900fd46c Mon Sep 17 00:00:00 2001
From: Sascha Volkenandt <sascha (at) akv-soft (dot) de>
Date: Tue, 16 Jan 2007 18:34:31 +0000
Subject: - rewritten task manager to make it more general

---
 tasks.h | 78 +++++++++++++++++++++++++++++++++++++++++++++--------------------
 1 file changed, 54 insertions(+), 24 deletions(-)

(limited to 'tasks.h')

diff --git a/tasks.h b/tasks.h
index 3ae63da..c90f9e1 100644
--- a/tasks.h
+++ b/tasks.h
@@ -1,52 +1,82 @@
 #ifndef VDR_LIVE_TASKS_H
 #define VDR_LIVE_TASKS_H
 
+#include <deque>
+#include <memory>
 #include <string>
-#include <utility>
+#include <vdr/channels.h>
 #include <vdr/thread.h>
 
 namespace vdrlive {
 
+class Task;
+
 class TaskManager: public cMutex
 {
 	friend TaskManager& LiveTaskManager();
 
+	typedef std::deque< Task* > TaskQueue;
+
 public:
-	bool SwitchChannel( int number );
-	bool ReplayRecording( std::string const& fileName );
+	bool Execute( Task* task, std::string& error );
+	bool Execute( Task* task );
 
 	// may only be called from Plugin::MainThreadHook
-	void DoScheduledWork();
-	
-private:
-	template< typename Type >
-	struct Task: std::pair< Type, bool > 
-	{
-		Task( Type const& first, bool second ): std::pair< Type, bool >( first, second ) {}
-	};
+	void DoScheduledTasks();
 
+private:
 	TaskManager();
 	TaskManager( TaskManager const& );
 
-	Task< int > m_switchChannel;
-	Task< std::string > m_replayRecording;
+	TaskQueue m_taskQueue;
 	cCondVar m_scheduleWait;
+};
+
+class Task
+{
+	friend void TaskManager::DoScheduledTasks();
+
+public:
+	virtual ~Task() {}
+
+	bool Result() const { return m_result; }
+	std::string const& Error() const { return m_error; }
 
-	template< typename Type >
-	bool ScheduleCommand( Task< Type >& member, Type const& param );
+protected:
+	Task(): m_result( true ) {}
+	Task( Task const& );
 
-	void DoSwitchChannel();
-	void DoReplayRecording();
+	void SetError( std::string const& error ) { m_result = false; m_error = error; }
+
+	virtual void Action() = 0;
+
+private:
+	bool m_result;
+	std::string m_error;
 };
+
+class SwitchChannelTask: public Task
+{
+public:
+	SwitchChannelTask( tChannelID channel ): m_channel( channel ) {}
 	
-template< typename Type >
-inline bool TaskManager::ScheduleCommand( Task< Type >& member, Type const& param )
+private:
+	tChannelID m_channel;
+
+	virtual void Action();
+};
+
+class ReplayRecordingTask: public Task
 {
-	cMutexLock lock( this );
-	member.first = param;
-	m_scheduleWait.Wait( *this );
-	return member.second;
-}
+public:
+	ReplayRecordingTask( std::string const& recording ): m_recording( recording ) {}
+
+private:
+	std::string m_recording;
+	
+	virtual void Action() {}
+};
+
 
 TaskManager& LiveTaskManager();
 
-- 
cgit v1.2.3