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, org.ow2.proactive.resourcemanager.frontend.RMEventListener, org.ow2.proactive.resourcemanager.frontend.RMMonitoring

public class RMMonitoringImpl
extends Object
implements org.ow2.proactive.resourcemanager.frontend.RMMonitoring, org.ow2.proactive.resourcemanager.frontend.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
org.ow2.proactive.resourcemanager.common.event.RMInitialState	addRMEventListener(org.ow2.proactive.resourcemanager.frontend.RMEventListener stub, org.ow2.proactive.resourcemanager.common.event.RMEventType... events) Register a new Resource manager listener.
org.apache.log4j.Logger	getLogger()
org.ow2.proactive.resourcemanager.common.event.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(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent event)
void	nodeEventOnlyForStatistic(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent event)
void	nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent event)
void	queueEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent event)
void	removeRMEventListener() Removes a listener from RMMonitoring.
boolean	removeRMEventListener(org.objectweb.proactive.core.UniqueID id)
void	rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent event)
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 org.ow2.proactive.resourcemanager.common.event.RMInitialState addRMEventListener(org.ow2.proactive.resourcemanager.frontend.RMEventListener stub,
                                                                                        org.ow2.proactive.resourcemanager.common.event.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 org.ow2.proactive.resourcemanager.frontend.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 org.ow2.proactive.resourcemanager.frontend.RMMonitoring

removeRMEventListener

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

isAlive

@Deprecated
public boolean isAlive()

Deprecated.

Specified by:

isAlive in interface org.ow2.proactive.resourcemanager.frontend.RMMonitoring

queueEvent

public void queueEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent event)

nodeEventOnlyForStatistic

public void nodeEventOnlyForStatistic(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent event)

nodeEvent

public void nodeEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent event)

Specified by:

nodeEvent in interface org.ow2.proactive.resourcemanager.frontend.RMEventListener

See Also:

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

setNeededNodes

public void setNeededNodes(int neededNodes)

nodeSourceEvent

public void nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent event)

Specified by:

nodeSourceEvent in interface org.ow2.proactive.resourcemanager.frontend.RMEventListener

See Also:

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

rmEvent

public void rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent event)

Specified by:

rmEvent in interface org.ow2.proactive.resourcemanager.frontend.RMEventListener

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 org.ow2.proactive.resourcemanager.common.event.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 org.ow2.proactive.resourcemanager.frontend.RMMonitoring

Returns:

the current state of the resource manager