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