diff options
Diffstat (limited to 'qpid/extras/dispatch/python')
| -rw-r--r-- | qpid/extras/dispatch/python/qpid/dispatch/router/link.py | 1 | ||||
| -rw-r--r-- | qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py | 15 |
2 files changed, 10 insertions, 6 deletions
diff --git a/qpid/extras/dispatch/python/qpid/dispatch/router/link.py b/qpid/extras/dispatch/python/qpid/dispatch/router/link.py index 4a770684cd..11307cd079 100644 --- a/qpid/extras/dispatch/python/qpid/dispatch/router/link.py +++ b/qpid/extras/dispatch/python/qpid/dispatch/router/link.py @@ -92,6 +92,7 @@ class LinkStateEngine(object): # Schedule LSRs for any routers referenced in this LS that we don't know about for _id in msg.ls.peers: if _id not in self.collection: + self.container.new_node(_id) self.needed_lsrs[(msg.area, _id)] = None 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 03bf0638a5..d5250872b2 100644 --- a/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py +++ b/qpid/extras/dispatch/python/qpid/dispatch/router/router_engine.py @@ -143,28 +143,28 @@ class RouterEngine: elif opcode == 'RA': msg = MessageRA(body) - self.log(LOG_TRACE, "RCVD: %r" % msg) + self.log(LOG_DEBUG, "RCVD: %r" % msg) self.link_state_engine.handle_ra(msg, now) self.mobile_address_engine.handle_ra(msg, now) elif opcode == 'LSU': msg = MessageLSU(body) - self.log(LOG_TRACE, "RCVD: %r" % msg) + self.log(LOG_DEBUG, "RCVD: %r" % msg) self.link_state_engine.handle_lsu(msg, now) elif opcode == 'LSR': msg = MessageLSR(body) - self.log(LOG_TRACE, "RCVD: %r" % msg) + self.log(LOG_DEBUG, "RCVD: %r" % msg) self.link_state_engine.handle_lsr(msg, now) elif opcode == 'MAU': msg = MessageMAU(body) - self.log(LOG_TRACE, "RCVD: %r" % msg) + self.log(LOG_DEBUG, "RCVD: %r" % msg) self.mobile_address_engine.handle_mau(msg, now) elif opcode == 'MAR': msg = MessageMAR(body) - self.log(LOG_TRACE, "RCVD: %r" % msg) + self.log(LOG_DEBUG, "RCVD: %r" % msg) self.mobile_address_engine.handle_mar(msg, now) except Exception, e: @@ -223,7 +223,10 @@ class RouterEngine: """ app_props = {'opcode' : msg.get_opcode() } self.io_adapter.send(dest, app_props, msg.to_dict()) - self.log(LOG_TRACE, "SENT: %r dest=%s" % (msg, dest)) + if "qdxhello" in dest: + self.log(LOG_TRACE, "SENT: %r dest=%s" % (msg, dest)) + else: + self.log(LOG_DEBUG, "SENT: %r dest=%s" % (msg, dest)) def node_updated(self, addr, reachable, neighbor): |