dlls/kernelbase/sync.c

   1 /*
   2  * Kernel synchronization objects
   3  *
   4  * Copyright 1998 Alexandre Julliard
   5  *
   6  * This library is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2.1 of the License, or (at your option) any later version.
  10  *
  11  * This library is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public
  17  * License along with this library; if not, write to the Free Software
  18  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  19  */
  20
  21 #include <stdarg.h>
  22 #include <string.h>
  23 #include <stdio.h>
  24
  25 #include "ntstatus.h"
  26 #define WIN32_NO_STATUS
  27 #define NONAMELESSUNION
  28 #include "windef.h"
  29 #include "winbase.h"
  30 #include "winerror.h"
  31 #include "winnls.h"
  32 #include "winternl.h"
  33 #include "winioctl.h"
  34 #include "ddk/wdm.h"
  35
  36 #include "kernelbase.h"
  37 #include "wine/asm.h"
  38 #include "wine/debug.h"
  39
  40 WINE_DEFAULT_DEBUG_CHANNEL(sync);
  41
  42 /* check if current version is NT or Win95 */
  43 static inline BOOL is_version_nt(void)
  44 {
  45     return !(GetVersion() & 0x80000000);
  46 }
  47
  48
  49 /***********************************************************************
  50  *              BaseGetNamedObjectDirectory  (kernelbase.@)
  51  */
  52 NTSTATUS WINAPI BaseGetNamedObjectDirectory( HANDLE *dir )
  53 {
  54     static HANDLE handle;
  55     static const WCHAR basenameW[] = {'\\','S','e','s','s','i','o','n','s','\\','%','u',
  56                                       '\\','B','a','s','e','N','a','m','e','d','O','b','j','e','c','t','s',0};
  57     WCHAR buffer[64];
  58     UNICODE_STRING str;
  59     OBJECT_ATTRIBUTES attr;
  60     NTSTATUS status = STATUS_SUCCESS;
  61
  62     if (!handle)
  63     {
  64         HANDLE dir;
  65
  66         swprintf( buffer, ARRAY_SIZE(buffer), basenameW, NtCurrentTeb()->Peb->SessionId );
  67         RtlInitUnicodeString( &str, buffer );
  68         InitializeObjectAttributes(&attr, &str, 0, 0, NULL);
  69         status = NtOpenDirectoryObject( &dir, DIRECTORY_CREATE_OBJECT|DIRECTORY_TRAVERSE, &attr );
  70         if (!status && InterlockedCompareExchangePointer( &handle, dir, 0 ) != 0)
  71         {
  72             /* someone beat us here... */
  73             CloseHandle( dir );
  74         }
  75     }
  76     *dir = handle;
  77     return status;
  78 }
  79
  80 static void get_create_object_attributes( OBJECT_ATTRIBUTES *attr, UNICODE_STRING *nameW,
  81                                           SECURITY_ATTRIBUTES *sa, const WCHAR *name )
  82 {
  83     attr->Length                   = sizeof(*attr);
  84     attr->RootDirectory            = 0;
  85     attr->ObjectName               = NULL;
  86     attr->Attributes               = OBJ_OPENIF | ((sa && sa->bInheritHandle) ? OBJ_INHERIT : 0);
  87     attr->SecurityDescriptor       = sa ? sa->lpSecurityDescriptor : NULL;
  88     attr->SecurityQualityOfService = NULL;
  89     if (name)
  90     {
  91         RtlInitUnicodeString( nameW, name );
  92         attr->ObjectName = nameW;
  93         BaseGetNamedObjectDirectory( &attr->RootDirectory );
  94     }
  95 }
  96
  97 static BOOL get_open_object_attributes( OBJECT_ATTRIBUTES *attr, UNICODE_STRING *nameW,
  98                                         BOOL inherit, const WCHAR *name )
  99 {
 100     HANDLE dir;
 101
 102     if (!name)
 103     {
 104         SetLastError( ERROR_INVALID_PARAMETER );
 105         return FALSE;
 106     }
 107     RtlInitUnicodeString( nameW, name );
 108     BaseGetNamedObjectDirectory( &dir );
 109     InitializeObjectAttributes( attr, nameW, inherit ? OBJ_INHERIT : 0, dir, NULL );
 110     return TRUE;
 111 }
 112
 113
 114 /***********************************************************************
 115  * Events
 116  ***********************************************************************/
 117
 118
 119 /***********************************************************************
 120  *           CreateEventA    (kernelbase.@)
 121  */
 122 HANDLE WINAPI DECLSPEC_HOTPATCH CreateEventA( SECURITY_ATTRIBUTES *sa, BOOL manual_reset,
 123                                               BOOL initial_state, LPCSTR name )
 124 {
 125     DWORD flags = 0;
 126
 127     if (manual_reset) flags |= CREATE_EVENT_MANUAL_RESET;
 128     if (initial_state) flags |= CREATE_EVENT_INITIAL_SET;
 129     return CreateEventExA( sa, name, flags, EVENT_ALL_ACCESS );
 130 }
 131
 132
 133 /***********************************************************************
 134  *           CreateEventW    (kernelbase.@)
 135  */
 136 HANDLE WINAPI DECLSPEC_HOTPATCH CreateEventW( SECURITY_ATTRIBUTES *sa, BOOL manual_reset,
 137                                               BOOL initial_state, LPCWSTR name )
 138 {
 139     DWORD flags = 0;
 140
 141     if (manual_reset) flags |= CREATE_EVENT_MANUAL_RESET;
 142     if (initial_state) flags |= CREATE_EVENT_INITIAL_SET;
 143     return CreateEventExW( sa, name, flags, EVENT_ALL_ACCESS );
 144 }
 145
 146
 147 /***********************************************************************
 148  *           CreateEventExA    (kernelbase.@)
 149  */
 150 HANDLE WINAPI DECLSPEC_HOTPATCH CreateEventExA( SECURITY_ATTRIBUTES *sa, LPCSTR name,
 151                                                 DWORD flags, DWORD access )
 152 {
 153     WCHAR buffer[MAX_PATH];
 154
 155     if (!name) return CreateEventExW( sa, NULL, flags, access );
 156
 157     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 158     {
 159         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 160         return 0;
 161     }
 162     return CreateEventExW( sa, buffer, flags, access );
 163 }
 164
 165
 166 /***********************************************************************
 167  *           CreateEventExW    (kernelbase.@)
 168  */
 169 HANDLE WINAPI DECLSPEC_HOTPATCH CreateEventExW( SECURITY_ATTRIBUTES *sa, LPCWSTR name,
 170                                                 DWORD flags, DWORD access )
 171 {
 172     HANDLE ret = 0;
 173     UNICODE_STRING nameW;
 174     OBJECT_ATTRIBUTES attr;
 175     NTSTATUS status;
 176
 177     /* one buggy program needs this
 178      * ("Van Dale Groot woordenboek der Nederlandse taal")
 179      */
 180     if (sa && IsBadReadPtr(sa,sizeof(SECURITY_ATTRIBUTES)))
 181     {
 182         ERR("Bad security attributes pointer %p\n",sa);
 183         SetLastError( ERROR_INVALID_PARAMETER);
 184         return 0;
 185     }
 186
 187     get_create_object_attributes( &attr, &nameW, sa, name );
 188
 189     status = NtCreateEvent( &ret, access, &attr,
 190                             (flags & CREATE_EVENT_MANUAL_RESET) ? NotificationEvent : SynchronizationEvent,
 191                             (flags & CREATE_EVENT_INITIAL_SET) != 0 );
 192     if (status == STATUS_OBJECT_NAME_EXISTS)
 193         SetLastError( ERROR_ALREADY_EXISTS );
 194     else
 195         SetLastError( RtlNtStatusToDosError(status) );
 196     return ret;
 197 }
 198
 199
 200 /***********************************************************************
 201  *           OpenEventA    (kernelbase.@)
 202  */
 203 HANDLE WINAPI DECLSPEC_HOTPATCH OpenEventA( DWORD access, BOOL inherit, LPCSTR name )
 204 {
 205     WCHAR buffer[MAX_PATH];
 206
 207     if (!name) return OpenEventW( access, inherit, NULL );
 208
 209     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 210     {
 211         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 212         return 0;
 213     }
 214     return OpenEventW( access, inherit, buffer );
 215 }
 216
 217
 218 /***********************************************************************
 219  *           OpenEventW    (kernelbase.@)
 220  */
 221 HANDLE WINAPI DECLSPEC_HOTPATCH OpenEventW( DWORD access, BOOL inherit, LPCWSTR name )
 222 {
 223     HANDLE ret;
 224     UNICODE_STRING nameW;
 225     OBJECT_ATTRIBUTES attr;
 226     NTSTATUS status;
 227
 228     if (!is_version_nt()) access = EVENT_ALL_ACCESS;
 229
 230     if (!get_open_object_attributes( &attr, &nameW, inherit, name )) return 0;
 231
 232     status = NtOpenEvent( &ret, access, &attr );
 233     if (status != STATUS_SUCCESS)
 234     {
 235         SetLastError( RtlNtStatusToDosError(status) );
 236         return 0;
 237     }
 238     return ret;
 239 }
 240
 241 /***********************************************************************
 242  *           PulseEvent    (kernelbase.@)
 243  */
 244 BOOL WINAPI DECLSPEC_HOTPATCH PulseEvent( HANDLE handle )
 245 {
 246     return set_ntstatus( NtPulseEvent( handle, NULL ));
 247 }
 248
 249
 250 /***********************************************************************
 251  *           SetEvent    (kernelbase.@)
 252  */
 253 BOOL WINAPI DECLSPEC_HOTPATCH SetEvent( HANDLE handle )
 254 {
 255     return set_ntstatus( NtSetEvent( handle, NULL ));
 256 }
 257
 258
 259 /***********************************************************************
 260  *           ResetEvent    (kernelbase.@)
 261  */
 262 BOOL WINAPI DECLSPEC_HOTPATCH ResetEvent( HANDLE handle )
 263 {
 264     return set_ntstatus( NtResetEvent( handle, NULL ));
 265 }
 266
 267
 268 /***********************************************************************
 269  * Mutexes
 270  ***********************************************************************/
 271
 272
 273 /***********************************************************************
 274  *           CreateMutexA   (kernelbase.@)
 275  */
 276 HANDLE WINAPI DECLSPEC_HOTPATCH CreateMutexA( SECURITY_ATTRIBUTES *sa, BOOL owner, LPCSTR name )
 277 {
 278     return CreateMutexExA( sa, name, owner ? CREATE_MUTEX_INITIAL_OWNER : 0, MUTEX_ALL_ACCESS );
 279 }
 280
 281
 282 /***********************************************************************
 283  *           CreateMutexW   (kernelbase.@)
 284  */
 285 HANDLE WINAPI DECLSPEC_HOTPATCH CreateMutexW( SECURITY_ATTRIBUTES *sa, BOOL owner, LPCWSTR name )
 286 {
 287     return CreateMutexExW( sa, name, owner ? CREATE_MUTEX_INITIAL_OWNER : 0, MUTEX_ALL_ACCESS );
 288 }
 289
 290
 291 /***********************************************************************
 292  *           CreateMutexExA   (kernelbase.@)
 293  */
 294 HANDLE WINAPI DECLSPEC_HOTPATCH CreateMutexExA( SECURITY_ATTRIBUTES *sa, LPCSTR name,
 295                                                 DWORD flags, DWORD access )
 296 {
 297     ANSI_STRING nameA;
 298     NTSTATUS status;
 299
 300     if (!name) return CreateMutexExW( sa, NULL, flags, access );
 301
 302     RtlInitAnsiString( &nameA, name );
 303     status = RtlAnsiStringToUnicodeString( &NtCurrentTeb()->StaticUnicodeString, &nameA, FALSE );
 304     if (status != STATUS_SUCCESS)
 305     {
 306         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 307         return 0;
 308     }
 309     return CreateMutexExW( sa, NtCurrentTeb()->StaticUnicodeString.Buffer, flags, access );
 310 }
 311
 312
 313 /***********************************************************************
 314  *           CreateMutexExW   (kernelbase.@)
 315  */
 316 HANDLE WINAPI DECLSPEC_HOTPATCH CreateMutexExW( SECURITY_ATTRIBUTES *sa, LPCWSTR name,
 317                                                 DWORD flags, DWORD access )
 318 {
 319     HANDLE ret = 0;
 320     UNICODE_STRING nameW;
 321     OBJECT_ATTRIBUTES attr;
 322     NTSTATUS status;
 323
 324     get_create_object_attributes( &attr, &nameW, sa, name );
 325
 326     status = NtCreateMutant( &ret, access, &attr, (flags & CREATE_MUTEX_INITIAL_OWNER) != 0 );
 327     if (status == STATUS_OBJECT_NAME_EXISTS)
 328         SetLastError( ERROR_ALREADY_EXISTS );
 329     else
 330         SetLastError( RtlNtStatusToDosError(status) );
 331     return ret;
 332 }
 333
 334
 335 /***********************************************************************
 336  *           OpenMutexW   (kernelbase.@)
 337  */
 338 HANDLE WINAPI DECLSPEC_HOTPATCH OpenMutexW( DWORD access, BOOL inherit, LPCWSTR name )
 339 {
 340     HANDLE ret;
 341     UNICODE_STRING nameW;
 342     OBJECT_ATTRIBUTES attr;
 343     NTSTATUS status;
 344
 345     if (!is_version_nt()) access = MUTEX_ALL_ACCESS;
 346
 347     if (!get_open_object_attributes( &attr, &nameW, inherit, name )) return 0;
 348
 349     status = NtOpenMutant( &ret, access, &attr );
 350     if (status != STATUS_SUCCESS)
 351     {
 352         SetLastError( RtlNtStatusToDosError(status) );
 353         return 0;
 354     }
 355     return ret;
 356 }
 357
 358
 359 /***********************************************************************
 360  *           ReleaseMutex   (kernelbase.@)
 361  */
 362 BOOL WINAPI DECLSPEC_HOTPATCH ReleaseMutex( HANDLE handle )
 363 {
 364     return set_ntstatus( NtReleaseMutant( handle, NULL ));
 365 }
 366
 367
 368 /***********************************************************************
 369  * Semaphores
 370  ***********************************************************************/
 371
 372
 373 /***********************************************************************
 374  *           CreateSemaphoreW   (kernelbase.@)
 375  */
 376 HANDLE WINAPI DECLSPEC_HOTPATCH CreateSemaphoreW( SECURITY_ATTRIBUTES *sa, LONG initial,
 377                                                   LONG max, LPCWSTR name )
 378 {
 379     return CreateSemaphoreExW( sa, initial, max, name, 0, SEMAPHORE_ALL_ACCESS );
 380 }
 381
 382
 383 /***********************************************************************
 384  *           CreateSemaphoreExW   (kernelbase.@)
 385  */
 386 HANDLE WINAPI DECLSPEC_HOTPATCH CreateSemaphoreExW( SECURITY_ATTRIBUTES *sa, LONG initial, LONG max,
 387                                                     LPCWSTR name, DWORD flags, DWORD access )
 388 {
 389     HANDLE ret = 0;
 390     UNICODE_STRING nameW;
 391     OBJECT_ATTRIBUTES attr;
 392     NTSTATUS status;
 393
 394     get_create_object_attributes( &attr, &nameW, sa, name );
 395
 396     status = NtCreateSemaphore( &ret, access, &attr, initial, max );
 397     if (status == STATUS_OBJECT_NAME_EXISTS)
 398         SetLastError( ERROR_ALREADY_EXISTS );
 399     else
 400         SetLastError( RtlNtStatusToDosError(status) );
 401     return ret;
 402 }
 403
 404
 405 /***********************************************************************
 406  *           OpenSemaphoreW   (kernelbase.@)
 407  */
 408 HANDLE WINAPI DECLSPEC_HOTPATCH OpenSemaphoreW( DWORD access, BOOL inherit, LPCWSTR name )
 409 {
 410     HANDLE ret;
 411     UNICODE_STRING nameW;
 412     OBJECT_ATTRIBUTES attr;
 413     NTSTATUS status;
 414
 415     if (!is_version_nt()) access = SEMAPHORE_ALL_ACCESS;
 416
 417     if (!get_open_object_attributes( &attr, &nameW, inherit, name )) return 0;
 418
 419     status = NtOpenSemaphore( &ret, access, &attr );
 420     if (status != STATUS_SUCCESS)
 421     {
 422         SetLastError( RtlNtStatusToDosError(status) );
 423         return 0;
 424     }
 425     return ret;
 426 }
 427
 428
 429 /***********************************************************************
 430  *           ReleaseSemaphore   (kernelbase.@)
 431  */
 432 BOOL WINAPI DECLSPEC_HOTPATCH ReleaseSemaphore( HANDLE handle, LONG count, LONG *previous )
 433 {
 434     return set_ntstatus( NtReleaseSemaphore( handle, count, (PULONG)previous ));
 435 }