#include "TimerDataNode.h"

void TimerDataNode::onBroadcast(BroadcastMessage &message, int msgId)
{ // This is pretty trivial.  In a sense, this whole data node is just an
  // adapter.  The timer thread can only talk to data nodes.  But anything can
  // listen to a data node.
  notifyListeners();
}

TimerDataNode::TimerDataNode(DataNodeArgument const &args) :
  _timerHelper(getOwnerChannel(), &getManager()->getTimerThread())
{
  const Integer periodInSeconds = args.getIntValue();
  getManager()->getTimerThread().requestPeriodicBroadcast
    (_timerHelper, periodInSeconds * 1000, true);
  registerForBroadcast(_timerHelper, 0);
}

DataNodeLink *TimerDataNode::find(DataNodeListener *listener, int msgId,
				  Integer periodInSeconds)
{
  TimerDataNode *unused;
  return findHelper(listener, msgId, unused, periodInSeconds);
}