blob: a10878e40e7885ee2b1f2758e9c0c14f1822d9ed [file] [log] [blame]
mbligh36491412010-03-05 23:54:13 +00001AUTHOR = "kdlucas@google.com (Kelly Lucas)"
mblighcf8e0b72008-09-12 02:14:29 +00002TIME = "SHORT"
mbligh36491412010-03-05 23:54:13 +00003NAME = "Netpipe Basic"
mblighcf8e0b72008-09-12 02:14:29 +00004TEST_CATEGORY = "Stress"
5TEST_CLASS = 'Hardware'
6TEST_TYPE = "Server"
7SYNC_COUNT = 2
8DOC = """
9netpipe_test is a test which produces bandwidth and latency values for
10incrementing buffer sizes.
11
12Arguments to run_test:
mblighcf8e0b72008-09-12 02:14:29 +000013bidirectional - indicates whether the test should run simultaneously in both
14 directions
15buffer_size - Sets the send and receive TCP buffer sizes (from man NPtcp)
16upper_bound - Specify the upper boundary to the size of message being tested.
17 By default, NetPIPE will stop when the time to transmit a block
18 exceeds one second. (from man NPtcp)
mbligh36491412010-03-05 23:54:13 +000019variance - NetPIPE chooses the message sizes at regular intervals,
mblighcf8e0b72008-09-12 02:14:29 +000020 increasing them exponentially from the lower boundary to the
21 upper boundary. At each point, it also tests perturbations of 3
22 bytes above and 3 bytes below (default) each test point to find
23 idiosyncrasies in the system. This perturbation value can be
24 changed using using this option or turned off by setting
25 perturbation_size to 0. (from man NPtcp)
26"""
27
28from autotest_lib.server import utils
29
mbligh36491412010-03-05 23:54:13 +000030buffer_size = 1048576
31upper_bound = 1048576
32variance = 17
mblighcf8e0b72008-09-12 02:14:29 +000033
34def run(pair):
mbligh36491412010-03-05 23:54:13 +000035 job.run_test('netpipe', pair=pair, buffer=buffer_size,
36 upper_bound=upper_bound, variance=variance)
mblighcf8e0b72008-09-12 02:14:29 +000037
38# grab the pairs (and failures)
39(pairs, failures) = utils.form_ntuples_from_machines(machines, 2)
40
41# log the failures
42for failure in failures:
43 job.record("FAIL", failure[0], "netpipe", failure[1])
44
45# now run through each pair and run
mbligh5d69ff02008-09-12 17:45:46 +000046job.parallel_simple(run, pairs, log=False)