rubidium@8934: /* $Id$ */
rubidium@8934: 
rubidium@8934: /** @file thread_os2.cpp OS2 implementation of Threads. */
rubidium@8934: 
rubidium@8934: #include "stdafx.h"
rubidium@8934: #include "thread.h"
rubidium@8934: 
rubidium@8934: #if 0
rubidium@8934: #include "debug.h"
rubidium@8934: #include "core/alloc_func.hpp"
rubidium@8934: #include <stdlib.h>
rubidium@8934: 
rubidium@8934: #define INCL_DOS
rubidium@8934: #include <os2.h>
rubidium@8934: #include <process.h>
rubidium@8934: 
rubidium@8934: struct OTTDThread {
rubidium@8934: 	TID thread;
rubidium@8934: 	OTTDThreadFunc func;
rubidium@8934: 	void *arg;
rubidium@8934: 	void *ret;
rubidium@8934: };
rubidium@8934: 
rubidium@8934: static void Proxy(void *arg)
rubidium@8934: {
rubidium@8934: 	OTTDThread *t = (OTTDThread *)arg;
rubidium@8934: 	t->ret = t->func(t->arg);
rubidium@8934: }
rubidium@8934: 
rubidium@8934: OTTDThread *OTTDCreateThread(OTTDThreadFunc function, void *arg)
rubidium@8934: {
rubidium@8934: 	OTTDThread *t = MallocT<OTTDThread>(1);
rubidium@8934: 
rubidium@8934: 	t->func = function;
rubidium@8934: 	t->arg  = arg;
rubidium@8934: 	t->thread = _beginthread(Proxy, NULL, 32768, t);
rubidium@8934: 	if (t->thread != (TID)-1) {
rubidium@8934: 		return t;
rubidium@8934: 	} else {
rubidium@8934: 		free(t);
rubidium@8934: 		return NULL;
rubidium@8934: 	}
rubidium@8934: }
rubidium@8934: 
rubidium@8934: void *OTTDJoinThread(OTTDThread *t)
rubidium@8934: {
rubidium@8934: 	if (t == NULL) return NULL;
rubidium@8934: 
rubidium@8934: 	DosWaitThread(&t->thread, DCWW_WAIT);
rubidium@8934: 	void *ret = t->ret;
rubidium@8934: 	free(t);
rubidium@8934: 	return ret;
rubidium@8934: }
rubidium@8934: 
rubidium@8934: void OTTDExitThread()
rubidium@8934: {
rubidium@8934: 	_endthread();
rubidium@8934: }
rubidium@8934: 
rubidium@8934: #endif
rubidium@8934: 
rubidium@8934: /* static */ ThreadObject *ThreadObject::New(OTTDThreadFunc proc, void *param)
rubidium@8934: {
rubidium@8934: 	return NULL;
rubidium@8934: }
rubidium@8934: 
rubidium@8934: /* static */ ThreadObject *ThreadObject::AttachCurrent()
rubidium@8934: {
rubidium@8934: 	return NULL;
rubidium@8934: }
rubidium@8934: 
rubidium@8934: /* static */ uint ThreadObject::CurrentId()
rubidium@8934: {
rubidium@8934: 	return -1;
rubidium@8934: }
rubidium@8934: 
rubidium@8934: /* static */ ThreadSemaphore *ThreadSemaphore::New()
rubidium@8934: {
rubidium@8934: 	return NULL;
rubidium@8934: }