tassl.application
Class InternalStarter

java.lang.Object
  tassl.application.InternalStarter

All Implemented Interfaces:

programming5.net.ServiceObjectFactory

public class InternalStarter
extends java.lang.Object
implements programming5.net.ServiceObjectFactory

Nested Class Summary

protected class	InternalStarter.CometControlObject
static class	InternalStarter.NodeType

Field Summary

protected java.util.Hashtable<java.lang.String,java.lang.String>	baseProperties
protected tassl.automate.overlay.OverlayControlInterface<DrtsPeerWfl>	controlInterface
protected java.util.Hashtable<java.lang.String,java.util.Hashtable<java.lang.String,java.lang.String>>	exceptionTable
protected java.lang.String	localNode
protected java.util.Hashtable<java.lang.String,java.util.Hashtable<java.lang.String,java.lang.String>>	nodeDescriptors
protected java.util.Vector<java.lang.String>	nodeList
protected static DrtsPeerWfl	peer
protected programming5.net.ServerDaemon	serverDaemon

Constructor Summary

InternalStarter()

InternalStarter(java.lang.String nodeFileName, java.lang.String portFileName, java.lang.String[] appPropertyFiles, java.lang.String[] exceptionFileNames, int overlayPort)
Creates a new instance of cometStarter

Method Summary

static boolean	checkRequestHandler(java.lang.String[] requestHandlerList)
void	dynamicCometStart(java.lang.String... propertyFiles)
void	dynamicGroupLeave(java.util.Vector<java.lang.String> nodeURIs, java.lang.String bootstrapPeerID)
void	dynamicGroupStart(java.lang.String... propertyFiles)
void	endConnectionListeners()
void	fillIDMapping(java.math.BigInteger[] idMapping, java.lang.String mapFileName)
java.util.Vector<tassl.automate.overlay.chord.ChordID>	getBalancedChordIDs(java.lang.String joinBitsProperty)
DrtsPeerWfl	getDrtsPeer()
java.util.Vector<java.lang.String>	getNodeMap()
programming5.net.ServiceObject	getServiceObject()
void	initComet()
static void	main(java.lang.String[] args)
void	remoteRunMethod(java.lang.String methodName, java.util.Vector<java.lang.String> remoteNodeList, java.io.Serializable... parameters)
void	sendControlMessage(java.lang.String messageType, java.lang.Object item)
void	startApp()
void	terminateAll()
void	terminateComet()
void	terminateOverlay()
void	terminateOverlayRemote()

Methods inherited from class java.lang.Object

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

Field Detail

peer

protected static DrtsPeerWfl peer

controlInterface

protected tassl.automate.overlay.OverlayControlInterface<DrtsPeerWfl> controlInterface

nodeList

protected java.util.Vector<java.lang.String> nodeList

baseProperties

protected java.util.Hashtable<java.lang.String,java.lang.String> baseProperties

nodeDescriptors

protected java.util.Hashtable<java.lang.String,java.util.Hashtable<java.lang.String,java.lang.String>> nodeDescriptors

exceptionTable

protected java.util.Hashtable<java.lang.String,java.util.Hashtable<java.lang.String,java.lang.String>> exceptionTable

localNode

protected java.lang.String localNode

serverDaemon

protected programming5.net.ServerDaemon serverDaemon

Constructor Detail

InternalStarter

public InternalStarter()

InternalStarter

public InternalStarter(java.lang.String nodeFileName,
                       java.lang.String portFileName,
                       java.lang.String[] appPropertyFiles,
                       java.lang.String[] exceptionFileNames,
                       int overlayPort)

Creates a new instance of cometStarter

Method Detail

initComet

public void initComet()
               throws java.net.URISyntaxException,
                      programming5.net.IncompleteResultException

Throws:

java.net.URISyntaxException

programming5.net.IncompleteResultException

terminateAll

public void terminateAll()

terminateComet

public void terminateComet()

terminateOverlayRemote

public void terminateOverlayRemote()

terminateOverlay

public void terminateOverlay()

endConnectionListeners

public void endConnectionListeners()

getBalancedChordIDs

public java.util.Vector<tassl.automate.overlay.chord.ChordID> getBalancedChordIDs(java.lang.String joinBitsProperty)

checkRequestHandler

public static boolean checkRequestHandler(java.lang.String[] requestHandlerList)

startApp

public void startApp()

remoteRunMethod

public void remoteRunMethod(java.lang.String methodName,
                            java.util.Vector<java.lang.String> remoteNodeList,
                            java.io.Serializable... parameters)

fillIDMapping

public void fillIDMapping(java.math.BigInteger[] idMapping,
                          java.lang.String mapFileName)
                   throws java.io.IOException

Throws:

java.io.IOException

getDrtsPeer

public DrtsPeerWfl getDrtsPeer()

getNodeMap

public java.util.Vector<java.lang.String> getNodeMap()

getServiceObject

public programming5.net.ServiceObject getServiceObject()

Specified by:

getServiceObject in interface programming5.net.ServiceObjectFactory

dynamicCometStart

public void dynamicCometStart(java.lang.String... propertyFiles)

dynamicGroupStart

public void dynamicGroupStart(java.lang.String... propertyFiles)

dynamicGroupLeave

public void dynamicGroupLeave(java.util.Vector<java.lang.String> nodeURIs,
                              java.lang.String bootstrapPeerID)

sendControlMessage

public void sendControlMessage(java.lang.String messageType,
                               java.lang.Object item)

main

public static void main(java.lang.String[] args)