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 "heap.h"
  12 #include "thread.h"
  13 #include "winerror.h"
  14 #include "syslevel.h"
  15 #include "server.h"
  16
  17 /***********************************************************************
  18  *              call_apcs
  19  *
  20  * Call outstanding APCs.
  21  */
  22 static void call_apcs(void)
  23 {
  24 #define MAX_APCS 16
  25     int i;
  26     void *buffer[MAX_APCS * 2];
  27     struct get_apcs_request *req = get_req_buffer();
  28
  29     if (server_call( REQ_GET_APCS ) || !req->count) return;
  30     assert( req->count <= MAX_APCS );
  31     memcpy( buffer, req->apcs, req->count * 2 * sizeof(req->apcs[0]) );
  32     for (i = 0; i < req->count * 2; i += 2)
  33     {
  34         PAPCFUNC func = (PAPCFUNC)req->apcs[i];
  35         if (func) func( (ULONG_PTR)req->apcs[i+1] );
  36     }
  37 }
  38
  39 /***********************************************************************
  40  *              Sleep  (KERNEL32.679)
  41  */
  42 VOID WINAPI Sleep( DWORD timeout )
  43 {
  44     WaitForMultipleObjectsEx( 0, NULL, FALSE, timeout, FALSE );
  45 }
  46
  47 /******************************************************************************
  48  *              SleepEx   (KERNEL32.680)
  49  */
  50 DWORD WINAPI SleepEx( DWORD timeout, BOOL alertable )
  51 {
  52     DWORD ret = WaitForMultipleObjectsEx( 0, NULL, FALSE, timeout, alertable );
  53     if (ret != WAIT_IO_COMPLETION) ret = 0;
  54     return ret;
  55 }
  56
  57
  58 /***********************************************************************
  59  *           WaitForSingleObject   (KERNEL32.723)
  60  */
  61 DWORD WINAPI WaitForSingleObject( HANDLE handle, DWORD timeout )
  62 {
  63     return WaitForMultipleObjectsEx( 1, &handle, FALSE, timeout, FALSE );
  64 }
  65
  66
  67 /***********************************************************************
  68  *           WaitForSingleObjectEx   (KERNEL32.724)
  69  */
  70 DWORD WINAPI WaitForSingleObjectEx( HANDLE handle, DWORD timeout,
  71                                     BOOL alertable )
  72 {
  73     return WaitForMultipleObjectsEx( 1, &handle, FALSE, timeout, alertable );
  74 }
  75
  76
  77 /***********************************************************************
  78  *           WaitForMultipleObjects   (KERNEL32.721)
  79  */
  80 DWORD WINAPI WaitForMultipleObjects( DWORD count, const HANDLE *handles,
  81                                      BOOL wait_all, DWORD timeout )
  82 {
  83     return WaitForMultipleObjectsEx( count, handles, wait_all, timeout, FALSE );
  84 }
  85
  86
  87 /***********************************************************************
  88  *           WaitForMultipleObjectsEx   (KERNEL32.722)
  89  */
  90 DWORD WINAPI WaitForMultipleObjectsEx( DWORD count, const HANDLE *handles,
  91                                        BOOL wait_all, DWORD timeout,
  92                                        BOOL alertable )
  93 {
  94     struct select_request *req = get_req_buffer();
  95     int i, ret;
  96
  97     if (count > MAXIMUM_WAIT_OBJECTS)
  98     {
  99         SetLastError( ERROR_INVALID_PARAMETER );
 100         return WAIT_FAILED;
 101     }
 102
 103     req->count   = count;
 104     req->flags   = 0;
 105     req->timeout = timeout;
 106     for (i = 0; i < count; i++) req->handles[i] = handles[i];
 107
 108     if (wait_all) req->flags |= SELECT_ALL;
 109     if (alertable) req->flags |= SELECT_ALERTABLE;
 110     if (timeout != INFINITE) req->flags |= SELECT_TIMEOUT;
 111
 112     server_call( REQ_SELECT );
 113     if ((ret = req->signaled) == STATUS_USER_APC) call_apcs();
 114     return ret;
 115 }
 116
 117
 118 /***********************************************************************
 119  *           WIN16_WaitForSingleObject   (KERNEL.460)
 120  */
 121 DWORD WINAPI WIN16_WaitForSingleObject( HANDLE handle, DWORD timeout )
 122 {
 123     DWORD retval;
 124
 125     SYSLEVEL_ReleaseWin16Lock();
 126     retval = WaitForSingleObject( handle, timeout );
 127     SYSLEVEL_RestoreWin16Lock();
 128
 129     return retval;
 130 }
 131
 132 /***********************************************************************
 133  *           WIN16_WaitForMultipleObjects   (KERNEL.461)
 134  */
 135 DWORD WINAPI WIN16_WaitForMultipleObjects( DWORD count, const HANDLE *handles,
 136                                            BOOL wait_all, DWORD timeout )
 137 {
 138     DWORD retval;
 139
 140     SYSLEVEL_ReleaseWin16Lock();
 141     retval = WaitForMultipleObjects( count, handles, wait_all, timeout );
 142     SYSLEVEL_RestoreWin16Lock();
 143
 144     return retval;
 145 }
 146
 147 /***********************************************************************
 148  *           WIN16_WaitForMultipleObjectsEx   (KERNEL.495)
 149  */
 150 DWORD WINAPI WIN16_WaitForMultipleObjectsEx( DWORD count,
 151                                              const HANDLE *handles,
 152                                              BOOL wait_all, DWORD timeout,
 153                                              BOOL alertable )
 154 {
 155     DWORD retval;
 156
 157     SYSLEVEL_ReleaseWin16Lock();
 158     retval = WaitForMultipleObjectsEx( count, handles,
 159                                        wait_all, timeout, alertable );
 160     SYSLEVEL_RestoreWin16Lock();
 161
 162     return retval;
 163 }
 164