thread.c File Reference

#include <process.h>
#include "msvcrt.h"
#include "wine/debug.h"

Include dependency graph for thread.c:

Go to the source code of this file.

Classes
struct	_beginthread_trampoline_t

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (msvcrt)
thread_data_t *CDECL	msvcrt_get_thread_data (void)
void CDECL	_endthread (void)
void CDECL	_endthreadex (unsigned int retval)
static DWORD CALLBACK	_beginthread_trampoline (LPVOID arg)
uintptr_t CDECL	_beginthread (_beginthread_start_routine_t start_address, unsigned int stack_size, void *arglist)
static DWORD CALLBACK	_beginthreadex_trampoline (LPVOID arg)
uintptr_t CDECL	_beginthreadex (void *security, unsigned int stack_size, _beginthreadex_start_routine_t start_address, void *arglist, unsigned int initflag, unsigned int *thrdaddr)

Function Documentation

_beginthread()

uintptr_t CDECL _beginthread	(	_beginthread_start_routine_t	start_address,
		unsigned int	stack_size,
		void *	arglist
	)

Definition at line 134 of file thread.c.

{
  _beginthread_trampoline_t* trampoline;
  HANDLE thread;
 
  TRACE("(%p, %d, %p)\n", start_address, stack_size, arglist);
 
  if (!MSVCRT_CHECK_PMT(start_address)) return -1;
 
  trampoline = malloc(sizeof(*trampoline));
  if(!trampoline) {
      *_errno() = EAGAIN;
      return -1;
  }
 
  thread = CreateThread(NULL, stack_size, _beginthread_trampoline,
          trampoline, CREATE_SUSPENDED, NULL);
  if(!thread) {
      free(trampoline);
      msvcrt_set_errno(GetLastError());
      return -1;
  }
 
  trampoline->thread = thread;
  trampoline->start_address = start_address;
  trampoline->arglist = arglist;
 
#if _MSVCR_VER >= 140
  if(!GetModuleHandleExW(GET_MODULE_HANDLE_EX_FLAG_FROM_ADDRESS,
              (void*)start_address, &trampoline->module))
  {
      trampoline->module = NULL;
      WARN("failed to get module for the start_address: %lu\n", GetLastError());
  }
#endif
 
  if(ResumeThread(thread) == -1) {
#if _MSVCR_VER >= 140
      FreeLibrary(trampoline->module);
#endif
      free(trampoline);
      *_errno() = EAGAIN;
      return -1;
  }
 
  return (uintptr_t)thread;
}

Referenced by test_thread_invalid_params(), and test_thread_library_reference().

_beginthread_trampoline()

static DWORD CALLBACK _beginthread_trampoline ( LPVOID  arg )

static

Definition at line 115 of file thread.c.

{
    _beginthread_trampoline_t local_trampoline;
    thread_data_t *data = msvcrt_get_thread_data();
 
    memcpy(&local_trampoline,arg,sizeof(local_trampoline));
    free(arg);
    data->handle = local_trampoline.thread;
#if _MSVCR_VER >= 140
    data->module = local_trampoline.module;
#endif
 
    local_trampoline.start_address(local_trampoline.arglist);
    _endthread();
}

Referenced by _beginthread().

_beginthreadex()

uintptr_t CDECL _beginthreadex	(	void *	security,
		unsigned int	stack_size,
		_beginthreadex_start_routine_t	start_address,
		void *	arglist,
		unsigned int	initflag,
		unsigned int *	thrdaddr
	)

Definition at line 207 of file thread.c.

{
  _beginthread_trampoline_t* trampoline;
  HANDLE thread;
 
  TRACE("(%p, %d, %p, %p, %d, %p)\n", security, stack_size, start_address, arglist, initflag, thrdaddr);
 
  /* FIXME: may use different errno / return values */
  if (!MSVCRT_CHECK_PMT(start_address)) return 0;
 
  if (!(trampoline = malloc(sizeof(*trampoline))))
      return 0;
 
  trampoline->thread = INVALID_HANDLE_VALUE;
  trampoline->start_address_ex = start_address;
  trampoline->arglist = arglist;
 
#if _MSVCR_VER >= 140
  if(!GetModuleHandleExW(GET_MODULE_HANDLE_EX_FLAG_FROM_ADDRESS,
              (void*)start_address, &trampoline->module))
  {
     trampoline->module = NULL;
     WARN("failed to get module for the start_address: %lu\n", GetLastError());
  }
#endif
 
  thread = CreateThread(security, stack_size, _beginthreadex_trampoline,
          trampoline, initflag, (DWORD *)thrdaddr);
  if(!thread) {
#if _MSVCR_VER >= 140
      FreeLibrary(trampoline->module);
#endif
      free(trampoline);
      msvcrt_set_errno(GetLastError());
      return 0;
  }
 
  return (uintptr_t)thread;
}

