orca.cod.plugins
Class CodBasePlugin

java.lang.Object
  orca.shirako.plugins.ShirakoPlugin
      orca.cod.plugins.CodBasePlugin

All Implemented Interfaces:

IInitialize, IRecover, ISerialize, IShirakoPlugin

Direct Known Subclasses:

ServiceManagerCodPlugin, Site

public abstract class CodBasePlugin
extends ShirakoPlugin

Field Summary

static int	LocationTransferInComplete
protected ConfigurationPropertiesMapper	propertiesMapper

Fields inherited from class orca.shirako.plugins.ShirakoPlugin

actor, config, db, factories, keystoreManager, logger, PropertyConfig, PropertyConfigClass, PropertyDatabase, PropertyDatabaseClass

Constructor Summary

CodBasePlugin()

Method Summary

Slice	createSlice(SliceID sliceID, java.lang.String name, ResourceData properties, java.lang.Object other) Slice factory.
protected abstract java.util.Properties	getConfigurationProperties(ResourceReservation reservation, Node node)
void	initialize() Initialization handler
protected void	loadFactories() Populates the factories list.
protected void	makeAndAttachCopy(Node node) Prepares properties to be passed down to the configuration engine.
void	modify(ResourceReservation reservation, Node node)
protected void	notify(int id, IReservation r) Raises the specified event
void	probe(ResourceReservation reservation, Node node)
protected void	processJoinComplete(java.lang.Object token, java.util.Properties properties) Callback handler for a completing join request
protected void	processLeaveComplete(java.lang.Object token, java.util.Properties properties) Callback handler for a completing leave request.
protected void	processModifyComplete(java.lang.Object token, java.util.Properties properties)
protected void	processProbeComplete(java.lang.Object token, java.util.Properties properties) Callback handler for a completing probe request
protected void	processRecoverComplete(java.lang.Object token, java.util.Properties properties) Deprecated.
protected void	processSavedProperties(Node node, java.util.Properties p)
void	recover(ResourceReservation reservation, Node node)
void	reset() Refreshes the actor
void	restartConfigurationActions(ResourceReservation r) Restarts any pending configuration actions for the specified reservation
void	restartConfigurationActions(ResourceReservation r, NodeGroup group)
void	setConfigMapUrl(java.lang.String url) Sets the configuration map location
void	transferIn(ResourceReservation reservation, Node node)
void	transferOut(ResourceReservation reservation, Node node)

Methods inherited from class orca.shirako.plugins.ShirakoPlugin

actorAdded, configurationComplete, getActor, getConfig, getDatabase, getFactory, getKeyStore, getLogger, getResultCode, initializeKeyStore, releaseSlice, reset, revisit, revisit, revisit, save, save, setActor, setConfig, setDatabase, setLogger, validateIncoming

Methods inherited from class java.lang.Object

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

Field Detail

LocationTransferInComplete

public static final int LocationTransferInComplete

See Also:

Constant Field Values

propertiesMapper

protected ConfigurationPropertiesMapper propertiesMapper

Constructor Detail

CodBasePlugin

public CodBasePlugin()

Method Detail

initialize

public void initialize()
                throws java.lang.Exception

Initialization handler

Specified by:

initialize in interface IInitialize

Overrides:

initialize in class ShirakoPlugin

Throws:

java.lang.Exception

restartConfigurationActions

public void restartConfigurationActions(ResourceReservation r)
                                 throws java.lang.Exception

Description copied from interface: IShirakoPlugin

Restarts any pending configuration actions for the specified reservation

Specified by:

restartConfigurationActions in interface IShirakoPlugin

Overrides:

restartConfigurationActions in class ShirakoPlugin

Parameters:

r - reservation

Throws:

java.lang.Exception

restartConfigurationActions

public void restartConfigurationActions(ResourceReservation r,
                                        NodeGroup group)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

processJoinComplete

