1

/* $Id$ */

     2

     3

/** @file thread_os2.cpp OS2 implementation of Threads. */

     4

     5

#include "stdafx.h"

     6

#include "thread.h"

     7

#include "debug.h"

     8

#include "core/alloc_func.hpp"

     9

#include <stdlib.h>

    10

    11

#define INCL_DOS

    12

#include <os2.h>

    13

#include <process.h>

    14

    15

struct OTTDThread {

    16

	TID thread;

    17

	OTTDThreadFunc func;

    18

	void *arg;

    19

	void *ret;

    20

};

    21

    22

static void Proxy(void *arg)

    23

{

    24

	OTTDThread *t = (OTTDThread *)arg;

    25

	t->ret = t->func(t->arg);

    26

}

    27

    28

OTTDThread *OTTDCreateThread(OTTDThreadFunc function, void *arg)

    29

{

    30

	OTTDThread *t = MallocT<OTTDThread>(1);

    31

    32

	if (t == NULL) return NULL;

    33

    34

	t->func = function;

    35

	t->arg  = arg;

    36

	t->thread = _beginthread(Proxy, NULL, 32768, t);

    37

	if (t->thread != (TID)-1) {

    38

		return t;

    39

	} else {

    40

		free(t);

    41

		return NULL;

    42

	}

    43

}

    44

    45

void *OTTDJoinThread(OTTDThread *t)

    46

{

    47

	void *ret;

    48

    49

	if (t == NULL) return NULL;

    50

    51

	DosWaitThread(&t->thread, DCWW_WAIT);

    52

	ret = t->ret;

    53

	free(t);

    54

	return ret;

    55

}

    56

    57

void OTTDExitThread()

    58

{

    59

	_endthread();

    60

}