scheduler/mutex.c

   1 /*
   2  * Win32 mutexes
   3  *
   4  * Copyright 1998 Alexandre Julliard
   5  */
   6
   7 #include <assert.h>
   8 #include "winerror.h"
   9 #include "k32obj.h"
  10 #include "process.h"
  11 #include "thread.h"
  12 #include "heap.h"
  13 #include "server/request.h"
  14 #include "server.h"
  15
  16 typedef struct _MUTEX
  17 {
  18     K32OBJ         header;
  19 } MUTEX;
  20
  21
  22 /***********************************************************************
  23  *           CreateMutex32A   (KERNEL32.166)
  24  */
  25 HANDLE WINAPI CreateMutexA( SECURITY_ATTRIBUTES *sa, BOOL owner,
  26                                 LPCSTR name )
  27 {
  28     struct create_mutex_request req;
  29     struct create_mutex_reply reply;
  30     int len = name ? strlen(name) + 1 : 0;
  31     HANDLE handle;
  32     MUTEX *mutex;
  33
  34     req.owned   = owner;
  35     req.inherit = (sa && (sa->nLength>=sizeof(*sa)) && sa->bInheritHandle);
  36
  37     CLIENT_SendRequest( REQ_CREATE_MUTEX, -1, 2, &req, sizeof(req), name, len );
  38     CLIENT_WaitSimpleReply( &reply, sizeof(reply), NULL );
  39     if (reply.handle == -1) return 0;
  40
  41     SYSTEM_LOCK();
  42     mutex = (MUTEX *)K32OBJ_Create( K32OBJ_MUTEX, sizeof(*mutex),
  43                                     name, reply.handle, MUTEX_ALL_ACCESS,
  44                                     sa, &handle );
  45     if (mutex) K32OBJ_DecCount( &mutex->header );
  46     if (handle == INVALID_HANDLE_VALUE) handle = 0;
  47     SYSTEM_UNLOCK();
  48     return handle;
  49 }
  50
  51
  52 /***********************************************************************
  53  *           CreateMutex32W   (KERNEL32.167)
  54  */
  55 HANDLE WINAPI CreateMutexW( SECURITY_ATTRIBUTES *sa, BOOL owner,
  56                                 LPCWSTR name )
  57 {
  58     LPSTR nameA = HEAP_strdupWtoA( GetProcessHeap(), 0, name );
  59     HANDLE ret = CreateMutexA( sa, owner, nameA );
  60     if (nameA) HeapFree( GetProcessHeap(), 0, nameA );
  61     return ret;
  62 }
  63
  64
  65 /***********************************************************************
  66  *           OpenMutex32A   (KERNEL32.541)
  67  */
  68 HANDLE WINAPI OpenMutexA( DWORD access, BOOL inherit, LPCSTR name )
  69 {
  70     HANDLE handle = 0;
  71     K32OBJ *obj;
  72     struct open_named_obj_request req;
  73     struct open_named_obj_reply reply;
  74     int len = name ? strlen(name) + 1 : 0;
  75
  76     req.type    = OPEN_MUTEX;
  77     req.access  = access;
  78     req.inherit = inherit;
  79     CLIENT_SendRequest( REQ_OPEN_NAMED_OBJ, -1, 2, &req, sizeof(req), name, len );
  80     CLIENT_WaitSimpleReply( &reply, sizeof(reply), NULL );
  81     if (reply.handle != -1)
  82     {
  83         SYSTEM_LOCK();
  84         if ((obj = K32OBJ_FindNameType( name, K32OBJ_MUTEX )) != NULL)
  85         {
  86             handle = HANDLE_Alloc( PROCESS_Current(), obj, access, inherit, reply.handle );
  87             K32OBJ_DecCount( obj );
  88             if (handle == INVALID_HANDLE_VALUE)
  89                 handle = 0; /* must return 0 on failure, not -1 */
  90         }
  91         else CLIENT_CloseHandle( reply.handle );
  92         SYSTEM_UNLOCK();
  93     }
  94     return handle;
  95 }
  96
  97
  98 /***********************************************************************
  99  *           OpenMutex32W   (KERNEL32.542)
 100  */
 101 HANDLE WINAPI OpenMutexW( DWORD access, BOOL inherit, LPCWSTR name )
 102 {
 103     LPSTR nameA = HEAP_strdupWtoA( GetProcessHeap(), 0, name );
 104     HANDLE ret = OpenMutexA( access, inherit, nameA );
 105     if (nameA) HeapFree( GetProcessHeap(), 0, nameA );
 106     return ret;
 107 }
 108
 109
 110 /***********************************************************************
 111  *           ReleaseMutex   (KERNEL32.582)
 112  */
 113 BOOL WINAPI ReleaseMutex( HANDLE handle )
 114 {
 115     struct release_mutex_request req;
 116
 117     req.handle = HANDLE_GetServerHandle( PROCESS_Current(), handle,
 118                                          K32OBJ_MUTEX, MUTEX_MODIFY_STATE );
 119     if (req.handle == -1) return FALSE;
 120     CLIENT_SendRequest( REQ_RELEASE_MUTEX, -1, 1, &req, sizeof(req) );
 121     return !CLIENT_WaitReply( NULL, NULL, 0 );
 122 }