1 files changed, 180 insertions, 0 deletions

diff --git a/private/os2/server/srvevent.c b/private/os2/server/srvevent.c
new file mode 100644
index 000000000..538297e61
--- /dev/null
+++ b/private/os2/server/srvevent.c
@@ -0,0 +1,180 @@
+/*++
+
+Copyright (c) 1989  Microsoft Corporation
+
+Module Name:
+
+    srvevent.c
+
+Abstract:
+
+    This module implements the OS/2 V2.0 Shared Event Semaphore API Calls.
+
+Author:
+
+    Steve Wood (stevewo) 07-Feb-1990
+
+Revision History:
+
+--*/
+
+#define INCL_OS2V20_SEMAPHORES
+#define INCL_OS2V20_ERRORS
+#include "os2srv.h"
+
+BOOLEAN
+Os2DosCreateEventSem(
+    IN POS2_THREAD t,
+    IN POS2_API_MSG m
+    )
+{
+    NTSTATUS Status;
+    POS2_DOSCREATEEVENTSEM_MSG a = &m->u.DosCreateEventSem;
+    OS2_SEMAPHORE Semaphore;
+    APIRET rc;
+
+    Semaphore.PointerCount = 0;
+    Semaphore.OpenCount = 1;
+    Semaphore.Type = Os2EventSem;
+    rc = Os2ProcessSemaphoreName( &a->ObjectName,
+                                  &Semaphore,
+                                  NULL
+                                );
+
+    if (rc != NO_ERROR) {
+        ReleaseHandleTableLock( Os2SharedSemaphoreTable );
+        m->ReturnedErrorValue = rc;
+        return( TRUE );
+        }
+
+    rc = ERROR_NOT_ENOUGH_MEMORY;
+    Status = NtCreateEvent( &Semaphore.u.EventHandle,
+                            EVENT_ALL_ACCESS,
+                            NULL,
+                            NotificationEvent,
+                            a->InitialState
+                          );
+    if (NT_SUCCESS( Status )) {
+        if (Or2CreateHandle( Os2SharedSemaphoreTable,
+                                       &a->HandleIndex,
+                                       (PVOID)&Semaphore
+                                     )
+           ) {
+            Status = NtDuplicateObject( NtCurrentProcess(),
+                                        Semaphore.u.EventHandle,
+                                        t->Process->ProcessHandle,
+                                        &a->NtEventHandle,
+                                        EVENT_ALL_ACCESS,
+                                        0,
+                                        0
+                                      );
+
+            if (NT_SUCCESS( Status )) {
+                rc = NO_ERROR;
+                }
+            else {
+                NtClose( (HANDLE)Os2DestroySemaphore( &Semaphore,
+                                                      a->HandleIndex
+                                                    )
+                       );
+                }
+            }
+        else {
+            NtClose( Semaphore.u.EventHandle );
+            ReleaseHandleTableLock( Os2SharedSemaphoreTable );
+            }
+        }
+    else {
+        ReleaseHandleTableLock( Os2SharedSemaphoreTable );
+        }
+
+    m->ReturnedErrorValue = rc;
+    return( TRUE );
+}
+
+
+BOOLEAN
+Os2DosOpenEventSem(
+    IN POS2_THREAD t,
+    IN POS2_API_MSG m
+    )
+{
+    NTSTATUS Status;
+    POS2_DOSOPENEVENTSEM_MSG a = &m->u.DosOpenEventSem;
+    POS2_SEMAPHORE Semaphore;
+    APIRET rc;
+
+    rc = Os2ProcessSemaphoreName( &a->ObjectName,
+                                  NULL,
+                                  &a->HandleIndex
+                                );
+
+    if (rc != NO_ERROR || a->ObjectName.Length != 0) {
+        ReleaseHandleTableLock( Os2SharedSemaphoreTable );
+        m->ReturnedErrorValue = rc;
+        return( TRUE );
+        }
+
+    Semaphore = (POS2_SEMAPHORE)Or2MapHandle( Os2SharedSemaphoreTable,
+                                                       a->HandleIndex,
+                                                       TRUE
+                                                     );
+    if (Semaphore == NULL) {
+        rc = ERROR_INVALID_HANDLE;
+        }
+    else {
+        Status = NtDuplicateObject( NtCurrentProcess(),
+                                    Semaphore->u.EventHandle,
+                                    t->Process->ProcessHandle,
+                                    &a->NtEventHandle,
+                                    EVENT_ALL_ACCESS,
+                                    0,
+                                    0
+                                  );
+        if (NT_SUCCESS( Status )) {
+            Semaphore->OpenCount++;
+            }
+        else {
+            rc = Or2MapNtStatusToOs2Error( Status, ERROR_ALREADY_EXISTS );
+            }
+        }
+
+    ReleaseHandleTableLock( Os2SharedSemaphoreTable );
+
+    m->ReturnedErrorValue = rc;
+    return( TRUE );
+}
+
+
+BOOLEAN
+Os2DosCloseEventSem(
+    IN POS2_THREAD t,
+    IN POS2_API_MSG m
+    )
+{
+    POS2_DOSCLOSEEVENTSEM_MSG a = &m->u.DosCloseEventSem;
+    POS2_SEMAPHORE Semaphore;
+    APIRET rc;
+
+    UNREFERENCED_PARAMETER(t);
+    Semaphore = (POS2_SEMAPHORE)Or2MapHandle( Os2SharedSemaphoreTable,
+                                                       a->HandleIndex,
+                                                       FALSE
+                                                     );
+    if (Semaphore == NULL) {
+        rc = ERROR_INVALID_HANDLE;
+        }
+    else {
+        rc = NO_ERROR;
+
+        if (--Semaphore->OpenCount == 0) {
+            NtClose( (HANDLE)Os2DestroySemaphore( Semaphore, a->HandleIndex ) );
+            }
+        else {
+            ReleaseHandleTableLock( Os2SharedSemaphoreTable );
+            }
+        }
+
+    m->ReturnedErrorValue = rc;
+    return( TRUE );
+}