Reduce the number of MetricsData protos to put in each request.

infra_libs/ts_mon/test/interface_test.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.
 
 import functools
 import threading
 import time
 import unittest
 
 import mock
@@ skipping 77 matching lines @@
   def test_flush_raises(self):
     self.assertIsNone(interface.state.global_monitor)
     with self.assertRaises(errors.MonitoringNoConfiguredMonitorError):
       interface.flush()
 
   def test_flush_many(self):
     interface.state.global_monitor = stubs.MockMonitor()
 
     # pylint: disable=unused-argument
     def serialize_to(pb, default_target=None, loop_action=None):
-      for _ in xrange(5001):
+      for _ in xrange(1001):
         loop_action(pb)
         pb.data.add().name = 'foo'
 
     # We can't use the mock's call_args_list here because the same object is
     # reused as the argument to both calls and cleared inbetween.
     data_lengths = []
     def send(proto):
       data_lengths.append(len(proto.data))
     interface.state.global_monitor.send.side_effect = send
 
     fake_metric = mock.Mock()
     fake_metric.serialize_to = mock.Mock(side_effect=serialize_to)
     interface.state.metrics.add(fake_metric)
 
     interface.flush()
     self.assertEquals(2, interface.state.global_monitor.send.call_count)
-    self.assertEqual(5000, data_lengths[0])
+    self.assertEqual(1000, data_lengths[0])
     self.assertEqual(1, data_lengths[1])
 
   def test_register_unregister(self):
     fake_metric = mock.Mock()
     self.assertEqual(0, len(interface.state.metrics))
     interface.register(fake_metric)
     self.assertEqual(1, len(interface.state.metrics))
     interface.unregister(fake_metric)
     self.assertEqual(0, len(interface.state.metrics))
 
@@ skipping 156 matching lines @@
 
   def test_sleeps_for_minimum_zero_secs(self):
     self.t.start()
 
     # Flush takes 65 seconds.
     interface.flush.side_effect = functools.partial(self.increment_time, 65)
 
     self.assertInRange(30, 60, self.stop_event.timeout_wait())
     self.assertAlmostEqual(0, self.stop_event.timeout_wait())
     self.assertAlmostEqual(0, self.stop_event.timeout_wait())