org.ow2.proactive.resourcemanager.frontend

Class RMMonitoringImpl

java.lang.Object

org.ow2.proactive.resourcemanager.frontend.RMMonitoringImpl

All Implemented Interfaces:

org.objectweb.proactive.Active, org.objectweb.proactive.InitActive, org.objectweb.proactive.RunActive, RMEventListener, RMMonitoring

public class RMMonitoringImpl
extends Object
implements RMMonitoring, RMEventListener, org.objectweb.proactive.InitActive, org.objectweb.proactive.RunActive

Active object designed for the Monitoring of the Resource Manager. This class provides a way for a monitor to ask at Resource Manager to throw events generated by nodes and nodes sources management. RMMonitoring dispatch events thrown by RMCore to all its monitors.

Since:

ProActive Scheduling 0.9

See Also:

RMEventListener

Field Summary

Fields

Modifier and Type	Field and Description
static RMStatistics	rmStatistics Resource Manager's statistics

Constructor Summary

Constructors

Constructor and Description
RMMonitoringImpl() ProActive empty constructor
RMMonitoringImpl(RMCore rmcore) Creates the RMMonitoring active object.

Method Summary

Modifier and Type	Method and Description
RMInitialState	addRMEventListener(RMEventListener stub, RMEventType... events) Register a new Resource manager listener.
org.apache.log4j.Logger	getLogger()
int	getNeededNodes()
RMInitialState	getState() Gets the current snapshot of the resource manager state providing detailed nodes and node source information.
void	initActivity(org.objectweb.proactive.Body body)
boolean	isAlive() Deprecated.
void	nodeEvent(RMNodeEvent event) new node available in RM.
void	nodeEventOnlyForStatistic(RMNodeEvent event)
void	nodeSourceEvent(RMNodeSourceEvent event) new node source available in RM.
void	queueEvent(RMEvent event)
void	removeRMEventListener() Removes a listener from RMMonitoring.
boolean	removeRMEventListener(org.objectweb.proactive.core.UniqueID id)
void	rmEvent(RMEvent event) RM is shutting down
void	runActivity(org.objectweb.proactive.Body body) Method controls the execution of every request.
void	setNeededNodes(int neededNodes)
org.objectweb.proactive.core.util.wrapper.BooleanWrapper	shutdown() Stop and remove monitoring active object

Methods inherited from class java.lang.Object

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

Field Detail

rmStatistics

public static final RMStatistics rmStatistics

Resource Manager's statistics

Constructor Detail

RMMonitoringImpl

public RMMonitoringImpl()

ProActive empty constructor

RMMonitoringImpl

public RMMonitoringImpl(RMCore rmcore)

Creates the RMMonitoring active object.

Parameters:

rmcore - Stub of the RMCore active object.

Method Detail

initActivity

public void initActivity(org.objectweb.proactive.Body body)

Specified by:

initActivity in interface org.objectweb.proactive.InitActive

See Also:

InitActive.initActivity(org.objectweb.proactive.Body)

runActivity

public void runActivity(org.objectweb.proactive.Body body)

Method controls the execution of every request. Tries to keep this active object alive in case of any exception.

Specified by:

runActivity in interface org.objectweb.proactive.RunActive

addRMEventListener

public RMInitialState addRMEventListener(RMEventListener stub,
                                         RMEventType... events)

Register a new Resource manager listener. Way to a monitor object to ask at RMMonitoring to throw RM events to it.

Specified by:

addRMEventListener in interface RMMonitoring

Parameters:

stub - a listener object which implements RMEventListener interface.

events - list of wanted events that must be received.

Returns:

RMInitialState snapshot of RM's current state : nodes and node sources.

removeRMEventListener

public void removeRMEventListener()

Removes a listener from RMMonitoring. Only listener itself must call this method

Specified by:

removeRMEventListener in interface RMMonitoring

removeRMEventListener

public boolean removeRMEventListener(org.objectweb.proactive.core.UniqueID id)

isAlive

@Deprecated
public boolean isAlive()

Deprecated.

Description copied from interface: RMMonitoring

ping the RM

Specified by:

isAlive in interface RMMonitoring

Returns:

true if the RM is still alive

queueEvent

public void queueEvent(RMEvent event)

nodeEventOnlyForStatistic

public void nodeEventOnlyForStatistic(RMNodeEvent event)

nodeEvent

public void nodeEvent(RMNodeEvent event)

Description copied from interface: RMEventListener

new node available in RM.

Specified by:

nodeEvent in interface RMEventListener

Parameters:

event - node event containing new RMNode properties.

See Also:

RMEventListener.nodeEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent)

setNeededNodes

public void setNeededNodes(int neededNodes)

getNeededNodes

public int getNeededNodes()

Specified by:

getNeededNodes in interface RMMonitoring

nodeSourceEvent

public void nodeSourceEvent(RMNodeSourceEvent event)

Description copied from interface: RMEventListener

new node source available in RM.

Specified by:

nodeSourceEvent in interface RMEventListener

Parameters:

event - node source event containing new NodeSource properties.

See Also:

RMEventListener.nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent)

rmEvent

public void rmEvent(RMEvent event)

Description copied from interface: RMEventListener

RM is shutting down

Specified by:

rmEvent in interface RMEventListener

Parameters:

event - object representing the event.

See Also:

RMEventListener.rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent)

shutdown

public org.objectweb.proactive.core.util.wrapper.BooleanWrapper shutdown()

Stop and remove monitoring active object

getLogger

public org.apache.log4j.Logger getLogger()

getState

public RMInitialState getState()

Gets the current snapshot of the resource manager state providing detailed nodes and node source information. To obtain summary of the resource manager state use ResourceManager.getState()

Specified by:

getState in interface RMMonitoring

Returns:

the current state of the resource manager