diff options
Diffstat (limited to 'csharp/test/Ice/retry/Client.cs')
-rw-r--r-- | csharp/test/Ice/retry/Client.cs | 101 |
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); + } + } |