|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectibis.rmi.server.RemoteObject
ibis.rmi.server.RemoteServer
ibis.rmi.server.UnicastRemoteObject
org.objectweb.proactive.core.body.ibis.IbisRemoteBodyImpl
Field Summary | |
protected UniversalBody |
body
The encapsulated local body transient to deal with custom serialization of requests. |
protected static RandomPortSocketFactory |
factory
A custom socket Factory |
Fields inherited from class ibis.rmi.server.RemoteObject |
ref |
Fields inherited from interface org.objectweb.proactive.core.body.RemoteBody |
bodyLogger |
Constructor Summary | |
IbisRemoteBodyImpl()
|
|
IbisRemoteBodyImpl(UniversalBody body)
|
Method Summary | |
void |
addNFEListener(NFEListener listener)
|
void |
changeProxiedBody(Body newBody)
Change the body referenced by this adapter |
void |
disableAC()
Disables automatic continuation mechanism for this body |
void |
enableAC()
Enables automatic continuation mechanism for this body |
int |
fireNFE(NonFunctionalException e)
|
java.security.cert.X509Certificate |
getCertificate()
entity certificate |
byte[] |
getCertificateEncoded()
Entity's X509Certificate as byte array |
java.util.ArrayList |
getEntities()
Retrieves all the entity's ID which contain this entity plus this entity ID. |
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)
Ask the entity to fill the securityContext parameters with its own policy according to the communication details contained in the given securityContext |
java.security.PublicKey |
getPublicKey()
entity public key |
byte[][] |
publicKeyExchange(long sessionID,
byte[] my_pub,
byte[] my_cert,
byte[] sig_code)
exchange entity certificate and/or public key if certificate are not available |
byte[] |
randomValue(long sessionID,
byte[] cl_rand)
Exchange random value between client and server entity |
java.lang.Object |
receiveFTMessage(FTMessage fte)
For sending a message to the FTManager linked to this object |
int |
receiveReply(Reply r)
Receives a reply in response to a former request. |
int |
receiveRequest(Request r)
Receives a request for later processing. |
void |
removeImmediateService(java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
void |
removeNFEListener(NFEListener listener)
|
byte[][] |
secretKeyExchange(long sessionID,
byte[] tmp,
byte[] tmp1,
byte[] tmp2,
byte[] tmp3,
byte[] tmp4)
this method sends encoded secret parameters to the target entity |
void |
setImmediateService(java.lang.String methodName)
For setting an immediate service for this body. |
void |
setImmediateService(java.lang.String methodName,
java.lang.Class[] parametersTypes)
|
long |
startNewSession(Communication policy)
start an unvalidated empty session |
void |
terminate()
Terminate the body. |
void |
terminateSession(long sessionID)
terminate a given session |
void |
unreferenced()
|
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 ibis.rmi.server.UnicastRemoteObject |
clone, exportObject, generated_DefaultReadObject, generated_DefaultWriteObject, generated_WriteObject |
Methods inherited from class ibis.rmi.server.RemoteServer |
getClientHost |
Methods inherited from class ibis.rmi.server.RemoteObject |
equals, hashCode, toString |
Methods inherited from class java.lang.Object |
finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
protected static RandomPortSocketFactory factory
protected transient UniversalBody body
Constructor Detail |
public IbisRemoteBodyImpl() throws ibis.rmi.RemoteException
public IbisRemoteBodyImpl(UniversalBody body) throws ibis.rmi.RemoteException
Method Detail |
public int receiveRequest(Request r) throws java.io.IOException, RenegotiateSessionException
RemoteBody
receiveRequest
in interface RemoteBody
r
- the request to process
java.io.IOException
- if the request cannot be accepted
RenegotiateSessionException
public int receiveReply(Reply r) throws java.io.IOException
RemoteBody
receiveReply
in interface RemoteBody
r
- the reply received
java.io.IOException
- if the reply cannot be acceptedpublic void terminate() throws java.io.IOException
RemoteBody
terminate
in interface RemoteBody
java.io.IOException
- if an exception occured during the remote communicationRemoteBody.terminate()
public java.lang.String getNodeURL()
RemoteBody
getNodeURL
in interface RemoteBody
public UniqueID getID()
RemoteBody
getID
in interface RemoteBody
public java.lang.String getJobID()
getJobID
in interface RemoteBody
public void updateLocation(UniqueID id, UniversalBody remoteBody) throws java.io.IOException
RemoteBody
updateLocation
in interface RemoteBody
id
- the id of the bodyremoteBody
- the stub to the new location
java.io.IOException
- if an exception occured during the remote communicationpublic void unreferenced()
unreferenced
in interface java.rmi.server.Unreferenced
public void enableAC() throws java.io.IOException
RemoteBody
enableAC
in interface RemoteBody
java.io.IOException
- if an exception occured during the remote communicationpublic void disableAC() throws java.io.IOException
RemoteBody
disableAC
in interface RemoteBody
java.io.IOException
- if an exception occured during the remote communicationpublic void setImmediateService(java.lang.String methodName) throws java.io.IOException
RemoteBody
setImmediateService
in interface RemoteBody
java.io.IOException
- if an exception occured during the remote communicationpublic void removeImmediateService(java.lang.String methodName, java.lang.Class[] parametersTypes) throws java.io.IOException
removeImmediateService
in interface RemoteBody
java.io.IOException
public void setImmediateService(java.lang.String methodName, java.lang.Class[] parametersTypes) throws java.io.IOException
setImmediateService
in interface RemoteBody
java.io.IOException
public void terminateSession(long sessionID) throws java.io.IOException, SecurityNotAvailableException
SecurityEntity
terminateSession
in interface SecurityEntity
sessionID
-
SecurityNotAvailableException
- id security is not available
java.io.IOException
public java.security.cert.X509Certificate getCertificate() throws SecurityNotAvailableException, java.io.IOException
SecurityEntity
getCertificate
in interface SecurityEntity
java.io.IOException
- if communication fails
SecurityNotAvailableException
- if security is not availablepublic long startNewSession(Communication policy) throws SecurityNotAvailableException, java.io.IOException, RenegotiateSessionException
SecurityEntity
startNewSession
in interface SecurityEntity
policy
- policy associated to the session
RenegotiateSessionException
- if the session immediatly expires
SecurityNotAvailableException
- if security is not available
java.io.IOException
public java.security.PublicKey getPublicKey() throws SecurityNotAvailableException, java.io.IOException
SecurityEntity
getPublicKey
in interface SecurityEntity
SecurityNotAvailableException
java.io.IOException
public byte[] randomValue(long sessionID, byte[] cl_rand) throws java.io.IOException, SecurityNotAvailableException, RenegotiateSessionException
SecurityEntity
randomValue
in interface SecurityEntity
sessionID
- the session IDcl_rand
- client random value
RenegotiateSessionException
- if the session has expired
SecurityNotAvailableException
- if the security is not available
java.io.IOException
public byte[][] publicKeyExchange(long sessionID, byte[] my_pub, byte[] my_cert, byte[] sig_code) throws java.io.IOException, SecurityNotAvailableException, RenegotiateSessionException, KeyExchangeException
SecurityEntity
publicKeyExchange
in interface SecurityEntity
sessionID
- the session IDmy_pub
- encoded public keymy_cert
- encoded certificatesig_code
- encoded signature of previous paramaters
SecurityNotAvailableException
- if the security is not available
KeyExchangeException
- if a key data/length/algorithm is not supported
RenegotiateSessionException
- if the session has expired
java.io.IOException
public byte[][] secretKeyExchange(long sessionID, byte[] tmp, byte[] tmp1, byte[] tmp2, byte[] tmp3, byte[] tmp4) throws java.io.IOException, SecurityNotAvailableException, RenegotiateSessionException
SecurityEntity
secretKeyExchange
in interface SecurityEntity
sessionID
- session IDtmp
- the AES key use to exchange secret messagetmp1
- Initilization parameters for the AES keytmp2
- MAC key for checking signature of future messagestmp3
- random value to prevent message replays by an external attackertmp4
- encoded signature of the previous parameters
java.io.IOException
- if communication fails
RenegotiateSessionException
- if the session has expired or has been cancelled during this exchange
SecurityNotAvailableException
- if this entity does not support securitypublic byte[] getCertificateEncoded() throws java.io.IOException, SecurityNotAvailableException
SecurityEntity
getCertificateEncoded
in interface SecurityEntity
java.io.IOException
SecurityNotAvailableException
public SecurityContext getPolicy(SecurityContext securityContext) throws java.io.IOException, SecurityNotAvailableException
SecurityEntity
getPolicy
in interface SecurityEntity
securityContext
- communication details allowing the entity to
look for a matching policy
SecurityNotAvailableException
- thrown the entity doest not support the security
java.io.IOException
public java.util.ArrayList getEntities() throws SecurityNotAvailableException, java.io.IOException
SecurityEntity
getEntities
in interface SecurityEntity
SecurityNotAvailableException
- if the target entity does not support security
java.io.IOException
public void changeProxiedBody(Body newBody)
RemoteBody
changeProxiedBody
in interface RemoteBody
newBody
- the body referenced after the callpublic void addNFEListener(NFEListener listener)
addNFEListener
in interface RemoteBody
public void removeNFEListener(NFEListener listener)
removeNFEListener
in interface RemoteBody
public int fireNFE(NonFunctionalException e)
fireNFE
in interface RemoteBody
public java.lang.Object receiveFTMessage(FTMessage fte) throws java.io.IOException
RemoteBody
receiveFTMessage
in interface RemoteBody
fte
- the message
java.io.IOException
- if an exception occured during the remote communicationRemoteBody.receiveFTMessage(org.objectweb.proactive.core.body.ft.internalmsg.FTMessage)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |