#include <thread.h>
#include <exception.h>
#include <logger.h>

namespace newsbeuter {

/*
 * The thread class is a wrapper around the pthread functions found on virtually
 * all modern Unix systems.
 *
 * To run a thread, you need to derive your own class from thread and implement the
 * run() method. Then you create an instance of your derived class with the new
 * operator (very important!), and run the start() method of the object. 
 */


thread::thread() {
}

thread::~thread() { 

}

pthread_t thread::start() {
	int rc = pthread_create(&pt, 0, run_thread, this);
	LOG(LOG_DEBUG, "thread::start: created new thread %d rc = %d", pt, rc);
	if (rc != 0) {
		throw exception(rc);
	}
	return pt;
}

void thread::join() {
	pthread_join(pt, NULL);
}

void thread::detach() {
	LOG(LOG_DEBUG, "thread::detach: detaching thread %d", pt);
	pthread_detach(pt);
}

void * run_thread(void * p) {
	thread * t = reinterpret_cast<thread *>(p);
	LOG(LOG_DEBUG, "run_thread: p = %p", p);
	t->run();
	delete t;
	return 0;
}

void thread::cleanup(thread * p) {
	delete p;
}

}