diff options
Diffstat (limited to 'python/test/Ice/blobject/Server.py')
-rwxr-xr-x | python/test/Ice/blobject/Server.py | 49 |
1 files changed, 21 insertions, 28 deletions
diff --git a/python/test/Ice/blobject/Server.py b/python/test/Ice/blobject/Server.py index b14e881805d..b1bd3095f81 100755 --- a/python/test/Ice/blobject/Server.py +++ b/python/test/Ice/blobject/Server.py @@ -8,12 +8,12 @@ # # ********************************************************************** -import os, sys, traceback - +from TestHelper import TestHelper +TestHelper.loadSlice('Test.ice') import Ice - -Ice.loadSlice('Test.ice') import Test +import time + class TestI(Test.Hello): def sayHello(self, delay, current=None): @@ -29,27 +29,20 @@ class TestI(Test.Hello): def shutdown(self, current=None): current.adapter.getCommunicator().shutdown() -def run(args, communicator): - communicator.getProperties().setProperty("TestAdapter.Endpoints", "default -p 12010") - adapter = communicator.createObjectAdapter("TestAdapter") - adapter.add(TestI(), Ice.stringToIdentity("test")) - adapter.activate() - communicator.waitForShutdown() - return True - -try: - initData = Ice.InitializationData() - initData.properties = Ice.createProperties(sys.argv) - # - # Its possible to have batch oneway requests dispatched after the - # adapter is deactivated due to thread scheduling so we supress - # this warning. - # - initData.properties.setProperty("Ice.Warn.Dispatch", "0"); - with Ice.initialize(sys.argv, initData) as communicator: - status = run(sys.argv, communicator) -except: - traceback.print_exc() - status = False - -sys.exit(not status) + +class Server(TestHelper): + + def run(self, args): + properties = self.createTestProperties(args) + # + # Its possible to have batch oneway requests dispatched after the + # adapter is deactivated due to thread scheduling so we supress + # this warning. + # + properties.setProperty("Ice.Warn.Dispatch", "0") + with self.initialize(properties=properties) as communicator: + communicator.getProperties().setProperty("TestAdapter.Endpoints", "default -p 12010") + adapter = communicator.createObjectAdapter("TestAdapter") + adapter.add(TestI(), Ice.stringToIdentity("test")) + adapter.activate() + communicator.waitForShutdown() |