|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.objectweb.proactive.core.event.AbstractEventProducer | +--org.objectweb.proactive.core.event.RuntimeRegistrationEventProducerImpl | +--org.objectweb.proactive.core.runtime.ProActiveRuntimeImpl
Implementation of ProActiveRuntime
Nested Class Summary | |
protected static class |
ProActiveRuntimeImpl.VMInformationImpl
|
Nested classes inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
AbstractEventProducer.ListenerList |
Field Summary |
Fields inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
eventListeners, logger, shouldSerializeListeners |
Fields inherited from interface org.objectweb.proactive.core.runtime.ProActiveRuntime |
runtimeLogger |
Method Summary | |
UniversalBody |
createBody(java.lang.String nodeName,
ConstructorCall bodyConstructorCall,
boolean isLocal)
This method is the basis for creating remote active objects. |
java.lang.String |
createLocalNode(java.lang.String nodeName,
boolean replacePreviousBinding,
PolicyServer ps,
java.lang.String vnName,
java.lang.String jobId)
Creates a new Node in the same VM as this ProActiveRuntime |
void |
createVM(UniversalProcess remoteProcess)
Creates a new ProActiveRuntime associated with a new VM on the host defined in the given process. |
void |
enableSecurityIfNeeded()
sets all needed modifications to enable security components MUST be called when the descriptor is ready |
java.util.ArrayList |
getActiveObjects(java.lang.String nodeName)
Returns all Active Objects deployed on the node with the given name on this ProActiveRuntime |
java.util.ArrayList |
getActiveObjects(java.lang.String nodeName,
java.lang.String objectName)
Returns all Active Objects with the specified class name, deployed on the node with the given name on this ProActiveRuntime |
java.security.cert.X509Certificate |
getCreatorCertificate()
|
ProActiveDescriptor |
getDescriptor(java.lang.String url)
|
java.util.ArrayList |
getEntities()
|
java.util.ArrayList |
getEntities(java.lang.String nodeName)
|
java.util.ArrayList |
getEntities(UniversalBody uBody)
|
java.lang.String |
getJobID()
|
java.lang.String |
getJobID(java.lang.String nodeUrl)
|
java.lang.String[] |
getLocalNodeNames()
Returns the name of all nodes known by this ProActiveRuntime on this VM |
java.security.cert.X509Certificate |
getNodeCertificate(java.lang.String nodeName)
(non-Javadoc) |
PolicyServer |
getNodePolicyServer(java.lang.String nodeName)
|
PolicyServer |
getPolicyServer()
|
static ProActiveRuntime |
getProActiveRuntime()
|
ProActiveRuntime |
getProActiveRuntime(java.lang.String proActiveRuntimeName)
Returns the ProActiveRuntime of specified name |
ProActiveRuntime[] |
getProActiveRuntimes()
Returns all the ProActiveRuntime registered on this ProActiveRuntime on this VM |
java.lang.String |
getURL()
Returns the url of this ProActiveRuntime on the local or remote VM |
VirtualNode |
getVirtualNode(java.lang.String virtualNodeName)
Returns the VirtualNode with the given name |
VMInformation |
getVMInformation()
Returns the JVM information as one object. |
java.lang.String |
getVNName(java.lang.String nodeName)
|
void |
killAllNodes()
**Under development** Kills all Nodes in this ProActiveRuntime |
void |
killNode(java.lang.String nodeName)
**Under development** Kills the Node of the given name and all Active Objects deployed on it. |
void |
killRT(boolean softly)
Kills this ProActiveRuntime and this VM |
void |
listVirtualNodes()
|
UniversalBody |
receiveBody(java.lang.String nodeName,
Body body)
This method is the basis for migrating active objects. |
void |
register(ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
<<<<<<< ProActiveRuntimeImpl.java |
void |
registerDescriptor(java.lang.String url,
ProActiveDescriptor pad)
|
void |
registerLocalVirtualNode(VirtualNode vn,
java.lang.String vnName)
Register the given VirtualNode on this ProActiveRuntime. |
void |
registerVirtualNode(java.lang.String virtualNodeName,
boolean replacePreviousBinding)
Registers the virtualNode of the given name in a registry such RMIRegistry or Jini Service Lookup |
void |
removeDescriptor(java.lang.String url)
|
void |
setDefaultNodeVirtualNodeName(java.lang.String s)
|
void |
setProActiveSecurityManager(ProActiveSecurityManager server)
set policy server to all virtual nodes |
void |
unregisterAllVirtualNodes()
Unregisters all VirtualNodes from the local runtime |
void |
unregisterVirtualNode(java.lang.String virtualNodeName)
Unregisters the VirtualNode of the given name from the local runtime. |
Methods inherited from class org.objectweb.proactive.core.event.RuntimeRegistrationEventProducerImpl |
addRuntimeRegistrationEventListener, notifyListeners, notifyOneListener, removeRuntimeRegistrationEventListener |
Methods inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
addListener, hasListeners, notifyAllListeners, removeListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
public static ProActiveRuntime getProActiveRuntime()
public void registerLocalVirtualNode(VirtualNode vn, java.lang.String vnName)
vn
- the virtualnode to registerpublic void registerDescriptor(java.lang.String url, ProActiveDescriptor pad)
public ProActiveDescriptor getDescriptor(java.lang.String url)
public void removeDescriptor(java.lang.String url)
public java.lang.String createLocalNode(java.lang.String nodeName, boolean replacePreviousBinding, PolicyServer ps, java.lang.String vnName, java.lang.String jobId) throws NodeException
ProActiveRuntime
createLocalNode
in interface ProActiveRuntime
nodeName
- the name of the node to create localyreplacePreviousBinding
-
NodeException
- if the new node cannot be createdProActiveRuntime.createLocalNode(String, boolean, PolicyServer, String, String)
public void killAllNodes()
ProActiveRuntime
killAllNodes
in interface ProActiveRuntime
ProActiveRuntime.killAllNodes()
public void killNode(java.lang.String nodeName)
ProActiveRuntime
killNode
in interface ProActiveRuntime
nodeName
- the name of the node to killProActiveRuntime.killNode(String)
public void createVM(UniversalProcess remoteProcess) throws java.io.IOException
ProActiveRuntime
createVM
in interface ProActiveRuntime
remoteProcess
- the process that will originate the creation of the runtime
java.io.IOException
- if the new VM cannot be createdProActiveRuntime.createVM(UniversalProcess)
public java.lang.String[] getLocalNodeNames()
ProActiveRuntime
getLocalNodeNames
in interface ProActiveRuntime
ProActiveRuntime.getLocalNodeNames()
public VMInformation getVMInformation()
ProActiveRuntime
getVMInformation
in interface ProActiveRuntime
ProActiveRuntime.getVMInformation()
public void register(ProActiveRuntime proActiveRuntimeDist, java.lang.String proActiveRuntimeName, java.lang.String creatorID, java.lang.String creationProtocol, java.lang.String vmName)
register
in interface ProActiveRuntime
proActiveRuntimeDist
- the remote ProactiveRuntime to registerproActiveRuntimeName
- the name of the remote ProActiveRuntimecreatorID
- the name of the creator of the remote ProActiveRuntimecreationProtocol
- the protocol used to register the remote ProActiveRuntime when created=======
,
>>>>>>> 1.18
public ProActiveRuntime[] getProActiveRuntimes()
ProActiveRuntime
getProActiveRuntimes
in interface ProActiveRuntime
ProActiveRuntime.getProActiveRuntimes()
public ProActiveRuntime getProActiveRuntime(java.lang.String proActiveRuntimeName)
ProActiveRuntime
getProActiveRuntime
in interface ProActiveRuntime
proActiveRuntimeName
- the name of the ProActiveruntime to return
ProActiveRuntime.getProActiveRuntime(String)
public void killRT(boolean softly)
ProActiveRuntime
killRT
in interface ProActiveRuntime
softly
- if false, this Runtime is killed abruptely
if true, if that runtime originates the creation of a rmi registry, it waits until the registry is empty before
dying. To be more precise a thread is created to ask periodically the registry if objects are still
registered.ProActiveRuntime.killRT(boolean)
public java.lang.String getURL()
ProActiveRuntime
getURL
in interface ProActiveRuntime
ProActiveRuntime.getURL()
public java.util.ArrayList getActiveObjects(java.lang.String nodeName)
ProActiveRuntime
getActiveObjects
in interface ProActiveRuntime
nodeName
- the name of the node
public VirtualNode getVirtualNode(java.lang.String virtualNodeName)
ProActiveRuntime
getVirtualNode
in interface ProActiveRuntime
public void registerVirtualNode(java.lang.String virtualNodeName, boolean replacePreviousBinding)
ProActiveRuntime
registerVirtualNode
in interface ProActiveRuntime
virtualNodeName
- public void unregisterVirtualNode(java.lang.String virtualNodeName)
ProActiveRuntime
unregisterVirtualNode
in interface ProActiveRuntime
virtualNodeName
- the virtualNode to unregister.public void unregisterAllVirtualNodes()
ProActiveRuntime
unregisterAllVirtualNodes
in interface ProActiveRuntime
public java.lang.String getJobID(java.lang.String nodeUrl)
getJobID
in interface ProActiveRuntime
ProActiveRuntime.getJobID(java.lang.String)
public java.util.ArrayList getActiveObjects(java.lang.String nodeName, java.lang.String objectName)
ProActiveRuntime
getActiveObjects
in interface ProActiveRuntime
nodeName
- the name of the node
public UniversalBody createBody(java.lang.String nodeName, ConstructorCall bodyConstructorCall, boolean isLocal) throws ConstructorCallExecutionFailedException, java.lang.reflect.InvocationTargetException
ProActiveRuntime
This method is the basis for creating remote active objects.
It receives a ConstructorCall
that is the constructor call of the body
of the active object to create. Inside the parameters of this constructor call is
the constructor call of the reified object. Upon execution of the constructor call of the
body, the body holding a reference on the reified object will get created and returned.
The method returns a reference on the RMI stub of the newly created body.
createBody
in interface ProActiveRuntime
nodeName
- the name of the node the newly created active object will be associated tobodyConstructorCall
- the Constructor call allowing to create the bodyisLocal
- boolean. True if proxy and body are on the same vm, false otherwise
ConstructorCallExecutionFailedException
- if the constructor call cannot be executed
java.lang.reflect.InvocationTargetException
- if the java constructor execution failedProActiveRuntime.createBody(String, ConstructorCall, boolean)
public UniversalBody receiveBody(java.lang.String nodeName, Body body)
ProActiveRuntime
This method is the basis for migrating active objects.
It receives a Body
that embbeds the reified object and its graph of
passive objects. Once transfered remotely using serialization, the body should restart
itself and perform all updates needed to be functionning.
The method returns a reference on the RMI stub of the migrated body.
receiveBody
in interface ProActiveRuntime
nodeName
- the name of the node the newly created active object will be associated tobody
- the body of the active object migrating to this node.
ProActiveRuntime.receiveBody(String, Body)
public java.security.cert.X509Certificate getCreatorCertificate()
getCreatorCertificate
in interface ProActiveRuntime
public PolicyServer getPolicyServer()
getPolicyServer
in interface ProActiveRuntime
public java.lang.String getVNName(java.lang.String nodeName)
getVNName
in interface ProActiveRuntime
public void setProActiveSecurityManager(ProActiveSecurityManager server)
setProActiveSecurityManager
in interface ProActiveRuntime
public void setDefaultNodeVirtualNodeName(java.lang.String s)
setDefaultNodeVirtualNodeName
in interface ProActiveRuntime
public void listVirtualNodes()
listVirtualNodes
in interface ProActiveRuntime
public PolicyServer getNodePolicyServer(java.lang.String nodeName)
getNodePolicyServer
in interface ProActiveRuntime
public void enableSecurityIfNeeded()
ProActiveRuntime
enableSecurityIfNeeded
in interface ProActiveRuntime
public java.security.cert.X509Certificate getNodeCertificate(java.lang.String nodeName)
getNodeCertificate
in interface ProActiveRuntime
nodeName
-
ProActiveRuntime.getNodeCertificate(java.lang.String)
public java.util.ArrayList getEntities(java.lang.String nodeName)
getEntities
in interface ProActiveRuntime
nodeName
-
public java.util.ArrayList getEntities(UniversalBody uBody)
getEntities
in interface ProActiveRuntime
public java.util.ArrayList getEntities()
getEntities
in interface ProActiveRuntime
public java.lang.String getJobID()
getJobID
in interface Job
Job.getJobID()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |