1 files changed, 106 insertions, 0 deletions
diff --git a/ACE/examples/APG/Reactor/Timer_Cancel.cpp b/ACE/examples/APG/Reactor/Timer_Cancel.cpp
new file mode 100644
index 00000000000..3e6a0f2ec61
--- /dev/null
+++ b/ACE/examples/APG/Reactor/Timer_Cancel.cpp
@@ -0,0 +1,106 @@
+/**
+ * $Id$
+ *
+ * Changing the interval and canceling
+ */
+
+#include "ace/OS_NS_time.h"
+#include "ace/Log_Msg.h"
+#include "ace/Reactor.h"
+#include "ace/Event_Handler.h"
+
+class MyTimerHandler : public ACE_Event_Handler
+{
+public:
+  int handle_timeout (const ACE_Time_Value &current_time,
+                      const void * = 0)
+  {
+    time_t epoch = ((timespec_t)current_time).tv_sec;
+    ACE_DEBUG ((LM_INFO,
+                ACE_TEXT ("handle_timeout: %s"),
+                ACE_OS::ctime(&epoch)));
+    return 0;
+  }
+
+};
+
+#if !defined (ACE_LACKS_UNIX_SIGNALS)
+
+// Listing 1 code/ch07
+class SignalHandler : public ACE_Event_Handler
+{
+public:
+  SignalHandler (long timerId, int currentInterval)
+    : ACE_Event_Handler(),
+      timerId_(timerId),
+      currentInterval_(currentInterval)
+  {
+  }
+
+  int handle_signal (int sig,
+                     siginfo_t * = 0,
+                     ucontext_t * = 0)
+  {
+    if (sig == SIGINT)
+      {
+        ACE_DEBUG ((LM_INFO,
+                    ACE_TEXT ("Resetting interval of timer ")
+                    ACE_TEXT ("%d to %d\n"),
+                    this->timerId_,
+                    ++this->currentInterval_));
+        ACE_Time_Value newInterval (this->currentInterval_);
+        ACE_Reactor::instance ()->
+          reset_timer_interval (this->timerId_, newInterval);
+      }
+    else if (sig == SIGTSTP)
+      {
+        ACE_DEBUG ((LM_INFO,
+                    ACE_TEXT ("Canceling timer %d\n"),
+                    this->timerId_));
+        ACE_Reactor::instance ()->cancel_timer (this->timerId_);
+      }
+
+    return 0;
+  }
+
+private:
+  long timerId_;
+  int currentInterval_;
+};
+// Listing 1
+
+#endif /* ACE_LACKS_UNIX_SIGNALS */
+
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  ACE_Time_Value initialDelay (3);
+  ACE_Time_Value interval (5);
+
+  // Listing 2 code/ch07
+  MyTimerHandler *handler = new MyTimerHandler ();
+  long timerId =
+    ACE_Reactor::instance ()->schedule_timer (handler,
+                                              0,
+                                              initialDelay,
+                                              interval);
+  // Listing 2
+
+#if !defined (ACE_LACKS_UNIX_SIGNALS)
+
+  // Listing 3 code/ch07
+  SignalHandler *mutateTimer =
+    new SignalHandler (timerId, 5);
+  ACE_Reactor::instance ()->register_handler (SIGINT,
+                                              mutateTimer);
+  ACE_Reactor::instance ()->register_handler (SIGTSTP,
+                                              mutateTimer);
+  // Listing 3
+
+#else
+   ACE_UNUSED_ARG (timerId);
+#endif /* ACE_LACKS_UNIX_SIGNALS */
+
+  ACE_Reactor::instance ()->run_reactor_event_loop ();
+  return 0;
+}