ACE/tests/Bug_2659_Regression_Test.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    Bug_2659_Regression_Test.cpp
   5  *
   6  *     Reproduces the problems reported in bug 2659:
   7  *      http://bugzilla.dre.vanderbilt.edu/show_bug.cgi?id=2659
   8  *
   9  *  @author Ciju John <johnc at ociweb>
  10  */
  11 //=============================================================================
  12
  13
  14 #include "test_config.h"
  15
  16 #include "ace/Log_Msg.h"
  17 #include "ace/Task.h"
  18 #include "ace/OS_NS_unistd.h"
  19 #include "ace/Thread_Manager.h"
  20 #include "ace/TP_Reactor.h"
  21
  22 #if !defined (ACE_LACKS_UNIX_SIGNALS)
  23
  24 bool reactor_task_ready = false;
  25
  26
  27 //#define RUN_DEBUG 1
  28
  29 #if defined RUN_DEBUG
  30
  31 #define EE_DEBUG(CNAME,MNAME,LOC) \
  32 EntryExit ee (CNAME,MNAME,LOC)
  33
  34 class EntryExit
  35 {
  36 public:
  37   EntryExit (const ACE_TCHAR* class_name,
  38              const ACE_TCHAR *method_name,
  39              void *location = 0)
  40   {
  41     class_name_ [20] = method_name_[20] = 0;
  42
  43     ACE_OS::strncpy (class_name_, class_name, 20);
  44     ACE_OS::strncpy (method_name_, method_name, 20);
  45     location_ = location;
  46
  47     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Entry %@ %s::%s\n")
  48          , location, class_name, method_name));
  49   };
  50
  51   ~EntryExit ()
  52   {
  53     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Exit %@ %s::%s\n")
  54          , location_, class_name_, method_name_));
  55   };
  56
  57 private:
  58   ACE_TCHAR class_name_[21];
  59   ACE_TCHAR method_name_[21];
  60   void *location_;
  61 };
  62
  63 #else
  64
  65 #define EE_DEBUG(CNAME,MNAME,LOC)
  66
  67 #endif // if defined RUN_DEBUG
  68
  69
  70 static void
  71 handle_signal (int )
  72 {
  73   EE_DEBUG ("", "handle_signal", 0);
  74
  75   // Dummy signal handler
  76 }
  77
  78 class ReactorTask : public ACE_Task_Base
  79 {
  80 public:
  81   ~ReactorTask () override
  82   {
  83     EE_DEBUG ("ReactorTask", "~ReactorTask", this);
  84   };
  85
  86   int svc ( ) override
  87   {
  88     EE_DEBUG ("ReactorTask", "svc", this);
  89
  90     // Register a valid signal handler
  91     // so process doesn't die upon receiving signal
  92     ACE_Sig_Action sa ((ACE_SignalHandler) &::handle_signal, SIGUSR1);
  93     ACE_UNUSED_ARG (sa);
  94
  95     if (simulate_perform_work () == -1) {
  96       ACE_ERROR_RETURN ((LM_ERROR,
  97        ACE_TEXT ("(%P|%t) ERROR: simulated_perform_work failed.\n"))
  98       , -1);
  99     }
 100
 101     return 0;
 102   };
 103
 104 private:
 105   int simulate_perform_work ()
 106   {
 107     EE_DEBUG ("ReactorTask", "simulate_perform_work", this);
 108
 109     // Create a reactor which doesn't automatically restart
 110     // upon interruption
 111     ACE_TP_Reactor tp_reactor (ACE_TP_Reactor::DEFAULT_SIZE, 0);
 112
 113     reactor_task_ready = true;
 114
 115     // This will return upon signal interruption
 116     return tp_reactor.handle_events ();
 117   }
 118 };
 119
 120 int
 121 run_main (int, ACE_TCHAR *[])
 122 {
 123   ACE_START_TEST (ACE_TEXT ("Bug_2659_Regression_Test"));
 124   EE_DEBUG ("", "run_main", 0);
 125
 126   ReactorTask reactor_task;
 127
 128 #if !defined ACE_HAS_PTHREADS || !defined ACE_LACKS_PTHREAD_KILL
 129
 130   if (reactor_task.activate () == -1)
 131     {
 132       ACE_ERROR_RETURN ((LM_ERROR,
 133              ACE_TEXT ("(%P|%t) Task activation failed.\n"))
 134             , -1);
 135     }
 136
 137   ACE_Thread_Manager *thread_manager = reactor_task.thr_mgr ();
 138   if (thread_manager == 0)
 139     {
 140       ACE_ERROR_RETURN ((LM_ERROR,
 141              ACE_TEXT ("(%P|%t) No Thread Manager found.\n"))
 142             , -1);
 143     }
 144
 145   while (!reactor_task_ready)
 146     {
 147       ACE_OS::sleep (1);
 148     }
 149
 150   ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Signalling task.\n")));
 151
 152   if (thread_manager->kill_all (SIGUSR1) == -1)
 153     {
 154       ACE_ERROR_RETURN ((LM_ERROR,
 155                         ACE_TEXT ("(%P|%t) Task signalling failed.\n")),
 156                         -1);
 157     }
 158
 159   // Wait 5 seconds for the other thread to exit, if it didn't exit the
 160   // wait return -1 and we return with an error
 161   ACE_Time_Value timeout (5);
 162   if (thread_manager->wait (&timeout, false, false) == -1)
 163     {
 164       ACE_ERROR_RETURN ((LM_ERROR,
 165                         ACE_TEXT ("(%P|%t) Error, task wait failed.\n")),
 166                         -1);
 167     }
 168
 169 #endif
 170   ACE_END_TEST;
 171
 172   return 0;
 173 }
 174
 175 #else
 176 int
 177 run_main (int, ACE_TCHAR *[])
 178 {
 179   ACE_START_TEST (ACE_TEXT ("Bug_2659_Regression_Test"));
 180   ACE_ERROR ((LM_INFO,
 181               ACE_TEXT ("The Unix Signals capability is not supported on this platform\n")));
 182   ACE_END_TEST;
 183   return 0;
 184 }
 185 #endif /* !defined (ACE_LACKS_UNIX_SIGNALS) */