org.ow2.proactive.resourcemanager.common.event

Class RMInitialState

java.lang.Object

org.ow2.proactive.resourcemanager.common.event.RMInitialState

All Implemented Interfaces:

Serializable

@PublicAPI
public class RMInitialState
extends Object
implements Serializable

Defines a state of the Resource Manager for a Monitor. In order to receive Resource Manager events, a monitor register itself to RMMonitoring by the method RMMonitoring.addRMEventListener(RMEventListener listener, RMEventType... events), and get an initial state which is the snapshot of Resource Manager state, with its nodes and NodeSources.

Since:

ProActive Scheduling 0.9

See Also:

RMNodeEvent, RMNodeSourceEvent, RMMonitoring, Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static Long	EMPTY_STATE

Constructor Summary

Constructors

Constructor and Description
RMInitialState()

Method Summary

Modifier and Type	Method and Description
void	addAll(Collection<? extends RMEvent> toAdd)
RMStateDelta	cloneAndFilter(long counterKnownByClient) Clones current state events, but keep only those events which has counter bigger than provided 'filter' Event counter can take values [0, +).
RMStateFull	cloneAndFilterNotRemovedOnly() Clones current state events, but keep only those events which was not removed.
long	getLatestCounter()
List<RMNodeEvent>	getNodeEvents()
List<RMNodeSourceEvent>	getNodeSourceEvents()
void	nodeAdded(RMNodeEvent event)
void	nodeRemoved(RMNodeEvent event)
void	nodeSourceAdded(RMNodeSourceEvent event)
void	nodeSourceRemoved(RMNodeSourceEvent event)
void	nodeSourceStateChanged(RMNodeSourceEvent event)
void	nodeStateChanged(RMNodeEvent event)
protected void	update(RMEvent event)

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_STATE

public static final Long EMPTY_STATE

Constructor Detail

RMInitialState

public RMInitialState()

Method Detail

addAll

public void addAll(Collection<? extends RMEvent> toAdd)

getNodeEvents

public List<RMNodeEvent> getNodeEvents()

getNodeSourceEvents

public List<RMNodeSourceEvent> getNodeSourceEvents()

getLatestCounter

public long getLatestCounter()

nodeAdded

public void nodeAdded(RMNodeEvent event)

nodeStateChanged

public void nodeStateChanged(RMNodeEvent event)

nodeRemoved

public void nodeRemoved(RMNodeEvent event)

nodeSourceAdded

public void nodeSourceAdded(RMNodeSourceEvent event)

nodeSourceRemoved

public void nodeSourceRemoved(RMNodeSourceEvent event)

nodeSourceStateChanged

public void nodeSourceStateChanged(RMNodeSourceEvent event)

update

protected void update(RMEvent event)

cloneAndFilter

public RMStateDelta cloneAndFilter(long counterKnownByClient)

Clones current state events, but keep only those events which has counter bigger than provided 'filter' Event counter can take values [0, +). So if filter is '-1' then all events will returned.

Parameters:

counterKnownByClient - latest counter associated with event known by client

Returns:

RMStateDelta where all the events bigger than 'filter'

cloneAndFilterNotRemovedOnly

public RMStateFull cloneAndFilterNotRemovedOnly()

Clones current state events, but keep only those events which was not removed.

Returns:

RMStateFull where all the events are correspond to existing node/nodesources