summaryrefslogtreecommitdiff
path: root/cs/src/Ice/IncomingAsync.cs
diff options
context:
space:
mode:
Diffstat (limited to 'cs/src/Ice/IncomingAsync.cs')
-rwxr-xr-xcs/src/Ice/IncomingAsync.cs156
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);
}
}
}