summaryrefslogtreecommitdiff
path: root/csharp/test/Ice/retry/Client.cs
diff options
context:
space:
mode:
Diffstat (limited to 'csharp/test/Ice/retry/Client.cs')
-rw-r--r--csharp/test/Ice/retry/Client.cs101
1 files changed, 35 insertions, 66 deletions
diff --git a/csharp/test/Ice/retry/Client.cs b/csharp/test/Ice/retry/Client.cs
index 952f90960ea..408f9392067 100644
--- a/csharp/test/Ice/retry/Client.cs
+++ b/csharp/test/Ice/retry/Client.cs
@@ -8,7 +8,6 @@
// **********************************************************************
using System;
-using System.Diagnostics;
using System.Reflection;
[assembly: CLSCompliant(true)]
@@ -17,81 +16,51 @@ using System.Reflection;
[assembly: AssemblyDescription("Ice test")]
[assembly: AssemblyCompany("ZeroC, Inc.")]
-public class Client
+public class Client : TestCommon.Application
{
- public static int run(string[] args, Ice.Communicator communicator, Ice.Communicator communicator2)
+ public override int run(string[] args)
{
- Test.RetryPrx retry = AllTests.allTests(communicator, communicator2, "retry:default -p 12010");
- retry.shutdown();
- return 0;
- }
-
- public static int Main(string[] args)
- {
- int status = 0;
- Ice.Communicator communicator = null;
- Ice.Communicator communicator2 = null;
+ //
+ // Configure a second communicator for the invocation timeout
+ // + retry test, we need to configure a large retry interval
+ // to avoid time-sensitive failures.
+ //
+ Ice.InitializationData initData2 = new Ice.InitializationData();
+ initData2.properties = communicator().getProperties().ice_clone_();
+ initData2.properties.setProperty("Ice.RetryIntervals", "0 1 10000");
+ initData2.observer = Instrumentation.getObserver();
+ Ice.Communicator communicator2 = Ice.Util.initialize(initData2);
try
{
- Ice.InitializationData initData = new Ice.InitializationData();
- initData.properties = Ice.Util.createProperties(ref args);
- initData.observer = Instrumentation.getObserver();
-
- initData.properties.setProperty("Ice.RetryIntervals", "0 1 10 1");
-
- //
- // This test kills connections, so we don't want warnings.
- //
- initData.properties.setProperty("Ice.Warn.Connections", "0");
-
- communicator = Ice.Util.initialize(ref args, initData);
-
- //
- // Configure a second communicator for the invocation timeout
- // + retry test, we need to configure a large retry interval
- // to avoid time-sensitive failures.
- //
- Ice.InitializationData initData2 = new Ice.InitializationData();
- initData2.properties = initData.properties.ice_clone_();
- initData2.properties.setProperty("Ice.RetryIntervals", "0 1 10000");
- initData2.observer = Instrumentation.getObserver();
- communicator2 = Ice.Util.initialize(initData2);
-
- status = run(args, communicator, communicator2);
+ Test.RetryPrx retry = AllTests.allTests(this, communicator2, "retry:" + getTestEndpoint(0));
+ retry.shutdown();
+ return 0;
}
- catch(System.Exception ex)
+ finally
{
- Console.Error.WriteLine(ex);
- status = 1;
+ communicator2.destroy();
}
+ }
- if(communicator != null)
- {
- try
- {
- communicator.destroy();
- }
- catch(Ice.LocalException ex)
- {
- Console.Error.WriteLine(ex);
- status = 1;
- }
- }
+ protected override Ice.InitializationData getInitData(ref string[] args)
+ {
+ Ice.InitializationData initData = base.getInitData(ref args);
+ initData.observer = Instrumentation.getObserver();
- if(communicator2 != null)
- {
- try
- {
- communicator2.destroy();
- }
- catch(Ice.LocalException ex)
- {
- Console.Error.WriteLine(ex);
- status = 1;
- }
- }
+ initData.properties.setProperty("Ice.RetryIntervals", "0 1 10 1");
- return status;
+ //
+ // This test kills connections, so we don't want warnings.
+ //
+ initData.properties.setProperty("Ice.Warn.Connections", "0");
+ return initData;
}
+
+ public static int Main(string[] args)
+ {
+ Client app = new Client();
+ return app.runmain(args);
+ }
+
}