|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.body.http.RemoteBodyAdapter
Field Summary | |
protected UniqueID |
bodyID
The unique ID of the body |
protected java.lang.String |
jobID
Cache the jobID locally for speed |
protected int |
port
The port of the Runntime where the body is located |
protected java.lang.String |
url
The url of the Runtime where the body is located |
protected static java.util.Hashtable |
urnBodys
an Hashtable containing all the http adapters registered. |
Constructor Summary | |
RemoteBodyAdapter()
|
|
RemoteBodyAdapter(UniversalBody body)
|
Method Summary | |
void |
changeProxiedBody(Body newBody)
This method must be called only locally. |
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)
|
static UniversalBody |
getBodyFromUrn(java.lang.String urn)
|
UniqueID |
getBodyID()
|
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 |
getURL()
|
java.lang.String |
getVNName()
|
int |
hashCode()
|
void |
initiateSession(int type,
UniversalBody body)
|
static UniversalBody |
lookup(java.lang.String urn)
Looks-up an active object previously registered in the bodys table . |
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)
|
int |
receiveFTMessage(FTMessage ev)
For sending a non fonctional message to the FTManager linked to this object. |
int |
receiveReply(Reply reply)
Receives a reply in response to a former request. |
int |
receiveRequest(Request request)
Receives a request for later processing. |
static void |
register(RemoteBodyAdapter paBody,
java.lang.String urn)
Registers an active object into the table of body. |
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 |
terminate()
Terminate the body. |
void |
terminateSession(long sessionID)
|
static void |
unregister(java.lang.String urn)
Unregisters an active object previously registered into the bodys table |
Handler |
unsetExceptionHandler(java.lang.Class exception)
Remove a handler from the table of the Handlerizable Object |
void |
updateLocation(UniqueID id,
UniversalBody body)
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 transient java.util.Hashtable urnBodys
protected java.lang.String jobID
protected UniqueID bodyID
protected java.lang.String url
protected int port
Constructor Detail |
public RemoteBodyAdapter()
public RemoteBodyAdapter(UniversalBody body) throws ProActiveException
Method Detail |
public static void register(RemoteBodyAdapter paBody, java.lang.String urn) throws java.io.IOException
paBody
- the body of the active object to register.urn
- The urn of the body (in fact his url + his name)
java.io.IOException
- if the remote body cannot be registeredpublic static void unregister(java.lang.String urn) throws java.io.IOException
urn
- the urn under which the active object has been registered
java.io.IOException
public static UniversalBody lookup(java.lang.String urn) throws java.io.IOException
urn
- the urn (in fact its url + name) the remote Body is registered to
java.io.IOException
public boolean equals(java.lang.Object o)
public int receiveRequest(Request request) throws java.io.IOException, RenegotiateSessionException
UniversalBody
receiveRequest
in interface UniversalBody
request
- the request to process
java.io.IOException
- if the request cannot be accepted
RenegotiateSessionException
public int receiveReply(Reply reply) throws java.io.IOException
UniversalBody
receiveReply
in interface UniversalBody
reply
- the reply received
java.io.IOException
- if the reply cannot be acceptedpublic void terminate() throws java.io.IOException
UniversalBody
terminate
in interface UniversalBody
java.io.IOException
UniversalBody.terminate()
public java.lang.String getURL()
public static UniversalBody getBodyFromUrn(java.lang.String urn)
public java.lang.String getNodeURL()
UniversalBody
getNodeURL
in interface UniversalBody
public UniqueID getID()
UniversalBody
getID
in interface UniversalBody
public void updateLocation(UniqueID id, UniversalBody body) throws java.io.IOException
UniversalBody
updateLocation
in interface UniversalBody
id
- the id of the bodybody
- 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 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
publicKeyExchange
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
public byte[][] secretKeyExchange(long sessionID, byte[] tmp, byte[] tmp1, byte[] tmp2, byte[] tmp3, byte[] tmp4) throws SecurityNotAvailableException, java.lang.Exception
secretKeyExchange
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
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 ProActiveSecurityManager getProActiveSecurityManager() throws SecurityNotAvailableException, java.io.IOException
getProActiveSecurityManager
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.util.HashMap getHandlersLevel() throws java.io.IOException
Handlerizable
getHandlersLevel
in interface Handlerizable
java.io.IOException
public Handler unsetExceptionHandler(java.lang.Class exception) throws java.io.IOException
Handlerizable
unsetExceptionHandler
in interface Handlerizable
exception
- A class of non functional exception. It is a subclass of NonFunctionalException
.
java.io.IOException
public void setExceptionHandler(Handler handler, java.lang.Class exception) throws java.io.IOException
Handlerizable
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 java.lang.String getJobID()
getJobID
in interface Job
public void clearHandlersLevel() throws java.io.IOException
clearHandlersLevel
in interface Handlerizable
java.io.IOException
public java.lang.String getHandlerizableInfo() throws java.io.IOException
getHandlerizableInfo
in interface Handlerizable
java.io.IOException
public UniqueID getBodyID()
public int hashCode()
public int receiveFTMessage(FTMessage ev) throws java.io.IOException
UniversalBody
receiveFTMessage
in interface UniversalBody
ev
- the message to send
java.io.IOException
UniversalBody.receiveFTMessage(org.objectweb.proactive.core.body.ft.internalmsg.FTMessage)
public void changeProxiedBody(Body newBody)
changeProxiedBody
in interface BodyAdapter
newBody
- the body referenced after the call
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |