diff options
Diffstat (limited to 'python/test/Ice/dispatcher/TestI.py')
-rw-r--r-- | python/test/Ice/dispatcher/TestI.py | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/python/test/Ice/dispatcher/TestI.py b/python/test/Ice/dispatcher/TestI.py new file mode 100644 index 00000000000..2dfa9cc3f52 --- /dev/null +++ b/python/test/Ice/dispatcher/TestI.py @@ -0,0 +1,40 @@ +# ********************************************************************** +# +# Copyright (c) 2003-2017 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 Ice, Test, Dispatcher, time + +def test(b): + if not b: + raise RuntimeError('test assertion failed') + +class TestIntfI(Test._TestIntfDisp): + def op(self, current=None): + test(Dispatcher.Dispatcher.isDispatcherThread()) + + def sleep(self, ms, current=None): + time.sleep(ms / 1000.0) + + def opWithPayload(self, bytes, current=None): + test(Dispatcher.Dispatcher.isDispatcherThread()) + + def shutdown(self, current=None): + test(Dispatcher.Dispatcher.isDispatcherThread()) + current.adapter.getCommunicator().shutdown() + +class TestIntfControllerI(Test._TestIntfControllerDisp): + def __init__(self, adapter): + self._adapter = adapter + + def holdAdapter(self, current=None): + test(Dispatcher.Dispatcher.isDispatcherThread()) + self._adapter.hold() + + def resumeAdapter(self, current=None): + test(Dispatcher.Dispatcher.isDispatcherThread()) + self._adapter.activate() |