ds.granules.interfere.placement

Class GIPlacementNode

java.lang.Object

ds.funnel.node.compnt.NodeComponentImpl

ds.funnel.node.NodeBase

ds.granules.interfere.placement.GIPlacementNode

All Implemented Interfaces:

ComponentManager, NodeComponent, Node, GIPlacementProxyOps

public class GIPlacementNode
extends NodeBase
implements GIPlacementProxyOps

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GIPlacementNode.Migration

Nested classes/interfaces inherited from interface ds.funnel.node.Node

Node.NodeState

Field Summary

Fields

Modifier and Type	Field and Description
static int	MIGRATE_LEAVEALONE
static int	MIGRATE_TASKRATE
static double	MIGRATE_THRESH_PCT
static boolean	STREAM_SYNC_DELAY
static int[][]	USAGE_RING_PARAMS
static int	USAGE_UPDATE_MILLIS
static int	USAGE_UPDATE_QUICKLY

Constructor Summary

Constructors

Constructor and Description
GIPlacementNode(java.lang.String... args)

Method Summary

Modifier and Type	Method and Description
static java.lang.String[]	getConfigDistr()
static GIPlacementNode.Migration	getConfigMigrate()
static GICompPlacerCmpnt	getConfigPlacer()
static ComputationUsage	getConfigUsage()
GIPlacementDetails	getDetails()
static GIPlacementNode	getNode()
GIStreamingTrackerCmpnt	getStreamingTracker()
boolean	joinSystem(NodeDetails inDetails)
boolean	leaveSystem(NodeDetails inDetails)
static void	main(java.lang.String[] args)
boolean	placeComputation(GIComputation inComputation)
boolean	updateUsage(NodeDetails inDetails, ComputationUsage inUsage, int inMigrTry, int inMigr)

Methods inherited from class ds.funnel.node.NodeBase

enterMultiCommands, getComponent, getName, getState, registerComponent, runCommand, runTask, startNode, stopNode, toString, unregisterComponent

Methods inherited from class ds.funnel.node.compnt.NodeComponentImpl

getComponentKey, getComponentLink, hashCode, setComponentKey, startComponent, stopComponent

Methods inherited from class java.lang.Object

equals, getClass, notify, notifyAll, wait, wait, wait

Field Detail

USAGE_UPDATE_MILLIS

public static final int USAGE_UPDATE_MILLIS

See Also:

Constant Field Values

USAGE_UPDATE_QUICKLY

public static final int USAGE_UPDATE_QUICKLY

See Also:

Constant Field Values

MIGRATE_TASKRATE

public static final int MIGRATE_TASKRATE

See Also:

Constant Field Values

MIGRATE_LEAVEALONE

public static final int MIGRATE_LEAVEALONE

See Also:

Constant Field Values

MIGRATE_THRESH_PCT

public static final double MIGRATE_THRESH_PCT

See Also:

Constant Field Values

STREAM_SYNC_DELAY

public static final boolean STREAM_SYNC_DELAY

See Also:

Constant Field Values

USAGE_RING_PARAMS

public static final int[][] USAGE_RING_PARAMS

Constructor Detail

GIPlacementNode

public GIPlacementNode(java.lang.String... args)

Method Detail

getNode

public static GIPlacementNode getNode()

getConfigUsage

public static ComputationUsage getConfigUsage()

getConfigPlacer

public static GICompPlacerCmpnt getConfigPlacer()

getConfigDistr

public static java.lang.String[] getConfigDistr()

getConfigMigrate

public static GIPlacementNode.Migration getConfigMigrate()

main

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

Throws:

java.lang.Exception

getDetails

public GIPlacementDetails getDetails()

Specified by:

getDetails in interface Node

Overrides:

getDetails in class NodeBase

Returns:

The address and other details of this node.

getStreamingTracker

public GIStreamingTrackerCmpnt getStreamingTracker()

joinSystem

public boolean joinSystem(NodeDetails inDetails)

Specified by:

joinSystem in interface GIPlacementProxyOps

leaveSystem

public boolean leaveSystem(NodeDetails inDetails)

Specified by:

leaveSystem in interface GIPlacementProxyOps

updateUsage

public boolean updateUsage(NodeDetails inDetails,
                           ComputationUsage inUsage,
                           int inMigrTry,
                           int inMigr)

Specified by:

updateUsage in interface GIPlacementProxyOps

placeComputation

public boolean placeComputation(GIComputation inComputation)

Specified by:

placeComputation in interface GIPlacementProxyOps