1

/* $Id$ */

     2

     3

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

     4

     5

#include "stdafx.h"

     6

#include "thread.h"

     7

     8

#if 0

     9

#include "debug.h"

    10

#include "core/alloc_func.hpp"

    11

#include <stdlib.h>

    12

    13

#define INCL_DOS

    14

#include <os2.h>

    15

#include <process.h>

    16

    17

struct OTTDThread {

    18

	TID thread;

    19

	OTTDThreadFunc func;

    20

	void *arg;

    21

	void *ret;

    22

};

    23

    24

static void Proxy(void *arg)

    25

{

    26

	OTTDThread *t = (OTTDThread *)arg;

    27

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

    28

}

    29

    30

OTTDThread *OTTDCreateThread(OTTDThreadFunc function, void *arg)

    31

{

    32

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

    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

	if (t == NULL) return NULL;

    48

    49

	DosWaitThread(&t->thread, DCWW_WAIT);

    50

	void *ret = t->ret;

    51

	free(t);

    52

	return ret;

    53

}

    54

    55

void OTTDExitThread()

    56

{

    57

	_endthread();

    58

}

    59

    60

#endif

    61

    62

/* static */ ThreadObject *ThreadObject::New(OTTDThreadFunc proc, void *param)

    63

{

    64

	return NULL;

    65

}

    66

    67

/* static */ ThreadObject *ThreadObject::AttachCurrent()

    68

{

    69

	return NULL;

    70

}

    71

    72

/* static */ uint ThreadObject::CurrentId()

    73

{

    74

	return -1;

    75

}

    76

    77

/* static */ ThreadSemaphore *ThreadSemaphore::New()

    78

{

    79

	return NULL;

    80

}