1999-03-09 17:47:51 +00:00
|
|
|
/*
|
|
|
|
* Process synchronisation
|
2002-03-09 23:29:33 +00:00
|
|
|
*
|
2003-05-20 04:00:42 +00:00
|
|
|
* Copyright 1996, 1997, 1998 Marcus Meissner
|
|
|
|
* Copyright 1997, 1999 Alexandre Julliard
|
2002-03-09 23:29:33 +00:00
|
|
|
* Copyright 1999, 2000 Juergen Schmied
|
2003-05-20 04:00:42 +00:00
|
|
|
* Copyright 2003 Eric Pouech
|
2002-03-09 23:29:33 +00:00
|
|
|
*
|
|
|
|
* 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
|
|
|
|
2003-03-31 01:37:04 +00:00
|
|
|
#include "config.h"
|
|
|
|
|
|
|
|
#include <assert.h>
|
|
|
|
#include <errno.h>
|
|
|
|
#include <signal.h>
|
|
|
|
#ifdef HAVE_SYS_TIME_H
|
|
|
|
# include <sys/time.h>
|
|
|
|
#endif
|
|
|
|
#ifdef HAVE_SYS_POLL_H
|
|
|
|
# include <sys/poll.h>
|
|
|
|
#endif
|
|
|
|
#ifdef HAVE_UNISTD_H
|
|
|
|
# include <unistd.h>
|
|
|
|
#endif
|
2004-10-09 02:26:29 +00:00
|
|
|
#ifdef HAVE_SCHED_H
|
|
|
|
# include <sched.h>
|
|
|
|
#endif
|
2003-03-31 01:37:04 +00:00
|
|
|
#include <string.h>
|
2003-09-05 23:08:26 +00:00
|
|
|
#include <stdarg.h>
|
1999-06-12 14:55:11 +00:00
|
|
|
#include <stdio.h>
|
1999-03-09 17:47:51 +00:00
|
|
|
#include <stdlib.h>
|
|
|
|
#include <time.h>
|
|
|
|
|
2003-03-31 19:32:20 +00:00
|
|
|
#define NONAMELESSUNION
|
|
|
|
#define NONAMELESSSTRUCT
|
|
|
|
|
2003-09-05 23:08:26 +00:00
|
|
|
#include "windef.h"
|
|
|
|
#include "winbase.h"
|
|
|
|
#include "winreg.h"
|
2002-09-12 22:07:02 +00:00
|
|
|
#include "winternl.h"
|
2003-03-31 01:37:04 +00:00
|
|
|
#include "async.h"
|
|
|
|
#include "thread.h"
|
|
|
|
#include "wine/server.h"
|
|
|
|
#include "wine/unicode.h"
|
|
|
|
#include "wine/debug.h"
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
#include "ntdll_misc.h"
|
1999-03-09 17:47:51 +00:00
|
|
|
|
2002-03-09 23:29:33 +00:00
|
|
|
WINE_DEFAULT_DEBUG_CHANNEL(ntdll);
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
|
|
|
|
|
1999-03-09 17:47:51 +00:00
|
|
|
/*
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
* Semaphores
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtCreateSemaphore (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtCreateSemaphore( OUT PHANDLE SemaphoreHandle,
|
|
|
|
IN ACCESS_MASK access,
|
|
|
|
IN const OBJECT_ATTRIBUTES *attr OPTIONAL,
|
|
|
|
IN ULONG InitialCount,
|
|
|
|
IN ULONG MaximumCount )
|
1999-03-09 17:47:51 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
DWORD len = attr && attr->ObjectName ? attr->ObjectName->Length : 0;
|
2000-01-26 01:39:51 +00:00
|
|
|
NTSTATUS ret;
|
|
|
|
|
2001-08-10 22:49:35 +00:00
|
|
|
if ((MaximumCount <= 0) || (InitialCount > MaximumCount))
|
2000-01-26 01:39:51 +00:00
|
|
|
return STATUS_INVALID_PARAMETER;
|
|
|
|
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_START_REQ( create_semaphore )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->initial = InitialCount;
|
|
|
|
req->max = MaximumCount;
|
|
|
|
req->inherit = attr && (attr->Attributes & OBJ_INHERIT);
|
2001-11-30 18:46:42 +00:00
|
|
|
if (len) wine_server_add_data( req, attr->ObjectName->Buffer, len );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*SemaphoreHandle = reply->handle;
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_END_REQ;
|
2000-01-26 01:39:51 +00:00
|
|
|
return ret;
|
1999-03-09 17:47:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtOpenSemaphore (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtOpenSemaphore( OUT PHANDLE SemaphoreHandle,
|
|
|
|
IN ACCESS_MASK access,
|
|
|
|
IN const OBJECT_ATTRIBUTES *attr )
|
1999-03-09 17:47:51 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
DWORD len = attr && attr->ObjectName ? attr->ObjectName->Length : 0;
|
2000-01-26 01:39:51 +00:00
|
|
|
NTSTATUS ret;
|
|
|
|
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_START_REQ( open_semaphore )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->access = access;
|
|
|
|
req->inherit = attr && (attr->Attributes & OBJ_INHERIT);
|
2001-11-30 18:46:42 +00:00
|
|
|
if (len) wine_server_add_data( req, attr->ObjectName->Buffer, len );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*SemaphoreHandle = reply->handle;
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_END_REQ;
|
2000-01-26 01:39:51 +00:00
|
|
|
return ret;
|
1999-03-09 17:47:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtQuerySemaphore (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtQuerySemaphore(
|
|
|
|
HANDLE SemaphoreHandle,
|
|
|
|
PVOID SemaphoreInformationClass,
|
|
|
|
OUT PVOID SemaphoreInformation,
|
|
|
|
ULONG Length,
|
2002-05-31 23:06:46 +00:00
|
|
|
PULONG ReturnLength)
|
1999-03-09 17:47:51 +00:00
|
|
|
{
|
2002-12-05 19:56:15 +00:00
|
|
|
FIXME("(%p,%p,%p,0x%08lx,%p) stub!\n",
|
1999-03-09 17:47:51 +00:00
|
|
|
SemaphoreHandle, SemaphoreInformationClass, SemaphoreInformation, Length, ReturnLength);
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
return STATUS_SUCCESS;
|
1999-03-09 17:47:51 +00:00
|
|
|
}
|
2000-08-30 00:00:48 +00:00
|
|
|
|
1999-03-09 17:47:51 +00:00
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtReleaseSemaphore (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtReleaseSemaphore( HANDLE handle, ULONG count, PULONG previous )
|
1999-03-09 17:47:51 +00:00
|
|
|
{
|
2000-01-26 01:39:51 +00:00
|
|
|
NTSTATUS ret;
|
2001-02-27 02:09:16 +00:00
|
|
|
SERVER_START_REQ( release_semaphore )
|
2000-01-26 01:39:51 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
req->handle = handle;
|
|
|
|
req->count = count;
|
2001-11-30 18:46:42 +00:00
|
|
|
if (!(ret = wine_server_call( req )))
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
2001-11-30 18:46:42 +00:00
|
|
|
if (previous) *previous = reply->prev_count;
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
2000-01-26 01:39:51 +00:00
|
|
|
}
|
2000-08-30 00:00:48 +00:00
|
|
|
SERVER_END_REQ;
|
2000-01-26 01:39:51 +00:00
|
|
|
return ret;
|
1999-03-09 17:47:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
* Events
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
2002-05-31 23:06:46 +00:00
|
|
|
|
1999-03-09 17:47:51 +00:00
|
|
|
/**************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtCreateEvent (NTDLL.@)
|
2001-07-11 18:56:41 +00:00
|
|
|
* ZwCreateEvent (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtCreateEvent(
|
|
|
|
OUT PHANDLE EventHandle,
|
|
|
|
IN ACCESS_MASK DesiredAccess,
|
2000-08-30 00:00:48 +00:00
|
|
|
IN const OBJECT_ATTRIBUTES *attr,
|
1999-03-09 17:47:51 +00:00
|
|
|
IN BOOLEAN ManualReset,
|
|
|
|
IN BOOLEAN InitialState)
|
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
DWORD len = attr && attr->ObjectName ? attr->ObjectName->Length : 0;
|
2000-01-26 01:39:51 +00:00
|
|
|
NTSTATUS ret;
|
|
|
|
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_START_REQ( create_event )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->manual_reset = ManualReset;
|
|
|
|
req->initial_state = InitialState;
|
|
|
|
req->inherit = attr && (attr->Attributes & OBJ_INHERIT);
|
2001-11-30 18:46:42 +00:00
|
|
|
if (len) wine_server_add_data( req, attr->ObjectName->Buffer, len );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*EventHandle = reply->handle;
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_END_REQ;
|
2000-01-26 01:39:51 +00:00
|
|
|
return ret;
|
1999-03-09 17:47:51 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtOpenEvent (NTDLL.@)
|
2001-07-11 18:56:41 +00:00
|
|
|
* ZwOpenEvent (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtOpenEvent(
|
|
|
|
OUT PHANDLE EventHandle,
|
|
|
|
IN ACCESS_MASK DesiredAccess,
|
2000-08-30 00:00:48 +00:00
|
|
|
IN const OBJECT_ATTRIBUTES *attr )
|
1999-03-09 17:47:51 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
DWORD len = attr && attr->ObjectName ? attr->ObjectName->Length : 0;
|
2000-01-26 01:39:51 +00:00
|
|
|
NTSTATUS ret;
|
|
|
|
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_START_REQ( open_event )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->access = DesiredAccess;
|
|
|
|
req->inherit = attr && (attr->Attributes & OBJ_INHERIT);
|
2001-11-30 18:46:42 +00:00
|
|
|
if (len) wine_server_add_data( req, attr->ObjectName->Buffer, len );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
*EventHandle = reply->handle;
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
2001-11-30 18:46:42 +00:00
|
|
|
SERVER_END_REQ;
|
2000-01-26 01:39:51 +00:00
|
|
|
return ret;
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
}
|
|
|
|
|
1999-03-09 17:47:51 +00:00
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtSetEvent (NTDLL.@)
|
2001-07-11 18:56:41 +00:00
|
|
|
* ZwSetEvent (NTDLL.@)
|
1999-03-09 17:47:51 +00:00
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtSetEvent( HANDLE handle, PULONG NumberOfThreadsReleased )
|
1999-03-09 17:47:51 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS ret;
|
2000-09-29 20:48:04 +00:00
|
|
|
|
|
|
|
/* FIXME: set NumberOfThreadsReleased */
|
|
|
|
|
2001-02-27 02:09:16 +00:00
|
|
|
SERVER_START_REQ( event_op )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->handle = handle;
|
|
|
|
req->op = SET_EVENT;
|
2001-11-30 18:46:42 +00:00
|
|
|
ret = wine_server_call( req );
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
1999-03-09 17:47:51 +00:00
|
|
|
}
|
|
|
|
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtResetEvent (NTDLL.@)
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtResetEvent( HANDLE handle, PULONG NumberOfThreadsReleased )
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS ret;
|
|
|
|
|
|
|
|
/* resetting an event can't release any thread... */
|
|
|
|
if (NumberOfThreadsReleased) *NumberOfThreadsReleased = 0;
|
|
|
|
|
2001-02-27 02:09:16 +00:00
|
|
|
SERVER_START_REQ( event_op )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->handle = handle;
|
|
|
|
req->op = RESET_EVENT;
|
2001-11-30 18:46:42 +00:00
|
|
|
ret = wine_server_call( req );
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtClearEvent (NTDLL.@)
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
*
|
|
|
|
* FIXME
|
|
|
|
* same as NtResetEvent ???
|
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtClearEvent ( HANDLE handle )
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
return NtResetEvent( handle, NULL );
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtPulseEvent (NTDLL.@)
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
*
|
|
|
|
* FIXME
|
|
|
|
* PulseCount
|
|
|
|
*/
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS WINAPI NtPulseEvent( HANDLE handle, PULONG PulseCount )
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
{
|
2000-08-30 00:00:48 +00:00
|
|
|
NTSTATUS ret;
|
2004-04-01 21:01:53 +00:00
|
|
|
|
|
|
|
if (PulseCount)
|
|
|
|
FIXME("(%p,%ld)\n", handle, *PulseCount);
|
|
|
|
|
2001-02-27 02:09:16 +00:00
|
|
|
SERVER_START_REQ( event_op )
|
2000-08-30 00:00:48 +00:00
|
|
|
{
|
|
|
|
req->handle = handle;
|
|
|
|
req->op = PULSE_EVENT;
|
2001-11-30 18:46:42 +00:00
|
|
|
ret = wine_server_call( req );
|
2000-08-30 00:00:48 +00:00
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return ret;
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
2001-06-19 18:20:47 +00:00
|
|
|
* NtQueryEvent (NTDLL.@)
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtQueryEvent (
|
|
|
|
IN HANDLE EventHandle,
|
|
|
|
IN UINT EventInformationClass,
|
|
|
|
OUT PVOID EventInformation,
|
|
|
|
IN ULONG EventInformationLength,
|
|
|
|
OUT PULONG ReturnLength)
|
|
|
|
{
|
2002-12-05 19:56:15 +00:00
|
|
|
FIXME("(%p)\n", EventHandle);
|
- implementation of RtlReg* (read access), RtlEvent*, RtlSemaphore*,
NtAllocateLocallyUniqueId
- implementation or stubs for NtAccessCheck, NtSetSecurityObject,
RtlClearBits, RtlEqualPrefixSid, RtlFindClearBits,
RtlFormatCurrentUserKeyPath, RtlGetControlSecurityDescriptor,
RtlIdentifierAuthoritySid, RtlImpersonateSelf, RtlInitializeBitMap,
RtlInitializeGenericTable, RtlMakeSelfRelativeSD,
RtlPrefixUnicodeString, RtlSetBits, RtlUnicodeToMultiByteN,
RtlUpcaseUnicodeStringToOemString, RtlUpcaseUnicodeToOemN,
RtlValidSid, RtlxUnicodeStringToOemSize
- corrected most RtlString* functions, added documentation
- more fixes and partial implementations
2000-01-23 22:35:33 +00:00
|
|
|
return STATUS_SUCCESS;
|
|
|
|
}
|
2003-03-31 01:37:04 +00:00
|
|
|
|
|
|
|
|
2003-05-20 04:00:42 +00:00
|
|
|
/*
|
|
|
|
* Timers
|
|
|
|
*/
|
|
|
|
|
|
|
|
/**************************************************************************
|
|
|
|
* NtCreateTimer [NTDLL.@]
|
|
|
|
* ZwCreateTimer [NTDLL.@]
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtCreateTimer(OUT HANDLE *handle,
|
|
|
|
IN ACCESS_MASK access,
|
|
|
|
IN const OBJECT_ATTRIBUTES *oa OPTIONAL,
|
|
|
|
IN TIMER_TYPE timer_type)
|
|
|
|
{
|
2003-06-04 20:14:24 +00:00
|
|
|
DWORD len = (oa && oa->ObjectName) ? oa->ObjectName->Length : 0;
|
2003-05-20 04:00:42 +00:00
|
|
|
NTSTATUS status;
|
|
|
|
|
|
|
|
if (timer_type != NotificationTimer && timer_type != SynchronizationTimer)
|
|
|
|
return STATUS_INVALID_PARAMETER;
|
|
|
|
|
|
|
|
SERVER_START_REQ( create_timer )
|
|
|
|
{
|
|
|
|
req->manual = (timer_type == NotificationTimer) ? TRUE : FALSE;
|
|
|
|
req->inherit = oa && (oa->Attributes & OBJ_INHERIT);
|
2003-06-04 20:14:24 +00:00
|
|
|
if (len) wine_server_add_data( req, oa->ObjectName->Buffer, len );
|
2003-05-20 04:00:42 +00:00
|
|
|
status = wine_server_call( req );
|
|
|
|
*handle = reply->handle;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return status;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**************************************************************************
|
|
|
|
* NtOpenTimer [NTDLL.@]
|
|
|
|
* ZwOpenTimer [NTDLL.@]
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtOpenTimer(OUT PHANDLE handle,
|
|
|
|
IN ACCESS_MASK access,
|
|
|
|
IN const OBJECT_ATTRIBUTES* oa )
|
|
|
|
{
|
2003-06-04 20:14:24 +00:00
|
|
|
DWORD len = (oa && oa->ObjectName) ? oa->ObjectName->Length : 0;
|
2003-05-20 04:00:42 +00:00
|
|
|
NTSTATUS status;
|
|
|
|
|
|
|
|
if (oa && oa->Length >= MAX_PATH * sizeof(WCHAR))
|
|
|
|
return STATUS_NAME_TOO_LONG;
|
|
|
|
|
|
|
|
SERVER_START_REQ( open_timer )
|
|
|
|
{
|
|
|
|
req->access = access;
|
|
|
|
req->inherit = oa && (oa->Attributes & OBJ_INHERIT);
|
2003-06-04 20:14:24 +00:00
|
|
|
if (len) wine_server_add_data( req, oa->ObjectName->Buffer, len );
|
2003-05-20 04:00:42 +00:00
|
|
|
status = wine_server_call( req );
|
|
|
|
*handle = reply->handle;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return status;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**************************************************************************
|
|
|
|
* NtSetTimer [NTDLL.@]
|
|
|
|
* ZwSetTimer [NTDLL.@]
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtSetTimer(IN HANDLE handle,
|
|
|
|
IN const LARGE_INTEGER* when,
|
|
|
|
IN PTIMERAPCROUTINE callback,
|
|
|
|
IN PVOID callback_arg,
|
|
|
|
IN BOOLEAN resume,
|
|
|
|
IN ULONG period OPTIONAL,
|
|
|
|
OUT PBOOLEAN state OPTIONAL)
|
|
|
|
{
|
|
|
|
NTSTATUS status = STATUS_SUCCESS;
|
|
|
|
|
|
|
|
TRACE("(%p,%p,%p,%p,%08x,0x%08lx,%p) stub\n",
|
|
|
|
handle, when, callback, callback_arg, resume, period, state);
|
|
|
|
|
|
|
|
SERVER_START_REQ( set_timer )
|
|
|
|
{
|
2004-01-23 01:51:33 +00:00
|
|
|
if (!when->u.LowPart && !when->u.HighPart)
|
2003-05-20 04:00:42 +00:00
|
|
|
{
|
|
|
|
/* special case to start timeout on now+period without too many calculations */
|
|
|
|
req->expire.sec = 0;
|
|
|
|
req->expire.usec = 0;
|
|
|
|
}
|
|
|
|
else NTDLL_get_server_timeout( &req->expire, when );
|
|
|
|
|
|
|
|
req->handle = handle;
|
|
|
|
req->period = period;
|
|
|
|
req->callback = callback;
|
|
|
|
req->arg = callback_arg;
|
|
|
|
status = wine_server_call( req );
|
|
|
|
if (state) *state = reply->signaled;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
|
|
|
|
/* set error but can still succeed */
|
|
|
|
if (resume && status == STATUS_SUCCESS) return STATUS_TIMER_RESUME_IGNORED;
|
|
|
|
return status;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**************************************************************************
|
|
|
|
* NtCancelTimer [NTDLL.@]
|
|
|
|
* ZwCancelTimer [NTDLL.@]
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtCancelTimer(IN HANDLE handle, OUT BOOLEAN* state)
|
|
|
|
{
|
|
|
|
NTSTATUS status;
|
|
|
|
|
|
|
|
SERVER_START_REQ( cancel_timer )
|
|
|
|
{
|
|
|
|
req->handle = handle;
|
|
|
|
status = wine_server_call( req );
|
|
|
|
if (state) *state = reply->signaled;
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
return status;
|
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtQueryTimerResolution [NTDLL.@]
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtQueryTimerResolution(OUT ULONG* min_resolution,
|
|
|
|
OUT ULONG* max_resolution,
|
|
|
|
OUT ULONG* current_resolution)
|
|
|
|
{
|
|
|
|
FIXME("(%p,%p,%p), stub!\n",
|
|
|
|
min_resolution, max_resolution, current_resolution);
|
|
|
|
|
|
|
|
return STATUS_NOT_IMPLEMENTED;
|
|
|
|
}
|
|
|
|
|
|
|
|
/******************************************************************************
|
|
|
|
* NtSetTimerResolution [NTDLL.@]
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtSetTimerResolution(IN ULONG resolution,
|
|
|
|
IN BOOLEAN set_resolution,
|
|
|
|
OUT ULONG* current_resolution )
|
|
|
|
{
|
|
|
|
FIXME("(%lu,%u,%p), stub!\n",
|
|
|
|
resolution, set_resolution, current_resolution);
|
|
|
|
|
|
|
|
return STATUS_NOT_IMPLEMENTED;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2003-03-31 01:37:04 +00:00
|
|
|
/***********************************************************************
|
|
|
|
* check_async_list
|
|
|
|
*
|
|
|
|
* Process a status event from the server.
|
|
|
|
*/
|
|
|
|
static void WINAPI check_async_list(async_private *asp, DWORD status)
|
|
|
|
{
|
|
|
|
async_private *ovp;
|
|
|
|
DWORD ovp_status;
|
|
|
|
|
|
|
|
for( ovp = NtCurrentTeb()->pending_list; ovp && ovp != asp; ovp = ovp->next );
|
|
|
|
|
|
|
|
if(!ovp)
|
|
|
|
return;
|
|
|
|
|
|
|
|
if( status != STATUS_ALERTED )
|
|
|
|
{
|
|
|
|
ovp_status = status;
|
2003-06-26 02:08:17 +00:00
|
|
|
ovp->iosb->u.Status = status;
|
2003-03-31 01:37:04 +00:00
|
|
|
}
|
2003-06-26 02:08:17 +00:00
|
|
|
else ovp_status = ovp->iosb->u.Status;
|
2003-03-31 01:37:04 +00:00
|
|
|
|
|
|
|
if( ovp_status == STATUS_PENDING ) ovp->func( ovp );
|
|
|
|
|
|
|
|
/* This will destroy all but PENDING requests */
|
|
|
|
register_old_async( ovp );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* wait_reply
|
|
|
|
*
|
|
|
|
* Wait for a reply on the waiting pipe of the current thread.
|
|
|
|
*/
|
|
|
|
static int wait_reply( void *cookie )
|
|
|
|
{
|
|
|
|
int signaled;
|
|
|
|
struct wake_up_reply reply;
|
|
|
|
for (;;)
|
|
|
|
{
|
|
|
|
int ret;
|
|
|
|
ret = read( NtCurrentTeb()->wait_fd[0], &reply, sizeof(reply) );
|
|
|
|
if (ret == sizeof(reply))
|
|
|
|
{
|
|
|
|
if (!reply.cookie) break; /* thread got killed */
|
|
|
|
if (reply.cookie == cookie) return reply.signaled;
|
|
|
|
/* we stole another reply, wait for the real one */
|
|
|
|
signaled = wait_reply( cookie );
|
|
|
|
/* and now put the wrong one back in the pipe */
|
|
|
|
for (;;)
|
|
|
|
{
|
|
|
|
ret = write( NtCurrentTeb()->wait_fd[1], &reply, sizeof(reply) );
|
|
|
|
if (ret == sizeof(reply)) break;
|
|
|
|
if (ret >= 0) server_protocol_error( "partial wakeup write %d\n", ret );
|
|
|
|
if (errno == EINTR) continue;
|
|
|
|
server_protocol_perror("wakeup write");
|
|
|
|
}
|
|
|
|
return signaled;
|
|
|
|
}
|
|
|
|
if (ret >= 0) server_protocol_error( "partial wakeup read %d\n", ret );
|
|
|
|
if (errno == EINTR) continue;
|
|
|
|
server_protocol_perror("wakeup read");
|
|
|
|
}
|
|
|
|
/* the server closed the connection; time to die... */
|
2003-11-06 00:08:05 +00:00
|
|
|
server_abort_thread(0);
|
2003-03-31 01:37:04 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***********************************************************************
|
|
|
|
* call_apcs
|
|
|
|
*
|
|
|
|
* Call outstanding APCs.
|
|
|
|
*/
|
|
|
|
static void call_apcs( BOOL alertable )
|
|
|
|
{
|
2003-04-04 22:26:34 +00:00
|
|
|
FARPROC proc;
|
2003-03-31 01:37:04 +00:00
|
|
|
LARGE_INTEGER time;
|
2003-04-04 22:26:34 +00:00
|
|
|
void *arg1, *arg2, *arg3;
|
2003-03-31 01:37:04 +00:00
|
|
|
|
|
|
|
for (;;)
|
|
|
|
{
|
|
|
|
int type = APC_NONE;
|
|
|
|
SERVER_START_REQ( get_apc )
|
|
|
|
{
|
|
|
|
req->alertable = alertable;
|
2003-04-04 22:26:34 +00:00
|
|
|
if (!wine_server_call( req )) type = reply->type;
|
|
|
|
proc = reply->func;
|
|
|
|
arg1 = reply->arg1;
|
|
|
|
arg2 = reply->arg2;
|
|
|
|
arg3 = reply->arg3;
|
2003-03-31 01:37:04 +00:00
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
|
|
|
|
switch(type)
|
|
|
|
{
|
|
|
|
case APC_NONE:
|
|
|
|
return; /* no more APCs */
|
|
|
|
case APC_ASYNC:
|
2003-04-04 22:26:34 +00:00
|
|
|
proc( arg1, arg2 );
|
2003-03-31 01:37:04 +00:00
|
|
|
break;
|
|
|
|
case APC_USER:
|
2003-04-04 22:26:34 +00:00
|
|
|
proc( arg1, arg2, arg3 );
|
2003-03-31 01:37:04 +00:00
|
|
|
break;
|
|
|
|
case APC_TIMER:
|
|
|
|
/* convert sec/usec to NT time */
|
2003-04-04 22:26:34 +00:00
|
|
|
RtlSecondsSince1970ToTime( (time_t)arg1, &time );
|
|
|
|
time.QuadPart += (DWORD)arg2 * 10;
|
2004-01-23 01:51:33 +00:00
|
|
|
proc( arg3, time.u.LowPart, time.u.HighPart );
|
2003-03-31 01:37:04 +00:00
|
|
|
break;
|
|
|
|
case APC_ASYNC_IO:
|
2003-04-04 22:26:34 +00:00
|
|
|
check_async_list( arg1, (DWORD) arg2 );
|
2003-03-31 01:37:04 +00:00
|
|
|
break;
|
|
|
|
default:
|
|
|
|
server_protocol_error( "get_apc_request: bad type %d\n", type );
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2003-06-30 21:00:15 +00:00
|
|
|
/***********************************************************************
|
|
|
|
* NTDLL_wait_for_multiple_objects
|
|
|
|
*
|
|
|
|
* Implementation of NtWaitForMultipleObjects
|
2003-03-31 01:37:04 +00:00
|
|
|
*/
|
2003-06-30 21:00:15 +00:00
|
|
|
NTSTATUS NTDLL_wait_for_multiple_objects( UINT count, const HANDLE *handles, UINT flags,
|
|
|
|
const LARGE_INTEGER *timeout )
|
2003-03-31 01:37:04 +00:00
|
|
|
{
|
2003-06-30 21:00:15 +00:00
|
|
|
NTSTATUS ret;
|
|
|
|
int cookie;
|
2003-03-31 01:37:04 +00:00
|
|
|
|
2003-06-30 21:00:15 +00:00
|
|
|
if (timeout) flags |= SELECT_TIMEOUT;
|
2003-03-31 01:37:04 +00:00
|
|
|
for (;;)
|
|
|
|
{
|
|
|
|
SERVER_START_REQ( select )
|
|
|
|
{
|
2003-06-30 21:00:15 +00:00
|
|
|
req->flags = flags;
|
2003-03-31 01:37:04 +00:00
|
|
|
req->cookie = &cookie;
|
2003-04-02 22:48:59 +00:00
|
|
|
NTDLL_get_server_timeout( &req->timeout, timeout );
|
2003-03-31 01:37:04 +00:00
|
|
|
wine_server_add_data( req, handles, count * sizeof(HANDLE) );
|
|
|
|
ret = wine_server_call( req );
|
|
|
|
}
|
|
|
|
SERVER_END_REQ;
|
|
|
|
if (ret == STATUS_PENDING) ret = wait_reply( &cookie );
|
|
|
|
if (ret != STATUS_USER_APC) break;
|
2003-06-30 21:00:15 +00:00
|
|
|
call_apcs( (flags & SELECT_ALERTABLE) != 0 );
|
|
|
|
if (flags & SELECT_ALERTABLE) break;
|
2003-03-31 01:37:04 +00:00
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2003-06-30 21:00:15 +00:00
|
|
|
/* wait operations */
|
|
|
|
|
|
|
|
/******************************************************************
|
|
|
|
* NtWaitForMultipleObjects (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtWaitForMultipleObjects( DWORD count, const HANDLE *handles,
|
|
|
|
BOOLEAN wait_all, BOOLEAN alertable,
|
|
|
|
const LARGE_INTEGER *timeout )
|
|
|
|
{
|
|
|
|
UINT flags = SELECT_INTERRUPTIBLE;
|
|
|
|
|
|
|
|
if (!count || count > MAXIMUM_WAIT_OBJECTS) return STATUS_INVALID_PARAMETER_1;
|
|
|
|
|
|
|
|
if (wait_all) flags |= SELECT_ALL;
|
|
|
|
if (alertable) flags |= SELECT_ALERTABLE;
|
|
|
|
return NTDLL_wait_for_multiple_objects( count, handles, flags, timeout );
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2003-03-31 01:37:04 +00:00
|
|
|
/******************************************************************
|
|
|
|
* NtWaitForSingleObject (NTDLL.@)
|
|
|
|
*/
|
2003-06-30 21:00:15 +00:00
|
|
|
NTSTATUS WINAPI NtWaitForSingleObject(HANDLE handle, BOOLEAN alertable, const LARGE_INTEGER *timeout )
|
2003-03-31 01:37:04 +00:00
|
|
|
{
|
|
|
|
return NtWaitForMultipleObjects( 1, &handle, FALSE, alertable, timeout );
|
|
|
|
}
|
2003-06-30 21:00:15 +00:00
|
|
|
|
|
|
|
|
2004-10-11 20:11:01 +00:00
|
|
|
/******************************************************************
|
|
|
|
* NtYieldExecution (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtYieldExecution(void)
|
|
|
|
{
|
|
|
|
#ifdef HAVE_SCHED_YIELD
|
|
|
|
sched_yield();
|
|
|
|
return STATUS_SUCCESS;
|
|
|
|
#else
|
|
|
|
return STATUS_NO_YIELD_PERFORMED;
|
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2003-06-30 21:00:15 +00:00
|
|
|
/******************************************************************
|
|
|
|
* NtDelayExecution (NTDLL.@)
|
|
|
|
*/
|
|
|
|
NTSTATUS WINAPI NtDelayExecution( BOOLEAN alertable, const LARGE_INTEGER *timeout )
|
|
|
|
{
|
|
|
|
/* if alertable or async I/O in progress, we need to query the server */
|
|
|
|
if (alertable || NtCurrentTeb()->pending_list)
|
|
|
|
{
|
|
|
|
UINT flags = SELECT_INTERRUPTIBLE;
|
|
|
|
if (alertable) flags |= SELECT_ALERTABLE;
|
|
|
|
return NTDLL_wait_for_multiple_objects( 0, NULL, flags, timeout );
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!timeout) /* sleep forever */
|
|
|
|
{
|
|
|
|
for (;;) select( 0, NULL, NULL, NULL, NULL );
|
|
|
|
}
|
2004-10-11 20:11:01 +00:00
|
|
|
else if (!timeout->QuadPart)
|
|
|
|
{
|
|
|
|
NtYieldExecution();
|
|
|
|
}
|
2003-06-30 21:00:15 +00:00
|
|
|
else
|
|
|
|
{
|
|
|
|
abs_time_t when;
|
|
|
|
|
|
|
|
NTDLL_get_server_timeout( &when, timeout );
|
|
|
|
for (;;)
|
|
|
|
{
|
|
|
|
struct timeval tv;
|
|
|
|
gettimeofday( &tv, 0 );
|
|
|
|
tv.tv_sec = when.sec - tv.tv_sec;
|
|
|
|
if ((tv.tv_usec = when.usec - tv.tv_usec) < 0)
|
|
|
|
{
|
|
|
|
tv.tv_usec += 1000000;
|
|
|
|
tv.tv_sec--;
|
|
|
|
}
|
|
|
|
if (tv.tv_sec < 0) tv.tv_sec = tv.tv_usec = 0;
|
|
|
|
if (select( 0, NULL, NULL, NULL, &tv ) != -1) break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return STATUS_SUCCESS;
|
|
|
|
}
|