summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/IncomingAsync.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/src/IceInternal/IncomingAsync.java')
-rw-r--r--java/src/IceInternal/IncomingAsync.java116
1 files changed, 58 insertions, 58 deletions
diff --git a/java/src/IceInternal/IncomingAsync.java b/java/src/IceInternal/IncomingAsync.java
index 7a7bb90678f..d985797169d 100644
--- a/java/src/IceInternal/IncomingAsync.java
+++ b/java/src/IceInternal/IncomingAsync.java
@@ -14,89 +14,89 @@ public class IncomingAsync extends IncomingBase
public
IncomingAsync(Incoming in) // Adopts the argument. It must not be used afterwards.
{
- super(in);
+ super(in);
}
final protected void
__response(boolean ok)
{
- try
- {
- if(!__servantLocatorFinished())
- {
- return;
- }
+ try
+ {
+ if(!__servantLocatorFinished())
+ {
+ return;
+ }
- if(_response)
- {
- _os.endWriteEncaps();
-
- int save = _os.pos();
- _os.pos(Protocol.headerSize + 4); // Dispatch status position.
-
- if(ok)
- {
- _os.writeByte((byte)DispatchStatus._DispatchOK);
- }
- else
- {
- _os.writeByte((byte)DispatchStatus._DispatchUserException);
- }
-
- _os.pos(save);
+ if(_response)
+ {
+ _os.endWriteEncaps();
+
+ int save = _os.pos();
+ _os.pos(Protocol.headerSize + 4); // Dispatch status position.
+
+ if(ok)
+ {
+ _os.writeByte((byte)DispatchStatus._DispatchOK);
+ }
+ else
+ {
+ _os.writeByte((byte)DispatchStatus._DispatchUserException);
+ }
+
+ _os.pos(save);
- _connection.sendResponse(_os, _compress);
- }
- else
- {
- _connection.sendNoResponse();
- }
- }
- catch(Ice.LocalException ex)
- {
- _connection.invokeException(ex, 1);
- }
+ _connection.sendResponse(_os, _compress);
+ }
+ else
+ {
+ _connection.sendNoResponse();
+ }
+ }
+ catch(Ice.LocalException ex)
+ {
+ _connection.invokeException(ex, 1);
+ }
}
final protected void
__exception(java.lang.Exception exc)
{
- try
- {
- if(!__servantLocatorFinished())
- {
- return;
- }
+ try
+ {
+ if(!__servantLocatorFinished())
+ {
+ return;
+ }
- __handleException(exc);
- }
- catch(Ice.LocalException ex)
- {
- _connection.invokeException(ex, 1);
- }
+ __handleException(exc);
+ }
+ catch(Ice.LocalException ex)
+ {
+ _connection.invokeException(ex, 1);
+ }
}
final private boolean
__servantLocatorFinished()
{
- try
- {
- if(_locator != null && _servant != null)
- {
- _locator.finished(_current, _servant, _cookie.value);
- }
- return true;
- }
+ try
+ {
+ if(_locator != null && _servant != null)
+ {
+ _locator.finished(_current, _servant, _cookie.value);
+ }
+ return true;
+ }
catch(java.lang.Exception ex)
{
- __handleException(ex);
- return false;
+ __handleException(ex);
+ return false;
}
}
final protected BasicStream
__os()
{
- return _os;
+ return _os;
}
}