1 files changed, 103 insertions, 0 deletions
diff --git a/src/JobQueue.hpp b/src/JobQueue.hpp
new file mode 100644
index 0000000..9b356f3
--- /dev/null
+++ b/src/JobQueue.hpp
@@ -0,0 +1,103 @@
+#ifndef JOBQUEUE_H
+#define JOBQUEUE_H 1
+
+#include <string>
+#include <map>
+#include <list>
+#include <wx/frame.h>
+#include <wx/thread.h>
+#include <wx/menu.h>
+#include <wx/app.h>
+
+#include "UpdateFactory.hpp"
+
+
+class JobArgs
+{
+public:
+	JobArgs()
+	    : jobid(-1), hostname(""), port(0),
+	      update_file(""), password("") {}
+	JobArgs(int jobid, UpdateFactory& uf)
+	    : jobid(jobid), hostname(uf.getHostname()),
+	      port(uf.getPort()), update_file(uf.getUpdateFile()), password(uf.getPassword()) {}
+	JobArgs(int jobid, const char *hostname, int port,
+	        const char *update_file, const char *password)
+	    : jobid(jobid), hostname(hostname), port(port),
+	      update_file(update_file), password(password) {}
+	JobArgs(int jobid, std::string& hostname, int port,
+	        std::string& update_file, std::string& password)
+	    : jobid(jobid), hostname(hostname), port(port),
+	      update_file(update_file), password(password) {}
+		
+	int jobid;
+	std::string hostname;
+	int port;
+	std::string update_file;
+	std::string password;
+};
+
+class Job
+{
+public:
+	enum JobEvents
+	{
+		/* thread should exit or wants to exit */
+		eID_THREAD_EXIT = wxID_HIGHEST + 1000,
+		/* dummy command */
+ 		eID_THREAD_NULL,
+		/* worker thread has started OK */
+		eID_THREAD_STARTED,
+		/* process normal job */
+		eID_THREAD_JOB,
+		/* process different messages in the frontend */
+		eID_THREAD_MSG,
+		eID_THREAD_MSGOK,
+		eID_THREAD_MSGERR
+	};
+
+	Job() : m_cmd(eID_THREAD_NULL) {}
+	Job(JobEvents cmd, JobArgs arg) : m_cmd(cmd), m_Arg(arg) {}
+	Job(JobEvents cmd, int jobid, UpdateFactory& uf) : m_cmd(cmd), m_Arg(jobid, uf) {}
+	JobEvents m_cmd;
+	JobArgs m_Arg;
+};
+
+class Queue
+{
+public:
+	enum JobPriority { eHIGHEST, eHIGHER, eNORMAL, eBELOW_NORMAL, eLOW, eIDLE };
+	Queue(wxEvtHandler *pParent) : m_pParent(pParent) {}
+	/* push a job with given priority class onto the FIFO */
+	void AddJob(const Job& job, const JobPriority& priority = eNORMAL);
+	Job Pop();
+	/* report back to parent */
+	void Report(const Job::JobEvents& cmd, const wxString& sArg = wxEmptyString, int iArg = 0);
+	size_t Stacksize()
+	{
+		wxMutexLocker lock(m_MutexQueue);
+		return m_Jobs.size();
+	}
+private:
+	wxEvtHandler *m_pParent;
+	/* a priority Queue using std::multimap */
+	std::multimap<JobPriority, Job> m_Jobs;
+	wxMutex m_MutexQueue;
+	wxSemaphore m_QueueCount;
+};
+ 
+class WorkerThread : public wxThread
+{
+public:
+	WorkerThread(Queue *pQueue, int id = 0) : m_pQueue(pQueue), m_ID(id) { assert(pQueue); wxThread::Create(); }
+private:
+	Queue *m_pQueue;
+	int m_ID;
+
+	wxThread::ExitCode doWork();
+	virtual wxThread::ExitCode Entry() { return this->doWork(); }
+	void doJob();
+	virtual void OnJob() { return this->doJob(); }
+};
+
+#endif