diff options
| author | Ted Ross <tross@apache.org> | 2013-10-04 21:28:24 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2013-10-04 21:28:24 +0000 |
| commit | d7f7a3933f2b1c0861a2316ff41a6fe2b54f2431 (patch) | |
| tree | c9387dc2bce14b4f4f49114cc9bd817d7ee80b74 /qpid/extras/dispatch/python | |
| parent | 6f05c50f75c055104275dee247e86f85e7f2711d (diff) | |
| download | qpid-python-d7f7a3933f2b1c0861a2316ff41a6fe2b54f2431.tar.gz | |
QPID-4967 - Bug fixes, added a lock to serialize calls into the Python interpreter.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1529307 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/extras/dispatch/python')
| -rw-r--r-- | qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py | 1 | ||||
| -rw-r--r-- | qpid/extras/dispatch/python/qpid/dispatch/router/routing.py | 4 |
2 files changed, 3 insertions, 2 deletions
diff --git a/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py b/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py index 02f0315104..03bf0638a5 100644 --- a/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py +++ b/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py @@ -176,6 +176,7 @@ class RouterEngine: This is the IoAdapter message-receive handler """ try: + #self.log(LOG_DEBUG, "Raw Receive: mp=%r body=%r link_id=%r" % (message_properties, body, link_id)) self.handleControlMessage(message_properties['opcode'], body, link_id) except Exception, e: self.log(LOG_ERROR, "Exception in raw message processing: properties=%r body=%r exception=%r" % diff --git a/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py b/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py index 1097d8fbba..a4b3e5484a 100644 --- a/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py +++ b/qpid/extras/dispatch/python/qpid/dispatch/router/routing.py @@ -48,13 +48,13 @@ class RoutingTableEngine(object): self.container.router_adapter.set_next_hop(mb_id, mb_nh) - def valid_origins_changes(self, valid_origins): + def valid_origins_changed(self, valid_origins): for _id, vo in valid_origins.items(): mb_id = self.node_tracker.maskbit_for_node(_id) mb_vo = [] for o in vo: mb_vo.append(self.node_tracker.maskbit_for_node(o)) - self.container.router_adapted.set_valid_origins(mb_id, mb_vo) + self.container.router_adapter.set_valid_origins(mb_id, mb_vo) def get_next_hops(self): |