org.objectweb.proactive.core.runtime
Interface ProActiveRuntimeForwarder

All Superinterfaces:
Job, ProActiveRuntime, SecurityEntity
All Known Implementing Classes:
ProActiveRuntimeForwarderImpl

public interface ProActiveRuntimeForwarder
extends ProActiveRuntime

A ProActiveRuntimeForwarder is a ProActiveRuntime and a forwarder. All ProActiveRuntime methods are inherited, and for each inherited a new one with the same name, the same return type, same arguments, but prefixed by an argument of type UniqueRuntimeID is defined. When a method inherited from ProActiveRuntime is called a forwarder behave like a normal runtime, it's a normal runtime. When a prefixed method is called, the prefix argument is used to forward the call to the right runtime. To perform the dispatch a forwarder uses a HashTable , which is filled during deserialization of ProActiveRuntimeAdapter objects. Check org.objectweb.proactive.core.runtime.ProActiveRuntimeAdapterForwarderImpl#readObject(java.io.ObjectInputStream)

Author:
ProActive Team
See Also:
ProActiveRuntimeAdapterImpl.readResolve()

Field Summary
static org.apache.log4j.Logger runtimeLogger
           
 
Method Summary
 void addAcquaintance(UniqueRuntimeID urid, java.lang.String proActiveRuntimeName)
           
 UniversalBody createBody(UniqueRuntimeID urid, java.lang.String nodeName, ConstructorCall bodyConstructorCall, boolean isNodeLocal)
           
 java.lang.String createLocalNode(UniqueRuntimeID urid, java.lang.String nodeName, boolean replacePreviousBinding, ProActiveSecurityManager psm, java.lang.String vnName, java.lang.String jobId)
           
 void createVM(UniqueRuntimeID urid, UniversalProcess remoteProcess)
           
 java.lang.String[] getAcquaintances(UniqueRuntimeID urid)
           
 java.util.ArrayList getActiveObjects(UniqueRuntimeID urid, java.lang.String nodeName)
           
 java.util.ArrayList getActiveObjects(UniqueRuntimeID urid, java.lang.String nodeName, java.lang.String className)
           
 java.security.cert.X509Certificate getCertificate(UniqueRuntimeID urid)
           
 byte[] getCertificateEncoded(UniqueRuntimeID urid)
           
 byte[] getClassDataFromParentRuntime(UniqueRuntimeID urid, java.lang.String className)
           
 byte[] getClassDataFromThisRuntime(UniqueRuntimeID urid, java.lang.String className)
           
 ProActiveDescriptor getDescriptor(UniqueRuntimeID urid, java.lang.String url, boolean isHierarchicalSearch)
           
 java.util.ArrayList getEntities(UniqueRuntimeID urid)
           
 java.lang.String getJobID(UniqueRuntimeID urid)
           
 java.lang.String getJobID(UniqueRuntimeID urid, java.lang.String nodeUrl)
           
 java.lang.String[] getLocalNodeNames(UniqueRuntimeID urid)
           
 SecurityContext getPolicy(UniqueRuntimeID urid, SecurityContext securityContext)
           
 ProActiveRuntime getProActiveRuntime(UniqueRuntimeID urid, java.lang.String proActiveRuntimeName)
           
 ProActiveRuntime[] getProActiveRuntimes(UniqueRuntimeID urid)
           
 ExternalProcess getProcessToDeploy(UniqueRuntimeID urid, ProActiveRuntime proActiveRuntimeDist, java.lang.String creatorID, java.lang.String vmName, java.lang.String padURL)
           
 java.security.PublicKey getPublicKey(UniqueRuntimeID urid)
           
 java.lang.String getURL(UniqueRuntimeID urid)
           
 VirtualNode getVirtualNode(UniqueRuntimeID urid, java.lang.String virtualNodeName)
           
 VMInformation getVMInformation(UniqueRuntimeID urid)
           
 java.lang.String getVNName(UniqueRuntimeID urid, java.lang.String Nodename)
           
 void killAllNodes(UniqueRuntimeID urid)
           
 void killNode(UniqueRuntimeID urid, java.lang.String nodeName)
           
 void killRT(UniqueRuntimeID urid, boolean softly)
           
 void launchMain(UniqueRuntimeID urid, java.lang.String className, java.lang.String[] parameters)
           
 void newRemote(UniqueRuntimeID urid, java.lang.String className)
           
 byte[][] publicKeyExchange(UniqueRuntimeID urid, long sessionID, byte[] myPublicKey, byte[] myCertificate, byte[] signature)
           
 byte[] randomValue(UniqueRuntimeID urid, long sessionID, byte[] clientRandomValue)
           
 UniversalBody receiveBody(UniqueRuntimeID urid, java.lang.String nodeName, Body body)
           
 UniversalBody receiveCheckpoint(UniqueRuntimeID urid, java.lang.String nodeName, Checkpoint ckpt, int inc)
           
 void register(UniqueRuntimeID urid, ProActiveRuntime proActiveRuntimeDist, java.lang.String proActiveRuntimeUrl, java.lang.String creatorID, java.lang.String creationProtocol, java.lang.String vmName)
           
 void registerVirtualNode(UniqueRuntimeID urid, java.lang.String virtualNodeName, boolean replacePreviousBinding)
           
 void rmAcquaintance(UniqueRuntimeID urid, java.lang.String proActiveRuntimeName)
           
 byte[][] secretKeyExchange(UniqueRuntimeID urid, long sessionID, byte[] encodedAESKey, byte[] encodedIVParameters, byte[] encodedClientMacKey, byte[] encodedLockData, byte[] parametersSignature)
           
 long startNewSession(UniqueRuntimeID urid, Communication policy)
           
 void terminateSession(UniqueRuntimeID urid, long sessionID)
           
 void unregister(UniqueRuntimeID urid, ProActiveRuntime proActiveRuntimeDist, java.lang.String proActiveRuntimeUrl, java.lang.String creatorID, java.lang.String creationProtocol, java.lang.String vmName)
           
 void unregisterAllVirtualNodes(UniqueRuntimeID urid)
           
 void unregisterVirtualNode(UniqueRuntimeID urid, java.lang.String virtualNodeName)
           
 
