org.objectweb.proactive.core.runtime
Interface RemoteProActiveRuntimeForwarder
- All Superinterfaces:
- RemoteProActiveRuntime, java.io.Serializable
- All Known Subinterfaces:
- RmiProActiveRuntimeForwarder
- All Known Implementing Classes:
- RmiProActiveRuntimeForwarderImpl
- public interface RemoteProActiveRuntimeForwarder
- extends RemoteProActiveRuntime
An adapter for a ProActiveRuntimeForwarder to be able to receive remote calls. This helps isolate
protocol-specific code into a small set of specific classes, thus enabling reuse when
using another remote objects library.
Implemented protocols are RMI, RMISSH, IBIS, JINI, HTTP
Note that contrary to BodyForwarder a RuntimeForwarder IS a Runtime.
- Author:
- ProActiveTeam
Method Summary |
void |
addAcquaintance(UniqueRuntimeID ruid,
java.lang.String proActiveRuntimeName)
|
UniversalBody |
createBody(UniqueRuntimeID ruid,
java.lang.String nodeName,
ConstructorCall bodyConstructorCall,
boolean isNodeLocal)
|
java.lang.String |
createLocalNode(UniqueRuntimeID ruid,
java.lang.String nodeName,
boolean replacePreviousBinding,
ProActiveSecurityManager psm,
java.lang.String VNname,
java.lang.String jobId)
|
void |
createVM(UniqueRuntimeID ruid,
UniversalProcess remoteProcess)
|
java.lang.String[] |
getAcquaintances(UniqueRuntimeID ruid)
|
java.util.ArrayList |
getActiveObjects(UniqueRuntimeID ruid,
java.lang.String nodeName)
|
java.util.ArrayList |
getActiveObjects(UniqueRuntimeID ruid,
java.lang.String nodeName,
java.lang.String objectName)
|
java.security.cert.X509Certificate |
getCertificate(UniqueRuntimeID ruid)
|
byte[] |
getCertificateEncoded(UniqueRuntimeID ruid)
|
byte[] |
getClassDataFromParentRuntime(UniqueRuntimeID ruid,
java.lang.String className)
|
byte[] |
getClassDataFromThisRuntime(UniqueRuntimeID ruid,
java.lang.String className)
|
ProActiveDescriptor |
getDescriptor(UniqueRuntimeID ruid,
java.lang.String url,
boolean isHierarchicalSearch)
|
java.util.ArrayList |
getEntities(UniqueRuntimeID ruid)
|
java.lang.String |
getJobID(UniqueRuntimeID ruid,
java.lang.String nodeUrl)
|
java.lang.String[] |
getLocalNodeNames(UniqueRuntimeID ruid)
|
SecurityContext |
getPolicy(UniqueRuntimeID ruid,
SecurityContext securityContext)
|
ProActiveRuntime |
getProActiveRuntime(UniqueRuntimeID ruid,
java.lang.String proActiveRuntimeName)
|
ProActiveRuntime[] |
getProActiveRuntimes(UniqueRuntimeID ruid)
|
ExternalProcess |
getProcessToDeploy(UniqueRuntimeID urid,
ProActiveRuntime proActiveRuntimeDist,
java.lang.String creatorID,
java.lang.String vmName,
java.lang.String padURL)
|
java.security.PublicKey |
getPublicKey(UniqueRuntimeID ruid)
|
java.lang.String |
getURL(UniqueRuntimeID ruid)
|
VirtualNode |
getVirtualNode(UniqueRuntimeID ruid,
java.lang.String virtualNodeName)
|
VMInformation |
getVMInformation(UniqueRuntimeID ruid)
|
java.lang.String |
getVNName(UniqueRuntimeID ruid,
java.lang.String Nodename)
|
void |
killAllNodes(UniqueRuntimeID ruid)
|
void |
killNode(UniqueRuntimeID ruid,
java.lang.String nodeName)
|
void |
killRT(UniqueRuntimeID ruid,
boolean softly)
|
void |
launchMain(UniqueRuntimeID ruid,
java.lang.String className,
java.lang.String[] parameters)
|
void |
newRemote(UniqueRuntimeID ruid,
java.lang.String className)
|
byte[][] |
publicKeyExchange(UniqueRuntimeID ruid,
long sessionID,
byte[] myPublicKey,
byte[] myCertificate,
byte[] signature)
|
byte[] |
randomValue(UniqueRuntimeID ruid,
long sessionID,
byte[] clientRandomValue)
|
UniversalBody |
receiveBody(UniqueRuntimeID ruid,
java.lang.String nodeName,
Body body)
|
UniversalBody |
receiveCheckpoint(UniqueRuntimeID ruid,
java.lang.String nodeName,
Checkpoint ckpt,
int inc)
|
void |
register(UniqueRuntimeID ruid,
ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
|
void |
registerVirtualNode(UniqueRuntimeID ruid,
java.lang.String virtualNodeName,
boolean replacePreviousBinding)
|
void |
rmAcquaintance(UniqueRuntimeID ruid,
java.lang.String proActiveRuntimeName)
|
byte[][] |
secretKeyExchange(UniqueRuntimeID ruid,
long sessionID,
byte[] encodedAESKey,
byte[] encodedIVParameters,
byte[] encodedClientMacKey,
byte[] encodedLockData,
byte[] parametersSignature)
|
long |
startNewSession(UniqueRuntimeID ruid,
Communication policy)
|
void |
terminateSession(UniqueRuntimeID ruid,
long sessionID)
|
void |
unregister(UniqueRuntimeID ruid,
ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
|
void |
unregisterAllVirtualNodes(UniqueRuntimeID ruid)
|
void |
unregisterVirtualNode(UniqueRuntimeID ruid,
java.lang.String virtualNodeName)
|
Methods inherited from interface org.objectweb.proactive.core.runtime.RemoteProActiveRuntime |
addAcquaintance, createBody, createLocalNode, createVM, getAcquaintances, getActiveObjects, getActiveObjects, getCertificate, getCertificateEncoded, getClassDataFromParentRuntime, getClassDataFromThisRuntime, getDescriptor, getEntities, getJobID, getLocalNodeNames, getPolicy, getProActiveRuntime, getProActiveRuntimes, getProcessToDeploy, getPublicKey, getURL, getVirtualNode, getVMInformation, getVNName, killAllNodes, killNode, killRT, launchMain, newRemote, publicKeyExchange, randomValue, receiveBody, receiveCheckpoint, register, registerVirtualNode, rmAcquaintance, secretKeyExchange, startNewSession, terminateSession, unregister, unregisterAllVirtualNodes, unregisterVirtualNode |
runtimeLogger
public static final org.apache.log4j.Logger runtimeLogger
createLocalNode
public java.lang.String createLocalNode(UniqueRuntimeID ruid,
java.lang.String nodeName,
boolean replacePreviousBinding,
ProActiveSecurityManager psm,
java.lang.String VNname,
java.lang.String jobId)
throws java.io.IOException,
NodeException
- Throws:
java.io.IOException
NodeException
killAllNodes
public void killAllNodes(UniqueRuntimeID ruid)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
killNode
public void killNode(UniqueRuntimeID ruid,
java.lang.String nodeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
createVM
public void createVM(UniqueRuntimeID ruid,
UniversalProcess remoteProcess)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getLocalNodeNames
public java.lang.String[] getLocalNodeNames(UniqueRuntimeID ruid)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getVMInformation
public VMInformation getVMInformation(UniqueRuntimeID ruid)
throws java.io.IOException
- Throws:
java.io.IOException
register
public void register(UniqueRuntimeID ruid,
ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
unregister
public void unregister(UniqueRuntimeID ruid,
ProActiveRuntime proActiveRuntimeDist,
java.lang.String proActiveRuntimeName,
java.lang.String creatorID,
java.lang.String creationProtocol,
java.lang.String vmName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getProActiveRuntimes
public ProActiveRuntime[] getProActiveRuntimes(UniqueRuntimeID ruid)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getProActiveRuntime
public ProActiveRuntime getProActiveRuntime(UniqueRuntimeID ruid,
java.lang.String proActiveRuntimeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
addAcquaintance
public void addAcquaintance(UniqueRuntimeID ruid,
java.lang.String proActiveRuntimeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getAcquaintances
public java.lang.String[] getAcquaintances(UniqueRuntimeID ruid)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
rmAcquaintance
public void rmAcquaintance(UniqueRuntimeID ruid,
java.lang.String proActiveRuntimeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
killRT
public void killRT(UniqueRuntimeID ruid,
boolean softly)
throws java.lang.Exception
- Throws:
java.lang.Exception
getURL
public java.lang.String getURL(UniqueRuntimeID ruid)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getActiveObjects
public java.util.ArrayList getActiveObjects(UniqueRuntimeID ruid,
java.lang.String nodeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getActiveObjects
public java.util.ArrayList getActiveObjects(UniqueRuntimeID ruid,
java.lang.String nodeName,
java.lang.String objectName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getVirtualNode
public VirtualNode getVirtualNode(UniqueRuntimeID ruid,
java.lang.String virtualNodeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
registerVirtualNode
public void registerVirtualNode(UniqueRuntimeID ruid,
java.lang.String virtualNodeName,
boolean replacePreviousBinding)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
unregisterVirtualNode
public void unregisterVirtualNode(UniqueRuntimeID ruid,
java.lang.String virtualNodeName)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
unregisterAllVirtualNodes
public void unregisterAllVirtualNodes(UniqueRuntimeID ruid)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getJobID
public java.lang.String getJobID(UniqueRuntimeID ruid,
java.lang.String nodeUrl)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
createBody
public UniversalBody createBody(UniqueRuntimeID ruid,
java.lang.String nodeName,
ConstructorCall bodyConstructorCall,
boolean isNodeLocal)
throws java.io.IOException,
ConstructorCallExecutionFailedException,
java.lang.reflect.InvocationTargetException,
ProActiveException
- Throws:
java.io.IOException
ConstructorCallExecutionFailedException
java.lang.reflect.InvocationTargetException
ProActiveException
receiveBody
public UniversalBody receiveBody(UniqueRuntimeID ruid,
java.lang.String nodeName,
Body body)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
receiveCheckpoint
public UniversalBody receiveCheckpoint(UniqueRuntimeID ruid,
java.lang.String nodeName,
Checkpoint ckpt,
int inc)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getProcessToDeploy
public ExternalProcess getProcessToDeploy(UniqueRuntimeID urid,
ProActiveRuntime proActiveRuntimeDist,
java.lang.String creatorID,
java.lang.String vmName,
java.lang.String padURL)
throws ProActiveException,
java.io.IOException
- Throws:
ProActiveException
java.io.IOException
getClassDataFromParentRuntime
public byte[] getClassDataFromParentRuntime(UniqueRuntimeID ruid,
java.lang.String className)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
- See Also:
ProActiveRuntime.getClassDataFromParentRuntime(String)
getClassDataFromThisRuntime
public byte[] getClassDataFromThisRuntime(UniqueRuntimeID ruid,
java.lang.String className)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
- See Also:
ProActiveRuntime.getClassDataFromThisRuntime(String)
getDescriptor
public ProActiveDescriptor getDescriptor(UniqueRuntimeID ruid,
java.lang.String url,
boolean isHierarchicalSearch)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
getCertificate
public java.security.cert.X509Certificate getCertificate(UniqueRuntimeID ruid)
throws SecurityNotAvailableException,
java.io.IOException
- Throws:
SecurityNotAvailableException
java.io.IOException
startNewSession
public long startNewSession(UniqueRuntimeID ruid,
Communication policy)
throws SecurityNotAvailableException,
RenegotiateSessionException,
java.io.IOException
- Throws:
SecurityNotAvailableException
RenegotiateSessionException
java.io.IOException
getPublicKey
public java.security.PublicKey getPublicKey(UniqueRuntimeID ruid)
throws SecurityNotAvailableException,
java.io.IOException
- Throws:
SecurityNotAvailableException
java.io.IOException
randomValue
public byte[] randomValue(UniqueRuntimeID ruid,
long sessionID,
byte[] clientRandomValue)
throws SecurityNotAvailableException,
RenegotiateSessionException,
java.io.IOException
- Throws:
SecurityNotAvailableException
RenegotiateSessionException
java.io.IOException
publicKeyExchange
public byte[][] publicKeyExchange(UniqueRuntimeID ruid,
long sessionID,
byte[] myPublicKey,
byte[] myCertificate,
byte[] signature)
throws SecurityNotAvailableException,
RenegotiateSessionException,
KeyExchangeException,
java.io.IOException
- Throws:
SecurityNotAvailableException
RenegotiateSessionException
KeyExchangeException
java.io.IOException
secretKeyExchange
public byte[][] secretKeyExchange(UniqueRuntimeID ruid,
long sessionID,
byte[] encodedAESKey,
byte[] encodedIVParameters,
byte[] encodedClientMacKey,
byte[] encodedLockData,
byte[] parametersSignature)
throws SecurityNotAvailableException,
RenegotiateSessionException,
java.io.IOException
- Throws:
SecurityNotAvailableException
RenegotiateSessionException
java.io.IOException
getPolicy
public SecurityContext getPolicy(UniqueRuntimeID ruid,
SecurityContext securityContext)
throws SecurityNotAvailableException,
java.io.IOException
- Throws:
SecurityNotAvailableException
java.io.IOException
getCertificateEncoded
public byte[] getCertificateEncoded(UniqueRuntimeID ruid)
throws SecurityNotAvailableException,
java.io.IOException
- Throws:
SecurityNotAvailableException
java.io.IOException
getEntities
public java.util.ArrayList getEntities(UniqueRuntimeID ruid)
throws SecurityNotAvailableException,
java.io.IOException
- Throws:
SecurityNotAvailableException
java.io.IOException
terminateSession
public void terminateSession(UniqueRuntimeID ruid,
long sessionID)
throws java.io.IOException,
SecurityNotAvailableException
- Throws:
java.io.IOException
SecurityNotAvailableException
getVNName
public java.lang.String getVNName(UniqueRuntimeID ruid,
java.lang.String Nodename)
throws java.io.IOException,
ProActiveException
- Throws:
java.io.IOException
ProActiveException
launchMain
public void launchMain(UniqueRuntimeID ruid,
java.lang.String className,
java.lang.String[] parameters)
throws java.io.IOException,
java.lang.ClassNotFoundException,
java.lang.NoSuchMethodException,
ProActiveException
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
java.lang.NoSuchMethodException
ProActiveException
newRemote
public void newRemote(UniqueRuntimeID ruid,
java.lang.String className)
throws java.io.IOException,
java.lang.ClassNotFoundException,
ProActiveException
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
ProActiveException
Copyright 2001-2005 INRIA All Rights Reserved.