diff options
Diffstat (limited to 'csharp/test/Ice/dispatcher/Server.cs')
-rw-r--r-- | csharp/test/Ice/dispatcher/Server.cs | 72 |
1 files changed, 27 insertions, 45 deletions
diff --git a/csharp/test/Ice/dispatcher/Server.cs b/csharp/test/Ice/dispatcher/Server.cs index 1cb0859231f..c0466541b33 100644 --- a/csharp/test/Ice/dispatcher/Server.cs +++ b/csharp/test/Ice/dispatcher/Server.cs @@ -8,7 +8,6 @@ // ********************************************************************** using System; -using System.Diagnostics; using System.Reflection; [assembly: CLSCompliant(true)] @@ -17,66 +16,49 @@ using System.Reflection; [assembly: AssemblyDescription("Ice test")] [assembly: AssemblyCompany("ZeroC, Inc.")] -public class Server +public class Server : TestCommon.Application { - private static int run(string[] args, Ice.Communicator communicator) + public override int run(string[] args) { - communicator.getProperties().setProperty("TestAdapter.Endpoints", "default -p 12010"); - communicator.getProperties().setProperty("ControllerAdapter.Endpoints", "tcp -p 12011"); - communicator.getProperties().setProperty("ControllerAdapter.ThreadPool.Size", "1"); + communicator().getProperties().setProperty("TestAdapter.Endpoints", getTestEndpoint(0)); + communicator().getProperties().setProperty("ControllerAdapter.Endpoints", getTestEndpoint(1)); + communicator().getProperties().setProperty("ControllerAdapter.ThreadPool.Size", "1"); - Ice.ObjectAdapter adapter = communicator.createObjectAdapter("TestAdapter"); - Ice.ObjectAdapter adapter2 = communicator.createObjectAdapter("ControllerAdapter"); + Ice.ObjectAdapter adapter = communicator().createObjectAdapter("TestAdapter"); + Ice.ObjectAdapter adapter2 = communicator().createObjectAdapter("ControllerAdapter"); - adapter.add(new TestI(), communicator.stringToIdentity("test")); + adapter.add(new TestI(), Ice.Util.stringToIdentity("test")); adapter.activate(); - adapter2.add(new TestControllerI(adapter), communicator.stringToIdentity("testController")); + adapter2.add(new TestControllerI(adapter), Ice.Util.stringToIdentity("testController")); adapter2.activate(); - communicator.waitForShutdown(); + communicator().waitForShutdown(); return 0; } - public static int Main(string[] args) + protected override Ice.InitializationData getInitData(ref string[] args) { - int status = 0; - Ice.Communicator communicator = null; + Ice.InitializationData initData = base.getInitData(ref args); + initData.properties.setProperty("Ice.ServerIdleTime", "30"); + // + // Limit the recv buffer size, this test relies on the socket + // send() blocking after sending a given amount of data. + // + initData.properties.setProperty("Ice.TCP.RcvSize", "50000"); + initData.dispatcher = new Dispatcher().dispatch; + return initData; + } + public static int Main(string[] args) + { + Server app = new Server(); try { - Ice.InitializationData initData = new Ice.InitializationData(); - initData.properties = Ice.Util.createProperties(ref args); - initData.properties.setProperty("Ice.ServerIdleTime", "30"); - // - // Limit the recv buffer size, this test relies on the socket - // send() blocking after sending a given amount of data. - // - initData.properties.setProperty("Ice.TCP.RcvSize", "50000"); - initData.dispatcher = new Dispatcher().dispatch; - communicator = Ice.Util.initialize(ref args, initData); - status = run(args, communicator); + return app.runmain(args); } - catch(System.Exception ex) + finally { - System.Console.Error.WriteLine(ex); - status = 1; + Dispatcher.terminate(); } - - if(communicator != null) - { - try - { - communicator.destroy(); - } - catch(Ice.LocalException ex) - { - System.Console.Error.WriteLine(ex); - status = 1; - } - } - - Dispatcher.terminate(); - - return status; } } |