Methods inherited from interface org.objectweb.proactive.core.runtime.ProActiveRuntime
addAcquaintance, createBody, createLocalNode, createVM, getAcquaintances, getActiveObjects, getActiveObjects, getClassDataFromParentRuntime, getClassDataFromThisRuntime, getDescriptor, getJobID, getLocalNodeNames, getProActiveRuntime, getProActiveRuntimes, getProcessToDeploy, getURL, getVirtualNode, getVMInformation, getVNName, killAllNodes, killNode, killRT, launchMain, newRemote, receiveBody, receiveCheckpoint, register, registerVirtualNode, rmAcquaintance, unregister, unregisterAllVirtualNodes, unregisterVirtualNode
 
Methods inherited from interface org.objectweb.proactive.Job
getJobID
 
Methods inherited from interface org.objectweb.proactive.ext.security.SecurityEntity
getCertificate, getCertificateEncoded, getEntities, getPolicy, getPublicKey, publicKeyExchange, randomValue, secretKeyExchange, startNewSession, terminateSession
 

Field Detail

runtimeLogger

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

createLocalNode

public java.lang.String createLocalNode(UniqueRuntimeID urid,
                                        java.lang.String nodeName,
                                        boolean replacePreviousBinding,
                                        ProActiveSecurityManager psm,
                                        java.lang.String vnName,
                                        java.lang.String jobId)
                                 throws NodeException
Throws:
NodeException
See Also:
ProActiveRuntime.createLocalNode(String, boolean, ProActiveSecurityManager, String, String)

killAllNodes

public void killAllNodes(UniqueRuntimeID urid)
                  throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.killAllNodes()

killNode

public void killNode(UniqueRuntimeID urid,
                     java.lang.String nodeName)
              throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.killNode(String)

createVM

public void createVM(UniqueRuntimeID urid,
                     UniversalProcess remoteProcess)
              throws java.io.IOException,
                     ProActiveException
Throws:
java.io.IOException
ProActiveException
See Also:
ProActiveRuntime.createVM(UniversalProcess)

getLocalNodeNames

public java.lang.String[] getLocalNodeNames(UniqueRuntimeID urid)
                                     throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getLocalNodeNames()

getVMInformation

