You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2015/09/28 23:22:32 UTC
[13/50] [abbrv] qpid-proton git commit: NO-JIRA: Handler tests
NO-JIRA: Handler tests
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/ef36bd67
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/ef36bd67
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/ef36bd67
Branch: refs/heads/proton-go
Commit: ef36bd67c9d4a3ace9c4b85f38ec14a3c76095e4
Parents: 3bae2f0
Author: Bozo Dragojevic <bo...@digiverse.si>
Authored: Mon Sep 28 10:52:16 2015 +0200
Committer: Bozo Dragojevic <bo...@digiverse.si>
Committed: Mon Sep 28 13:01:24 2015 +0200
----------------------------------------------------------------------
proton-c/bindings/python/proton/__init__.py | 1 +
tests/python/proton_tests/__init__.py | 1 +
tests/python/proton_tests/handler.py | 112 +++++++++++++++++++++++
3 files changed, 114 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ef36bd67/proton-c/bindings/python/proton/__init__.py
----------------------------------------------------------------------
diff --git a/proton-c/bindings/python/proton/__init__.py b/proton-c/bindings/python/proton/__init__.py
index a315f62..150b434 100644
--- a/proton-c/bindings/python/proton/__init__.py
+++ b/proton-c/bindings/python/proton/__init__.py
@@ -4089,6 +4089,7 @@ __all__ = [
"Described",
"Endpoint",
"Event",
+ "EventType",
"Handler",
"Link",
"Message",
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ef36bd67/tests/python/proton_tests/__init__.py
----------------------------------------------------------------------
diff --git a/tests/python/proton_tests/__init__.py b/tests/python/proton_tests/__init__.py
index 5f270cc..091fa49 100644
--- a/tests/python/proton_tests/__init__.py
+++ b/tests/python/proton_tests/__init__.py
@@ -20,6 +20,7 @@
import proton_tests.codec
import proton_tests.engine
import proton_tests.message
+import proton_tests.handler
import proton_tests.reactor
import proton_tests.reactor_interop
import proton_tests.messenger
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ef36bd67/tests/python/proton_tests/handler.py
----------------------------------------------------------------------
diff --git a/tests/python/proton_tests/handler.py b/tests/python/proton_tests/handler.py
new file mode 100644
index 0000000..b64e898
--- /dev/null
+++ b/tests/python/proton_tests/handler.py
@@ -0,0 +1,112 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+from __future__ import absolute_import
+
+import os, gc, traceback
+import sys
+from . import common
+from time import time, sleep
+from proton import *
+from .common import pump, Skipped
+from proton.reactor import Reactor
+
+
+CUSTOM = EventType("custom")
+
+class HandlerTest(common.Test):
+ def test_reactorHandlerCycling(self, n=0):
+
+ class CustomHandler(Handler):
+ UNSET = 999999999
+ def __init__(self):
+ self.offset = len(traceback.extract_stack())
+ def on_reactor_init(self, event):
+ self.depth = len(traceback.extract_stack())
+ def reset(self):
+ self.depth = self.UNSET
+ @property
+ def init_depth(self):
+ d = self.depth - self.offset
+ return d
+ custom = CustomHandler()
+
+ reactor = Reactor()
+ reactor.handler = custom
+ for i in range(n):
+ h = reactor.handler
+ reactor.handler = h
+ custom.reset()
+ reactor.run()
+ assert custom.init_depth < 50, "Unexpectedly long traceback for a simple handler"
+
+ def test_reactorHandlerCycling10k(self):
+ self.test_reactorHandlerCycling(10000)
+
+ def test_reactorHandlerCycling100(self):
+ self.test_reactorHandlerCycling(100)
+
+ def do_customEvent(self, reactor_handler, event_root):
+
+ class CustomHandler:
+ did_custom = False
+ did_init = False
+ def __init__(self, *handlers):
+ self.handlers = handlers
+ def on_reactor_init(self, event):
+ self.did_init = True
+ def on_custom(self, event):
+ self.did_custom = True
+
+ class CustomInvoker(CustomHandler):
+ def on_reactor_init(self, event):
+ h = event_root(event)
+ event.dispatch(h, CUSTOM)
+ self.did_init = True
+
+ child = CustomInvoker()
+ root = CustomHandler(child)
+
+ reactor = Reactor()
+
+ reactor_handler(reactor, root)
+ reactor.run()
+ assert root.did_init
+ assert child.did_init
+ assert root.did_custom
+ assert child.did_custom
+
+ def set_root(self, reactor, root):
+ reactor.handler = root
+ def add_root(self, reactor, root):
+ reactor.handler.add(root)
+ def append_root(self, reactor, root):
+ reactor.handler.handlers.append(root)
+
+ def event_reactor_handler(self, event):
+ return event.reactor.handler
+
+ def test_set_handler(self):
+ self.do_customEvent(self.set_root, self.event_reactor_handler)
+
+ def test_add_handler(self):
+ self.do_customEvent(self.add_root, self.event_reactor_handler)
+
+ def test_append_handler(self):
+ self.do_customEvent(self.append_root, self.event_reactor_handler)
+
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org