diff options
Diffstat (limited to 'java/src/IceInternal/IncomingAsync.java')
-rw-r--r-- | java/src/IceInternal/IncomingAsync.java | 116 |
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; } } |