stats: Condense all vote_link_q shard stats into one stats key.

This commit is contained in:
Neil Williams
2012-11-15 16:12:42 -08:00
parent 4a48331422
commit bdad9c4635

View File

@@ -1470,10 +1470,13 @@ def handle_vote(user, thing, dir, ip, organic,
def process_votes(qname, limit=0):
# limit is taken but ignored for backwards compatibility
stats_qname = qname
if stats_qname.startswith("vote_link"):
stats_qname = "vote_link_q"
@g.stats.amqp_processor(qname)
@g.stats.amqp_processor(stats_qname)
def _handle_vote(msg):
timer = stats.get_timer("service_time." + qname)
timer = stats.get_timer("service_time." + stats_qname)
timer.start()
#assert(len(msgs) == 1)