1 files changed, 98 insertions, 0 deletions
diff --git a/src/JobQueue.cpp b/src/JobQueue.cpp
new file mode 100644
index 0000000..77e9603
--- /dev/null
+++ b/src/JobQueue.cpp
@@ -0,0 +1,98 @@
+#include "JobQueue.hpp"
+#include "UpdateFactory.hpp"
+
+
+void Queue::AddJob(const Job& job, const JobPriority& priority)
+{
+	wxMutexLocker lock(m_MutexQueue);
+	m_Jobs.insert(std::make_pair(priority, job));
+	m_QueueCount.Post();
+}
+
+Job Queue::Pop()
+{
+	Job element;
+	m_QueueCount.Wait();
+	m_MutexQueue.Lock();
+	element = (m_Jobs.begin())->second;
+	m_Jobs.erase(m_Jobs.begin());
+	m_MutexQueue.Unlock();
+	return element;
+}
+
+void Queue::Report(const Job::JobEvents& cmd, const wxString& sArg, int iArg)
+{
+	wxCommandEvent evt(wxEVT_THREAD, cmd);
+	evt.SetString(sArg);
+	evt.SetInt(iArg);
+	m_pParent->AddPendingEvent(evt);
+}
+
+wxThread::ExitCode WorkerThread::doWork()
+{
+	Sleep(1000);
+	Job::JobEvents iErr;
+	m_pQueue->Report(Job::eID_THREAD_STARTED, wxEmptyString, m_ID);
+	try { while(true) OnJob(); }
+	catch (Job::JobEvents& i) { m_pQueue->Report(iErr=i, wxEmptyString, m_ID); }
+	return (wxThread::ExitCode) iErr;
+}
+
+void WorkerThread::doJob()
+{
+	int rv;
+	std::string err;
+	UpdateFactory uf;
+
+	Job job = m_pQueue->Pop();
+	switch(job.m_cmd)
+	{
+		case Job::eID_THREAD_EXIT:
+			throw Job::eID_THREAD_EXIT;
+		case Job::eID_THREAD_JOB:
+			m_pQueue->Report(Job::eID_THREAD_MSG,
+			    wxString::Format(wxT("Job #%d: Connecting to %s:%i"),
+			        job.m_Arg.jobid, job.m_Arg.hostname, job.m_Arg.port), m_ID);
+			uf.setDest(job.m_Arg.hostname, job.m_Arg.port);
+			uf.setPass(job.m_Arg.password);
+
+			rv = uf.doAuth();
+			if (rv != UPDATE_OK) {
+				mapEmcError(rv, err);
+				m_pQueue->Report(Job::eID_THREAD_MSGERR,
+				    wxString::Format(wxT("Job #%d: %s."),
+				        job.m_Arg.jobid, err.c_str()), m_ID);
+				break;
+			}
+
+			m_pQueue->Report(Job::eID_THREAD_MSG,
+			    wxString::Format(wxT("Job #%d: Uploading file \"%s\""),
+			        job.m_Arg.jobid, job.m_Arg.update_file), m_ID);
+			uf.setUpdateFile(job.m_Arg.update_file.c_str());
+			rv = uf.loadUpdateFile();
+			if (rv != UPDATE_OK) {
+				mapEmcError(rv, err);
+				m_pQueue->Report(Job::eID_THREAD_MSGERR,
+				    wxString::Format(wxT("Job #%d: %s."),
+				        job.m_Arg.jobid, err.c_str()), m_ID);
+				break;
+			}
+
+			rv = uf.doUpdate();
+			mapEmcError(rv, err);
+			if (rv != UPDATE_OK) {
+				m_pQueue->Report(Job::eID_THREAD_MSGERR,
+				    wxString::Format(wxT("Job #%d: %s."),
+				        job.m_Arg.jobid, err.c_str()), m_ID);
+				break;
+			}
+
+			m_pQueue->Report(Job::eID_THREAD_MSGOK,
+			    wxString::Format(wxT("Job #%d: %s."),
+			        job.m_Arg.jobid, err), m_ID);
+			break;
+		case Job::eID_THREAD_NULL:
+		default:
+			break;
+	}
+}