1 files changed, 97 insertions, 0 deletions
diff --git a/examples/Reactor/WFMO_Reactor/test_exceptions.cpp b/examples/Reactor/WFMO_Reactor/test_exceptions.cpp
new file mode 100644
index 00000000000..951959f39e1
--- /dev/null
+++ b/examples/Reactor/WFMO_Reactor/test_exceptions.cpp
@@ -0,0 +1,97 @@
+// $Id$
+//
+// ============================================================================
+//
+// = LIBRARY
+//    examples
+//
+// = FILENAME
+//    test_exceptions.cpp
+//
+// = DESCRIPTION
+//
+//    This test application tests the state of WFMO_Reactor when
+//    exceptions occurs when executing user callbacks.
+//
+//    The thread count in WFMO_Reactor is used to ensure that state of
+//    WFMO_Reactor is not fouled up when exceptions occur in user code.
+//    This example also shows how to write event loops that survive
+//    user exceptions
+//
+// = AUTHOR
+//    Irfan Pyarali
+//
+// ============================================================================
+
+#include "ace/WFMO_Reactor.h"
+
+ACE_RCSID(WFMO_Reactor, test_exceptions, "$Id$")
+
+class Event_Handler : public ACE_Event_Handler
+{
+public:
+  Event_Handler (void)
+    : event_ (1)
+  {
+    ACE_DEBUG ((LM_DEBUG,
+                "Event_Handler created\n"));
+  }
+
+  ~Event_Handler (void)
+  {
+    ACE_DEBUG ((LM_DEBUG,
+                "Event_Handler destroyed\n"));
+  }
+
+  int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0)
+  {
+    char *cause_exception = 0;
+    char a = *cause_exception;
+    return 0;
+  }
+
+  ACE_HANDLE get_handle (void) const
+  {
+    return this->event_.handle ();
+  }
+private:
+  ACE_Manual_Event event_;
+};
+
+class ACE_WFMO_Reactor_Test
+{
+public:
+  static void doit (ACE_WFMO_Reactor &wfmo_reactor)
+  {
+    for (int i = 1; i <= 10; i++)
+      {
+        ACE_DEBUG ((LM_DEBUG,
+                    "Active threads in WFMO_Reactor (before handle_events) = %d\n",
+                    wfmo_reactor.active_threads_));
+        ACE_SEH_TRY
+          {
+            wfmo_reactor.handle_events ();
+          }
+        ACE_SEH_EXCEPT (EXCEPTION_EXECUTE_HANDLER)
+          {
+            ACE_DEBUG ((LM_DEBUG,
+                        "Exception occurred\n"));
+          }
+        ACE_DEBUG ((LM_DEBUG,
+                    "Active threads in WFMO_Reactor (after handle_events) = %d\n",
+                    wfmo_reactor.active_threads_));
+      }
+  }
+};
+
+int
+main (int, char *[])
+{
+  Event_Handler handler;
+  ACE_WFMO_Reactor wfmo_reactor;
+  wfmo_reactor.register_handler (&handler);
+
+  ACE_WFMO_Reactor_Test::doit (wfmo_reactor);
+
+  return 0;
+}