From 6d8ee132d838c64d027091f13d597887b3033db5 Mon Sep 17 00:00:00 2001
From: Xavier Leroy <xavier.leroy@inria.fr>
Date: Thu, 13 Aug 1998 15:57:20 +0000
Subject: [PATCH] Ajout de wait_signal (a debugger)

git-svn-id: http://caml.inria.fr/svn/ocaml/trunk@2049 f963ae5c-01c2-4b8c-9fe0-0dff7051ff02
---
 otherlibs/systhreads/thread_win32.ml |  1 +
 otherlibs/systhreads/win32.c         | 48 ++++++++++++++++++++++++++++
 2 files changed, 49 insertions(+)

diff --git a/otherlibs/systhreads/thread_win32.ml b/otherlibs/systhreads/thread_win32.ml
index 95309d309..328dbe80f 100644
--- a/otherlibs/systhreads/thread_win32.ml
+++ b/otherlibs/systhreads/thread_win32.ml
@@ -69,3 +69,4 @@ let select rd wr ex delay = invalid_arg "Thread.select: not implemented"
 
 let wait_pid p = Unix.waitpid [] p
 
+external wait_signal : int list -> int = "caml_wait_signal"
diff --git a/otherlibs/systhreads/win32.c b/otherlibs/systhreads/win32.c
index e46cdf383..052e7487f 100644
--- a/otherlibs/systhreads/win32.c
+++ b/otherlibs/systhreads/win32.c
@@ -575,6 +575,54 @@ value caml_condition_broadcast(value cond)           /* ML */
   return Val_unit;
 }
 
+/* Synchronous signal wait */
+
+static HANDLE wait_signal_event[NSIG];
+static int * wait_signal_received[NSIG];
+
+static void caml_wait_signal_handler(int signo)
+{
+  *(wait_signal_received[signo]) = signo;
+  SetEvent(wait_signal_event[signo]);
+}
+
+value caml_wait_signal(value sigs)
+{
+  HANDLE event;
+  int res, s, retcode;
+  value l;
+  void (*)(int) oldsignals[NSIG];
+
+  Begin_root(sigs);
+  event = CreateEvent(NULL, FALSE, 0, NULL);
+  if (event == NULL)
+    caml_wthread_error("Thread.wait_signal (CreateEvent)");
+  res = 0;
+  for (l = sigs; l != Val_int(0); l = Field(l, 1)) {
+    s = convert_signal_number(Int_val(Field(l, 0)));
+    if (s < 0) s = posix_signals[-s-1];
+    oldsignals[s] = signal(s, caml_wait_signal_handler);
+    if (oldsignals[s] == SIG_ERR) {
+      CloseHandle(event);
+      caml_wthread_error("Thread.wait_signal (signal)");
+    }
+    wait_signal_event[s] = event;
+    wait_signal_received[s] = &res;
+  }
+  enter_blocking_section();
+  retcode = WaitForSingleObject(event, INFINITE);
+  leave_blocking_section();
+  for (l = sigs; l != Val_int(0); l = Field(l, 1)) {
+    s = convert_signal_number(Int_val(Field(l, 0)));
+    signal(s, oldsignals[s]);
+  }
+  CloseHandle(event);
+  End_roots();
+  if (retcode == WAIT_FAILED || retcode == WAIT_ABANDONED)
+    caml_wthread_error("Thread.wait_signal (WaitForSingleObject)");
+  return Val_int(res);
+}
+
 /* Error report */
 
 static void caml_wthread_error(char * msg)