diff options
Diffstat (limited to 'csharp/test/Ice/interceptor/AMDInterceptorI.cs')
-rw-r--r-- | csharp/test/Ice/interceptor/AMDInterceptorI.cs | 125 |
1 files changed, 0 insertions, 125 deletions
diff --git a/csharp/test/Ice/interceptor/AMDInterceptorI.cs b/csharp/test/Ice/interceptor/AMDInterceptorI.cs deleted file mode 100644 index a1f6573b786..00000000000 --- a/csharp/test/Ice/interceptor/AMDInterceptorI.cs +++ /dev/null @@ -1,125 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved. -// -// This copy of Ice is licensed to you under the terms described in the -// ICE_LICENSE file included in this distribution. -// -// ********************************************************************** - -// -// A dispatch interceptor with special handling for AMD requests -// - -using System; - -class AMDInterceptorI : InterceptorI, Ice.DispatchInterceptorAsyncCallback -{ - class DispatchInterceptorAsyncCallbackI : Ice.DispatchInterceptorAsyncCallback - { - public bool response(bool ok) - { - test(ok); - return false; - } - - public bool exception(System.Exception ex) - { - test(ex is Test.RetryException); - return false; - } - }; - - - internal AMDInterceptorI(Ice.Object servant) : base(servant) - { - } - - public override Ice.DispatchStatus - dispatch(Ice.Request request) - { - Ice.Current current = request.getCurrent(); - lastOperation_ = current.operation; - - if(lastOperation_.Equals("amdAddWithRetry")) - { - for(int i = 0; i < 10; ++i) - { - Ice.DispatchInterceptorAsyncCallback cb = new DispatchInterceptorAsyncCallbackI(); - - lastStatus_ = servant_.ice_dispatch(request, cb); - test(lastStatus_ == Ice.DispatchStatus.DispatchAsync); - } - - request.getCurrent().ctx["retry"] = "no"; - } - - - lastStatus_ = servant_.ice_dispatch(request, this); - return lastStatus_; - } - - public bool response(bool ok) - { - setActualStatus(ok ? Ice.DispatchStatus.DispatchOK : Ice.DispatchStatus.DispatchUserException); - return true; - } - - public bool exception(System.Exception ex) - { - setActualStatus(ex); - return true; - } - - internal override void - clear() - { - base.clear(); - lock(this) - { - actualStatus_ = Ice.DispatchStatus.DispatchAsync; - exception_ = null; - } - } - - internal void - setActualStatus(Ice.DispatchStatus status) - { - lock(this) - { - actualStatus_ = status; - exception_ = null; - } - } - - internal void - setActualStatus(System.Exception ex) - { - lock(this) - { - exception_ = ex; - actualStatus_ = Ice.DispatchStatus.DispatchAsync; - } - } - - internal Ice.DispatchStatus - getActualStatus() - { - lock(this) - { - return actualStatus_; - } - } - - internal System.Exception - getException() - { - lock(this) - { - return exception_; - } - } - - private Ice.DispatchStatus actualStatus_; - private System.Exception exception_; -} |