Referenced by clnt_vc_create(), CDirectoryWatcher::CreateAPCThread(), DialogProc_0(), DialogProc_1(), CIconWatcher::Initialize(), InitProgressDialog(), nfs41_delegation_recall(), nfs41_session_set_lease(), CAutoComplete::OnAutoCompStart(), OpenPropSheet(), pattern_fork(), ProgressDlg::ProcessWindowMessage(), CDeviceView::Refresh(), CZipCreator::runThread(), ServiceStart(), START_TEST(), StartWatchGUI(), CDownloadManager::StartWorkerThread(), test_file_inherit(), test_thread_handle_close(), test_thread_invalid_params(), test_thread_library_reference(), test_thread_setlocale(), and test_thread_suspended().

_beginthreadex_trampoline()

static DWORD CALLBACK _beginthreadex_trampoline ( LPVOID  arg )

static

Definition at line 188 of file thread.c.

{
    unsigned int retval;
    _beginthread_trampoline_t local_trampoline;
    thread_data_t *data = msvcrt_get_thread_data();
 
    memcpy(&local_trampoline, arg, sizeof(local_trampoline));
    free(arg);
    data->handle = local_trampoline.thread;
#if _MSVCR_VER >= 140
    data->module = local_trampoline.module;
#endif
 
    retval = local_trampoline.start_address_ex(local_trampoline.arglist);
    _endthreadex(retval);
}

Referenced by _beginthreadex().

_endthread()

void CDECL _endthread

(

void

)

Definition at line 73 of file thread.c.

{
  thread_data_t *tls;
 
  TRACE("(void)\n");
 
  tls = TlsGetValue(msvcrt_tls_index);
  if (tls && tls->handle != INVALID_HANDLE_VALUE)
  {
      CloseHandle(tls->handle);
      tls->handle = INVALID_HANDLE_VALUE;
  } else
      WARN("tls=%p tls->handle=%p\n", tls, tls ? tls->handle : INVALID_HANDLE_VALUE);
 
  _endthreadex(0);
}

Referenced by _beginthread_trampoline().

_endthreadex()

void CDECL _endthreadex

(

unsigned int

retval

)

Definition at line 93 of file thread.c.

{
  TRACE("(%d)\n", retval);
 
#if _MSVCR_VER >= 140
  {
      thread_data_t *tls = TlsGetValue(msvcrt_tls_index);
 
      if (tls && tls->module != NULL)
          FreeLibraryAndExitThread(tls->module, retval);
      else
          WARN("tls=%p tls->module=%p\n", tls, tls ? tls->module : NULL);
  }
#endif
 
  ExitThread(retval);
}

Referenced by _beginthreadex_trampoline(), and _endthread().

msvcrt_get_thread_data()

thread_data_t *CDECL msvcrt_get_thread_data

(

void

)

Definition at line 45 of file thread.c.

{
    thread_data_t *ptr;
    DWORD err = GetLastError();  /* need to preserve last error */
 
    if (!(ptr = TlsGetValue( msvcrt_tls_index )))
    {
        if (!(ptr = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*ptr) )))
            _amsg_exit( _RT_THREAD );
        if (!TlsSetValue( msvcrt_tls_index, ptr )) _amsg_exit( _RT_THREAD );
        ptr->tid = GetCurrentThreadId();
        ptr->handle = INVALID_HANDLE_VALUE;
        ptr->random_seed = 1;
        ptr->locinfo = MSVCRT_locale->locinfo;
        ptr->mbcinfo = MSVCRT_locale->mbcinfo;
        ptr->cached_locale[0] = 'C';
        ptr->cached_locale[1] = 0;
#if _MSVCR_VER >= 140
        ptr->module = NULL;
#endif
    }
    SetLastError( err );
    return ptr;
}

Referenced by _beginthread_trampoline(), and _beginthreadex_trampoline().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

msvcrt

)