ACE/protocols/ace/TMCast/FaultDetector.hpp

   1 // author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
   2
   3 #include "Protocol.hpp"
   4
   5 namespace ACE_TMCast
   6 {
   7   class FaultDetector
   8   {
   9   public:
  10     FaultDetector ()
  11         : alone_ (true), silence_period_ (-1)
  12     {
  13     }
  14
  15   public:
  16     class Failed {};
  17
  18
  19     void
  20     insync ()
  21     {
  22       if (alone_)
  23         alone_ = false;
  24
  25       silence_period_ = 0;
  26     }
  27
  28     void
  29     outsync ()
  30     {
  31       if (!alone_ && ++silence_period_ >= Protocol::FATAL_SILENCE_FRAME)
  32       {
  33         // cerr << "Silence period has been passed." << endl;
  34         // cerr << "Decalring the node failed." << endl;
  35         throw Failed ();
  36       }
  37     }
  38
  39   private:
  40     bool alone_; // true if we haven't heard from any members yet.
  41     short silence_period_;
  42   };
  43 }