/*
* ptw32_threadStart.c
*
* Description:
* This translation unit implements routines which are private to
* the implementation and may be used throughout it.
*
* --------------------------------------------------------------------------
*
* Pthreads-win32 - POSIX Threads Library for Win32
* Copyright(C) 1998 John E. Bossom
* Copyright(C) 1999,2005 Pthreads-win32 contributors
*
* Contact Email: rpj@callisto.canberra.edu.au
*
* The current list of contributors is contained
* in the file CONTRIBUTORS included with the source
* code distribution. The list can also be seen at the
* following World Wide Web location:
* http://sources.redhat.com/pthreads-win32/contributors.html
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library in the file COPYING.LIB;
* if not, write to the Free Software Foundation, Inc.,
* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
*/
#include "pthread.h"
#include "implement.h"
#include <stdio.h>
#if defined(__CLEANUP_C)
# include <setjmp.h>
#endif
#if defined(__CLEANUP_SEH)
static DWORD
ExceptionFilter (EXCEPTION_POINTERS * ep, DWORD * ei)
{
switch (ep->ExceptionRecord->ExceptionCode)
{
case EXCEPTION_PTW32_SERVICES:
{
DWORD param;
DWORD numParams = ep->ExceptionRecord->NumberParameters;
numParams = (numParams > 3) ? 3 : numParams;
for (param = 0; param < numParams; param++)
{
ei[param] = ep->ExceptionRecord->ExceptionInformation[param];
}
return EXCEPTION_EXECUTE_HANDLER;
break;
}
default:
{
/*
* A system unexpected exception has occurred running the user's
* routine. We need to cleanup before letting the exception
* out of thread scope.
*/
pthread_t self = pthread_self ();
ptw32_callUserDestroyRoutines (self);
return EXCEPTION_CONTINUE_SEARCH;
break;
}
}
}
#elif defined(__CLEANUP_CXX)
#if defined(_MSC_VER)
# include <eh.h>
#elif defined(__WATCOMC__)
# include <eh.h>
# include <exceptio.h>
typedef terminate_handler
terminate_function;
#else
# if defined(__GNUC__) && __GNUC__ < 3
# include <new.h>
# else
# include <new>
using
std::terminate_handler;
using
std::terminate;
using
std::set_terminate;
# endif
typedef terminate_handler
terminate_function;
#endif
static terminate_function
ptw32_oldTerminate;
void
ptw32_terminate ()
{
set_terminate (ptw32_oldTerminate);
(void) pthread_win32_thread_detach_np ();
terminate ();
}
#endif
#if ! (defined(__MINGW64__) || defined(__MINGW32__)) || (defined (__MSVCRT__) && ! defined (__DMC__))
unsigned
__stdcall
#else
void
#endif
ptw32_threadStart (void *vthreadParms)
{
ThreadParms * threadParms = (ThreadParms *) vthreadParms;
pthread_t self;
ptw32_thread_t * sp;
void * (PTW32_CDECL *start) (void *);
void * arg;
#if defined(__CLEANUP_SEH)
DWORD
ei[] = { 0, 0, 0 };
#endif
#if defined(__CLEANUP_C)
int setjmp_rc;
#endif
ptw32_mcs_local_node_t stateLock;
void * status = (void *) 0;
self = threadParms->tid;
sp = (ptw32_thread_t *) self.p;
start = threadParms->start;
arg = threadParms->arg;
free (threadParms);
#if (defined(__MINGW64__) || defined(__MINGW32__)) && ! defined (__MSVCRT__)
/*
* beginthread does not return the thread id and is running
* before it returns us the thread handle, and so we do it here.
*/
sp->thread = GetCurrentThreadId ();
/*
* Here we're using stateLock as a general-purpose lock
* to make the new thread wait until the creating thread
* has the new handle.
*/
ptw32_mcs_lock_acquire (&sp->stateLock, &stateLock);
pthread_setspecific (ptw32_selfThreadKey, sp);
#else
pthread_setspecific (ptw32_selfThreadKey, sp);
ptw32_mcs_lock_acquire (&sp->stateLock, &stateLock);
#endif
sp->state = PThreadStateRunning;
ptw32_mcs_lock_release (&stateLock);
#if defined(__CLEANUP_SEH)
__try
{
/*
* Run the caller's routine;
*/
status = sp->exitStatus = (*start) (arg);
sp->state = PThreadStateExiting;
#if defined(_UWIN)
if (--pthread_count <= 0)
exit (0);
#endif
}
__except (ExceptionFilter (GetExceptionInformation (), ei))
{
switch (ei[0])
{
case PTW32_EPS_CANCEL:
status = sp->exitStatus = PTHREAD_CANCELED;
#if defined(_UWIN)
if (--pthread_count <= 0)
exit (0);
#endif
break;
case PTW32_EPS_EXIT:
status = sp->exitStatus;
break;
default:
status = sp->exitStatus = PTHREAD_CANCELED;
break;
}
}
#else /* __CLEANUP_SEH */
#if defined(__CLEANUP_C)
setjmp_rc = setjmp (sp->start_mark);
if (0 == setjmp_rc)
{
/*
* Run the caller's routine;
*/
status = sp->exitStatus = (*start) (arg);
sp->state = PThreadStateExiting;
}
else
{
switch (setjmp_rc)
{
case PTW32_EPS_CANCEL:
status = sp->exitStatus = PTHREAD_CANCELED;
break;
case PTW32_EPS_EXIT:
status = sp->exitStatus;
break;
default:
status = sp->exitStatus = PTHREAD_CANCELED;
break;
}
}
#else /* __CLEANUP_C */
#if defined(__CLEANUP_CXX)
ptw32_oldTerminate = set_terminate (&ptw32_terminate);
try
{
/*
* Run the caller's routine in a nested try block so that we
* can run the user's terminate function, which may call
* pthread_exit() or be canceled.
*/
try
{
status = sp->exitStatus = (*start) (arg);
sp->state = PThreadStateExiting;
}
catch (ptw32_exception &)
{
/*
* Pass these through to the outer block.
*/
throw;
}
catch (...)
{
/*
* We want to run the user's terminate function if supplied.
* That function may call pthread_exit() or be canceled, which will
* be handled by the outer try block.
*
* ptw32_terminate() will be called if there is no user
* supplied function.
*/
terminate_function
term_func = set_terminate (0);
set_terminate (term_func);
if (term_func != 0)
{
term_func ();
}
throw;
}
}
catch (ptw32_exception_cancel &)
{
/*
* Thread was canceled.
*/
status = sp->exitStatus = PTHREAD_CANCELED;
}
catch (ptw32_exception_exit &)
{
/*
* Thread was exited via pthread_exit().
*/
status = sp->exitStatus;
}
catch (...)
{
/*
* A system unexpected exception has occurred running the user's
* terminate routine. We get control back within this block
* and exit with a substitute status. If the thread was not
* cancelled then this indicates the unhandled exception.
*/
status = sp->exitStatus = PTHREAD_CANCELED;
}
(void) set_terminate (ptw32_oldTerminate);
#else
#error ERROR [__FILE__, line __LINE__]: Cleanup type undefined.
#endif /* __CLEANUP_CXX */
#endif /* __CLEANUP_C */
#endif /* __CLEANUP_SEH */
#if defined(PTW32_STATIC_LIB)
/*
* We need to cleanup the pthread now if we have
* been statically linked, in which case the cleanup
* in dllMain won't get done. Joinable threads will
* only be partially cleaned up and must be fully cleaned
* up by pthread_join() or pthread_detach().
*
* Note: if this library has been statically linked,
* implicitly created pthreads (those created
* for Win32 threads which have called pthreads routines)
* must be cleaned up explicitly by the application
* (by calling pthread_win32_thread_detach_np()).
* For the dll, dllMain will do the cleanup automatically.
*/
(void) pthread_win32_thread_detach_np ();
#endif
#if ! (defined(__MINGW64__) || defined(__MINGW32__)) || defined (__MSVCRT__) || defined (__DMC__)
_endthreadex ((unsigned)(size_t) status);
#else
_endthread ();
#endif
/*
* Never reached.
*/
#if ! (defined(__MINGW64__) || defined(__MINGW32__)) || defined (__MSVCRT__) || defined (__DMC__)
return (unsigned)(size_t) status;
#endif
} /* ptw32_threadStart */