1 files changed, 121 insertions, 0 deletions
diff --git a/examples/Reactor/WFMO_Reactor/test_abandoned.cpp b/examples/Reactor/WFMO_Reactor/test_abandoned.cpp
new file mode 100644
index 00000000000..b3c6c14b86c
--- /dev/null
+++ b/examples/Reactor/WFMO_Reactor/test_abandoned.cpp
@@ -0,0 +1,121 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    examples
+//
+// = FILENAME
+//    test_abandoned.cpp
+//
+// = DESCRIPTION
+//
+//    Tests the WFMO_Reactor's ability to handle abandoned mutexes.
+//
+// = AUTHOR
+//
+//    Irfan Pyarali <irfan@cs.wustl.edu>
+//
+// ============================================================================
+
+#include "ace/Reactor.h"
+#include "ace/Thread_Manager.h"
+#include "ace/Process_Mutex.h"
+
+ACE_RCSID(WFMO_Reactor, test_abandoned, "$Id$")
+
+class Event_Handler : public ACE_Event_Handler
+{
+public:
+  int handle_signal (int signum,
+                     siginfo_t * = 0,
+                     ucontext_t * = 0);
+
+  int handle_timeout (const ACE_Time_Value &tv,
+                      const void *arg = 0);
+
+  ACE_Auto_Event handle_;
+  ACE_Process_Mutex *mutex_;
+  int iterations_;
+};
+
+static int abandon = 1;
+
+static void *
+worker (void *data)
+{
+  Event_Handler *handler = (Event_Handler *) data;
+
+  handler->handle_.signal ();
+  handler->mutex_->acquire ();
+
+  if (!abandon)
+    handler->mutex_->release ();
+
+  return 0;
+}
+
+int
+Event_Handler::handle_signal (int signum,
+                              siginfo_t *s,
+                              ucontext_t *)
+{
+  HANDLE handle = s->si_handle_;
+  if (handle == this->handle_.handle ())
+    ACE_Reactor::instance ()->register_handler (this,
+                                                this->mutex_->lock ().proc_mutex_);
+  else
+    {
+      ACE_Reactor::instance ()->remove_handler (this->mutex_->lock ().proc_mutex_,
+                                                ACE_Event_Handler::DONT_CALL);
+      delete this->mutex_;
+    }
+
+  return 0;
+}
+
+int
+Event_Handler::handle_timeout (const ACE_Time_Value &tv,
+                               const void *arg)
+{
+  --this->iterations_;
+  ACE_DEBUG ((LM_DEBUG,
+              "(%t) timeout occured @ %T, iterations left %d\n",
+              this->iterations_));
+
+  if (this->iterations_ == 0)
+    ACE_Reactor::end_event_loop ();
+  else
+    {
+      ACE_NEW_RETURN (this->mutex_,
+                      ACE_Process_Mutex,
+                      -1);
+      int result = ACE_Thread_Manager::instance ()->spawn (&worker, this);
+      ACE_ASSERT (result != -1);
+    }
+
+  return 0;
+}
+
+int
+main (int argc, char *argv[])
+{
+  Event_Handler event_handler;
+
+  event_handler.iterations_ = 5;
+  int result = ACE_Reactor::instance ()->register_handler
+    (&event_handler,
+     event_handler.handle_.handle ());
+  ACE_ASSERT (result == 0);
+
+  ACE_Time_Value timeout (2);
+  result = ACE_Reactor::instance ()->schedule_timer (&event_handler,
+                                                     0,
+                                                     timeout,
+                                                     timeout);
+  ACE_ASSERT (result != -1);
+
+  ACE_Reactor::run_event_loop ();
+
+  return 0;
+}