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) |