scheduler/critsection.c

   1 /*
   2  * Win32 critical sections
   3  *
   4  * Copyright 1998 Alexandre Julliard
   5  */
   6
   7 #include <assert.h>
   8 #include <errno.h>
   9 #include <stdio.h>
  10 #include <sys/types.h>
  11 #include "debug.h"
  12 #include "winerror.h"
  13 #include "winbase.h"
  14 #include "heap.h"
  15 #include "debug.h"
  16 #include "thread.h"
  17
  18 DEFAULT_DEBUG_CHANNEL(win32)
  19
  20
  21 /***********************************************************************
  22  *           InitializeCriticalSection   (KERNEL32.472) (NTDLL.406)
  23  */
  24 void WINAPI InitializeCriticalSection( CRITICAL_SECTION *crit )
  25 {
  26     crit->LockCount      = -1;
  27     crit->RecursionCount = 0;
  28     crit->OwningThread   = 0;
  29     crit->LockSemaphore  = 0;
  30     crit->LockSemaphore  = CreateSemaphoreA( NULL, 0, 1, NULL );
  31     crit->Reserved       = (DWORD)-1;
  32 }
  33
  34
  35 /***********************************************************************
  36  *           DeleteCriticalSection   (KERNEL32.185) (NTDLL.327)
  37  */
  38 void WINAPI DeleteCriticalSection( CRITICAL_SECTION *crit )
  39 {
  40     if (crit->LockSemaphore)
  41     {
  42         if (crit->RecursionCount)  /* Should not happen */
  43             MSG("Deleting owned critical section (%p)\n", crit );
  44         crit->LockCount      = -1;
  45         crit->RecursionCount = 0;
  46         crit->OwningThread   = 0;
  47         CloseHandle( crit->LockSemaphore );
  48         crit->LockSemaphore  = 0;
  49     }
  50 }
  51
  52
  53 /***********************************************************************
  54  *           EnterCriticalSection   (KERNEL32.195) (NTDLL.344)
  55  */
  56 void WINAPI EnterCriticalSection( CRITICAL_SECTION *crit )
  57 {
  58     DWORD res;
  59
  60     if (!crit->LockSemaphore)
  61     {
  62         FIXME(win32,"entering uninitialized section(%p)?\n",crit);
  63         InitializeCriticalSection(crit);
  64     }
  65     if (InterlockedIncrement( &crit->LockCount ))
  66     {
  67         if (crit->OwningThread == GetCurrentThreadId())
  68         {
  69             crit->RecursionCount++;
  70             return;
  71         }
  72         /* Now wait for it */
  73
  74         res = WaitForSingleObject( crit->LockSemaphore, 2000 );
  75         if (res == STATUS_TIMEOUT) res = WaitForSingleObject( crit->LockSemaphore, 2000 );
  76         if (res != STATUS_WAIT_0)
  77         {
  78             ERR(win32, "Critical section %p wait failed err=%lx\n", crit, res );
  79             /* FIXME: should raise an exception */
  80         }
  81     }
  82     crit->OwningThread   = GetCurrentThreadId();
  83     crit->RecursionCount = 1;
  84 }
  85
  86
  87 /***********************************************************************
  88  *           TryEnterCriticalSection   (KERNEL32.898) (NTDLL.969)
  89  */
  90 BOOL WINAPI TryEnterCriticalSection( CRITICAL_SECTION *crit )
  91 {
  92     if (InterlockedIncrement( &crit->LockCount ))
  93     {
  94         if (crit->OwningThread == GetCurrentThreadId())
  95         {
  96             crit->RecursionCount++;
  97             return TRUE;
  98         }
  99         /* FIXME: this doesn't work */
 100         InterlockedDecrement( &crit->LockCount );
 101         return FALSE;
 102     }
 103     crit->OwningThread   = GetCurrentThreadId();
 104     crit->RecursionCount = 1;
 105     return TRUE;
 106 }
 107
 108
 109 /***********************************************************************
 110  *           LeaveCriticalSection   (KERNEL32.494) (NTDLL.426)
 111  */
 112 void WINAPI LeaveCriticalSection( CRITICAL_SECTION *crit )
 113 {
 114     if (crit->OwningThread != GetCurrentThreadId()) return;
 115
 116     if (--crit->RecursionCount)
 117     {
 118         InterlockedDecrement( &crit->LockCount );
 119         return;
 120     }
 121     crit->OwningThread = 0;
 122     if (InterlockedDecrement( &crit->LockCount ) >= 0)
 123     {
 124         /* Someone is waiting */
 125         ReleaseSemaphore( crit->LockSemaphore, 1, NULL );
 126     }
 127 }
 128
 129
 130 /***********************************************************************
 131  *           MakeCriticalSectionGlobal   (KERNEL32.515)
 132  */
 133 void WINAPI MakeCriticalSectionGlobal( CRITICAL_SECTION *crit )
 134 {
 135     crit->LockSemaphore = ConvertToGlobalHandle( crit->LockSemaphore );
 136 }
 137
 138
 139 /***********************************************************************
 140  *           ReinitializeCriticalSection   (KERNEL32.581)
 141  */
 142 void WINAPI ReinitializeCriticalSection( CRITICAL_SECTION *crit )
 143 {
 144     DeleteCriticalSection( crit );
 145     InitializeCriticalSection( crit );
 146 }
 147
 148
 149 /***********************************************************************
 150  *           UninitializeCriticalSection   (KERNEL32.703)
 151  */
 152 void WINAPI UninitializeCriticalSection( CRITICAL_SECTION *crit )
 153 {
 154     FIXME(win32, "(%p) half a stub\n", crit);
 155     DeleteCriticalSection( crit );
 156 }