org.objectweb.proactive.core.runtime.jini
Class JiniRuntimeImpl
java.lang.Object
java.rmi.server.RemoteObject
java.rmi.server.RemoteServer
java.rmi.server.UnicastRemoteObject
org.objectweb.proactive.core.runtime.jini.JiniRuntimeImpl
- All Implemented Interfaces:
- net.jini.discovery.DiscoveryListener, java.util.EventListener, JiniRuntime, net.jini.lease.LeaseListener, java.rmi.Remote, java.io.Serializable
- public class JiniRuntimeImpl
- extends java.rmi.server.UnicastRemoteObject
- implements JiniRuntime, java.io.Serializable, net.jini.discovery.DiscoveryListener, net.jini.lease.LeaseListener
An adapter for a ProActiveRuntime to be able to receive remote calls. This helps isolate JINI-specific
code into a small set of specific classes, thus enabling reuse if we one day decide to switch
to anothe remote objects library.
- See Also:
- Adapter Pattern,
Serialized Form
Fields inherited from class java.rmi.server.RemoteObject |
ref |
Fields inherited from interface org.objectweb.proactive.core.runtime.jini.JiniRuntime |
logger |
Method Summary |
void |
addParent(java.lang.String proActiveRuntimeName)
|
UniversalBody |
createBody(java.lang.String nodeName,
ConstructorCall bodyConstructorCall,
boolean isNodeLocal)
|
java.lang.String |
createLocalNode(java.lang.String nodeName,
boolean replacePreviousBinding,
PolicyServer ps,
java.lang.String vnname,
java.lang.String jobId)
|
void |
createVM(UniversalProcess remoteProcess)
|
void |
discarded(net.jini.discovery.DiscoveryEvent evt)
|
void |
discovered(net.jini.discovery.DiscoveryEvent evt)
|
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)
|
java.util.ArrayList |
getActiveObjects(java.lang.String nodeName,
java.lang.String objectName)
|
java.security.cert.X509Certificate |
getCreatorCertificate()
|
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 nodeUrl)
|
java.lang.String[] |
getLocalNodeNames()
|
java.security.cert.X509Certificate |
getNodeCertificate(java.lang.String nodeName)
|
PolicyServer |
getNodePolicyServer(java.lang.String nodeName)
|
java.lang.String[] |
getParents()
|
SecurityContext |
getPolicy(SecurityContext sc)
|
PolicyServer |
getPolicyServer()
|
ProActiveRuntime |
getProActiveRuntime(java.lang.String proActiveRuntimeName)
|
ProActiveRuntime[] |
getProActiveRuntimes()
|
java.lang.String |
getURL()
|
VirtualNode |
getVirtualNode(java.lang.String virtualNodeName)
|
VMInformation |
getVMInformation()
|
java.lang.String |
getVNName(java.lang.String Nodename)
|
void |
killAllNodes()
|
void |
killNode(java.lang.String nodeName)
|
void |
killRT(boolean softly)
|
protected net.jini.core.lookup.ServiceID |
newServiceID()
|
void |
notify(net.jini.lease.LeaseRenewalEvent evt)
|
UniversalBody |
receiveBody(java.lang.String nodeName,
Body body)
|
void |
register(ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
|
void |
registerVirtualNode(java.lang.String virtualNodeName,
boolean replacePreviousBinding)
|
void |
setDefaultNodeVirtualNodeName(java.lang.String s)
|
void |
setProActiveSecurityManager(ProActiveSecurityManager ps)
|
void |
unregisterAllVirtualNodes()
|
void |
unregisterVirtualNode(java.lang.String virtualNodeName)
|
void |
updateLocalNodeVirtualName()
|
Methods inherited from class java.rmi.server.UnicastRemoteObject |
clone, exportObject, exportObject, exportObject, unexportObject |
Methods inherited from class java.rmi.server.RemoteServer |
getClientHost, getLog, setLog |
Methods inherited from class java.rmi.server.RemoteObject |
equals, getRef, hashCode, toString, toStub |
Methods inherited from class java.lang.Object |
finalize, getClass, notify, notifyAll, wait, wait, wait |
proActiveRuntime
protected transient ProActiveRuntimeImpl proActiveRuntime
proActiveRuntimeURL
protected java.lang.String proActiveRuntimeURL
registrarsTable
protected java.util.Vector registrarsTable
jiniRuntimeMap
protected java.util.Hashtable jiniRuntimeMap
jiniNodeMap
protected java.util.Hashtable jiniNodeMap
jiniVirtualNodeMap
protected java.util.Hashtable jiniVirtualNodeMap
leaseManager
protected transient net.jini.lease.LeaseRenewalManager leaseManager
JiniRuntimeImpl
public JiniRuntimeImpl()
throws java.rmi.RemoteException
createLocalNode
public java.lang.String createLocalNode(java.lang.String nodeName,
boolean replacePreviousBinding,
PolicyServer ps,
java.lang.String vnname,
java.lang.String jobId)
throws java.rmi.RemoteException,
NodeException
- Specified by:
createLocalNode
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
NodeException
killAllNodes
public void killAllNodes()
throws java.rmi.RemoteException
- Specified by:
killAllNodes
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
killNode
public void killNode(java.lang.String nodeName)
throws java.rmi.RemoteException
- Specified by:
killNode
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
createVM
public void createVM(UniversalProcess remoteProcess)
throws java.io.IOException
- Specified by:
createVM
in interface JiniRuntime
- Throws:
java.io.IOException
getLocalNodeNames
public java.lang.String[] getLocalNodeNames()
- Specified by:
getLocalNodeNames
in interface JiniRuntime
getVMInformation
public VMInformation getVMInformation()
- Specified by:
getVMInformation
in interface JiniRuntime
register
public void register(ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
- Specified by:
register
in interface JiniRuntime
getProActiveRuntimes
public ProActiveRuntime[] getProActiveRuntimes()
- Specified by:
getProActiveRuntimes
in interface JiniRuntime
getProActiveRuntime
public ProActiveRuntime getProActiveRuntime(java.lang.String proActiveRuntimeName)
- Specified by:
getProActiveRuntime
in interface JiniRuntime
addParent
public void addParent(java.lang.String proActiveRuntimeName)
- Specified by:
addParent
in interface JiniRuntime
getParents
public java.lang.String[] getParents()
- Specified by:
getParents
in interface JiniRuntime
killRT
public void killRT(boolean softly)
throws java.rmi.RemoteException
- Specified by:
killRT
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
getURL
public java.lang.String getURL()
- Specified by:
getURL
in interface JiniRuntime
getActiveObjects
public java.util.ArrayList getActiveObjects(java.lang.String nodeName)
- Specified by:
getActiveObjects
in interface JiniRuntime
getActiveObjects
public java.util.ArrayList getActiveObjects(java.lang.String nodeName,
java.lang.String objectName)
- Specified by:
getActiveObjects
in interface JiniRuntime
getVirtualNode
public VirtualNode getVirtualNode(java.lang.String virtualNodeName)
- Specified by:
getVirtualNode
in interface JiniRuntime
registerVirtualNode
public void registerVirtualNode(java.lang.String virtualNodeName,
boolean replacePreviousBinding)
throws java.rmi.RemoteException
- Specified by:
registerVirtualNode
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
unregisterVirtualNode
public void unregisterVirtualNode(java.lang.String virtualNodeName)
throws java.rmi.RemoteException
- Specified by:
unregisterVirtualNode
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
unregisterAllVirtualNodes
public void unregisterAllVirtualNodes()
throws java.rmi.RemoteException
- Specified by:
unregisterAllVirtualNodes
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
createBody
public UniversalBody createBody(java.lang.String nodeName,
ConstructorCall bodyConstructorCall,
boolean isNodeLocal)
throws ConstructorCallExecutionFailedException,
java.lang.reflect.InvocationTargetException
- Specified by:
createBody
in interface JiniRuntime
- Throws:
ConstructorCallExecutionFailedException
java.lang.reflect.InvocationTargetException
receiveBody
public UniversalBody receiveBody(java.lang.String nodeName,
Body body)
- Specified by:
receiveBody
in interface JiniRuntime
discovered
public void discovered(net.jini.discovery.DiscoveryEvent evt)
- Specified by:
discovered
in interface net.jini.discovery.DiscoveryListener
discarded
public void discarded(net.jini.discovery.DiscoveryEvent evt)
- Specified by:
discarded
in interface net.jini.discovery.DiscoveryListener
notify
public void notify(net.jini.lease.LeaseRenewalEvent evt)
- Specified by:
notify
in interface net.jini.lease.LeaseListener
newServiceID
protected net.jini.core.lookup.ServiceID newServiceID()
getCreatorCertificate
public java.security.cert.X509Certificate getCreatorCertificate()
throws java.rmi.RemoteException
- Specified by:
getCreatorCertificate
in interface JiniRuntime
- Returns:
- creator certificate
- Throws:
java.rmi.RemoteException
getPolicyServer
public PolicyServer getPolicyServer()
throws java.rmi.RemoteException
- Specified by:
getPolicyServer
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
setProActiveSecurityManager
public void setProActiveSecurityManager(ProActiveSecurityManager ps)
throws java.rmi.RemoteException
- Specified by:
setProActiveSecurityManager
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
getVNName
public java.lang.String getVNName(java.lang.String Nodename)
throws java.rmi.RemoteException
- Specified by:
getVNName
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
setDefaultNodeVirtualNodeName
public void setDefaultNodeVirtualNodeName(java.lang.String s)
throws java.rmi.RemoteException
- Specified by:
setDefaultNodeVirtualNodeName
in interface JiniRuntime
- Parameters:
s
-
- Throws:
java.rmi.RemoteException
updateLocalNodeVirtualName
public void updateLocalNodeVirtualName()
throws java.rmi.RemoteException
- Specified by:
updateLocalNodeVirtualName
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
getNodePolicyServer
public PolicyServer getNodePolicyServer(java.lang.String nodeName)
throws java.rmi.RemoteException
- Specified by:
getNodePolicyServer
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
enableSecurityIfNeeded
public void enableSecurityIfNeeded()
throws java.rmi.RemoteException
- Description copied from interface:
JiniRuntime
- sets all needed modifications to enable security components
MUST be called when the descriptor is ready
- Specified by:
enableSecurityIfNeeded
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
getNodeCertificate
public java.security.cert.X509Certificate getNodeCertificate(java.lang.String nodeName)
throws java.rmi.RemoteException
- Specified by:
getNodeCertificate
in interface JiniRuntime
- Parameters:
nodeName
-
- Returns:
- node certificate
- Throws:
java.rmi.RemoteException
getEntities
public java.util.ArrayList getEntities(java.lang.String nodeName)
throws java.rmi.RemoteException
- Specified by:
getEntities
in interface JiniRuntime
- Parameters:
nodeName
-
- Returns:
- returns all entities associated to the node
- Throws:
java.rmi.RemoteException
getEntities
public java.util.ArrayList getEntities(UniversalBody uBody)
throws java.rmi.RemoteException
- Specified by:
getEntities
in interface JiniRuntime
- Parameters:
uBody
-
- Returns:
- returns all entities associated to the node
- Throws:
java.rmi.RemoteException
getEntities
public java.util.ArrayList getEntities()
throws java.rmi.RemoteException
- Specified by:
getEntities
in interface JiniRuntime
- Returns:
- returns all entities associated to this runtime
- Throws:
java.rmi.RemoteException
getPolicy
public SecurityContext getPolicy(SecurityContext sc)
throws SecurityNotAvailableException
- Specified by:
getPolicy
in interface JiniRuntime
- Parameters:
sc
-
- Throws:
SecurityNotAvailableException
getJobID
public java.lang.String getJobID(java.lang.String nodeUrl)
throws java.rmi.RemoteException
- Specified by:
getJobID
in interface JiniRuntime
- Throws:
java.rmi.RemoteException
- See Also:
JiniRuntime.getJobID(java.lang.String)
Copyright ? October 2004 INRIA All Rights Reserved.