diff options
Diffstat (limited to 'python/test/Ice/proxy/ServerAMD.py')
-rwxr-xr-x | python/test/Ice/proxy/ServerAMD.py | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/python/test/Ice/proxy/ServerAMD.py b/python/test/Ice/proxy/ServerAMD.py new file mode 100755 index 00000000000..f94496bbcb7 --- /dev/null +++ b/python/test/Ice/proxy/ServerAMD.py @@ -0,0 +1,65 @@ +#!/usr/bin/env python +# ********************************************************************** +# +# Copyright (c) 2003-2015 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. +# +# ********************************************************************** + +import os, sys, traceback, time + +import Ice +slice_dir = Ice.getSliceDir() +if not slice_dir: + print(sys.argv[0] + ': Slice directory not found.') + sys.exit(1) + +Ice.loadSlice("'-I" + slice_dir + "' TestAMD.ice") +import Test + +class MyDerivedClassI(Test.MyDerivedClass): + def __init__(self): + self.ctx = None + + def shutdown_async(self, cb, current=None): + current.adapter.getCommunicator().shutdown() + cb.ice_response() + + def getContext_async(self, cb, current): + return cb.ice_response(self.ctx) + + def echo_async(self, cb, obj, current): + return cb.ice_response(obj) + + def ice_isA(self, s, current): + self.ctx = current.ctx + return Test.MyDerivedClass.ice_isA(self, s, current) + +def run(args, communicator): + communicator.getProperties().setProperty("TestAdapter.Endpoints", "default -p 12010:udp") + adapter = communicator.createObjectAdapter("TestAdapter") + adapter.add(MyDerivedClassI(), communicator.stringToIdentity("test")) + adapter.activate() + communicator.waitForShutdown() + return True + +try: + initData = Ice.InitializationData() + initData.properties = Ice.createProperties(sys.argv) + initData.properties.setProperty("Ice.Warn.Connections", "0"); + communicator = Ice.initialize(sys.argv, initData) + status = run(sys.argv, communicator) +except: + traceback.print_exc() + status = False + +if communicator: + try: + communicator.destroy() + except: + traceback.print_exc() + status = False + +sys.exit(not status) |