for counter, (desc, text) in enumerate(reader):
receive_time = perf_counter()
text = text.strip()
- print('{1}: received text "{0}"'.format(text, counter))
+ print('{1}: received text "{0}" at {2}'
+ .format(text, counter, receive_time))
index = text.index(':')
count_text = int(text[:index].strip())
self.assertEqual(count_text, counter)
if counter == n_texts-1:
print('stop since have {0} reads'.format(counter))
break
- print('time diffs in us: {0}'.format(time_diffs))
- self.assertTrue(max(time_diffs) < 1500., 'read took more than 1.5ms!')
+ print('time diffs in ms: {0}'.format(time_diffs))
+ self.assertTrue(max(time_diffs) < 1000.,
+ 'read took more than 1ms (max was {0:.3f}ms)!'
+ .format(max(time_diffs)))
def test_line_read(self):
""" write partial lines, full lines and multiple lines """