Attachment 937991 Details for Bug 1123778 – Patch proposal for 0.22 downstream

[patch] Patch proposal for 0.22 downstream

bz1123778_downstream.patch (text/plain), 2.71 KB, created by Pavel Moravec on 2014-09-16 12:48:30 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2014-09-16 12:48:30 UTC

Size: 2.71 KB

patch

obsolete

>--- /usr/lib/python2.6/site-packages/qpid/messaging/driver.py.orig	2014-09-16 14:28:00.027001526 +0200
>+++ /usr/lib/python2.6/site-packages/qpid/messaging/driver.py.new	2014-09-16 14:40:25.471001618 +0200
>@@ -121,9 +121,9 @@ class SessionState:
> 
>     self.destinations = {}
> 
>-  def write_query(self, query, handler):
>+  def write_query(self, query, handler, obj):
>     id = self.sent
>-    self.write_cmd(query, lambda: handler(self.results.pop(id)))
>+    self.write_cmd(query, lambda: handler(self.results.pop(id), obj))
> 
>   def apply_overrides(self, cmd, overrides):
>     for k, v in overrides.items():
>@@ -991,35 +991,47 @@ class Engine:
>       except KeyError:
>         pass
> 
>-    args = []
>-    def do_result(r):
>-      args.append(r)
>-    def do_action(r):
>-      do_result(r)
>-      er, qr = args
>-      if node_type == "topic" and not er.not_found:
>+    args = { "topic":None, "queue":None }
>+    def do_result(r, obj):
>+      args[obj] = r
>+    def do_action():
>+      er = args["topic"]
>+      qr = args["queue"]
>+      if node_type == "topic" and er and not er.not_found:
>         type, subtype = "topic", er.type
>-      elif node_type == "queue" and qr.queue:
>+      elif node_type == "queue" and qr and qr.queue:
>         type, subtype = "queue", None
>-      elif er.not_found and not qr.queue:
>+      elif (er and er.not_found) and qr and not qr.queue:
>         type, subtype = None, None
>-      elif qr.queue:
>+      elif (qr and qr.queue):
>         if node_type == "topic" and force:
>           type, subtype = None, None
>         else:
>           type, subtype = "queue", None
>-      elif not er.not_found:
>+      elif (er and not er.not_found):
>         if node_type == "queue" and force:
>           type, subtype = None, None
>         else:
>           type, subtype = "topic", er.type
>-      else:
>+      elif er:
>         type, subtype = "topic", er.type
>+      else:
>+        type, subtype = None, None
>       if type is not None:
>         self.address_cache[name] = (type, subtype)
>       action(type, subtype)
>-    sst.write_query(ExchangeQuery(name), do_result)
>-    sst.write_query(QueueQuery(name), do_action)
>+    def do_result_and_action(r, obj):
>+      do_result(r, obj)
>+      do_action()
>+    if (node_type is None): # we don't know the type, let check broker
>+      sst.write_query(ExchangeQuery(name), do_result, "topic")
>+      sst.write_query(QueueQuery(name), do_result_and_action, "queue")
>+    elif force: # we forcefully declare known type, dont ask broker
>+      do_action()
>+    elif node_type == "topic":
>+      sst.write_query(ExchangeQuery(name), do_result_and_action, "topic")
>+    else:
>+      sst.write_query(QueueQuery(name), do_result_and_action, "queue")
> 
>   def declare(self, sst, lnk, action):
>     name = lnk.name

Actions: View | Diff

Attachments on bug 1123778: 926687 | 927455 | 937991 | 1038103