Commit a074a873 authored by Kenneth Giusti's avatar Kenneth Giusti

bugfix: leak of timed callbacks

parent fbe5806d
......@@ -779,9 +779,10 @@ class Connection(Endpoint):
deadline = heapq.heappop(self._timers_heap)
callbacks = self._timers.get(deadline)
if callbacks:
del self._timers[deadline]
for cb in callbacks:
cb()
del self._timers[deadline]
return self._timers_heap[0] if self._timers_heap else 0
# Proton's event model was changed after 0.7
......
......@@ -431,9 +431,6 @@ class SenderLink(_Link):
self._pn_link.delivery(tag)
LOG.debug("Sending a message, tag=%s", tag)
if deadline:
self._connection._add_timer(deadline, send_req)
pn_delivery = self._pn_link.current
if pn_delivery and pn_delivery.writable:
# send oldest pending:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment