From 43dbcfc4eeec0e46c8dbefc363b875117df5cf25 Mon Sep 17 00:00:00 2001
From: Logan Hanks <logan@reddit.com>
Date: Tue, 8 Nov 2011 16:56:02 -0700
Subject: [PATCH] Apply timing stats recording to remaining amqp processors.

---
 r2/r2/lib/media.py      | 1 +
 r2/r2/lib/solrsearch.py | 1 +
 2 files changed, 2 insertions(+)

diff --git a/r2/r2/lib/media.py b/r2/r2/lib/media.py
index bcbd3d6f7..63dc5529d 100644
--- a/r2/r2/lib/media.py
+++ b/r2/r2/lib/media.py
@@ -174,6 +174,7 @@ def force_thumbnail(link, image_data, never_expire=True, file_type=".jpg"):
     update_link(link, thumbnail=thumb_url, media_object=None, thumbnail_size=image.size)
 
 def run():
+    @g.stats.amqp_processor
     def process_link(msg):
         def _process_link(fname):
             link = Link._by_fullname(fname, data=True)
diff --git a/r2/r2/lib/solrsearch.py b/r2/r2/lib/solrsearch.py
index d51b04383..5e4dc0687 100644
--- a/r2/r2/lib/solrsearch.py
+++ b/r2/r2/lib/solrsearch.py
@@ -687,5 +687,6 @@ def run_changed(drain=False):
                 for i in delete_things:
                     s.delete(id=i._fullname)
 
+    @g.stats.amqp_processor
     amqp.handle_items('solrsearch_changes', _run_changed, limit=1000,
                       drain=drain)