// file      : ACE_TMCast/FaultDetector.hpp
// author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
// cvs-id    : $Id$

#include "Protocol.hpp"

namespace ACE_TMCast
{
  class FaultDetector
  {
  public:
    FaultDetector ()
        : silence_period_ (-1)
    {
    }

  public:
    class Failed {};


    void
    insync ()
    {
      silence_period_ = 0;
    }

    void
    outsync ()
    {
      if (++silence_period_ >= Protocol::FATAL_SILENCE_FRAME)
      {
        // cerr << "Silence period has been passed." << endl;
        // cerr << "Decalring the node failed." << endl;
        throw Failed ();
      }
    }

  private:
    short silence_period_;
  };
}