| OLD | NEW |
| 1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
| 2 # Copyright 2014 The LUCI Authors. All rights reserved. | 2 # Copyright 2014 The LUCI Authors. All rights reserved. |
| 3 # Use of this source code is governed under the Apache License, Version 2.0 | 3 # Use of this source code is governed under the Apache License, Version 2.0 |
| 4 # that can be found in the LICENSE file. | 4 # that can be found in the LICENSE file. |
| 5 | 5 |
| 6 """Integration test for the Swarming server, Swarming bot and Swarming client. | 6 """Integration test for the Swarming server, Swarming bot and Swarming client. |
| 7 | 7 |
| 8 It starts both a Swarming server and a Swarming bot and triggers tasks with the | 8 It starts both a Swarming server and a Swarming bot and triggers tasks with the |
| 9 Swarming client to ensure the system works end to end. | 9 Swarming client to ensure the system works end to end. |
| 10 """ | 10 """ |
| (...skipping 620 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 631 ['--secret-bytes-path', tmp, '--', '${ISOLATED_OUTDIR}'], | 631 ['--secret-bytes-path', tmp, '--', '${ISOLATED_OUTDIR}'], |
| 632 expected_summary, {os.path.join('0', 'sekret'): 'foobar\n'}) | 632 expected_summary, {os.path.join('0', 'sekret'): 'foobar\n'}) |
| 633 finally: | 633 finally: |
| 634 os.remove(tmp) | 634 os.remove(tmp) |
| 635 | 635 |
| 636 def test_local_cache(self): | 636 def test_local_cache(self): |
| 637 # First task creates the cache, second copy the content to the output | 637 # First task creates the cache, second copy the content to the output |
| 638 # directory. Each time it's the exact same script. | 638 # directory. Each time it's the exact same script. |
| 639 script = '\n'.join(( | 639 script = '\n'.join(( |
| 640 'import os, shutil, sys', | 640 'import os, shutil, sys', |
| 641 'if not os.path.islink("p/b"):', | |
| 642 ' print("p/b is not a symlink")', | |
| 643 ' sys.exit(1)', | |
| 644 'p = "p/b/a.txt"', | 641 'p = "p/b/a.txt"', |
| 645 'if not os.path.isfile(p):', | 642 'if not os.path.isfile(p):', |
| 646 ' with open(p, "wb") as f:', | 643 ' with open(p, "wb") as f:', |
| 647 ' f.write("Yo!")', | 644 ' f.write("Yo!")', |
| 648 'else:', | 645 'else:', |
| 649 ' shutil.copy(p, sys.argv[1])', | 646 ' shutil.copy(p, sys.argv[1])', |
| 650 'print "hi"')) | 647 'print "hi"')) |
| 651 sizes = sorted([len(script), 200]) | 648 sizes = sorted([len(script), 200]) |
| 652 expected_summary = self.gen_expected( | 649 expected_summary = self.gen_expected( |
| 653 name=u'cache_first', | 650 name=u'cache_first', |
| (...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 873 if bot is not None and bot.poll() is None: | 870 if bot is not None and bot.poll() is None: |
| 874 bot.kill() | 871 bot.kill() |
| 875 bot.wait() | 872 bot.wait() |
| 876 finally: | 873 finally: |
| 877 cleanup(bot, client, servers, failed or verbose, leak) | 874 cleanup(bot, client, servers, failed or verbose, leak) |
| 878 return int(failed) | 875 return int(failed) |
| 879 | 876 |
| 880 | 877 |
| 881 if __name__ == '__main__': | 878 if __name__ == '__main__': |
| 882 sys.exit(main()) | 879 sys.exit(main()) |
| OLD | NEW |