summaryrefslogtreecommitdiff
path: root/python/test/Ice/dispatcher/TestI.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/test/Ice/dispatcher/TestI.py')
-rw-r--r--python/test/Ice/dispatcher/TestI.py40
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()