luci-py: Roll infra_libs.

client/third_party/infra_libs/ts_mon/common/interface.py

 # Copyright 2015 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.
 
 """Classes representing the monitoring interface for tasks or devices.
 
 Usage:
   import argparse
   from infra_libs import ts_mon
 
@@ skipping 27 matching lines @@
 import time
 import traceback
 
 from infra_libs.ts_mon.common import errors
 from infra_libs.ts_mon.common import metric_store
 from infra_libs.ts_mon.protos.current import metrics_pb2
 from infra_libs.ts_mon.protos.new import metrics_pb2 as new_metrics_pb2
 
 # The maximum number of MetricsData messages to include in each HTTP request.
 # MetricsCollections larger than this will be split into multiple requests.
-METRICS_DATA_LENGTH_LIMIT = 1000
+METRICS_DATA_LENGTH_LIMIT = 500
 
 
 class State(object):
   """Package-level state is stored here so that it is easily accessible.
 
   Configuration is kept in this one object at the global level so that all
   libraries in use by the same tool or service can all take advantage of the
   same configuration.
   """
 
@@ skipping 190 matching lines @@
     except Exception:
       logging.exception('Automatic monitoring flush failed.')
 
   def run(self):
     # Jitter the first interval so tasks started at the same time (say, by cron)
     # on different machines don't all send metrics simultaneously.
     next_timeout = random.uniform(self.interval_secs / 2.0, self.interval_secs)
 
     while True:
       if self.stop_event.wait(next_timeout):
-        self._flush_and_log_exceptions()
         return
 
       # Try to flush every N seconds exactly so rate calculations are more
       # consistent.
       start = time.time()
       self._flush_and_log_exceptions()
       flush_duration = time.time() - start
       next_timeout = self.interval_secs - flush_duration
 
       if next_timeout < 0:
         logging.warning(
             'Last monitoring flush took %f seconds (longer than '
             '--ts-mon-flush-interval-secs = %f seconds)',
             flush_duration, self.interval_secs)
         next_timeout = 0
 
   def stop(self):
     """Stops the background thread and performs a final flush."""
 
     self.stop_event.set()
     self.join()