|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectist.palcom.routing.AbstractRoutingManager2
public abstract class AbstractRoutingManager2
Abstract class for a routing manager, implements RoutingManager. Handles chopped and reliable messages.
| Nested Class Summary | |
|---|---|
protected class |
AbstractRoutingManager2.ChoppedMessageHandler
Handles chopping and reassembling of messages |
| Field Summary | |
|---|---|
protected HgraphNode |
_node
hgraph impl |
| Fields inherited from interface ist.palcom.hgraph.IHgraphNode |
|---|
CHILD_NAME_CLASH, CIRCULARITY_CLASH, COMMAND_OR_NODE_MISSING, ERROR, HANDLER_MISSING, INVOKATOR_MISSING, LISTENER_MISSING, NODE_NOT_CHILD, PATH_MISSING, SIBLING_ALREADY_EXISTS, SIBLING_NONEXISTENT, SIBLING_REFERENCE_ALREADY_EXISTS, SIBLING_REFERENCE_NONEXISTENT, STATUS_OK, VALUE_ALREADY_EXISTS, VALUE_NOT_PRESENT |
| Constructor Summary | |
|---|---|
AbstractRoutingManager2()
|
|
| Method Summary | |
|---|---|
abstract void |
addErrorHandler(PalcomThread handler)
|
int |
addNodeChild(IHgraphNode node,
Path callerPath)
Adds a child to the node's private list of children. |
protected Message |
adjustMessageRawData(Message message)
This method is required, in the current implementation, when a message header node has been removed. |
java.util.Iterator |
getChildIterator()
|
AbstractRoutingManager2.ChoppedMessageHandler |
getChoppedMessageHandler()
|
FuncFunc |
getFuncFunc()
|
abstract java.lang.String |
getLocalDeviceCache()
|
java.lang.String |
getNodeName()
hgraph impl below |
IHgraphNode |
getNodeParent()
|
Path |
getPath()
|
SiblingFunc |
getSiblingFunc()
|
ValueFunc |
getValueFunc()
|
boolean |
hasChildNamed(java.lang.String name)
Checks whether the node has a child with a given name |
boolean |
isAncestorOf(IHgraphNode node)
Checks whether this node is an ancestor of the parameter node. |
abstract void |
registerAsListener(PalcomThread communicationManager)
|
abstract void |
registerForHeartBeats(PalcomThread resourceManager)
|
int |
removeNodeChild(java.lang.String name,
Path callerPath)
Removes a child based on its name. |
abstract boolean |
send(Message message,
java.lang.String receiverDeviceID)
|
abstract boolean |
send(Message msg,
URN urn1,
Selector selector1,
URN urn2,
Selector selector2)
|
abstract void |
sendBroadcast(Message message)
|
void |
sendGroupJoinMessage(java.lang.String groupID)
|
void |
sendGroupLeaveMessage(java.lang.String groupID)
|
abstract void |
sendHeartAttack()
|
abstract void |
sendHeartBeat(boolean isHeartBeatAck)
|
abstract void |
setDiscoverySelector(Selector selector)
|
abstract void |
setLocalDeviceCache(java.lang.String localDeviceCache)
|
abstract void |
setLocalDeviceID(java.lang.String localDeviceID)
|
abstract void |
setLocalDiscoveryVersion(java.lang.String discoveryVersion)
|
abstract void |
setLocalStatusFlag(byte statusFlag)
|
int |
setNodeName(java.lang.String name,
Path callerPath)
Sets the name of the node. |
int |
setNodeParent(IHgraphNode newParent,
Path callerPath)
Sets the parent of the HgraphNode. |
void |
stop()
Clears the choppedMessageHandler. |
abstract void |
stopReceiving(PalcomThread receiver)
|
abstract void |
stopReceiving(Selector selector)
|
java.lang.String |
toXML()
|
java.lang.String |
toXMLFull()
|
java.lang.String |
toXMLFullRecursively()
|
java.lang.String |
toXMLRecursively()
|
void |
unregisterDevice(java.lang.String deviceID)
Remove the device with deviceID from the list of registered devices. |
void |
updatePath()
Updates the path of the H-Graph node along with its offspring recursively. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected HgraphNode _node
| Constructor Detail |
|---|
public AbstractRoutingManager2()
| Method Detail |
|---|
public abstract void stopReceiving(PalcomThread receiver)
stopReceiving in interface RoutingManagerpublic abstract void stopReceiving(Selector selector)
stopReceiving in interface RoutingManager
public abstract boolean send(Message msg,
URN urn1,
Selector selector1,
URN urn2,
Selector selector2)
send in interface RoutingManager
public abstract boolean send(Message message,
java.lang.String receiverDeviceID)
send in interface RoutingManagerpublic void stop()
stop in interface RoutingManagerpublic void unregisterDevice(java.lang.String deviceID)
unregisterDevice in interface RoutingManagerpublic abstract void addErrorHandler(PalcomThread handler)
addErrorHandler in interface RoutingManagerpublic abstract void setLocalDeviceCache(java.lang.String localDeviceCache)
setLocalDeviceCache in interface RoutingManagerpublic abstract java.lang.String getLocalDeviceCache()
getLocalDeviceCache in interface RoutingManagerpublic abstract void setLocalDeviceID(java.lang.String localDeviceID)
setLocalDeviceID in interface RoutingManagerpublic abstract void setLocalStatusFlag(byte statusFlag)
setLocalStatusFlag in interface RoutingManagerpublic abstract void setLocalDiscoveryVersion(java.lang.String discoveryVersion)
setLocalDiscoveryVersion in interface RoutingManagerpublic abstract void setDiscoverySelector(Selector selector)
setDiscoverySelector in interface RoutingManagerpublic abstract void sendBroadcast(Message message)
sendBroadcast in interface RoutingManagerpublic abstract void sendHeartAttack()
sendHeartAttack in interface RoutingManagerpublic abstract void registerAsListener(PalcomThread communicationManager)
registerAsListener in interface RoutingManagerpublic abstract void registerForHeartBeats(PalcomThread resourceManager)
registerForHeartBeats in interface RoutingManagerpublic abstract void sendHeartBeat(boolean isHeartBeatAck)
sendHeartBeat in interface RoutingManagerpublic void sendGroupJoinMessage(java.lang.String groupID)
sendGroupJoinMessage in interface RoutingManagerpublic void sendGroupLeaveMessage(java.lang.String groupID)
sendGroupLeaveMessage in interface RoutingManagerpublic AbstractRoutingManager2.ChoppedMessageHandler getChoppedMessageHandler()
protected Message adjustMessageRawData(Message message)
message -
public java.lang.String getNodeName()
getNodeName in interface IHgraphNode
public int setNodeName(java.lang.String name,
Path callerPath)
IHgraphNode
setNodeName in interface IHgraphNodename - The new name
public Path getPath()
getPath in interface IHgraphNodepublic void updatePath()
IHgraphNode
updatePath in interface IHgraphNodepublic boolean hasChildNamed(java.lang.String name)
IHgraphNode
hasChildNamed in interface IHgraphNodename - The name to check
public boolean isAncestorOf(IHgraphNode node)
IHgraphNode
isAncestorOf in interface IHgraphNode
public int removeNodeChild(java.lang.String name,
Path callerPath)
IHgraphNode
removeNodeChild in interface IHgraphNodename - The name of the child to be removed
public java.lang.String toXML()
toXML in interface IHgraphNodepublic java.lang.String toXMLFull()
toXMLFull in interface IHgraphNodepublic java.lang.String toXMLRecursively()
toXMLRecursively in interface IHgraphNodepublic java.lang.String toXMLFullRecursively()
toXMLFullRecursively in interface IHgraphNode
public int setNodeParent(IHgraphNode newParent,
Path callerPath)
IHgraphNode
setNodeParent in interface IHgraphNodenewParent - the new parent
public int addNodeChild(IHgraphNode node,
Path callerPath)
IHgraphNode
addNodeChild in interface IHgraphNodenode - The new child to be added
public SiblingFunc getSiblingFunc()
getSiblingFunc in interface IHgraphNodepublic ValueFunc getValueFunc()
getValueFunc in interface IHgraphNodepublic FuncFunc getFuncFunc()
getFuncFunc in interface IHgraphNodepublic IHgraphNode getNodeParent()
getNodeParent in interface IHgraphNodepublic java.util.Iterator getChildIterator()
getChildIterator in interface IHgraphNode
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||