usr.localcontroller

Class LocalController

java.lang.Object

usr.localcontroller.LocalController

All Implemented Interfaces:

ComponentController

public class LocalController
extends java.lang.Object
implements ComponentController

The local controller is intended to run on every machine. Its job is to start up router processes as needed. It should be started by being given a port to listen on specified on the command line java LocalController.java 8080 In its own start up the Global Controller will contact each Local Controller to give it more state

Constructor Summary

Constructors

Constructor and Description
LocalController(int port) Constructor for local controller starting on port

Method Summary

Methods

Modifier and Type	Method and Description
void	aliveMessage(LocalHostInfo gc) Received alive message from GlobalController.
us.monoid.json.JSONObject	appStop(int routerID, java.lang.String appName) Stop something on a Router.
us.monoid.json.JSONObject	connectRouters(LocalHostInfo r1, LocalHostInfo r2, int weight, java.lang.String name) Connect two Routers on two specified hosts.
boolean	endLink(LocalHostInfo r1, java.lang.String r2Addr) Local controller receives request to end a router
boolean	endRouter(LocalHostInfo r1) Local controller receives request to end a router
BasicRouterInfo	findRouterInfo(int rId) Find some router info
BasicRouterInfo	findRouterInfoByPort(int port) Get a BasicRouterInfo by looking up a router port.
GlobalControllerInteractor	getGlobalControllerInteractor()
LocalControllerInfo	getHostInfo() Get the host info the the host this is a LocalController for.
cc.clayman.console.ManagementConsole	getManagementConsole() Get the ManagementConsole this ComponentController interacts with.
java.lang.String	getName() Get the name of this LocalController.
java.util.List<java.lang.String>	getRouterStats() Get router stats for all routers managed by this LocalController
java.util.List<java.lang.String>	getRouterStats(int routerID) Get some router stats
static void	main(java.lang.String[] args) Main entry point.
us.monoid.json.JSONObject	onRouter(int routerID, java.lang.String className, java.lang.String[] args) Run something on a Router.
boolean	reportAP(int GID, int AP) Report the Aggregation point for a given router
java.lang.String	requestNewRouter(int routerId, int port1, int port2, java.lang.String address, java.lang.String name) Received start new router command
boolean	sendRouterStats(java.util.List<java.lang.String> list) Send router stats to global controller
boolean	setAP(int GID, int AP) Set the Aggregation point for a given router
boolean	setLinkWeight(LocalHostInfo r1, java.lang.String r2Addr, int weight) Local controller receives request to set a link weight
void	setRouterOptions(java.lang.String str) Set string which configures routers
void	shutDown() Received shut Down data gram from global
void	startMonitoring(java.net.InetSocketAddress socketAddress, int timeout) Start monitoring, sending data to a specified address with a particular timeout.
void	stopMonitoring() Stop any monitoring

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalController

public LocalController(int port)

Constructor for local controller starting on port

Method Detail

main

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

Main entry point.

getName

public java.lang.String getName()

Get the name of this LocalController.

Specified by:

getName in interface ComponentController

shutDown

public void shutDown()

Received shut Down data gram from global

getHostInfo

public LocalControllerInfo getHostInfo()

Get the host info the the host this is a LocalController for.

aliveMessage

public void aliveMessage(LocalHostInfo gc)

Received alive message from GlobalController.

requestNewRouter

public java.lang.String requestNewRouter(int routerId,
                                int port1,
                                int port2,
                                java.lang.String address,
                                java.lang.String name)

Received start new router command

Returns:

the name of the router, on success, or null, on failure.

connectRouters

public us.monoid.json.JSONObject connectRouters(LocalHostInfo r1,
                                       LocalHostInfo r2,
                                       int weight,
                                       java.lang.String name)

Connect two Routers on two specified hosts.

Returns:

the name of the connection, on success, or null, on failure.

sendRouterStats

public boolean sendRouterStats(java.util.List<java.lang.String> list)

Send router stats to global controller

endRouter

public boolean endRouter(LocalHostInfo r1)

Local controller receives request to end a router

endLink

public boolean endLink(LocalHostInfo r1,
              java.lang.String r2Addr)

Local controller receives request to end a router

setLinkWeight

public boolean setLinkWeight(LocalHostInfo r1,
                    java.lang.String r2Addr,
                    int weight)

Local controller receives request to set a link weight

setRouterOptions

public void setRouterOptions(java.lang.String str)

Set string which configures routers

setAP

public boolean setAP(int GID,
            int AP)

Set the Aggregation point for a given router

getRouterStats

public java.util.List<java.lang.String> getRouterStats()

Get router stats for all routers managed by this LocalController

getRouterStats

public java.util.List<java.lang.String> getRouterStats(int routerID)

Get some router stats

startMonitoring

public void startMonitoring(java.net.InetSocketAddress socketAddress,
                   int timeout)

Start monitoring, sending data to a specified address with a particular timeout.

stopMonitoring

public void stopMonitoring()

Stop any monitoring

onRouter

public us.monoid.json.JSONObject onRouter(int routerID,
                                 java.lang.String className,
                                 java.lang.String[] args)

Run something on a Router.

appStop

public us.monoid.json.JSONObject appStop(int routerID,
                                java.lang.String appName)

Stop something on a Router.

reportAP

public boolean reportAP(int GID,
               int AP)

Report the Aggregation point for a given router

findRouterInfo

public BasicRouterInfo findRouterInfo(int rId)

Find some router info

findRouterInfoByPort

public BasicRouterInfo findRouterInfoByPort(int port)

Get a BasicRouterInfo by looking up a router port.

getManagementConsole

public cc.clayman.console.ManagementConsole getManagementConsole()

Get the ManagementConsole this ComponentController interacts with.

Specified by:

getManagementConsole in interface ComponentController

getGlobalControllerInteractor

public GlobalControllerInteractor getGlobalControllerInteractor()