From 5eff5db70d443362a7d8695bc782889d5bbea8a5 Mon Sep 17 00:00:00 2001
From: Dannon Baker <dannon.baker@gmail.com>
Date: Fri, 6 Feb 2015 10:55:15 -0500
Subject: [PATCH 1/2] Minor formatting of routes in buildapp.py

---
 lib/galaxy/webapps/galaxy/buildapp.py | 24 ++++++++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/lib/galaxy/webapps/galaxy/buildapp.py b/lib/galaxy/webapps/galaxy/buildapp.py
index aa618d3171d..1026f6527c8 100644
--- a/lib/galaxy/webapps/galaxy/buildapp.py
+++ b/lib/galaxy/webapps/galaxy/buildapp.py
@@ -248,12 +248,28 @@ def populate_api_routes( webapp, app ):
     webapp.add_route( '/visualization/show/:visualization_name', controller='visualization', action='render', visualization_name=None )
 
     # Deprecated in favor of POST /api/workflows with 'workflow' in payload.
-    webapp.mapper.connect( 'import_workflow_deprecated', '/api/workflows/upload', controller='workflows', action='import_new_workflow_deprecated', conditions=dict( method=['POST'] ) )
-    webapp.mapper.connect( 'workflow_dict', '/api/workflows/{workflow_id}/download', controller='workflows', action='workflow_dict', conditions=dict( method=['GET'] ) )
+    webapp.mapper.connect( 'import_workflow_deprecated',
+                           '/api/workflows/upload',
+                           controller='workflows',
+                           action='import_new_workflow_deprecated',
+                           conditions=dict( method=['POST'] ) )
+    webapp.mapper.connect( 'workflow_dict',
+                           '/api/workflows/{workflow_id}/download',
+                           controller='workflows',
+                           action='workflow_dict',
+                           conditions=dict( method=['GET'] ) )
     # Preserve the following download route for now for dependent applications  -- deprecate at some point
-    webapp.mapper.connect( 'workflow_dict', '/api/workflows/download/{workflow_id}', controller='workflows', action='workflow_dict', conditions=dict( method=['GET'] ) )
+    webapp.mapper.connect( 'workflow_dict',
+                           '/api/workflows/download/{workflow_id}',
+                           controller='workflows',
+                           action='workflow_dict',
+                           conditions=dict( method=['GET'] ) )
     # Deprecated in favor of POST /api/workflows with shared_workflow_id in payload.
-    webapp.mapper.connect( 'import_shared_workflow_deprecated', '/api/workflows/import', controller='workflows', action='import_shared_workflow_deprecated', conditions=dict( method=['POST'] ) )
+    webapp.mapper.connect( 'import_shared_workflow_deprecated',
+                           '/api/workflows/import',
+                           controller='workflows',
+                           action='import_shared_workflow_deprecated',
+                           conditions=dict( method=['POST'] ) )
 
     # API refers to usages and invocations - these mean the same thing but the
     # usage routes should be considered deprecated.

From 7adff59c5f30060c0b3f6165d16d59d6b3fc4aff Mon Sep 17 00:00:00 2001
From: Dannon Baker <dannon.baker@gmail.com>
Date: Fri, 6 Feb 2015 11:05:06 -0500
Subject: [PATCH 2/2] Force postfork unique servername on uwsgi workers in the
 format of 'servername.workername'.  Use this for correctly routing messages.

---
 lib/galaxy/queues.py                  | 17 +++++++++++++----
 lib/galaxy/webapps/galaxy/buildapp.py |  3 +++
 2 files changed, 16 insertions(+), 4 deletions(-)

diff --git a/lib/galaxy/queues.py b/lib/galaxy/queues.py
index 8823ef3a18e..2f656c56b32 100644
--- a/lib/galaxy/queues.py
+++ b/lib/galaxy/queues.py
@@ -27,8 +27,12 @@ def all_control_queues_for_declare(config):
 
     Refactor later to actually persist this somewhere instead of building it repeatedly.
     """
-    return [Queue('control.%s' % q, galaxy_exchange, routing_key='control') for
-            q in config.server_names]
+    possible_uwsgi_queues = []
+    if config.is_uwsgi:
+        import uwsgi
+        possible_uwsgi_queues = [Queue("control.%s.%s" % (config.server_name, wkr['id']), galaxy_exchange, routing_key='control') for wkr in uwsgi.workers()]
+    return possible_uwsgi_queues + [Queue('c ntrol.%s' % q, galaxy_exchange, routing_key='control') for
+                                    q in config.server_names]
 
 
 def control_queue_from_config(config):
@@ -36,5 +40,10 @@ def control_queue_from_config(config):
     Returns a Queue instance with the correct name and routing key for this
     galaxy process's config
     """
-    return Queue("control.%s" % config.server_name, galaxy_exchange,
-                 routing_key='control')
+    if config.is_uwsgi:
+        import uwsgi
+        return Queue("control.%s.%s" % (config.server_name, uwsgi.worker_id()), galaxy_exchange,
+                     routing_key='control')
+    else:
+        return Queue("control.%s" % config.server_name, galaxy_exchange,
+                     routing_key='control')
diff --git a/lib/galaxy/webapps/galaxy/buildapp.py b/lib/galaxy/webapps/galaxy/buildapp.py
index 1026f6527c8..819ff58e13e 100644
--- a/lib/galaxy/webapps/galaxy/buildapp.py
+++ b/lib/galaxy/webapps/galaxy/buildapp.py
@@ -124,6 +124,9 @@ def app_factory( global_conf, **kwargs ):
 def postfork_setup():
     from galaxy.app import app
     from galaxy.queue_worker import GalaxyQueueWorker
+    if app.config.is_uwsgi:
+        import uwsgi
+        app.config.server_name += ".%s" % uwsgi.worker_id()
     app.control_worker = GalaxyQueueWorker(app, galaxy.queues.control_queue_from_config(app.config),
                                            galaxy.queue_worker.control_message_to_task)
     app.control_worker.daemon = True