TAO/tao/LF_Strategy_Complete.cpp

   1 #include "tao/LF_Strategy_Complete.h"
   2 #include "tao/LF_Follower.h"
   3 #include "tao/Leader_Follower.h"
   4 #include "ace/Guard_T.h"
   5 #include "tao/debug.h"
   6
   7 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   8
   9 TAO_LF_Strategy_Complete::~TAO_LF_Strategy_Complete ()
  10 {
  11 }
  12
  13 void
  14 TAO_LF_Strategy_Complete::set_upcall_thread (TAO_Leader_Follower &lf)
  15 {
  16   lf.set_upcall_thread ();
  17 }
  18
  19 int
  20 TAO_LF_Strategy_Complete::set_event_loop_thread (ACE_Time_Value *tv,
  21                                                  TAO_Leader_Follower &lf)
  22 {
  23   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, lf.lock (), -1);
  24
  25   return lf.set_event_loop_thread (tv);
  26 }
  27
  28 void
  29 TAO_LF_Strategy_Complete::reset_event_loop_thread (int call_reset,
  30                                                    TAO_Leader_Follower &lf)
  31 {
  32   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, lf.lock ());
  33
  34   if (call_reset)
  35     lf.reset_event_loop_thread ();
  36
  37   int const result = lf.elect_new_leader ();
  38
  39   if (result == -1)
  40     TAOLIB_ERROR ((LM_ERROR,
  41                 ACE_TEXT ("TAO (%P|%t) - Failed to wake up ")
  42                 ACE_TEXT ("a follower thread\n")));
  43 }
  44
  45 TAO_END_VERSIONED_NAMESPACE_DECL