ACE/tests/Task_Wait_Test.cpp

   1 //=============================================================================
   2 /**
   3  *  @file    Task_Wait_Test.cpp
   4  *
   5  *    This program tests the ACE_Thread_Manager::wait() from a called-back
   6  *    ACE_Task::close() on thread exit.
   7  *
   8  *  @author Steve Huston <shuston@riverace.com>
   9  */
  10 //=============================================================================
  11
  12
  13 #include "test_config.h"
  14 #include "ace/Event.h"
  15 #include "ace/Thread_Manager.h"
  16 #include "ace/Task.h"
  17 #include "ace/OS_NS_unistd.h"
  18
  19 // On Windows, this test will deadlock because a thread tries to join with
  20 // itself. Pthreads, et al, have deadlock protection in join; Windows Vista
  21 // and Server 2003 have API to access the info needed to check for deadlock
  22 // in ACE_OS::thr_join() - don't run this test on earlier Windows versions
  23 // because it will hang/time out and there's little to be done about it.
  24 #if defined (ACE_HAS_THREADS) && ((defined (_WIN32_WINNT) && (_WIN32_WINNT >= 0x0502)) || !defined (WIN32))
  25 #  define RUN_THIS_TEST
  26 #endif
  27
  28 #ifdef RUN_THIS_TEST
  29
  30 static ACE_Event TaskDone;
  31
  32 // Define a ACE_Task that does little except exit and try to clean up.
  33
  34 class Do_Nothing_Task : public ACE_Task_Base {
  35 public:
  36   int close (u_long flags = 0) override;
  37
  38   int svc () override;
  39 };
  40
  41 // close tries to wait for other threads. There aren't any, but as long as
  42 // we don't deadlock, it's good.
  43 int
  44 Do_Nothing_Task::close (u_long)
  45 {
  46   ACE_DEBUG ((LM_DEBUG,
  47               ACE_TEXT ("Task 0x%x, thread %t closing\n"),
  48               this));
  49   this->wait ();
  50   TaskDone.signal ();
  51   return 0;
  52 }
  53
  54
  55 // svc just waits a second then exits.
  56 int
  57 Do_Nothing_Task::svc ()
  58 {
  59   ACE_DEBUG ((LM_DEBUG,
  60               ACE_TEXT ("Task 0x%x, thread %t waiting to exit\n"),
  61               this));
  62   ACE_OS::sleep (1);
  63
  64   return 0;
  65 }
  66
  67 #endif /* RUN_THIS_TEST */
  68
  69 int
  70 run_main (int, ACE_TCHAR *[])
  71 {
  72   ACE_START_TEST (ACE_TEXT ("Task_Wait_Test"));
  73   int status = 0;
  74
  75 #if defined (RUN_THIS_TEST)
  76
  77   Do_Nothing_Task t;
  78   status = t.activate ();
  79   TaskDone.wait();
  80
  81 #else
  82   ACE_ERROR ((LM_INFO,
  83               ACE_TEXT ("inadequate thread support on this platform\n")));
  84 #endif /* RUN_THIS_TEST */
  85
  86   ACE_END_TEST;
  87   return status;
  88 }