public VMInformation getVMInformation(UniqueRuntimeID urid)
See Also:
ProActiveRuntime.getVMInformation()

register

public void register(UniqueRuntimeID urid,
                     ProActiveRuntime proActiveRuntimeDist,
                     java.lang.String proActiveRuntimeUrl,
                     java.lang.String creatorID,
                     java.lang.String creationProtocol,
                     java.lang.String vmName)
              throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.register(ProActiveRuntime, String, String, String, String)

unregister

public void unregister(UniqueRuntimeID urid,
                       ProActiveRuntime proActiveRuntimeDist,
                       java.lang.String proActiveRuntimeUrl,
                       java.lang.String creatorID,
                       java.lang.String creationProtocol,
                       java.lang.String vmName)
                throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.unregister(ProActiveRuntime, String, String, String, String)

getProActiveRuntimes

public ProActiveRuntime[] getProActiveRuntimes(UniqueRuntimeID urid)
                                        throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getProActiveRuntimes()

getProActiveRuntime

public ProActiveRuntime getProActiveRuntime(UniqueRuntimeID urid,
                                            java.lang.String proActiveRuntimeName)
                                     throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getProActiveRuntime(String)

addAcquaintance

public void addAcquaintance(UniqueRuntimeID urid,
                            java.lang.String proActiveRuntimeName)
                     throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.addAcquaintance(String)

getAcquaintances

public java.lang.String[] getAcquaintances(UniqueRuntimeID urid)
                                    throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getAcquaintances()

rmAcquaintance

public void rmAcquaintance(UniqueRuntimeID urid,
                           java.lang.String proActiveRuntimeName)
                    throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.rmAcquaintance(String)

killRT

public void killRT(UniqueRuntimeID urid,
                   boolean softly)
            throws java.lang.Exception
Throws:
java.lang.Exception
See Also:
ProActiveRuntime.killRT(boolean)

getURL

public java.lang.String getURL(UniqueRuntimeID urid)
See Also:
ProActiveRuntime.getURL()

getActiveObjects

public java.util.ArrayList getActiveObjects(UniqueRuntimeID urid,
                                            java.lang.String nodeName)
                                     throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getActiveObjects(String)

getActiveObjects

public java.util.ArrayList getActiveObjects(UniqueRuntimeID urid,
                                            java.lang.String nodeName,
                                            java.lang.String className)
                                     throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getActiveObjects(String, String)

getVirtualNode

public VirtualNode getVirtualNode(UniqueRuntimeID urid,
                                  java.lang.String virtualNodeName)
                           throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getVirtualNode(String)

registerVirtualNode

public void registerVirtualNode(UniqueRuntimeID urid,
                                java.lang.String virtualNodeName,
                                boolean replacePreviousBinding)
                         throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.registerVirtualNode(String, boolean)

unregisterVirtualNode

public void unregisterVirtualNode(UniqueRuntimeID urid,
                                  java.lang.String virtualNodeName)
                           throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.unregisterVirtualNode(String)

unregisterAllVirtualNodes

public void unregisterAllVirtualNodes(UniqueRuntimeID urid)
                               throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.unregisterAllVirtualNodes()

getJobID

public java.lang.String getJobID(UniqueRuntimeID urid,
                                 java.lang.String nodeUrl)
                          throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getJobID(String)

createBody

public UniversalBody createBody(UniqueRuntimeID urid,
                                java.lang.String nodeName,
                                ConstructorCall bodyConstructorCall,
                                boolean isNodeLocal)
                         throws ProActiveException,
                                ConstructorCallExecutionFailedException,
                                java.lang.reflect.InvocationTargetException
Throws:
ProActiveException
ConstructorCallExecutionFailedException
java.lang.reflect.InvocationTargetException
See Also:
ProActiveRuntime.createBody(String, ConstructorCall, boolean)

receiveBody

public UniversalBody receiveBody(UniqueRuntimeID urid,
                                 java.lang.String nodeName,
                                 Body body)
                          throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.receiveBody(String, Body)

receiveCheckpoint

public UniversalBody receiveCheckpoint(UniqueRuntimeID urid,
                                       java.lang.String nodeName,
                                       Checkpoint ckpt,
                                       int inc)
                                throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.receiveCheckpoint(String, Checkpoint, int)