protected void processJoinComplete(java.lang.Object token,
                                   java.util.Properties properties)

Description copied from class: ShirakoPlugin

Callback handler for a completing join request

Overrides:

processJoinComplete in class ShirakoPlugin

processLeaveComplete

protected void processLeaveComplete(java.lang.Object token,
                                    java.util.Properties properties)

Description copied from class: ShirakoPlugin

Callback handler for a completing leave request.

Overrides:

processLeaveComplete in class ShirakoPlugin

processModifyComplete

protected void processModifyComplete(java.lang.Object token,
                                     java.util.Properties properties)

Overrides:

processModifyComplete in class ShirakoPlugin

processProbeComplete

protected void processProbeComplete(java.lang.Object token,
                                    java.util.Properties properties)

Description copied from class: ShirakoPlugin

Callback handler for a completing probe request

Overrides:

processProbeComplete in class ShirakoPlugin

processRecoverComplete

@Deprecated
protected void processRecoverComplete(java.lang.Object token,
                                                 java.util.Properties properties)

Deprecated.

Description copied from class: ShirakoPlugin

Callback handler for a completing recover crequest

Overrides:

processRecoverComplete in class ShirakoPlugin

createSlice

public Slice createSlice(SliceID sliceID,
                         java.lang.String name,
                         ResourceData properties,
                         java.lang.Object other)
                  throws java.lang.Exception

Description copied from class: ShirakoPlugin

Slice factory. Called on the server side to create a slice object for a new client.

Specified by:

createSlice in interface IShirakoPlugin

Overrides:

createSlice in class ShirakoPlugin

Parameters:

sliceID - guid for the slice

name - name for the slice

properties - properties for the slice

other - other relevant information

Returns:

a slice object

Throws:

java.lang.Exception

getConfigurationProperties

protected abstract java.util.Properties getConfigurationProperties(ResourceReservation reservation,
                                                                   Node node)
                                                            throws java.lang.Exception

Throws:

java.lang.Exception

makeAndAttachCopy

protected void makeAndAttachCopy(Node node)
                          throws java.lang.Exception

Prepares properties to be passed down to the configuration engine. Extracts properties from the reservation, slice, and node and maps them to configuration properties.

Parameters:

reservation -

node -

Throws:

java.lang.Exception

processSavedProperties

protected void processSavedProperties(Node node,
                                      java.util.Properties p)

notify

protected void notify(int id,
                      IReservation r)
               throws java.lang.Exception

Raises the specified event

Parameters:

id - event id

r - reservation this event is associated with

Throws:

java.lang.Exception

transferIn

public void transferIn(ResourceReservation reservation,
                       Node node)
                throws java.lang.Exception

Throws:

java.lang.Exception

transferOut

public void transferOut(ResourceReservation reservation,
                        Node node)
                 throws java.lang.Exception

Throws:

java.lang.Exception

modify

public void modify(ResourceReservation reservation,
                   Node node)
            throws java.lang.Exception

Throws:

java.lang.Exception

probe

public void probe(ResourceReservation reservation,
                  Node node)
           throws java.lang.Exception

Throws:

java.lang.Exception

recover

public void recover(ResourceReservation reservation,
                    Node node)
             throws java.lang.Exception

Throws:

java.lang.Exception

reset

public void reset()
           throws java.lang.Exception

Description copied from class: ShirakoPlugin

Refreshes the actor

Specified by:

reset in interface IShirakoPlugin

Overrides:

reset in class ShirakoPlugin

Throws:

java.lang.Exception

loadFactories

protected void loadFactories()
                      throws java.lang.Exception

Description copied from class: ShirakoPlugin

Populates the factories list. Override if different factories

Overrides:

loadFactories in class ShirakoPlugin

Throws:

java.lang.Exception

setConfigMapUrl

public void setConfigMapUrl(java.lang.String url)

Sets the configuration map location

Parameters:

url -