2020-06-01 12:52:05 +02:00
|
|
|
/*
|
|
|
|
* NT threads support
|
|
|
|
*
|
|
|
|
* Copyright 1996, 2003 Alexandre Julliard
|
|
|
|
*
|
|
|
|
* 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.1 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; if not, write to the Free Software
|
|
|
|
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
|
|
|
|
*/
|
|
|
|
|
|
|
|
#if 0
|
|
|
|
#pragma makedep unix
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#include "config.h"
|
|
|
|
#include "wine/port.h"
|
|
|
|
|
|
|
|
#include <assert.h>
|
2020-06-03 16:32:02 +02:00
|
|
|
#include <errno.h>
|
2020-06-01 12:52:05 +02:00
|
|
|
#include <limits.h>
|
|
|
|
#include <stdarg.h>
|
|
|
|
#include <pthread.h>
|
|
|
|
#include <signal.h>
|
|
|
|
#include <sys/types.h>
|
|
|
|
#ifdef HAVE_SYS_MMAN_H
|
|
|
|
#include <sys/mman.h>
|
|
|
|
#endif
|
|
|
|
#ifdef HAVE_SYS_TIMES_H
|
|
|
|
#include <sys/times.h>
|
|
|
|
#endif
|
|
|
|
#ifdef HAVE_SYS_SYSCALL_H
|
|
|
|
#include <sys/syscall.h>
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#define NONAMELESSUNION
|
|
|
|
#include "ntstatus.h"
|
|
|
|
#define WIN32_NO_STATUS
|
|
|
|
#include "winternl.h"
|
|
|
|
#include "ddk/wdm.h"
|
|
|
|
#include "wine/server.h"
|
|
|
|
#include "wine/debug.h"
|
|
|
|
#include "wine/exception.h"
|
|
|
|
#include "unix_private.h"
|
|
|
|
|
2020-06-06 13:56:19 +02:00
|
|
|
WINE_DEFAULT_DEBUG_CHANNEL(seh);
|
|
|
|
|
2020-06-01 12:52:05 +02:00
|
|
|
#ifndef PTHREAD_STACK_MIN
|
|
|
|
#define PTHREAD_STACK_MIN 16384
|
|
|
|
#endif
|
|
|
|
|
|
|
|
static int *nb_threads;
|
|
|
|
|
|
|
|
static inline int get_unix_exit_code( NTSTATUS status )
|
|
|
|
{
|
|
|
|
/* prevent a nonzero exit code to end up truncated to zero in unix */
|
|
|
|
if (status && !(status & 0xff)) return 1;
|
|
|
|
return status;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* pthread_exit_wrapper
|
|
|
|
*/
|
|
|
|
static void pthread_exit_wrapper( int status )
|
|
|
|
{
|
|
|
|
close( ntdll_get_thread_data()->wait_fd[0] );
|
|
|
|
close( ntdll_get_thread_data()->wait_fd[1] );
|
|
|
|
close( ntdll_get_thread_data()->reply_fd );
|
|
|
|
close( ntdll_get_thread_data()->request_fd );
|
|
|
|
pthread_exit( UIntToPtr(status) );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* init_threading
|
|
|
|
*/
|
2020-06-04 19:37:35 +02:00
|
|
|
TEB * CDECL init_threading( int *nb_threads_ptr, struct ldt_copy **ldt_copy, SIZE_T *size, BOOL *suspend,
|
|
|
|
unsigned int *cpus, BOOL *wow64, timeout_t *start_time )
|
2020-06-01 12:52:05 +02:00
|
|
|
{
|
2020-06-04 19:37:35 +02:00
|
|
|
TEB *teb;
|
|
|
|
SIZE_T info_size;
|
|
|
|
struct ntdll_thread_data *thread_data;
|
2020-06-01 12:52:05 +02:00
|
|
|
#ifdef __i386__
|
|
|
|
extern struct ldt_copy __wine_ldt_copy;
|
|
|
|
*ldt_copy = &__wine_ldt_copy;
|
|
|
|
#endif
|
|
|
|
nb_threads = nb_threads_ptr;
|
2020-06-04 19:37:35 +02:00
|
|
|
|
|
|
|
teb = virtual_alloc_first_teb();
|
|
|
|
thread_data = (struct ntdll_thread_data *)&teb->GdiTebBatch;
|
|
|
|
thread_data->request_fd = -1;
|
|
|
|
thread_data->reply_fd = -1;
|
|
|
|
thread_data->wait_fd[0] = -1;
|
|
|
|
thread_data->wait_fd[1] = -1;
|
|
|
|
|
|
|
|
signal_init_threading();
|
|
|
|
signal_alloc_thread( teb );
|
|
|
|
signal_init_thread( teb );
|
|
|
|
dbg_init();
|
|
|
|
server_init_process();
|
|
|
|
info_size = server_init_thread( teb->Peb, suspend );
|
2020-06-04 19:48:26 +02:00
|
|
|
virtual_map_user_shared_data();
|
2020-06-13 12:59:17 +02:00
|
|
|
init_files();
|
2020-06-04 21:27:22 +02:00
|
|
|
NtCreateKeyedEvent( &keyed_event, GENERIC_READ | GENERIC_WRITE, NULL, 0 );
|
2020-06-04 19:48:26 +02:00
|
|
|
|
2020-06-04 19:37:35 +02:00
|
|
|
if (size) *size = info_size;
|
|
|
|
if (cpus) *cpus = server_cpus;
|
|
|
|
if (wow64) *wow64 = is_wow64;
|
|
|
|
if (start_time) *start_time = server_start_time;
|
|
|
|
return teb;
|
2020-06-01 12:52:05 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-03 21:09:13 +02:00
|
|
|
/* info passed to a starting thread */
|
|
|
|
struct startup_info
|
|
|
|
{
|
|
|
|
PRTL_THREAD_START_ROUTINE entry;
|
|
|
|
void *arg;
|
|
|
|
HANDLE actctx;
|
|
|
|
};
|
|
|
|
|
2020-06-01 12:52:05 +02:00
|
|
|
/***********************************************************************
|
2020-06-03 16:32:02 +02:00
|
|
|
* start_thread
|
2020-06-03 21:09:13 +02:00
|
|
|
*
|
|
|
|
* Startup routine for a newly created thread.
|
2020-06-01 12:52:05 +02:00
|
|
|
*/
|
2020-06-03 21:09:13 +02:00
|
|
|
static void start_thread( TEB *teb )
|
2020-06-01 12:52:05 +02:00
|
|
|
{
|
2020-06-03 21:09:13 +02:00
|
|
|
struct startup_info *info = (struct startup_info *)(teb + 1);
|
|
|
|
struct ntdll_thread_data *thread_data = (struct ntdll_thread_data *)&teb->GdiTebBatch;
|
|
|
|
struct debug_info debug_info;
|
2020-06-03 16:32:02 +02:00
|
|
|
BOOL suspend;
|
2020-06-03 21:09:13 +02:00
|
|
|
ULONG_PTR cookie;
|
2020-06-03 16:32:02 +02:00
|
|
|
|
2020-06-03 21:09:13 +02:00
|
|
|
debug_info.str_pos = debug_info.out_pos = 0;
|
|
|
|
thread_data->debug_info = &debug_info;
|
|
|
|
thread_data->pthread_id = pthread_self();
|
2020-06-01 12:52:05 +02:00
|
|
|
signal_init_thread( teb );
|
2020-06-04 19:37:35 +02:00
|
|
|
server_init_thread( info->entry, &suspend );
|
2020-06-03 21:09:13 +02:00
|
|
|
if (info->actctx)
|
|
|
|
{
|
|
|
|
RtlActivateActivationContext( 0, info->actctx, &cookie );
|
|
|
|
RtlReleaseActivationContext( info->actctx );
|
|
|
|
}
|
2020-06-17 11:57:32 +02:00
|
|
|
signal_start_thread( info->entry, info->arg, suspend, pRtlUserThreadStart, teb );
|
2020-06-03 21:09:13 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
2020-06-05 16:37:49 +02:00
|
|
|
* update_attr_list
|
|
|
|
*
|
|
|
|
* Update the output attributes.
|
2020-06-03 21:09:13 +02:00
|
|
|
*/
|
2020-06-05 16:37:49 +02:00
|
|
|
static void update_attr_list( PS_ATTRIBUTE_LIST *attr, const CLIENT_ID *id )
|
|
|
|
{
|
|
|
|
SIZE_T i, count = (attr->TotalLength - sizeof(attr->TotalLength)) / sizeof(PS_ATTRIBUTE);
|
|
|
|
|
|
|
|
for (i = 0; i < count; i++)
|
|
|
|
{
|
|
|
|
if (attr->Attributes[i].Attribute == PS_ATTRIBUTE_CLIENT_ID)
|
|
|
|
{
|
|
|
|
SIZE_T size = min( attr->Attributes[i].Size, sizeof(*id) );
|
|
|
|
memcpy( attr->Attributes[i].ValuePtr, id, size );
|
|
|
|
if (attr->Attributes[i].ReturnLength) *attr->Attributes[i].ReturnLength = size;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* NtCreateThreadEx (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtCreateThreadEx( HANDLE *handle, ACCESS_MASK access, OBJECT_ATTRIBUTES *attr,
|
|
|
|
HANDLE process, PRTL_THREAD_START_ROUTINE start, void *param,
|
|
|
|
ULONG flags, SIZE_T zero_bits, SIZE_T stack_commit,
|
|
|
|
SIZE_T stack_reserve, PS_ATTRIBUTE_LIST *attr_list )
|
2020-06-03 21:09:13 +02:00
|
|
|
{
|
|
|
|
sigset_t sigset;
|
|
|
|
pthread_t pthread_id;
|
2020-06-05 14:09:19 +02:00
|
|
|
pthread_attr_t pthread_attr;
|
|
|
|
data_size_t len;
|
|
|
|
struct object_attributes *objattr;
|
2020-06-03 21:09:13 +02:00
|
|
|
struct ntdll_thread_data *thread_data;
|
|
|
|
struct startup_info *info;
|
2020-06-05 14:09:19 +02:00
|
|
|
DWORD tid = 0;
|
|
|
|
int request_pipe[2];
|
2020-06-03 21:09:13 +02:00
|
|
|
SIZE_T extra_stack = PTHREAD_STACK_MIN;
|
2020-06-05 16:37:49 +02:00
|
|
|
CLIENT_ID client_id;
|
2020-06-05 14:09:19 +02:00
|
|
|
HANDLE actctx;
|
2020-06-03 21:09:13 +02:00
|
|
|
TEB *teb;
|
|
|
|
INITIAL_TEB stack;
|
|
|
|
NTSTATUS status;
|
|
|
|
|
2020-06-05 14:09:19 +02:00
|
|
|
if (process != NtCurrentProcess())
|
|
|
|
{
|
|
|
|
apc_call_t call;
|
|
|
|
apc_result_t result;
|
|
|
|
|
|
|
|
memset( &call, 0, sizeof(call) );
|
|
|
|
|
|
|
|
call.create_thread.type = APC_CREATE_THREAD;
|
2020-06-05 15:23:37 +02:00
|
|
|
call.create_thread.flags = flags;
|
2020-06-05 14:09:19 +02:00
|
|
|
call.create_thread.func = wine_server_client_ptr( start );
|
|
|
|
call.create_thread.arg = wine_server_client_ptr( param );
|
|
|
|
call.create_thread.reserve = stack_reserve;
|
|
|
|
call.create_thread.commit = stack_commit;
|
|
|
|
status = server_queue_process_apc( process, &call, &result );
|
|
|
|
if (status != STATUS_SUCCESS) return status;
|
|
|
|
|
|
|
|
if (result.create_thread.status == STATUS_SUCCESS)
|
|
|
|
{
|
|
|
|
*handle = wine_server_ptr_handle( result.create_thread.handle );
|
2020-06-05 16:37:49 +02:00
|
|
|
client_id.UniqueProcess = ULongToHandle( result.create_thread.pid );
|
|
|
|
client_id.UniqueThread = ULongToHandle( result.create_thread.tid );
|
|
|
|
if (attr_list) update_attr_list( attr_list, &client_id );
|
2020-06-05 14:09:19 +02:00
|
|
|
}
|
|
|
|
return result.create_thread.status;
|
|
|
|
}
|
|
|
|
|
|
|
|
if ((status = alloc_object_attributes( attr, &objattr, &len ))) return status;
|
|
|
|
|
|
|
|
if (server_pipe( request_pipe ) == -1)
|
|
|
|
{
|
|
|
|
RtlFreeHeap( GetProcessHeap(), 0, objattr );
|
|
|
|
return STATUS_TOO_MANY_OPENED_FILES;
|
|
|
|
}
|
|
|
|
server_send_fd( request_pipe[0] );
|
|
|
|
|
2020-06-05 16:37:49 +02:00
|
|
|
if (!access) access = THREAD_ALL_ACCESS;
|
|
|
|
|
2020-06-05 14:09:19 +02:00
|
|
|
SERVER_START_REQ( new_thread )
|
|
|
|
{
|
|
|
|
req->process = wine_server_obj_handle( process );
|
|
|
|
req->access = access;
|
|
|
|
req->suspend = flags & THREAD_CREATE_FLAGS_CREATE_SUSPENDED;
|
|
|
|
req->request_fd = request_pipe[0];
|
|
|
|
wine_server_add_data( req, objattr, len );
|
|
|
|
if (!(status = wine_server_call( req )))
|
|
|
|
{
|
|
|
|
*handle = wine_server_ptr_handle( reply->handle );
|
|
|
|
tid = reply->tid;
|
|
|
|
}
|
|
|
|
close( request_pipe[0] );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
|
|
|
|
RtlFreeHeap( GetProcessHeap(), 0, objattr );
|
|
|
|
if (status)
|
|
|
|
{
|
|
|
|
close( request_pipe[1] );
|
|
|
|
return status;
|
|
|
|
}
|
|
|
|
|
|
|
|
RtlGetActiveActivationContext( &actctx );
|
|
|
|
|
2020-06-03 21:09:13 +02:00
|
|
|
pthread_sigmask( SIG_BLOCK, &server_block_set, &sigset );
|
|
|
|
|
|
|
|
if ((status = virtual_alloc_teb( &teb ))) goto done;
|
|
|
|
|
|
|
|
if ((status = virtual_alloc_thread_stack( &stack, stack_reserve, stack_commit, &extra_stack )))
|
|
|
|
{
|
|
|
|
virtual_free_teb( teb );
|
|
|
|
goto done;
|
|
|
|
}
|
|
|
|
|
2020-06-05 16:37:49 +02:00
|
|
|
client_id.UniqueProcess = ULongToHandle( GetCurrentProcessId() );
|
|
|
|
client_id.UniqueThread = ULongToHandle( tid );
|
|
|
|
teb->ClientId = client_id;
|
2020-06-03 21:09:13 +02:00
|
|
|
|
|
|
|
info = (struct startup_info *)(teb + 1);
|
|
|
|
info->entry = start;
|
|
|
|
info->arg = param;
|
|
|
|
info->actctx = actctx;
|
|
|
|
|
|
|
|
teb->Tib.StackBase = stack.StackBase;
|
|
|
|
teb->Tib.StackLimit = stack.StackLimit;
|
|
|
|
teb->DeallocationStack = stack.DeallocationStack;
|
|
|
|
|
|
|
|
thread_data = (struct ntdll_thread_data *)&teb->GdiTebBatch;
|
2020-06-05 14:09:19 +02:00
|
|
|
thread_data->request_fd = request_pipe[1];
|
2020-06-03 21:09:13 +02:00
|
|
|
thread_data->reply_fd = -1;
|
|
|
|
thread_data->wait_fd[0] = -1;
|
|
|
|
thread_data->wait_fd[1] = -1;
|
|
|
|
thread_data->start_stack = (char *)teb->Tib.StackBase;
|
|
|
|
|
2020-06-05 14:09:19 +02:00
|
|
|
pthread_attr_init( &pthread_attr );
|
|
|
|
pthread_attr_setstack( &pthread_attr, teb->DeallocationStack,
|
2020-06-03 21:09:13 +02:00
|
|
|
(char *)teb->Tib.StackBase + extra_stack - (char *)teb->DeallocationStack );
|
2020-06-05 14:09:19 +02:00
|
|
|
pthread_attr_setguardsize( &pthread_attr, 0 );
|
|
|
|
pthread_attr_setscope( &pthread_attr, PTHREAD_SCOPE_SYSTEM ); /* force creating a kernel thread */
|
2020-06-03 21:09:13 +02:00
|
|
|
InterlockedIncrement( nb_threads );
|
2020-06-05 14:09:19 +02:00
|
|
|
if (pthread_create( &pthread_id, &pthread_attr, (void * (*)(void *))start_thread, teb ))
|
2020-06-03 21:09:13 +02:00
|
|
|
{
|
|
|
|
InterlockedDecrement( nb_threads );
|
|
|
|
virtual_free_teb( teb );
|
|
|
|
status = STATUS_NO_MEMORY;
|
|
|
|
}
|
2020-06-05 14:09:19 +02:00
|
|
|
pthread_attr_destroy( &pthread_attr );
|
|
|
|
|
2020-06-03 21:09:13 +02:00
|
|
|
done:
|
|
|
|
pthread_sigmask( SIG_SETMASK, &sigset, NULL );
|
2020-06-05 16:37:49 +02:00
|
|
|
if (status)
|
|
|
|
{
|
|
|
|
NtClose( *handle );
|
|
|
|
RtlReleaseActivationContext( actctx );
|
|
|
|
close( request_pipe[1] );
|
|
|
|
return status;
|
|
|
|
}
|
|
|
|
if (attr_list) update_attr_list( attr_list, &client_id );
|
|
|
|
return STATUS_SUCCESS;
|
2020-06-03 16:32:02 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-01 12:52:05 +02:00
|
|
|
/***********************************************************************
|
|
|
|
* abort_thread
|
|
|
|
*/
|
2020-06-09 12:34:37 +02:00
|
|
|
void abort_thread( int status )
|
2020-06-01 12:52:05 +02:00
|
|
|
{
|
|
|
|
pthread_sigmask( SIG_BLOCK, &server_block_set, NULL );
|
2020-06-16 11:35:55 +02:00
|
|
|
if (InterlockedDecrement( nb_threads ) <= 0) abort_process( status );
|
2020-06-01 12:52:05 +02:00
|
|
|
signal_exit_thread( status, pthread_exit_wrapper );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-16 11:35:55 +02:00
|
|
|
/***********************************************************************
|
|
|
|
* abort_process
|
|
|
|
*/
|
|
|
|
void abort_process( int status )
|
|
|
|
{
|
|
|
|
_exit( get_unix_exit_code( status ));
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-01 12:52:05 +02:00
|
|
|
/***********************************************************************
|
|
|
|
* exit_thread
|
|
|
|
*/
|
|
|
|
void CDECL exit_thread( int status )
|
|
|
|
{
|
2020-06-03 21:26:47 +02:00
|
|
|
static void *prev_teb;
|
|
|
|
TEB *teb;
|
|
|
|
|
2020-06-01 12:52:05 +02:00
|
|
|
pthread_sigmask( SIG_BLOCK, &server_block_set, NULL );
|
2020-06-03 21:26:47 +02:00
|
|
|
|
|
|
|
if ((teb = InterlockedExchangePointer( &prev_teb, NtCurrentTeb() )))
|
|
|
|
{
|
|
|
|
struct ntdll_thread_data *thread_data = (struct ntdll_thread_data *)&teb->GdiTebBatch;
|
|
|
|
|
|
|
|
if (thread_data->pthread_id)
|
|
|
|
{
|
|
|
|
pthread_join( thread_data->pthread_id, NULL );
|
|
|
|
virtual_free_teb( teb );
|
|
|
|
}
|
|
|
|
}
|
2020-06-01 12:52:05 +02:00
|
|
|
signal_exit_thread( status, pthread_exit_wrapper );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* exit_process
|
|
|
|
*/
|
|
|
|
void CDECL exit_process( int status )
|
|
|
|
{
|
|
|
|
pthread_sigmask( SIG_BLOCK, &server_block_set, NULL );
|
|
|
|
signal_exit_thread( get_unix_exit_code( status ), exit );
|
|
|
|
}
|
2020-06-02 13:11:54 +02:00
|
|
|
|
|
|
|
|
2020-06-03 16:32:02 +02:00
|
|
|
/**********************************************************************
|
|
|
|
* wait_suspend
|
|
|
|
*
|
|
|
|
* Wait until the thread is no longer suspended.
|
|
|
|
*/
|
|
|
|
void wait_suspend( CONTEXT *context )
|
|
|
|
{
|
|
|
|
int saved_errno = errno;
|
|
|
|
|
|
|
|
/* wait with 0 timeout, will only return once the thread is no longer suspended */
|
|
|
|
server_select( NULL, 0, SELECT_INTERRUPTIBLE, 0, context, NULL, NULL );
|
|
|
|
errno = saved_errno;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-06 13:56:19 +02:00
|
|
|
/**********************************************************************
|
|
|
|
* send_debug_event
|
|
|
|
*
|
|
|
|
* Send an EXCEPTION_DEBUG_EVENT event to the debugger.
|
|
|
|
*/
|
2020-06-09 12:32:41 +02:00
|
|
|
NTSTATUS send_debug_event( EXCEPTION_RECORD *rec, CONTEXT *context, BOOL first_chance )
|
2020-06-06 13:56:19 +02:00
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
DWORD i;
|
|
|
|
obj_handle_t handle = 0;
|
|
|
|
client_ptr_t params[EXCEPTION_MAXIMUM_PARAMETERS];
|
|
|
|
CONTEXT exception_context = *context;
|
|
|
|
select_op_t select_op;
|
|
|
|
sigset_t old_set;
|
|
|
|
|
|
|
|
if (!NtCurrentTeb()->Peb->BeingDebugged) return 0; /* no debugger present */
|
|
|
|
|
|
|
|
pthread_sigmask( SIG_BLOCK, &server_block_set, &old_set );
|
|
|
|
|
|
|
|
for (i = 0; i < min( rec->NumberParameters, EXCEPTION_MAXIMUM_PARAMETERS ); i++)
|
|
|
|
params[i] = rec->ExceptionInformation[i];
|
|
|
|
|
|
|
|
SERVER_START_REQ( queue_exception_event )
|
|
|
|
{
|
|
|
|
req->first = first_chance;
|
|
|
|
req->code = rec->ExceptionCode;
|
|
|
|
req->flags = rec->ExceptionFlags;
|
|
|
|
req->record = wine_server_client_ptr( rec->ExceptionRecord );
|
|
|
|
req->address = wine_server_client_ptr( rec->ExceptionAddress );
|
|
|
|
req->len = i * sizeof(params[0]);
|
|
|
|
wine_server_add_data( req, params, req->len );
|
|
|
|
if (!(ret = wine_server_call( req ))) handle = reply->handle;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
|
|
|
|
if (handle)
|
|
|
|
{
|
|
|
|
select_op.wait.op = SELECT_WAIT;
|
|
|
|
select_op.wait.handles[0] = handle;
|
|
|
|
server_select( &select_op, offsetof( select_op_t, wait.handles[1] ), SELECT_INTERRUPTIBLE,
|
|
|
|
TIMEOUT_INFINITE, &exception_context, NULL, NULL );
|
|
|
|
|
|
|
|
SERVER_START_REQ( get_exception_status )
|
|
|
|
{
|
|
|
|
req->handle = handle;
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
if (ret >= 0) *context = exception_context;
|
|
|
|
}
|
|
|
|
|
|
|
|
pthread_sigmask( SIG_SETMASK, &old_set, NULL );
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*******************************************************************
|
|
|
|
* NtRaiseException (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtRaiseException( EXCEPTION_RECORD *rec, CONTEXT *context, BOOL first_chance )
|
|
|
|
{
|
|
|
|
NTSTATUS status = send_debug_event( rec, context, first_chance );
|
|
|
|
|
|
|
|
if (status == DBG_CONTINUE || status == DBG_EXCEPTION_HANDLED)
|
|
|
|
NtSetContextThread( GetCurrentThread(), context );
|
|
|
|
|
2020-06-17 11:57:32 +02:00
|
|
|
if (first_chance) pKiUserExceptionDispatcher( rec, context );
|
2020-06-06 13:56:19 +02:00
|
|
|
|
|
|
|
if (rec->ExceptionFlags & EH_STACK_INVALID)
|
|
|
|
ERR("Exception frame is not in stack limits => unable to dispatch exception.\n");
|
|
|
|
else if (rec->ExceptionCode == STATUS_NONCONTINUABLE_EXCEPTION)
|
|
|
|
ERR("Process attempted to continue execution after noncontinuable exception.\n");
|
|
|
|
else
|
|
|
|
ERR("Unhandled exception code %x flags %x addr %p\n",
|
|
|
|
rec->ExceptionCode, rec->ExceptionFlags, rec->ExceptionAddress );
|
|
|
|
|
|
|
|
NtTerminateProcess( NtCurrentProcess(), rec->ExceptionCode );
|
|
|
|
return STATUS_SUCCESS;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-09 12:34:37 +02:00
|
|
|
/***********************************************************************
|
|
|
|
* NtOpenThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtOpenThread( HANDLE *handle, ACCESS_MASK access,
|
|
|
|
const OBJECT_ATTRIBUTES *attr, const CLIENT_ID *id )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
SERVER_START_REQ( open_thread )
|
|
|
|
{
|
|
|
|
req->tid = HandleToULong(id->UniqueThread);
|
|
|
|
req->access = access;
|
|
|
|
req->attributes = attr ? attr->Attributes : 0;
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*handle = wine_server_ptr_handle( reply->handle );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtSuspendThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtSuspendThread( HANDLE handle, ULONG *count )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
SERVER_START_REQ( suspend_thread )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
if (!(ret = wine_server_call( req )))
|
|
|
|
{
|
|
|
|
if (count) *count = reply->count;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtResumeThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtResumeThread( HANDLE handle, ULONG *count )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
SERVER_START_REQ( resume_thread )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
if (!(ret = wine_server_call( req )))
|
|
|
|
{
|
|
|
|
if (count) *count = reply->count;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtAlertResumeThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtAlertResumeThread( HANDLE handle, ULONG *count )
|
|
|
|
{
|
|
|
|
FIXME( "stub: should alert thread %p\n", handle );
|
|
|
|
return NtResumeThread( handle, count );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtAlertThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtAlertThread( HANDLE handle )
|
|
|
|
{
|
|
|
|
FIXME( "stub: %p\n", handle );
|
|
|
|
return STATUS_NOT_IMPLEMENTED;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtTerminateThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtTerminateThread( HANDLE handle, LONG exit_code )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
BOOL self = (handle == GetCurrentThread());
|
|
|
|
|
|
|
|
if (!self || exit_code)
|
|
|
|
{
|
|
|
|
SERVER_START_REQ( terminate_thread )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
req->exit_code = exit_code;
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
self = !ret && reply->self;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
}
|
|
|
|
if (self) abort_thread( exit_code );
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-06 15:16:38 +02:00
|
|
|
/***********************************************************************
|
|
|
|
* NtContinue (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtContinue( CONTEXT *context, BOOLEAN alertable )
|
|
|
|
{
|
|
|
|
static const LARGE_INTEGER zero_timeout;
|
|
|
|
|
|
|
|
if (alertable) server_wait( NULL, 0, SELECT_INTERRUPTIBLE | SELECT_ALERTABLE, &zero_timeout );
|
|
|
|
return NtSetContextThread( GetCurrentThread(), context );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-09 12:34:37 +02:00
|
|
|
/******************************************************************************
|
|
|
|
* NtQueueApcThread (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtQueueApcThread( HANDLE handle, PNTAPCFUNC func, ULONG_PTR arg1,
|
|
|
|
ULONG_PTR arg2, ULONG_PTR arg3 )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
SERVER_START_REQ( queue_apc )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
if (func)
|
|
|
|
{
|
|
|
|
req->call.type = APC_USER;
|
|
|
|
req->call.user.user.func = wine_server_client_ptr( func );
|
|
|
|
req->call.user.user.args[0] = arg1;
|
|
|
|
req->call.user.user.args[1] = arg2;
|
|
|
|
req->call.user.user.args[2] = arg3;
|
|
|
|
}
|
|
|
|
else req->call.type = APC_NONE; /* wake up only */
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-02 13:11:54 +02:00
|
|
|
/***********************************************************************
|
|
|
|
* set_thread_context
|
|
|
|
*/
|
|
|
|
NTSTATUS set_thread_context( HANDLE handle, const context_t *context, BOOL *self )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
SERVER_START_REQ( set_thread_context )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
wine_server_add_data( req, context, sizeof(*context) );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*self = reply->self;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
|
|
|
|
return ret;
|
|
|
|
}
|
2020-06-02 14:05:42 +02:00
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* get_thread_context
|
|
|
|
*/
|
|
|
|
NTSTATUS get_thread_context( HANDLE handle, context_t *context, unsigned int flags, BOOL *self )
|
|
|
|
{
|
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
SERVER_START_REQ( get_thread_context )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
req->flags = flags;
|
|
|
|
wine_server_set_reply( req, context, sizeof(*context) );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*self = reply->self;
|
|
|
|
handle = wine_server_ptr_handle( reply->handle );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
|
|
|
|
if (ret == STATUS_PENDING)
|
|
|
|
{
|
|
|
|
LARGE_INTEGER timeout;
|
|
|
|
timeout.QuadPart = -1000000;
|
|
|
|
if (NtWaitForSingleObject( handle, FALSE, &timeout ))
|
|
|
|
{
|
|
|
|
NtClose( handle );
|
|
|
|
return STATUS_ACCESS_DENIED;
|
|
|
|
}
|
|
|
|
SERVER_START_REQ( get_thread_context )
|
|
|
|
{
|
|
|
|
req->handle = wine_server_obj_handle( handle );
|
|
|
|
req->flags = flags;
|
|
|
|
wine_server_set_reply( req, context, sizeof(*context) );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|