|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use UniqueID | |
org.objectweb.proactive | Provides the main classes for creating active objects and futures. |
org.objectweb.proactive.core.body | Provides all classes used for implementing the active part of an active object. |
org.objectweb.proactive.core.body.ft.checkpointing | Defines the implementation of an active object checkpoint. |
org.objectweb.proactive.core.body.ft.message | Defines message logs, i.e. messages that have to be resent after a recovery. |
org.objectweb.proactive.core.body.ft.protocols | Defines specific behavior for each implemented fault-tolerance protocol. |
org.objectweb.proactive.core.body.ft.protocols.cic.servers | Defines the CIC protocol specific behavior of the fault-tolerance servers. |
org.objectweb.proactive.core.body.ft.protocols.pmlrb.servers | Defines the PML protocol specific behavior of the fault-tolerance servers. |
org.objectweb.proactive.core.body.ft.servers | Defines all needed servers for fault-tolerance mecanism, and a global server that implements all needed behaviors. |
org.objectweb.proactive.core.body.ft.servers.location | Defines the location interface of fault-tolerance server, i.e. for retrieving a reference on a failed-and-restart active object. |
org.objectweb.proactive.core.body.ft.servers.recovery | Defines recovery process interface, i.e. the process responsible for triggering the recovery. |
org.objectweb.proactive.core.body.ft.servers.storage | Defines the storage process interface of the fault-tolerance server, i.e. the checkpoints storage service. |
org.objectweb.proactive.core.body.future | Provides the definition and implementation of the future object. |
org.objectweb.proactive.core.body.http | HTTP implementation of the remote Body |
org.objectweb.proactive.core.body.http.util | Provides Exceptions for HTTP communications |
org.objectweb.proactive.core.body.http.util.messages | Contains all types of messages usefull for HTTP communications |
org.objectweb.proactive.core.body.ibis | IBIS implementation of the remote Body |
org.objectweb.proactive.core.body.message | **For internal use only** Defines the common message layer of Requests and Replies. |
org.objectweb.proactive.core.body.proxy | **For internal use only** Defines the proxy associated to any ProActive Stub of an active Object. |
org.objectweb.proactive.core.body.reply | Defines the reply messages based of the common message layer. |
org.objectweb.proactive.core.body.request | Defines the request messages based of the common message layer. |
org.objectweb.proactive.core.body.rmi | The body of an active object act as a hub of communication with other remote objects. |
org.objectweb.proactive.core.component.identity | The ProActiveComponentIdentityImpl class is the base class for the component meta-objects. |
org.objectweb.proactive.core.component.representative | A representative is the reference on a ProActive component. |
org.objectweb.proactive.core.event | The active object created with ProActive generated events on demand when a listener registers to one component of the active object. |
org.objectweb.proactive.ext.implicit | *under development* Defines an implicit way of programming the live method using declarations. |
org.objectweb.proactive.ext.locationserver | Defines a Body associated with a location server able to give the location of one body on demand. |
org.objectweb.proactive.ext.mixedlocation | |
org.objectweb.proactive.ext.security | |
org.objectweb.proactive.ext.util | Provides some utility classes for end user usage or used across the extension package. |
Uses of UniqueID in org.objectweb.proactive |
Methods in org.objectweb.proactive with parameters of type UniqueID | |
UniversalBody |
Body.checkNewLocation(UniqueID uniqueID)
Tries to find a local version of the body of id uniqueID. |
Uses of UniqueID in org.objectweb.proactive.core.body |
Fields in org.objectweb.proactive.core.body declared as UniqueID | |
protected UniqueID |
AbstractUniversalBody.bodyID
Unique ID of the body. |
protected UniqueID |
BodyAdapter.bodyID
Cache the ID of the Body locally for speed |
Methods in org.objectweb.proactive.core.body that return UniqueID | |
UniqueID |
UniversalBodyForwarder.getID(UniqueID id)
|
UniqueID |
BodyForwarderImpl.getID(UniqueID id)
|
UniqueID |
BodyAdapterImpl.getID()
|
UniqueID |
RemoteBodyForwarder.getID(UniqueID id)
|
UniqueID |
RemoteBody.getID()
Returns the UniqueID of this body This identifier is unique accross all JVMs |
UniqueID |
BodyAdapterForwarder.getID()
|
UniqueID |
AbstractUniversalBody.getID()
|
UniqueID |
UniversalBody.getID()
Returns the UniqueID of this body This identifier is unique accross all JVMs |
Methods in org.objectweb.proactive.core.body with parameters of type UniqueID | |
BlockingRequestQueue |
ProActiveMetaObjectFactory.RequestQueueFactoryImpl.newRequestQueue(UniqueID ownerID)
|
Body |
LocalBodyStore.getLocalBody(UniqueID bodyID)
Returns the body belonging to this JVM whose ID is the one specified. |
Body |
LocalBodyStore.getLocalHalfBody(UniqueID bodyID)
Returns the halfbody belonging to this JVM whose ID is the one specified. |
Body |
LocalBodyStore.getForwarder(UniqueID bodyID)
Returns the forwarder belonging to this JVM whose ID is the one specified. |
int |
UniversalBodyForwarder.receiveRequest(UniqueID id,
Request request)
|
int |
UniversalBodyForwarder.receiveReply(UniqueID id,
Reply r)
|
java.lang.String |
UniversalBodyForwarder.getNodeURL(UniqueID id)
|
UniqueID |
UniversalBodyForwarder.getID(UniqueID id)
|
void |
UniversalBodyForwarder.updateLocation(UniqueID id,
UniqueID uid,
UniversalBody body)
|
void |
UniversalBodyForwarder.createShortcut(UniqueID id,
Shortcut shortcut)
|
BodyAdapter |
UniversalBodyForwarder.getRemoteAdapter(UniqueID id)
|
void |
UniversalBodyForwarder.terminate(UniqueID id)
|
void |
UniversalBodyForwarder.enableAC(UniqueID id)
|
void |
UniversalBodyForwarder.disableAC(UniqueID id)
|
void |
UniversalBodyForwarder.setImmediateService(UniqueID id,
java.lang.String methodName)
|
void |
UniversalBodyForwarder.setImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
void |
UniversalBodyForwarder.removeImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
java.security.cert.X509Certificate |
UniversalBodyForwarder.getCertificate(UniqueID id)
|
long |
UniversalBodyForwarder.startNewSession(UniqueID id,
Communication policy)
|
java.security.PublicKey |
UniversalBodyForwarder.getPublicKey(UniqueID id)
|
byte[] |
UniversalBodyForwarder.randomValue(UniqueID id,
long sessionID,
byte[] clientRandomValue)
|
byte[][] |
UniversalBodyForwarder.publicKeyExchange(UniqueID id,
long sessionID,
byte[] myPublicKey,
byte[] myCertificate,
byte[] signature)
|
byte[][] |
UniversalBodyForwarder.secretKeyExchange(UniqueID id,
long sessionID,
byte[] encodedAESKey,
byte[] encodedIVParameters,
byte[] encodedClientMacKey,
byte[] encodedLockData,
byte[] parametersSignature)
|
SecurityContext |
UniversalBodyForwarder.getPolicy(UniqueID id,
SecurityContext securityContext)
|
byte[] |
UniversalBodyForwarder.getCertificateEncoded(UniqueID id)
|
java.util.ArrayList |
UniversalBodyForwarder.getEntities(UniqueID id)
|
void |
UniversalBodyForwarder.terminateSession(UniqueID id,
long sessionID)
|
java.lang.Object |
UniversalBodyForwarder.receiveFTMessage(UniqueID id,
FTMessage ev)
|
java.lang.String |
UniversalBodyForwarder.getJobID(UniqueID id)
|
void |
UniversalBodyForwarder.addNFEListener(UniqueID id,
NFEListener listener)
|
void |
UniversalBodyForwarder.removeNFEListener(UniqueID id,
NFEListener listener)
|
int |
UniversalBodyForwarder.fireNFE(UniqueID id,
NonFunctionalException e)
|
void |
UniversalBodyForwarder.changeProxiedBody(UniqueID id,
Body newBody)
|
UniversalBody |
UniversalBodyForwarder.lookup(UniqueID id,
java.lang.String url)
|
void |
UniversalBodyForwarder.register(UniqueID id,
java.lang.String url)
|
void |
UniversalBodyForwarder.unregister(UniqueID id,
java.lang.String url)
|
void |
BodyForwarderImpl.addcreatedBody(UniqueID id)
Add id to the collection of body created through this forwarder |
void |
BodyForwarderImpl.createShortcut(UniqueID id,
Shortcut shortcut)
|
void |
BodyForwarderImpl.disableAC(UniqueID id)
|
void |
BodyForwarderImpl.enableAC(UniqueID id)
|
java.security.cert.X509Certificate |
BodyForwarderImpl.getCertificate(UniqueID id)
|
byte[] |
BodyForwarderImpl.getCertificateEncoded(UniqueID id)
|
java.util.ArrayList |
BodyForwarderImpl.getEntities(UniqueID id)
|
UniqueID |
BodyForwarderImpl.getID(UniqueID id)
|
java.lang.String |
BodyForwarderImpl.getNodeURL(UniqueID id)
|
SecurityContext |
BodyForwarderImpl.getPolicy(UniqueID id,
SecurityContext securityContext)
|
java.security.PublicKey |
BodyForwarderImpl.getPublicKey(UniqueID id)
|
BodyAdapter |
BodyForwarderImpl.getRemoteAdapter(UniqueID id)
|
byte[][] |
BodyForwarderImpl.publicKeyExchange(UniqueID id,
long sessionID,
byte[] my_pub,
byte[] my_cert,
byte[] sig_code)
|
java.lang.Object |
BodyForwarderImpl.receiveFTMessage(UniqueID id,
FTMessage ev)
|
int |
BodyForwarderImpl.receiveReply(UniqueID id,
Reply r)
|
int |
BodyForwarderImpl.receiveRequest(UniqueID id,
Request request)
|
void |
BodyForwarderImpl.removeImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
byte[][] |
BodyForwarderImpl.secretKeyExchange(UniqueID id,
long sessionID,
byte[] tmp,
byte[] tmp1,
byte[] tmp2,
byte[] tmp3,
byte[] tmp4)
|
void |
BodyForwarderImpl.setImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
void |
BodyForwarderImpl.setImmediateService(UniqueID id,
java.lang.String methodName)
|
long |
BodyForwarderImpl.startNewSession(UniqueID id,
Communication policy)
|
void |
BodyForwarderImpl.terminate(UniqueID id)
|
void |
BodyForwarderImpl.terminateSession(UniqueID id,
long sessionID)
|
byte[] |
BodyForwarderImpl.randomValue(UniqueID id,
long sessionID,
byte[] cl_rand)
|
void |
BodyForwarderImpl.updateLocation(UniqueID id,
UniqueID uid,
UniversalBody body)
|
java.lang.String |
BodyForwarderImpl.getJobID(UniqueID id)
|
void |
BodyForwarderImpl.addNFEListener(UniqueID id,
NFEListener listener)
|
void |
BodyForwarderImpl.removeNFEListener(UniqueID id,
NFEListener listener)
|
void |
BodyForwarderImpl.changeProxiedBody(UniqueID id,
Body newBody)
|
int |
BodyForwarderImpl.fireNFE(UniqueID id,
NonFunctionalException e)
|
UniversalBody |
BodyForwarderImpl.lookup(UniqueID id,
java.lang.String url)
|
void |
BodyForwarderImpl.register(UniqueID id,
java.lang.String url)
|
void |
BodyForwarderImpl.unregister(UniqueID id,
java.lang.String url)
|
void |
BodyAdapterImpl.updateLocation(UniqueID id,
UniversalBody body)
|
int |
RemoteBodyForwarder.receiveRequest(UniqueID id,
Request r)
|
int |
RemoteBodyForwarder.receiveReply(UniqueID id,
Reply r)
|
void |
RemoteBodyForwarder.terminate(UniqueID id)
|
java.lang.String |
RemoteBodyForwarder.getNodeURL(UniqueID id)
|
UniqueID |
RemoteBodyForwarder.getID(UniqueID id)
|
java.lang.String |
RemoteBodyForwarder.getJobID(UniqueID id)
|
void |
RemoteBodyForwarder.updateLocation(UniqueID id,
UniqueID uid,
UniversalBody body)
|
void |
RemoteBodyForwarder.enableAC(UniqueID id)
|
void |
RemoteBodyForwarder.disableAC(UniqueID id)
|
void |
RemoteBodyForwarder.setImmediateService(UniqueID id,
java.lang.String methodName)
|
void |
RemoteBodyForwarder.setImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
void |
RemoteBodyForwarder.removeImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
java.security.cert.X509Certificate |
RemoteBodyForwarder.getCertificate(UniqueID id)
|
long |
RemoteBodyForwarder.startNewSession(UniqueID id,
Communication policy)
|
java.security.PublicKey |
RemoteBodyForwarder.getPublicKey(UniqueID id)
|
byte[] |
RemoteBodyForwarder.randomValue(UniqueID id,
long sessionID,
byte[] clientRandomValue)
|
byte[][] |
RemoteBodyForwarder.publicKeyExchange(UniqueID id,
long sessionID,
byte[] myPublicKey,
byte[] myCertificate,
byte[] signature)
|
byte[][] |
RemoteBodyForwarder.secretKeyExchange(UniqueID id,
long sessionID,
byte[] encodedAESKey,
byte[] encodedIVParameters,
byte[] encodedClientMacKey,
byte[] encodedLockData,
byte[] parametersSignature)
|
SecurityContext |
RemoteBodyForwarder.getPolicy(UniqueID id,
SecurityContext securityContext)
|
byte[] |
RemoteBodyForwarder.getCertificateEncoded(UniqueID id)
|
java.util.ArrayList |
RemoteBodyForwarder.getEntities(UniqueID id)
|
void |
RemoteBodyForwarder.terminateSession(UniqueID id,
long sessionID)
|
java.lang.Object |
RemoteBodyForwarder.receiveFTMessage(UniqueID id,
FTMessage fte)
|
void |
RemoteBodyForwarder.changeProxiedBody(UniqueID id,
Body newBody)
|
void |
RemoteBodyForwarder.addNFEListener(UniqueID id,
NFEListener listener)
|
void |
RemoteBodyForwarder.removeNFEListener(UniqueID id,
NFEListener listener)
|
int |
RemoteBodyForwarder.fireNFE(UniqueID id,
NonFunctionalException e)
|
UniversalBody |
RemoteBodyForwarder.lookup(UniqueID id,
java.lang.String url)
|
void |
RemoteBodyForwarder.unregister(UniqueID id,
java.lang.String url)
|
void |
RemoteBodyForwarder.register(UniqueID id,
java.lang.String url)
|
BodyAdapter |
RemoteBodyForwarder.getRemoteAdapter(UniqueID id)
|
void |
RemoteBody.updateLocation(UniqueID id,
UniversalBody body)
Signals to this body that the body identified by id is now to a new remote location. |
protected void |
BodyAdapterForwarder.construct(BodyAdapterForwarder localBody,
BodyAdapter remoteBody,
UniqueID id)
|
void |
BodyAdapterForwarder.updateLocation(UniqueID uid,
UniversalBody body)
|
void |
BodyMap.putBody(UniqueID id,
UniversalBody b)
add the set (id, node) in the idToBodyMap block if it already exists until it is removed |
void |
BodyMap.updateBody(UniqueID id,
UniversalBody b)
add the set (id, node) in the idToBodyMap erase any previous entry |
void |
BodyMap.removeBody(UniqueID id)
|
UniversalBody |
BodyMap.getBody(UniqueID id)
|
boolean |
BodyMap.containsBody(UniqueID id)
|
void |
AbstractUniversalBody.updateLocation(UniqueID bodyID,
UniversalBody body)
|
UniversalBody |
AbstractBody.checkNewLocation(UniqueID bodyID)
|
void |
UniversalBody.updateLocation(UniqueID id,
UniversalBody body)
Signals to this body that the body identified by id is now to a new remote location. |
Constructors in org.objectweb.proactive.core.body with parameters of type UniqueID | |
BodyAdapterForwarder(RemoteBodyForwarder remoteBodyForwarder,
UniqueID id)
Create an adapter pointing on remoteBodyForwarder and associated to the id. |
Uses of UniqueID in org.objectweb.proactive.core.body.ft.checkpointing |
Methods in org.objectweb.proactive.core.body.ft.checkpointing that return UniqueID | |
UniqueID |
Checkpoint.getBodyID()
|
Methods in org.objectweb.proactive.core.body.ft.checkpointing with parameters of type UniqueID | |
void |
Checkpoint.setBodyID(UniqueID uniqueID)
|
Uses of UniqueID in org.objectweb.proactive.core.body.ft.message |
Fields in org.objectweb.proactive.core.body.ft.message declared as UniqueID | |
UniqueID |
HistoryUpdater.owner
ID of the owner |
Constructors in org.objectweb.proactive.core.body.ft.message with parameters of type UniqueID | |
HistoryUpdater(java.util.List elements,
long base,
long last,
UniqueID owner,
int checkpointIndex,
int incarnation)
Create an history updater. |
Uses of UniqueID in org.objectweb.proactive.core.body.ft.protocols |
Fields in org.objectweb.proactive.core.body.ft.protocols declared as UniqueID | |
protected UniqueID |
FTManager.ownerID
|
Methods in org.objectweb.proactive.core.body.ft.protocols with parameters of type UniqueID | |
UniversalBody |
FTManager.communicationFailed(UniqueID suspect,
UniversalBody suspectLocation,
java.lang.Exception e)
Common behavior when a communication with another active object failed. |
Uses of UniqueID in org.objectweb.proactive.core.body.ft.protocols.cic.servers |
Methods in org.objectweb.proactive.core.body.ft.protocols.cic.servers with parameters of type UniqueID | |
protected void |
RecoveryProcessCIC.recover(UniqueID failed)
|
Checkpoint |
CheckpointServerCIC.getCheckpoint(UniqueID id,
int sequenceNumber)
|
Checkpoint |
CheckpointServerCIC.getLastCheckpoint(UniqueID id)
|
void |
CheckpointServerCIC.addInfoToCheckpoint(CheckpointInfo ci,
UniqueID id,
int sequenceNumber,
int incarnation)
|
CheckpointInfo |
CheckpointServerCIC.getInfoFromCheckpoint(UniqueID id,
int sequenceNumber)
|
void |
CheckpointServerCIC.storeRequest(UniqueID receiverId,
Request request)
Not implemented for the CIC protocol |
void |
CheckpointServerCIC.storeReply(UniqueID receiverID,
Reply reply)
Not implemented for the CIC protocol |
protected void |
CheckpointServerCIC.internalRecover(UniqueID failed)
|
Uses of UniqueID in org.objectweb.proactive.core.body.ft.protocols.pmlrb.servers |
Methods in org.objectweb.proactive.core.body.ft.protocols.pmlrb.servers with parameters of type UniqueID | |
protected void |
RecoveryProcessPMLRB.recover(UniqueID failed)
|
Checkpoint |
CheckpointServerPMLRB.getCheckpoint(UniqueID id,
int sequenceNumber)
Not implemented for this procotol. |
Checkpoint |
CheckpointServerPMLRB.getLastCheckpoint(UniqueID id)
|
void |
CheckpointServerPMLRB.addInfoToCheckpoint(CheckpointInfo ci,
UniqueID id,
int sequenceNumber,
int incarnation)
Not implemented for this protocol. |
CheckpointInfo |
CheckpointServerPMLRB.getInfoFromCheckpoint(UniqueID id,
int sequenceNumber)
Not implemented for this protocol. |
void |
CheckpointServerPMLRB.storeRequest(UniqueID receiverId,
Request request)
|
void |
CheckpointServerPMLRB.storeReply(UniqueID receiverID,
Reply reply)
|
Uses of UniqueID in org.objectweb.proactive.core.body.ft.servers |
Methods in org.objectweb.proactive.core.body.ft.servers with parameters of type UniqueID | |
UniversalBody |
FTServer.searchObject(UniqueID id,
UniversalBody oldLocation,
UniqueID caller)
|
void |
FTServer.updateLocation(UniqueID id,
UniversalBody newLocation)
|
UniversalBody |
FTServer.getLocation(UniqueID id)
|
void |
FTServer.register(UniqueID id)
|
void |
FTServer.unregister(UniqueID id)
|
void |
FTServer.failureDetected(UniqueID id)
|
void |
FTServer.updateState(UniqueID id,
int state)
|
Checkpoint |
FTServer.getCheckpoint(UniqueID id,
int sequenceNumber)
|
Checkpoint |
FTServer.getLastCheckpoint(UniqueID id)
|
void |
FTServer.addInfoToCheckpoint(CheckpointInfo ci,
UniqueID id,
int sequenceNumber,
int incarnation)
|
CheckpointInfo |
FTServer.getInfoFromCheckpoint(UniqueID id,
int sequenceNumber)
|
void |
FTServer.storeRequest(UniqueID receiverId,
Request request)
|
void |
FTServer.storeReply(UniqueID receiverID,
Reply reply)
|
Uses of UniqueID in org.objectweb.proactive.core.body.ft.servers.location |
Methods in org.objectweb.proactive.core.body.ft.servers.location with parameters of type UniqueID | |
UniversalBody |
LocationServerImpl.searchObject(UniqueID id,
UniversalBody oldLocation,
UniqueID caller)
|
void |
LocationServerImpl.updateLocation(UniqueID id,
UniversalBody newLocation)
|
UniversalBody |
LocationServerImpl.getLocation(UniqueID id)
|
UniversalBody |
LocationServer.searchObject(UniqueID id,
UniversalBody oldLocation,
UniqueID caller)
Return the current location of object id. |
void |
LocationServer.updateLocation(UniqueID id,
UniversalBody newLocation)
Set the new location of the active object identified by id. |
UniversalBody |
LocationServer.getLocation(UniqueID id)
Return the current known location of a registred body. |
Uses of UniqueID in org.objectweb.proactive.core.body.ft.servers.recovery |
Methods in org.objectweb.proactive.core.body.ft.servers.recovery with parameters of type UniqueID | |
protected abstract void |
RecoveryProcessImpl.recover(UniqueID failed)
This method define the recovery behavior. |
void |
RecoveryProcessImpl.register(UniqueID id)
|
void |
RecoveryProcessImpl.unregister(UniqueID id)
|
void |
RecoveryProcessImpl.failureDetected(UniqueID id)
|
void |
RecoveryProcessImpl.updateState(UniqueID id,
int state)
|
void |
RecoveryProcess.register(UniqueID id)
Register the calling AO. |
void |
RecoveryProcess.unregister(UniqueID id)
Unregister the AO identified by id. |
void |
RecoveryProcess.failureDetected(UniqueID id)
Notify the recovery process that the body passed in paramater is suspected to be failed. |
void |
RecoveryProcess.updateState(UniqueID id,
int state)
Update the current state of the active object id. |
Uses of UniqueID in org.objectweb.proactive.core.body.ft.servers.storage |
Methods in org.objectweb.proactive.core.body.ft.servers.storage with parameters of type UniqueID | |
Checkpoint |
CheckpointServer.getCheckpoint(UniqueID id,
int sequenceNumber)
Return a checkpoint of the object identified by id. |
Checkpoint |
CheckpointServer.getLastCheckpoint(UniqueID id)
Return the latest checkpoint of the object identified by id |
void |
CheckpointServer.addInfoToCheckpoint(CheckpointInfo ci,
UniqueID id,
int sequenceNumber,
int incarnation)
Add informations to an already stored checkpoint |
CheckpointInfo |
CheckpointServer.getInfoFromCheckpoint(UniqueID id,
int sequenceNumber)
Return informations on the given checkpoint |
void |
CheckpointServer.storeRequest(UniqueID receiverId,
Request request)
The request passed in paramter must be synchronously logged on the server. |
void |
CheckpointServer.storeReply(UniqueID receiverID,
Reply reply)
The reply passed in paramter must be synchronously logged on the server. |
Uses of UniqueID in org.objectweb.proactive.core.body.future |
Fields in org.objectweb.proactive.core.body.future declared as UniqueID | |
protected UniqueID |
FutureProxy.creatorID
UniqueID of the body which create this future |
protected UniqueID |
FutureProxy.senderID
Unique ID of the sender (in case of automatic continuation). |
Methods in org.objectweb.proactive.core.body.future that return UniqueID | |
UniqueID |
FutureProxy.getCreatorID()
|
UniqueID |
Future.getCreatorID()
To get the creatorID. |
UniqueID |
FuturePool.getOwnerBody()
Getter of the ID of the body corresonding to this FuturePool |
Methods in org.objectweb.proactive.core.body.future with parameters of type UniqueID | |
void |
FutureProxy.setCreatorID(UniqueID i)
|
void |
FutureProxy.setSenderID(UniqueID i)
|
void |
FutureEventProducerImpl.notifyListeners(UniqueID bodyID,
UniqueID creatorID,
int type)
|
void |
FutureMap.addAutomaticContinuation(long id,
UniqueID creatorID,
UniversalBody bodyDest)
Add an AC to do for bodyDest when the futurPool will receive the value of the future indexed by (id, creatorID) |
java.util.ArrayList |
FutureMap.getFuturesToUpdate(long id,
UniqueID creatorID)
Return the list of futures corresponding to (id,bodyID) if any, null otherwise. |
java.util.ArrayList |
FutureMap.getAutomaticContinuation(long id,
UniqueID bodyID)
Return the list of ACs to (ie bodies destination) corresponding to (id,bodyID) if any, null otherwise. |
void |
FutureMap.removeFutures(long id,
UniqueID creatorID)
Remove entry corresponding to (id, creatorID) in the futureMap. |
void |
Future.setCreatorID(UniqueID i)
To set the creatorID, ie the UniqueID of the body which create this future |
void |
Future.setSenderID(UniqueID i)
To set the senderID, ie the UniqueID of the body that will send this future, in case of automatic continuation. |
void |
FuturePool.setOwnerBody(UniqueID i)
Setter of the ID of the body corresonding to this FuturePool |
int |
FuturePool.receiveFutureValue(long id,
UniqueID creatorID,
FutureResult result,
Reply reply)
Method called when a reply is recevied, ie a value is available for a future. |
void |
FuturePool.addAutomaticContinuation(long id,
UniqueID creatorID,
UniversalBody bodyDest)
To add an automatic contiunation, ie a destination body, for a particular future. |
Uses of UniqueID in org.objectweb.proactive.core.body.http |
Methods in org.objectweb.proactive.core.body.http that return UniqueID | |
UniqueID |
HttpRemoteBodyImpl.getID()
|
Methods in org.objectweb.proactive.core.body.http with parameters of type UniqueID | |
void |
HttpRemoteBodyImpl.updateLocation(UniqueID id,
UniversalBody body)
|
Uses of UniqueID in org.objectweb.proactive.core.body.http.util |
Methods in org.objectweb.proactive.core.body.http.util with parameters of type UniqueID | |
static Body |
HttpUtils.getBody(UniqueID id)
Search a Body matching with a given unique ID |
Uses of UniqueID in org.objectweb.proactive.core.body.http.util.messages |
Constructors in org.objectweb.proactive.core.body.http.util.messages with parameters of type UniqueID | |
HttpRequest(Request request,
UniqueID idBody,
java.lang.String url)
|
|
HttpReply(Reply reply,
UniqueID idBody,
java.lang.String url)
Constructs an HTTP Message containing a ProActive Reply |
|
BodyRequest(java.lang.String methodName,
java.util.ArrayList parameters,
UniqueID oaid,
java.lang.String url)
Construct a request to send to the Active object identified by the UniqueID |
Uses of UniqueID in org.objectweb.proactive.core.body.ibis |
Methods in org.objectweb.proactive.core.body.ibis that return UniqueID | |
UniqueID |
IbisRemoteBodyImpl.getID()
|
Methods in org.objectweb.proactive.core.body.ibis with parameters of type UniqueID | |
void |
IbisRemoteBodyImpl.updateLocation(UniqueID id,
UniversalBody remoteBody)
|
Uses of UniqueID in org.objectweb.proactive.core.body.message |
Fields in org.objectweb.proactive.core.body.message declared as UniqueID | |
protected UniqueID |
MessageImpl.sourceID
The UniqueID of the body sending the message |
Methods in org.objectweb.proactive.core.body.message that return UniqueID | |
UniqueID |
MessageImpl.getSourceBodyID()
|
UniqueID |
Message.getSourceBodyID()
Returns the id of the body source of this message |
Methods in org.objectweb.proactive.core.body.message with parameters of type UniqueID | |
void |
MessageEventProducerImpl.notifyListeners(Message message,
int type,
UniqueID bodyID,
int requestQueueLength)
|
void |
MessageEventProducerImpl.notifyListeners(Message message,
int type,
UniqueID bodyID)
|
Constructors in org.objectweb.proactive.core.body.message with parameters of type UniqueID | |
MessageImpl(UniqueID sourceID,
long sequenceNumber,
boolean isOneWay,
java.lang.String methodName)
Creates a new Message based on the given information. |
Uses of UniqueID in org.objectweb.proactive.core.body.proxy |
Fields in org.objectweb.proactive.core.body.proxy declared as UniqueID | |
protected UniqueID |
AbstractBodyProxy.bodyID
|
Methods in org.objectweb.proactive.core.body.proxy that return UniqueID | |
UniqueID |
BodyProxy.getBodyID()
|
UniqueID |
AbstractBodyProxy.getBodyID()
|
Uses of UniqueID in org.objectweb.proactive.core.body.reply |
Constructors in org.objectweb.proactive.core.body.reply with parameters of type UniqueID | |
ReplyImpl(UniqueID senderID,
long sequenceNumber,
java.lang.String methodName,
FutureResult result,
ProActiveSecurityManager psm)
|
|
ReplyImpl(UniqueID senderID,
long sequenceNumber,
java.lang.String methodName,
FutureResult result,
ProActiveSecurityManager psm,
boolean isAutomaticContinuation)
|
Uses of UniqueID in org.objectweb.proactive.core.body.request |
Fields in org.objectweb.proactive.core.body.request declared as UniqueID | |
protected UniqueID |
RequestQueueImpl.ownerID
|
Methods in org.objectweb.proactive.core.body.request that return UniqueID | |
UniqueID |
AwaitedRequest.getAwaitedSender()
Return the id of the awaited sender |
UniqueID |
AwaitedRequest.getSourceBodyID()
|
Methods in org.objectweb.proactive.core.body.request with parameters of type UniqueID | |
BlockingRequestQueue |
RequestQueueFactory.newRequestQueue(UniqueID ownerID)
Creates or reuses a RequestQueue object |
Constructors in org.objectweb.proactive.core.body.request with parameters of type UniqueID | |
RequestQueueImpl(UniqueID ownerID)
|
|
BlockingRequestQueueImpl(UniqueID ownerID)
|
|
AwaitedRequest(UniqueID awaitedSender)
Create a new awaited request. |
Uses of UniqueID in org.objectweb.proactive.core.body.rmi |
Methods in org.objectweb.proactive.core.body.rmi that return UniqueID | |
UniqueID |
RmiRemoteBodyForwarderImpl.getID(UniqueID id)
|
UniqueID |
RmiRemoteBodyImpl.getID()
|
Methods in org.objectweb.proactive.core.body.rmi with parameters of type UniqueID | |
int |
RmiRemoteBodyForwarderImpl.receiveRequest(UniqueID id,
Request r)
|
int |
RmiRemoteBodyForwarderImpl.receiveReply(UniqueID id,
Reply r)
|
void |
RmiRemoteBodyForwarderImpl.terminate(UniqueID id)
|
java.lang.String |
RmiRemoteBodyForwarderImpl.getNodeURL(UniqueID id)
|
UniqueID |
RmiRemoteBodyForwarderImpl.getID(UniqueID id)
|
void |
RmiRemoteBodyForwarderImpl.updateLocation(UniqueID id,
UniqueID uid,
UniversalBody remoteBody)
|
void |
RmiRemoteBodyForwarderImpl.unreferenced(UniqueID id)
|
void |
RmiRemoteBodyForwarderImpl.enableAC(UniqueID id)
|
void |
RmiRemoteBodyForwarderImpl.disableAC(UniqueID id)
|
void |
RmiRemoteBodyForwarderImpl.setImmediateService(UniqueID id,
java.lang.String methodName)
|
void |
RmiRemoteBodyForwarderImpl.removeImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
void |
RmiRemoteBodyForwarderImpl.setImmediateService(UniqueID id,
java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
void |
RmiRemoteBodyForwarderImpl.terminateSession(UniqueID id,
long sessionID)
|
java.security.cert.X509Certificate |
RmiRemoteBodyForwarderImpl.getCertificate(UniqueID id)
|
long |
RmiRemoteBodyForwarderImpl.startNewSession(UniqueID id,
Communication policy)
|
java.security.PublicKey |
RmiRemoteBodyForwarderImpl.getPublicKey(UniqueID id)
|
byte[] |
RmiRemoteBodyForwarderImpl.randomValue(UniqueID id,
long sessionID,
byte[] cl_rand)
|
byte[][] |
RmiRemoteBodyForwarderImpl.publicKeyExchange(UniqueID id,
long sessionID,
byte[] my_pub,
byte[] my_cert,
byte[] sig_code)
|
byte[] |
RmiRemoteBodyForwarderImpl.getCertificateEncoded(UniqueID id)
|
SecurityContext |
RmiRemoteBodyForwarderImpl.getPolicy(UniqueID id,
SecurityContext securityContext)
|
java.util.ArrayList |
RmiRemoteBodyForwarderImpl.getEntities(UniqueID id)
|
java.lang.Object |
RmiRemoteBodyForwarderImpl.receiveFTMessage(UniqueID id,
FTMessage fte)
|
void |
RmiRemoteBodyForwarderImpl.changeProxiedBody(UniqueID id,
Body newBody)
|
void |
RmiRemoteBodyForwarderImpl.addNFEListener(UniqueID id,
NFEListener listener)
|
void |
RmiRemoteBodyForwarderImpl.removeNFEListener(UniqueID id,
NFEListener listener)
|
int |
RmiRemoteBodyForwarderImpl.fireNFE(UniqueID id,
NonFunctionalException e)
|
java.lang.String |
RmiRemoteBodyForwarderImpl.getJobID(UniqueID id)
|
UniversalBody |
RmiRemoteBodyForwarderImpl.lookup(UniqueID id,
java.lang.String url)
|
void |
RmiRemoteBodyForwarderImpl.register(UniqueID id,
java.lang.String url)
|
void |
RmiRemoteBodyForwarderImpl.unregister(UniqueID id,
java.lang.String url)
|
BodyAdapter |
RmiRemoteBodyForwarderImpl.getRemoteAdapter(UniqueID id)
|
byte[][] |
RmiRemoteBodyForwarderImpl.secretKeyExchange(UniqueID id,
long sessionID,
byte[] encodedAESKey,
byte[] encodedIVParameters,
byte[] encodedClientMacKey,
byte[] encodedLockData,
byte[] parametersSignature)
|
void |
RmiRemoteBodyImpl.updateLocation(UniqueID id,
UniversalBody remoteBody)
|
Uses of UniqueID in org.objectweb.proactive.core.component.identity |
Methods in org.objectweb.proactive.core.component.identity that return UniqueID | |
UniqueID |
ProActiveComponentImpl.getID()
see ProActiveComponent.getID() |
UniqueID |
ProActiveComponent.getID()
getter for a unique identifier |
Uses of UniqueID in org.objectweb.proactive.core.component.representative |
Methods in org.objectweb.proactive.core.component.representative that return UniqueID | |
UniqueID |
ProActiveComponentRepresentativeImpl.getID()
Only valid for a single element. return null for a group. |
UniqueID |
FunctionalInterfaceID.getComponentBodyID()
|
Constructors in org.objectweb.proactive.core.component.representative with parameters of type UniqueID | |
FunctionalInterfaceID(java.lang.String functionalInterfaceName,
UniqueID componentBodyID)
|
Uses of UniqueID in org.objectweb.proactive.core.event |
Fields in org.objectweb.proactive.core.event declared as UniqueID | |
protected UniqueID |
RequestQueueEvent.ownerID
id of the object owner of the Queue |
protected UniqueID |
MessageEvent.destinationID
|
Methods in org.objectweb.proactive.core.event that return UniqueID | |
UniqueID |
FutureEvent.getCreatorID()
Returns the UniqueID of the body that created the corresponding Future |
UniqueID |
FutureEvent.getBodyID()
Returns the UniqueID of the body that is waiting |
UniqueID |
RequestQueueEvent.getOwnerID()
Returns the id of the owner of the RequestQueue in which the event occured |
UniqueID |
MessageEvent.getDestinationBodyID()
Returns the id of the body receiver of the encapsulated message. |
UniqueID |
MessageEvent.getSourceBodyID()
|
Constructors in org.objectweb.proactive.core.event with parameters of type UniqueID | |
FutureEvent(UniqueID bodyID,
UniqueID creatorID,
int type)
Creates a new FutureEvent based on the given FutureProxy |
|
RequestQueueEvent(UniqueID ownerID,
int type)
Creates a new RequestQueueEvent based on the given owner id and type |
|
MessageEvent(Message message,
int messageActionType,
UniqueID destinationID,
int requestQueueLength)
Creates a new MessageEvent based on the message
message and on the given action |
Uses of UniqueID in org.objectweb.proactive.ext.implicit |
Constructors in org.objectweb.proactive.ext.implicit with parameters of type UniqueID | |
ImplicitService(UniqueID id)
|
Uses of UniqueID in org.objectweb.proactive.ext.locationserver |
Methods in org.objectweb.proactive.ext.locationserver with parameters of type UniqueID | |
protected UniversalBody |
TimedRequestWithLocationServer.queryServer(UniqueID bodyID)
|
protected UniversalBody |
RequestWithLocationServer.queryServer(UniqueID bodyID)
|
static LocationServer |
LocationServerFactory.getLocationServer(UniqueID id)
Return the location server associated with the id |
void |
LocationServer.updateLocation(UniqueID i,
UniversalBody s)
|
UniversalBody |
LocationServer.searchObject(UniqueID i)
|
Uses of UniqueID in org.objectweb.proactive.ext.mixedlocation |
Fields in org.objectweb.proactive.ext.mixedlocation declared as UniqueID | |
protected UniqueID |
UniversalBodyWrapper.id
|
Methods in org.objectweb.proactive.ext.mixedlocation that return UniqueID | |
UniqueID |
UniversalBodyWrapper.getID()
|
Methods in org.objectweb.proactive.ext.mixedlocation with parameters of type UniqueID | |
protected UniversalBody |
RequestWithMixedLocation.queryServer(UniqueID bodyID)
|
void |
UniversalBodyWrapper.updateLocation(UniqueID id,
UniversalBody body)
|
Uses of UniqueID in org.objectweb.proactive.ext.security |
Methods in org.objectweb.proactive.ext.security that return UniqueID | |
UniqueID |
EncryptedBody.getID()
|
Methods in org.objectweb.proactive.ext.security with parameters of type UniqueID | |
UniversalBody |
EncryptedBody.checkNewLocation(UniqueID uniqueID)
|
void |
EncryptedBody.updateLocation(UniqueID id,
UniversalBody body)
|
Uses of UniqueID in org.objectweb.proactive.ext.util |
Methods in org.objectweb.proactive.ext.util with parameters of type UniqueID | |
void |
SimpleLocationServer.updateLocation(UniqueID i,
UniversalBody s)
Update the location for the mobile object s with id |
UniversalBody |
SimpleLocationServer.searchObject(UniqueID id)
Return a reference to the remote body if available. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |