org.objectweb.proactive.ext.locationserver
Class TimedRequestWithLocationServer

java.lang.Object
  org.objectweb.proactive.core.body.message.MessageImpl
      org.objectweb.proactive.core.body.request.RequestImpl
          org.objectweb.proactive.ext.locationserver.TimedRequestWithLocationServer

All Implemented Interfaces:

java.io.Serializable, Message, Request, Securizable

Direct Known Subclasses:

TimedRequestWithMixedLocation

public class TimedRequestWithLocationServer
extends RequestImpl
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

protected long

startTime the number of time we try before reporting a failure

Fields inherited from class org.objectweb.proactive.core.body.request.RequestImpl

ciphered, codebase, isNFRequest, logger, loggerNFE, methodCall, nfRequestPriority, sendCounter, sender, sessionID

Fields inherited from class org.objectweb.proactive.core.body.message.MessageImpl

ftm, ignoreIt, isOneWay, messageInfos, methodName, sequenceNumber, sourceID, timeStamp

Fields inherited from interface org.objectweb.proactive.core.body.request.Request

NFREQUEST_IMMEDIATE_PRIORITY, NFREQUEST_NO_PRIORITY, NFREQUEST_PRIORITY

Constructor Summary

TimedRequestWithLocationServer(MethodCall methodCall, UniversalBody sender, boolean isOneWay, long nextSequenceID, LocationServer server)

Method Summary

protected void	backupSolution(UniversalBody destinationBody) Implements the backup solution
protected UniversalBody	queryServer(UniqueID bodyID)
protected int	sendRequest(UniversalBody destinationBody)
Reply	serve(Body targetBody) Serves this request by executing the embedded method call using the given targetBody.

Methods inherited from class org.objectweb.proactive.core.body.request.RequestImpl

createReply, crypt, decrypt, getMethodCall, getNFRequestPriority, getParameter, getSender, getSessionId, hasBeenForwarded, isCiphered, isFunctionalRequest, notifyReception, resetSendCounter, send, serveAlternate, serveInternal, setFunctionalRequest, setNFRequestPriority

Methods inherited from class org.objectweb.proactive.core.body.message.MessageImpl

getFTManager, getMessageInfo, getMethodName, getSequenceNumber, getSourceBodyID, getTimeStamp, ignoreIt, isOneWay, setFTManager, setIgnoreIt, setMessageInfo, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.objectweb.proactive.core.body.message.Message

getFTManager, getMessageInfo, getMethodName, getSequenceNumber, getSourceBodyID, getTimeStamp, ignoreIt, isOneWay, setFTManager, setIgnoreIt, setMessageInfo

Field Detail

startTime

protected long startTime

the number of time we try before reporting a failure

Constructor Detail

TimedRequestWithLocationServer

public TimedRequestWithLocationServer(MethodCall methodCall,
                                      UniversalBody sender,
                                      boolean isOneWay,
                                      long nextSequenceID,
                                      LocationServer server)

Method Detail

serve

public Reply serve(Body targetBody)
            throws ServeException

Description copied from interface: Request

Serves this request by executing the embedded method call using the given targetBody. Once the eventual result obtained from the method call a the reply is returned (based on that result).

Specified by:

serve in interface Request

Overrides:

serve in class RequestImpl

Parameters:

targetBody - the body destination of the call

Returns:

the reply built using the result or null if the request is one way

Throws:

ServeException - if the method call fails to be served

sendRequest

protected int sendRequest(UniversalBody destinationBody)
                   throws java.io.IOException

Overrides:

sendRequest in class RequestImpl

Throws:

java.io.IOException

backupSolution

protected void backupSolution(UniversalBody destinationBody)
                       throws java.io.IOException

Implements the backup solution

Overrides:

backupSolution in class RequestImpl

Throws:

java.io.IOException

queryServer

protected UniversalBody queryServer(UniqueID bodyID)

Overrides:

queryServer in class RequestImpl