diff options
Diffstat (limited to 'cs/src/Ice/IncomingAsync.cs')
-rwxr-xr-x | cs/src/Ice/IncomingAsync.cs | 156 |
1 files changed, 78 insertions, 78 deletions
diff --git a/cs/src/Ice/IncomingAsync.cs b/cs/src/Ice/IncomingAsync.cs index c77e4f4851e..e0b150f5546 100755 --- a/cs/src/Ice/IncomingAsync.cs +++ b/cs/src/Ice/IncomingAsync.cs @@ -21,82 +21,82 @@ namespace IceInternal protected void response__(bool 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); + } } - + protected internal void exception__(System.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); + } } - + protected internal BasicStream os__() { return os_; } - private bool servantLocatorFinished__() - { - try - { - if(locator_ != null && servant_ != null) - { - locator_.finished(current_, servant_, cookie_); - } - return true; - } - catch(System.Exception ex) - { - handleException__(ex); - return false; - } - } + private bool servantLocatorFinished__() + { + try + { + if(locator_ != null && servant_ != null) + { + locator_.finished(current_, servant_, cookie_); + } + return true; + } + catch(System.Exception ex) + { + handleException__(ex); + return false; + } + } } } @@ -115,24 +115,24 @@ namespace Ice : base(inc) { } - + public void ice_response(bool ok, byte[] outParams) { - try - { - os__().writeBlob(outParams); - } - catch(Ice.LocalException ex) - { - exception__(ex); - return; - } - response__(ok); - } - + try + { + os__().writeBlob(outParams); + } + catch(Ice.LocalException ex) + { + exception__(ex); + return; + } + response__(ok); + } + public void ice_exception(System.Exception ex) { - exception__(ex); + exception__(ex); } } } |