Object obj = versionedRead(inputStream, invoker, getClass().getClassLoader(), version);
// setting timestamp since about to start processing
lastRequestHandledTimestamp = System.currentTimeMillis();
InvocationRequest req = null;
boolean createdInvocationRequest = false;
boolean isError = false;
if(obj instanceof InvocationRequest)
{
req = (InvocationRequest)obj;
}
else
{
req = createInvocationRequest(obj, socketWrapper);
createdInvocationRequest = true;
performVersioning = false;
}
boolean isServerSideOnewayRequest = isServerSideOneway(req);
InetAddress clientAddress = socketWrapper.getSocket().getInetAddress();
Object resp = null;
try
{
// Make absolutely sure thread interrupted is cleared.
Thread.interrupted();
if(trace) { log.trace("about to call " + invoker + ".invoke()"); }
if (req.getRequestPayload() == null)
req.setRequestPayload(new HashMap());
req.getRequestPayload().put(Remoting.CLIENT_ADDRESS, clientAddress);
// call transport on the subclass, get the result to handback
resp = invoker.invoke(req);
if(trace) { log.trace(invoker + ".invoke() returned " + resp); }
}
catch (Throwable ex)
{
resp = ex;
isError = true;
if (trace) log.trace(invoker + ".invoke() call failed", ex);
}
Thread.interrupted(); // clear interrupted state so we don't fail on socket writes
if(isServerSideOnewayRequest)
{
if(trace) { log.trace("oneway request, writing no reply on the wire"); }
}
else
{
if(!createdInvocationRequest)
{
// need to return invocation response
if(trace) { log.trace("creating response instance"); }
resp = new InvocationResponse(req.getSessionId(), resp, isError, req.getReturnPayload());
}
OutputStream outputStream = socketWrapper.getOutputStream();
if (performVersioning)
{