357 lines
8.3 KiB
C
357 lines
8.3 KiB
C
/*
|
|
* 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.,
|
|
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, 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 */
|