Factored out Thread (and Slave, an explicitly signal-driven thread)

git-svn-id: http://svn.drobilla.net/lad/ingen@87 a436a847-0d15-0410-975c-d299462d15a1

1 files changed, 104 insertions, 0 deletions

diff --git a/src/libs/engine/Thread.cpp b/src/libs/engine/Thread.cpp
new file mode 100644
index 00000000..6ddfa621
--- /dev/null
+++ b/src/libs/engine/Thread.cpp
@@ -0,0 +1,104 @@
+/* This file is part of Ingen.  Copyright (C) 2006 Dave Robillard.
+ * 
+ * Om is free software; you can redistribute it and/or modify it under the
+ * terms of the GNU General Public License as published by the Free Software
+ * Foundation; either version 2 of the License, or (at your option) any later
+ * version.
+ * 
+ * Om is distributed in the hope that it will be useful, but WITHOUT ANY
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
+ * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for details.
+ * 
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#include "Thread.h"
+#include <cassert>
+#include <iostream>
+#include <pthread.h>
+
+using std::cerr; using std::cout; using std::endl;
+
+namespace Om {
+
+
+Thread::Thread()
+: _pthread_exists(false)
+{
+}
+
+
+Thread::~Thread()
+{
+	stop();
+}
+
+
+/** Start the process thread.
+ */
+void
+Thread::start() 
+{
+	cout << "[" << _name << " Thread] Starting." << endl;
+
+	pthread_attr_t attr;
+	pthread_attr_init(&attr);
+	pthread_attr_setstacksize(&attr, 1500000);
+
+	pthread_create(&_pthread, &attr, _static_run, this);
+	_pthread_exists = true;
+}
+
+
+/** Stop the process thread.
+ */
+void
+Thread::stop()
+{
+	if (_pthread_exists) {
+		pthread_cancel(_pthread);
+		pthread_join(_pthread, NULL);
+		_pthread_exists = false;
+	}
+}
+
+
+/** Set the scheduling policy for this thread.
+ *
+ * @param must be one of SCHED_FIFO, SCHED_RR, or SCHED_OTHER.
+ */
+void
+Thread::set_scheduling(int policy, unsigned int priority)
+{
+	sched_param sp;
+	sp.sched_priority = priority;
+	int result = pthread_setschedparam(_pthread, SCHED_FIFO, &sp);
+	if (!result) {
+		cout << "[" << _name << " Thread] Set scheduling policy to ";
+		switch (policy) {
+		case SCHED_FIFO:  cout << "SCHED_FIFO";  break;
+		case SCHED_RR:    cout << "SCHED_RR";    break;
+		case SCHED_OTHER: cout << "SCHED_OTHER"; break;
+		default:          cout << "UNKNOWN";     break;
+		}
+		cout << ", priority " << sp.sched_priority << endl;
+	} else {
+		cout << "[" << _name << " Thread] Unable to set scheduling policy ("
+			<< strerror(result) << ")" << endl;
+	}
+}
+
+
+void*
+Thread::_static_run(void* me)
+{
+	Thread* myself = (Thread*)me;
+	myself->_run();
+	// and I
+	return NULL;
+}
+
+} // namespace Om
+