Make Buildbot masters send ts_mon metrics, and add standard HTTP server metrics.

scripts/master/monitoring_status_receiver.py

Index: scripts/master/monitoring_status_receiver.py
diff --git a/scripts/master/monitoring_status_receiver.py b/scripts/master/monitoring_status_receiver.py
new file mode 100644
index 0000000000000000000000000000000000000000..85634851656c1439a671188ba2fffe1a79a164f5
--- /dev/null
+++ b/scripts/master/monitoring_status_receiver.py
@@ -0,0 +1,40 @@
+# Copyright 2016 The Chromium Authors. All rights reserved.
+# Use of this source code is governed by a BSD-style license that can be
+# found in the LICENSE file.
+
+from buildbot.status.base import StatusReceiverMultiService
+from twisted.internet import task
+from twisted.python import log, threadpool
+
+from infra_libs import ts_mon
+
+
+class MonitoringStatusReceiver(StatusReceiverMultiService):
+  """Flushes ts_mon metrics once per minute."""
+
+  def __init__(self):
+    StatusReceiverMultiService.__init__(self)
+    self.thread_pool = threadpool.ThreadPool(1, 1)
+    self.loop = task.LoopingCall(self._flush)
+
+  def startService(self):
+    StatusReceiverMultiService.startService(self)
+    self.status = self.parent.getStatus()
+    self.status.subscribe(self)
+
+    self.thread_pool.start()
+    self.loop.start(60, now=False)

[agable, 2016/06/29 20:17:59]

Nice, I like this a lot better than using a changesource.

+
+  def stopService(self):
+    self.loop.stop()
+    self.thread_pool.stop()
+    return StatusReceiverMultiService.stopService(self)
+
+  def _flush(self):
+    self.thread_pool.callInThread(self._flush_and_log_exceptions)
+
+  def _flush_and_log_exceptions(self):
+    try:
+      ts_mon.flush()
+    except Exception:
+      log.err(None, 'Automatic monitoring flush failed.')