X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=win32%2Fwin32thread.c;h=1fdd0efc020807f48fa274202127a0ec95a9c40a;hb=f56fdd801e5b3d02170cb8e7692ffdc790f190a9;hp=0dd3e77f47d4a903cac6bcf562a0aa1a12599c7c;hpb=4c36ecb7bb90b0ff73777a2addf5e8968d98eec5;p=p5sagit%2Fp5-mst-13.2.git diff --git a/win32/win32thread.c b/win32/win32thread.c index 0dd3e77..1fdd0ef 100644 --- a/win32/win32thread.c +++ b/win32/win32thread.c @@ -2,52 +2,60 @@ #include "perl.h" #ifdef USE_DECLSPEC_THREAD -__declspec(thread) struct perl_thread *Perl_current_thread = NULL; +__declspec(thread) void *PL_current_context = NULL; #endif void -Perl_setTHR(struct perl_thread *t) +Perl_set_context(void *t) { -#ifdef USE_THREADS -#ifdef USE_DECLSPEC_THREAD - Perl_current_thread = t; -#else - TlsSetValue(thr_key,t); -#endif +#if defined(USE_5005THREADS) || defined(USE_ITHREADS) +# ifdef USE_DECLSPEC_THREAD + Perl_current_context = t; +# else + DWORD err = GetLastError(); + TlsSetValue(PL_thr_key,t); + SetLastError(err); +# endif #endif } -struct perl_thread * -Perl_getTHR(void) +void * +Perl_get_context(void) { -#ifdef USE_THREADS -#ifdef USE_DECLSPEC_THREAD - return Perl_current_thread; -#else - return (struct perl_thread *) TlsGetValue(thr_key); -#endif +#if defined(USE_5005THREADS) || defined(USE_ITHREADS) +# ifdef USE_DECLSPEC_THREAD + return Perl_current_context; +# else + DWORD err = GetLastError(); + void *result = TlsGetValue(PL_thr_key); + SetLastError(err); + return result; +# endif #else - return NULL; + return NULL; #endif } +#ifdef USE_5005THREADS void -Perl_alloc_thread_key(void) +Perl_init_thread_intern(struct perl_thread *athr) { -#ifdef USE_THREADS - static int key_allocated = 0; - if (!key_allocated) { - if ((thr_key = TlsAlloc()) == TLS_OUT_OF_INDEXES) - croak("panic: TlsAlloc"); - key_allocated = 1; - } +#ifndef USE_DECLSPEC_THREAD + + /* + * Initialize port-specific per-thread data in thr->i + * as only things we have there are just static areas for + * return values we don't _need_ to do anything but + * this is good practice: + */ + memset(&athr->i,0,sizeof(athr->i)); + #endif } void Perl_set_thread_self(struct perl_thread *thr) { -#ifdef USE_THREADS /* Set thr->self. GetCurrentThread() retrurns a pseudo handle, need this to convert it into a handle another thread can use. */ @@ -58,22 +66,48 @@ Perl_set_thread_self(struct perl_thread *thr) 0, FALSE, DUPLICATE_SAME_ACCESS); -#endif } -#ifdef USE_THREADS int Perl_thread_create(struct perl_thread *thr, thread_func_t *fn) { DWORD junk; + unsigned long th; - MUTEX_LOCK(&thr->mutex); - DEBUG_L(PerlIO_printf(PerlIO_stderr(), + DEBUG_S(PerlIO_printf(Perl_debug_log, "%p: create OS thread\n", thr)); +#ifdef USE_RTL_THREAD_API + /* See comment about USE_RTL_THREAD_API in win32thread.h */ +#if defined(__BORLANDC__) + th = _beginthreadNT(fn, /* start address */ + 0, /* stack size */ + (void *)thr, /* parameters */ + (void *)NULL, /* security attrib */ + 0, /* creation flags */ + (unsigned long *)&junk); /* tid */ + if (th == (unsigned long)-1) + th = 0; +#elif defined(_MSC_VER_) + th = _beginthreadex((void *)NULL, /* security attrib */ + 0, /* stack size */ + fn, /* start address */ + (void*)thr, /* parameters */ + 0, /* creation flags */ + (unsigned *)&junk); /* tid */ +#else /* compilers using CRTDLL.DLL only have _beginthread() */ + th = _beginthread(fn, /* start address */ + 0, /* stack size */ + (void*)thr); /* parameters */ + if (th == (unsigned long)-1) + th = 0; +#endif + thr->self = (HANDLE)th; +#else /* !USE_RTL_THREAD_API */ thr->self = CreateThread(NULL, 0, fn, (void*)thr, 0, &junk); - DEBUG_L(PerlIO_printf(PerlIO_stderr(), +#endif /* !USE_RTL_THREAD_API */ + DEBUG_S(PerlIO_printf(Perl_debug_log, "%p: OS thread = %p, id=%ld\n", thr, thr->self, junk)); - MUTEX_UNLOCK(&thr->mutex); return thr->self ? 0 : -1; } #endif +