|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.body.ibis.IbisRemoteBodyAdapter
Field Summary | |
protected UniqueID |
bodyID
Cache the ID of the Body locally for speed |
protected java.lang.String |
jobID
Cache the jobID locally for speed |
protected static org.apache.log4j.Logger |
logger
|
protected IbisRemoteBody |
proxiedRemoteBody
The encapsulated IbisRemoteBody |
Constructor Summary | |
IbisRemoteBodyAdapter()
|
|
IbisRemoteBodyAdapter(IbisRemoteBody remoteBody)
|
|
IbisRemoteBodyAdapter(UniversalBody body)
|
Method Summary | |
void |
clearHandlersLevel()
Clear the local map of handlers |
void |
disableAC()
Disables automatic continuation mechanism for this body |
void |
enableAC()
Enables automatic continuation mechanism for this body |
boolean |
equals(java.lang.Object o)
|
java.security.cert.X509Certificate |
getCertificate()
|
byte[] |
getCertificateEncoded()
|
java.util.ArrayList |
getEntities()
|
java.lang.String |
getHandlerizableInfo()
Get information about the handlerizable object |
java.util.HashMap |
getHandlersLevel()
Give a reference to a local map of handlers |
UniqueID |
getID()
Returns the UniqueID of this body This identifier is unique accross all JVMs |
java.lang.String |
getJobID()
|
java.lang.String |
getNodeURL()
Returns the url of the node this body is associated to The url of the node can change if the active object migrates |
SecurityContext |
getPolicy(SecurityContext securityContext)
|
Policy |
getPolicyFrom(java.security.cert.X509Certificate certificate)
|
Communication |
getPolicyTo(java.lang.String type,
java.lang.String from,
java.lang.String to)
|
ProActiveSecurityManager |
getProActiveSecurityManager()
|
java.security.PublicKey |
getPublicKey()
|
UniversalBody |
getRemoteAdapter()
Returns the remote friendly version of this body |
java.lang.String |
getVNName()
|
int |
hashCode()
|
void |
initiateSession(int type,
UniversalBody body)
|
static UniversalBody |
lookup(java.lang.String url)
Looks-up an active object previously registered in a RMI registry. |
ConfidentialityTicket |
negociateKeyReceiverSide(ConfidentialityTicket confidentialityTicket,
long sessionID)
|
byte[][] |
publicKeyExchange(long sessionID,
UniversalBody distantBody,
byte[] my_pub,
byte[] my_cert,
byte[] sig_code)
|
byte[] |
randomValue(long sessionID,
byte[] cl_rand)
|
void |
receiveReply(Reply r)
Receives a reply in response to a former request. |
void |
receiveRequest(Request r)
Receives a request for later processing. |
static void |
register(IbisRemoteBodyAdapter bodyAdapter,
java.lang.String url)
Registers an active object into a RMI registry. |
byte[][] |
secretKeyExchange(long sessionID,
byte[] tmp,
byte[] tmp1,
byte[] tmp2,
byte[] tmp3,
byte[] tmp4)
|
void |
setExceptionHandler(Handler handler,
java.lang.Class exception)
Set a new handler within the table of the Handlerizable Object |
void |
setImmediateService(java.lang.String methodName)
For setting an immediate service for this body. |
long |
startNewSession(Communication policy)
|
void |
terminateSession(long sessionID)
|
static void |
unregister(java.lang.String url)
Unregisters an active object previously registered into a RMI registry. |
Handler |
unsetExceptionHandler(java.lang.Class exception)
Remove a handler from the table of the Handlerizable Object |
void |
updateLocation(UniqueID id,
UniversalBody remoteBody)
Signals to this body that the body identified by id is now to a new remote location. |
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static org.apache.log4j.Logger logger
protected IbisRemoteBody proxiedRemoteBody
protected UniqueID bodyID
protected java.lang.String jobID
Constructor Detail |
public IbisRemoteBodyAdapter()
public IbisRemoteBodyAdapter(IbisRemoteBody remoteBody) throws ProActiveException
public IbisRemoteBodyAdapter(UniversalBody body) throws ProActiveException
Method Detail |
public static void register(IbisRemoteBodyAdapter bodyAdapter, java.lang.String url) throws java.io.IOException
bodyAdapter
- the bodyadapter of the active object to register.url
- the url under which the remote body is registered.
java.io.IOException
- if the remote body cannot be registeredpublic static void unregister(java.lang.String url) throws java.io.IOException
url
- the url under which the active object is registered.
java.io.IOException
- if the remote object cannot be removed from the registrypublic static UniversalBody lookup(java.lang.String url) throws java.io.IOException
url
- the url the remote Body is registered to
java.io.IOException
- if the remote body cannot be found under the given url
or if the object found is not of type IbisRemoteBodypublic boolean equals(java.lang.Object o)
public int hashCode()
public java.lang.String getJobID()
getJobID
in interface Job
public void receiveRequest(Request r) throws java.io.IOException, RenegotiateSessionException
UniversalBody
receiveRequest
in interface UniversalBody
r
- the request to process
java.io.IOException
- if the request cannot be accepted
RenegotiateSessionException
public void receiveReply(Reply r) throws java.io.IOException
UniversalBody
receiveReply
in interface UniversalBody
r
- the reply received
java.io.IOException
- if the reply cannot be acceptedpublic java.lang.String getNodeURL()
UniversalBody
getNodeURL
in interface UniversalBody
public UniqueID getID()
UniversalBody
getID
in interface UniversalBody
public void updateLocation(UniqueID id, UniversalBody remoteBody) throws java.io.IOException
UniversalBody
updateLocation
in interface UniversalBody
id
- the id of the bodyremoteBody
- the stub to the new location
java.io.IOException
public UniversalBody getRemoteAdapter()
UniversalBody
getRemoteAdapter
in interface UniversalBody
public void enableAC() throws java.io.IOException
UniversalBody
enableAC
in interface UniversalBody
java.io.IOException
public void disableAC() throws java.io.IOException
UniversalBody
disableAC
in interface UniversalBody
java.io.IOException
public void setImmediateService(java.lang.String methodName) throws java.io.IOException
UniversalBody
setImmediateService
in interface UniversalBody
java.io.IOException
public void initiateSession(int type, UniversalBody body) throws java.io.IOException, CommunicationForbiddenException, AuthenticationException, RenegotiateSessionException, SecurityNotAvailableException
initiateSession
in interface UniversalBody
java.io.IOException
CommunicationForbiddenException
AuthenticationException
RenegotiateSessionException
SecurityNotAvailableException
public void terminateSession(long sessionID) throws java.io.IOException, SecurityNotAvailableException
terminateSession
in interface UniversalBody
java.io.IOException
SecurityNotAvailableException
public java.security.cert.X509Certificate getCertificate() throws SecurityNotAvailableException, java.io.IOException
getCertificate
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public ProActiveSecurityManager getProActiveSecurityManager() throws SecurityNotAvailableException, java.io.IOException
getProActiveSecurityManager
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public Policy getPolicyFrom(java.security.cert.X509Certificate certificate) throws SecurityNotAvailableException, java.io.IOException
getPolicyFrom
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public long startNewSession(Communication policy) throws SecurityNotAvailableException, java.io.IOException, RenegotiateSessionException
startNewSession
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
RenegotiateSessionException
public ConfidentialityTicket negociateKeyReceiverSide(ConfidentialityTicket confidentialityTicket, long sessionID) throws SecurityNotAvailableException, KeyExchangeException, java.io.IOException
negociateKeyReceiverSide
in interface UniversalBody
SecurityNotAvailableException
KeyExchangeException
java.io.IOException
public java.security.PublicKey getPublicKey() throws SecurityNotAvailableException, java.io.IOException
getPublicKey
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public byte[] randomValue(long sessionID, byte[] cl_rand) throws SecurityNotAvailableException, java.lang.Exception
randomValue
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
public byte[][] publicKeyExchange(long sessionID, UniversalBody distantBody, byte[] my_pub, byte[] my_cert, byte[] sig_code) throws SecurityNotAvailableException, java.lang.Exception, RenegotiateSessionException
publicKeyExchange
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
RenegotiateSessionException
public byte[][] secretKeyExchange(long sessionID, byte[] tmp, byte[] tmp1, byte[] tmp2, byte[] tmp3, byte[] tmp4) throws SecurityNotAvailableException, java.lang.Exception, RenegotiateSessionException
secretKeyExchange
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
RenegotiateSessionException
public Communication getPolicyTo(java.lang.String type, java.lang.String from, java.lang.String to) throws SecurityNotAvailableException, java.io.IOException
getPolicyTo
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public SecurityContext getPolicy(SecurityContext securityContext) throws SecurityNotAvailableException, java.io.IOException
getPolicy
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.lang.String getVNName() throws SecurityNotAvailableException, java.io.IOException
getVNName
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public byte[] getCertificateEncoded() throws SecurityNotAvailableException, java.io.IOException
getCertificateEncoded
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.util.ArrayList getEntities() throws SecurityNotAvailableException, java.io.IOException
getEntities
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.lang.String getHandlerizableInfo() throws java.io.IOException
getHandlerizableInfo
in interface Handlerizable
java.io.IOException
public java.util.HashMap getHandlersLevel() throws java.io.IOException
getHandlersLevel
in interface Handlerizable
java.io.IOException
public void clearHandlersLevel() throws java.io.IOException
clearHandlersLevel
in interface Handlerizable
java.io.IOException
public void setExceptionHandler(Handler handler, java.lang.Class exception) throws java.io.IOException
setExceptionHandler
in interface Handlerizable
handler
- A handler associated with a class of non functional exception.exception
- A class of non functional exception. It is a subclass of NonFunctionalException
.
java.io.IOException
public Handler unsetExceptionHandler(java.lang.Class exception) throws java.io.IOException
unsetExceptionHandler
in interface Handlerizable
exception
- A class of non functional exception. It is a subclass of NonFunctionalException
.
java.io.IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |