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

Field Summary
static org.apache.log4j.Logger runtimeLogger
           
 
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
 

Field Detail

runtimeLogger

public static final org.apache.log4j.Logger runtimeLogger
Method Detail

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.