| Index: server/tests/barriertest_2client/control.srv
|
| diff --git a/server/tests/barriertest_2client/control.srv b/server/tests/barriertest_2client/control.srv
|
| deleted file mode 100644
|
| index d6a70bb0685e8845316cd186c64daa2c09312bb5..0000000000000000000000000000000000000000
|
| --- a/server/tests/barriertest_2client/control.srv
|
| +++ /dev/null
|
| @@ -1,78 +0,0 @@
|
| -AUTHOR = "gps@google.com (Gregory P. Smith)"
|
| -TIME = "SHORT"
|
| -NAME = "barrier_2client"
|
| -TEST_CATEGORY = "Functional"
|
| -TEST_CLASS = 'Network'
|
| -TEST_TYPE = "Server"
|
| -EXPERIMENTAL = True # This is functional a test of autotest itself.
|
| -SYNC_COUNT = 2
|
| -DOC = """
|
| -A functional test of autotest's Barrier mechanisms for synchronizing
|
| -events between two clients without the help of the server.
|
| -"""
|
| -
|
| -from autotest_lib.server import utils
|
| -
|
| -def run(pair):
|
| - logging.info('Running on %s and %s', pair[0], pair[1])
|
| - host_objs = [hosts.create_host(machine) for machine in pair]
|
| - host_at_objs = [autotest.Autotest(host) for host in host_objs]
|
| -
|
| - client_control_template = """
|
| -import logging, platform, socket, traceback
|
| -try:
|
| - client_hostnames = %r
|
| - master_hostname = client_hostnames[0]
|
| - client_hostname = client_hostnames[1]
|
| -
|
| - logging.info('Testing hostname only barrier')
|
| - barrier = job.barrier(platform.node(), 'barriertest_2client', 120)
|
| - logging.info('rendezvous-ing')
|
| - barrier.rendezvous(master_hostname, client_hostname)
|
| - logging.info('done.')
|
| -
|
| - logging.info('Testing local identifier barrier')
|
| - barrier = job.barrier(platform.node() + '#id0', 'barriertest_2client', 120)
|
| - logging.info('rendezvous-ing')
|
| - barrier.rendezvous(master_hostname + '#id0',
|
| - client_hostname + '#id0')
|
| - logging.info('done.')
|
| -
|
| - logging.info('Testing IP@ barrier')
|
| - barrier = job.barrier(socket.gethostbyname(platform.node()),
|
| - 'barriertest_2client', 120)
|
| - logging.info('rendezvous-ing')
|
| - barrier.rendezvous(socket.gethostbyname(master_hostname),
|
| - socket.gethostbyname(client_hostname))
|
| - logging.info('done.')
|
| -
|
| - logging.info('Testing IP@ barrier with ids')
|
| - barrier = job.barrier(socket.gethostbyname(platform.node()) + '#42',
|
| - 'barriertest_2client', 120)
|
| - logging.info('rendezvous-ing')
|
| - barrier.rendezvous(socket.gethostbyname(master_hostname) + '#42',
|
| - socket.gethostbyname(client_hostname) + '#42')
|
| - logging.info('done.')
|
| -except:
|
| - traceback.print_exc()
|
| - raise
|
| -"""
|
| - client_controls = [client_control_template % (pair,) for host in host_objs]
|
| -
|
| - subcommand_list = []
|
| - for host, host_at, control in zip(host_objs, host_at_objs, client_controls):
|
| - subcommand_list.append(subcommand(host_at.run,
|
| - (control, host.hostname)))
|
| -
|
| - parallel(subcommand_list)
|
| -
|
| -
|
| -# grab the pairs (and failures)
|
| -(pairs, failures) = utils.form_ntuples_from_machines(machines, 2)
|
| -
|
| -# log the failures
|
| -for failure in failures:
|
| - job.record("FAIL", failure[0], "barrier_2client", failure[1])
|
| -
|
| -# now run through each pair and run
|
| -job.parallel_simple(run, pairs, log=False)
|
|
|