1 files changed, 66 insertions, 0 deletions
diff --git a/examples/Threads/test_process_mutex.cpp b/examples/Threads/test_process_mutex.cpp
new file mode 100644
index 00000000000..1978e3601f0
--- /dev/null
+++ b/examples/Threads/test_process_mutex.cpp
@@ -0,0 +1,66 @@
+// This program tests ACE_Process_Mutexes.  To run it, open 3 
+// @(#)test_process_mutex.cpp	1.1	10/18/96
+
+// or 4 windows and run this program in each window...
+
+#include "ace/Log_Msg.h"
+#include "ace/Synch.h"
+#include "ace/Signal.h"
+
+#if defined (ACE_HAS_THREADS)
+
+static sig_atomic_t done;
+
+static void 
+handler (int)
+{
+  done = 1;
+}
+
+int
+main (int argc, char *argv[])
+{
+  char *name = argc == 1 ? "hello" : argv[1];
+
+  ACE_Process_Mutex pm (name);
+  ACE_Sig_Action handle ((ACE_SignalHandler) handler, SIGINT);
+
+  for (int i = 0; i < 100 && !done; i++)
+    {
+      ACE_DEBUG ((LM_DEBUG, "(%P|%t) = acquiring\n"));
+      if (pm.acquire () == -1)
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = %p\n", "acquire failed"));
+      else
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = acquired\n"));
+
+      ACE_OS::sleep (3);
+
+      if (pm.release () == -1)
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = %p\n", "release failed"));
+      else
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = released\n"));
+
+      if (pm.tryacquire () == -1)
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = %p\n", "tryacquire failed"));
+      else
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = tryacquire\n"));
+
+      if (pm.release () == -1)
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = %p\n", "release failed"));
+      else
+	ACE_DEBUG ((LM_DEBUG, "(%P|%t) = released\n"));
+    }
+
+  if (argc > 2)
+    pm.remove ();
+  return 0;
+}
+#else
+int 
+main (void)
+{
+  ACE_ERROR_RETURN ((LM_ERROR, 
+		     "ACE doesn't support support threads on this platform (yet)\n"),
+		    -1);
+}
+#endif /* ACE_HAS_THREADS */