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
  71 static void
  72 handle_signal (int )
  73 {
  74   EE_DEBUG ("", "handle_signal", 0);
  75
  76   // Dummy signal handler
  77 }
  78
  79 class ReactorTask : public ACE_Task_Base
  80 {
  81 public:
  82
  83   virtual ~ReactorTask ()
  84   {
  85     EE_DEBUG ("ReactorTask", "~ReactorTask", this);
  86   };
  87
  88   virtual int svc (void )
  89   {
  90     EE_DEBUG ("ReactorTask", "svc", this);
  91
  92     // Register a valid signal handler
  93     // so process doesn't die upon receiving signal
  94     ACE_Sig_Action sa ((ACE_SignalHandler) &::handle_signal, SIGUSR1);
  95     ACE_UNUSED_ARG (sa);
  96
  97     if (simulate_perform_work () == -1) {
  98       ACE_ERROR_RETURN ((LM_ERROR,
  99        ACE_TEXT ("(%P|%t) ERROR: simulated_perform_work failed.\n"))
 100       , -1);
 101     }
 102
 103     return 0;
 104   };
 105
 106 private:
 107   int simulate_perform_work ()
 108   {
 109     EE_DEBUG ("ReactorTask", "simulate_perform_work", this);
 110
 111     // Create a reactor which doesn't automatically restart
 112     // upon interruption
 113     ACE_TP_Reactor tp_reactor (ACE_TP_Reactor::DEFAULT_SIZE, 0);
 114
 115     reactor_task_ready = true;
 116
 117     // This will return upon signal interruption
 118     return tp_reactor.handle_events ();
 119   }
 120 };
 121
 122 int
 123 run_main (int, ACE_TCHAR *[])
 124 {
 125   ACE_START_TEST (ACE_TEXT ("Bug_2659_Regression_Test"));
 126   EE_DEBUG ("", "run_main", 0);
 127
 128   ReactorTask reactor_task;
 129
 130 #if !defined ACE_HAS_PTHREADS || !defined ACE_LACKS_PTHREAD_KILL
 131
 132   if (reactor_task.activate () == -1)
 133     {
 134       ACE_ERROR_RETURN ((LM_ERROR,
 135              ACE_TEXT ("(%P|%t) Task activation failed.\n"))
 136             , -1);
 137     }
 138
 139   ACE_Thread_Manager *thread_manager = reactor_task.thr_mgr ();
 140   if (thread_manager == 0)
 141     {
 142       ACE_ERROR_RETURN ((LM_ERROR,
 143              ACE_TEXT ("(%P|%t) No Thread Manager found.\n"))
 144             , -1);
 145     }
 146
 147   while (!reactor_task_ready)
 148     {
 149       ACE_OS::sleep (1);
 150     }
 151
 152   ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Signalling task.\n")));
 153
 154   if (thread_manager->kill_all (SIGUSR1) == -1)
 155     {
 156       ACE_ERROR_RETURN ((LM_ERROR,
 157                         ACE_TEXT ("(%P|%t) Task signalling failed.\n")),
 158                         -1);
 159     }
 160
 161   // Wait 5 seconds for the other thread to exit, if it didn't exit the
 162   // wait return -1 and we return with an error
 163   ACE_Time_Value timeout (5);
 164   if (thread_manager->wait (&timeout, false, false) == -1)
 165     {
 166       ACE_ERROR_RETURN ((LM_ERROR,
 167                         ACE_TEXT ("(%P|%t) Error, task wait failed.\n")),
 168                         -1);
 169     }
 170
 171 #endif
 172   ACE_END_TEST;
 173
 174   return 0;
 175 }
 176
 177 #else
 178 int
 179 run_main (int, ACE_TCHAR *[])
 180 {
 181   ACE_START_TEST (ACE_TEXT ("Bug_2659_Regression_Test"));
 182   ACE_ERROR ((LM_INFO,
 183               ACE_TEXT ("The Unix Signals capability is not supported on this platform\n")));
 184   ACE_END_TEST;
 185   return 0;
 186 }
 187 #endif /* !defined (ACE_LACKS_UNIX_SIGNALS) */