getProcessToDeploy

public ExternalProcess getProcessToDeploy(UniqueRuntimeID urid,
                                          ProActiveRuntime proActiveRuntimeDist,
                                          java.lang.String creatorID,
                                          java.lang.String vmName,
                                          java.lang.String padURL)
                                   throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getProcessToDeploy(ProActiveRuntime, String, String, String)

getClassDataFromThisRuntime

public byte[] getClassDataFromThisRuntime(UniqueRuntimeID urid,
                                          java.lang.String className)
                                   throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getClassDataFromThisRuntime(String)

getClassDataFromParentRuntime

public byte[] getClassDataFromParentRuntime(UniqueRuntimeID urid,
                                            java.lang.String className)
                                     throws ProActiveException
Throws:
ProActiveException
See Also:
ProActiveRuntime.getClassDataFromParentRuntime(String)

launchMain

public void launchMain(UniqueRuntimeID urid,
                       java.lang.String className,
                       java.lang.String[] parameters)
                throws java.lang.ClassNotFoundException,
                       java.lang.NoSuchMethodException,
                       ProActiveException
Throws:
java.lang.ClassNotFoundException
java.lang.NoSuchMethodException
ProActiveException
See Also:
ProActiveRuntime.launchMain(String, String[])

newRemote

public void newRemote(UniqueRuntimeID urid,
                      java.lang.String className)
               throws java.lang.ClassNotFoundException,
                      ProActiveException
Throws:
java.lang.ClassNotFoundException
ProActiveException
See Also:
ProActiveRuntime.newRemote(String)

getCertificate

public java.security.cert.X509Certificate getCertificate(UniqueRuntimeID urid)
                                                  throws SecurityNotAvailableException,
                                                         java.io.IOException
Throws:
SecurityNotAvailableException
java.io.IOException

startNewSession

public long startNewSession(UniqueRuntimeID urid,
                            Communication policy)
                     throws SecurityNotAvailableException,
                            RenegotiateSessionException,
                            java.io.IOException
Throws:
SecurityNotAvailableException
RenegotiateSessionException
java.io.IOException

getPublicKey

public java.security.PublicKey getPublicKey(UniqueRuntimeID urid)
                                     throws SecurityNotAvailableException,
                                            java.io.IOException
Throws:
SecurityNotAvailableException
java.io.IOException

randomValue

public byte[] randomValue(UniqueRuntimeID urid,
                          long sessionID,
                          byte[] clientRandomValue)
                   throws SecurityNotAvailableException,
                          RenegotiateSessionException,
                          java.io.IOException
Throws:
SecurityNotAvailableException
RenegotiateSessionException
java.io.IOException

publicKeyExchange

public byte[][] publicKeyExchange(UniqueRuntimeID urid,
                                  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 urid,
                                  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 urid,
                                 SecurityContext securityContext)
                          throws SecurityNotAvailableException,
                                 java.io.IOException
Throws:
SecurityNotAvailableException
java.io.IOException

getCertificateEncoded

public byte[] getCertificateEncoded(UniqueRuntimeID urid)
                             throws SecurityNotAvailableException,
                                    java.io.IOException
Throws:
SecurityNotAvailableException
java.io.IOException

getEntities

public java.util.ArrayList getEntities(UniqueRuntimeID urid)
                                throws SecurityNotAvailableException,
                                       java.io.IOException
Throws:
SecurityNotAvailableException
java.io.IOException

terminateSession

public void terminateSession(UniqueRuntimeID urid,
                             long sessionID)
                      throws SecurityNotAvailableException,
                             java.io.IOException
Throws:
SecurityNotAvailableException
java.io.IOException

getVNName

public java.lang.String getVNName(UniqueRuntimeID urid,
                                  java.lang.String Nodename)
                           throws ProActiveException
Throws:
ProActiveException

getDescriptor

public ProActiveDescriptor getDescriptor(UniqueRuntimeID urid,
                                         java.lang.String url,
                                         boolean isHierarchicalSearch)
                                  throws java.io.IOException,
                                         ProActiveException
Throws:
java.io.IOException
ProActiveException

getJobID

public java.lang.String getJobID(UniqueRuntimeID urid)


Copyright 2001-2005 INRIA All Rights Reserved.