rice.scribe.maintenance
Class ScribeMaintainer

java.lang.Object
  |
  +--rice.scribe.maintenance.ScribeMaintainer

public class ScribeMaintainer

extends java.lang.Object

This is responsible for all the Scribe tree maintainance activities corresponding to all the topics in this local node.

Version:

$Id: ScribeMaintainer.java,v 1.14 2003/06/12 21:56:53 atuls Exp $

Author:

Atul Singh, Animesh Nandi

Constructor Summary

ScribeMaintainer(rice.scribe.Scribe scribe)

Method Summary

void	scheduleHB() Sends heartbeat messages to this local node's children for all the topics on this local scribe node.
void	scheduleTR(rice.scribe.Topic topic) Starts a tree repair for a particular topic in the local node

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScribeMaintainer

public ScribeMaintainer(rice.scribe.Scribe scribe)

Method Detail

scheduleHB

public void scheduleHB()

Sends heartbeat messages to this local node's children for all the topics on this local scribe node. This method should be invoked periodically by the driver with the same frequency in all nodes. In addition to initiating sending of heartbeat messages from this local node, this method also implicitly notifies the local node that it should expect a heartbeat message from its parents for all the topics on this local node. So, if it fails to receive a threshold value of such heartbeat messages from any parent for a particular topic, a tree repair event is triggered for that topic.

scheduleTR

public void scheduleTR(rice.scribe.Topic topic)

Starts a tree repair for a particular topic in the local node