scheduler/synchro.c

   1 /*
   2  * Win32 process and thread synchronisation
   3  *
   4  * Copyright 1997 Alexandre Julliard
   5  */
   6
   7 #include <assert.h>
   8 #include <signal.h>
   9 #include <sys/time.h>
  10 #include <unistd.h>
  11 #include "k32obj.h"
  12 #include "heap.h"
  13 #include "process.h"
  14 #include "thread.h"
  15 #include "winerror.h"
  16 #include "syslevel.h"
  17 #include "server.h"
  18 #include "debug.h"
  19
  20 /***********************************************************************
  21  *           SYNC_BuildWaitStruct
  22  */
  23 static BOOL32 SYNC_BuildWaitStruct( DWORD count, const HANDLE32 *handles,
  24                                     BOOL32 wait_all, BOOL32 wait_msg,
  25                                     WAIT_STRUCT *wait )
  26 {
  27     DWORD i;
  28     K32OBJ **ptr;
  29
  30     SYSTEM_LOCK();
  31     wait->count    = count;
  32     wait->signaled = WAIT_FAILED;
  33     wait->wait_all = wait_all;
  34     wait->wait_msg = wait_msg;
  35     for (i = 0, ptr = wait->objs; i < count; i++, ptr++)
  36     {
  37         if (!(*ptr = HANDLE_GetObjPtr( PROCESS_Current(), handles[i],
  38                                        K32OBJ_UNKNOWN, SYNCHRONIZE,
  39                                        &wait->server[i] )))
  40         {
  41             ERR(win32, "Bad handle %08x\n", handles[i]);
  42             break;
  43         }
  44         if (wait->server[i] == -1)
  45             WARN(win32,"No server handle for %08x (type %d)\n",
  46                  handles[i], (*ptr)->type );
  47     }
  48
  49     if (i != count)
  50     {
  51         /* There was an error */
  52         wait->wait_msg = FALSE;
  53         while (i--) K32OBJ_DecCount( wait->objs[i] );
  54     }
  55     SYSTEM_UNLOCK();
  56     return (i == count);
  57 }
  58
  59
  60 /***********************************************************************
  61  *           SYNC_FreeWaitStruct
  62  */
  63 static void SYNC_FreeWaitStruct( WAIT_STRUCT *wait )
  64 {
  65     DWORD i;
  66     K32OBJ **ptr;
  67     SYSTEM_LOCK();
  68     wait->wait_msg = FALSE;
  69     for (i = 0, ptr = wait->objs; i < wait->count; i++, ptr++)
  70         K32OBJ_DecCount( *ptr );
  71     SYSTEM_UNLOCK();
  72 }
  73
  74
  75 /***********************************************************************
  76  *           SYNC_DoWait
  77  */
  78 DWORD SYNC_DoWait( DWORD count, const HANDLE32 *handles,
  79                    BOOL32 wait_all, DWORD timeout,
  80                    BOOL32 alertable, BOOL32 wait_msg )
  81 {
  82     WAIT_STRUCT *wait = &THREAD_Current()->wait_struct;
  83
  84     if (count > MAXIMUM_WAIT_OBJECTS)
  85     {
  86         SetLastError( ERROR_INVALID_PARAMETER );
  87         return WAIT_FAILED;
  88     }
  89
  90     if (alertable)
  91         FIXME(win32, "alertable not implemented\n" );
  92
  93     if (!SYNC_BuildWaitStruct( count, handles, wait_all, wait_msg, wait ))
  94         wait->signaled = WAIT_FAILED;
  95     else
  96     {
  97         int flags = 0;
  98         if (wait_all) flags |= SELECT_ALL;
  99         if (alertable) flags |= SELECT_ALERTABLE;
 100         if (wait_msg) flags |= SELECT_MSG;
 101         if (timeout != INFINITE32) flags |= SELECT_TIMEOUT;
 102         wait->signaled = CLIENT_Select( count, wait->server, flags, timeout );
 103         SYNC_FreeWaitStruct( wait );
 104     }
 105     return wait->signaled;
 106 }
 107
 108 /***********************************************************************
 109  *              Sleep  (KERNEL32.679)
 110  */
 111 VOID WINAPI Sleep( DWORD timeout )
 112 {
 113     SYNC_DoWait( 0, NULL, FALSE, timeout, FALSE, FALSE );
 114 }
 115
 116 /******************************************************************************
 117  *              SleepEx   (KERNEL32.680)
 118  */
 119 DWORD WINAPI SleepEx( DWORD timeout, BOOL32 alertable )
 120 {
 121     DWORD ret = SYNC_DoWait( 0, NULL, FALSE, timeout, alertable, FALSE );
 122     if (ret != WAIT_IO_COMPLETION) ret = 0;
 123     return ret;
 124 }
 125
 126
 127 /***********************************************************************
 128  *           WaitForSingleObject   (KERNEL32.723)
 129  */
 130 DWORD WINAPI WaitForSingleObject( HANDLE32 handle, DWORD timeout )
 131 {
 132     return SYNC_DoWait( 1, &handle, FALSE, timeout, FALSE, FALSE );
 133 }
 134
 135
 136 /***********************************************************************
 137  *           WaitForSingleObjectEx   (KERNEL32.724)
 138  */
 139 DWORD WINAPI WaitForSingleObjectEx( HANDLE32 handle, DWORD timeout,
 140                                     BOOL32 alertable )
 141 {
 142     return SYNC_DoWait( 1, &handle, FALSE, timeout, alertable, FALSE );
 143 }
 144
 145
 146 /***********************************************************************
 147  *           WaitForMultipleObjects   (KERNEL32.721)
 148  */
 149 DWORD WINAPI WaitForMultipleObjects( DWORD count, const HANDLE32 *handles,
 150                                      BOOL32 wait_all, DWORD timeout )
 151 {
 152     return SYNC_DoWait( count, handles, wait_all, timeout, FALSE, FALSE );
 153 }
 154
 155
 156 /***********************************************************************
 157  *           WaitForMultipleObjectsEx   (KERNEL32.722)
 158  */
 159 DWORD WINAPI WaitForMultipleObjectsEx( DWORD count, const HANDLE32 *handles,
 160                                        BOOL32 wait_all, DWORD timeout,
 161                                        BOOL32 alertable )
 162 {
 163     return SYNC_DoWait( count, handles, wait_all, timeout, alertable, FALSE );
 164 }
 165
 166
 167 /***********************************************************************
 168  *           WIN16_WaitForSingleObject   (KERNEL.460)
 169  */
 170 DWORD WINAPI WIN16_WaitForSingleObject( HANDLE32 handle, DWORD timeout )
 171 {
 172     DWORD retval;
 173
 174     SYSLEVEL_ReleaseWin16Lock();
 175     retval = WaitForSingleObject( handle, timeout );
 176     SYSLEVEL_RestoreWin16Lock();
 177
 178     return retval;
 179 }
 180
 181 /***********************************************************************
 182  *           WIN16_WaitForMultipleObjects   (KERNEL.461)
 183  */
 184 DWORD WINAPI WIN16_WaitForMultipleObjects( DWORD count, const HANDLE32 *handles,
 185                                            BOOL32 wait_all, DWORD timeout )
 186 {
 187     DWORD retval;
 188
 189     SYSLEVEL_ReleaseWin16Lock();
 190     retval = WaitForMultipleObjects( count, handles, wait_all, timeout );
 191     SYSLEVEL_RestoreWin16Lock();
 192
 193     return retval;
 194 }
 195