OLD | NEW |
1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
2 # Copyright 2015 The Chromium Authors. All rights reserved. | 2 # Copyright 2015 The Chromium Authors. All rights reserved. |
3 # Use of this source code is governed by a BSD-style license that can be | 3 # Use of this source code is governed by a BSD-style license that can be |
4 # found in the LICENSE file. | 4 # found in the LICENSE file. |
5 | 5 |
6 """A simple host test module. | 6 """A simple host test module. |
7 | 7 |
8 This module runs on the host machine and is responsible for creating 2 | 8 This module runs on the host machine and is responsible for creating 2 |
9 client machines, waiting for them, and running RPC calls on them. | 9 client machines, waiting for them, and running RPC calls on them. |
10 """ | 10 """ |
(...skipping 14 matching lines...) Expand all Loading... |
25 def __init__(self): | 25 def __init__(self): |
26 super(ExampleController, self).__init__() | 26 super(ExampleController, self).__init__() |
27 self.client1 = None | 27 self.client1 = None |
28 self.client2 = None | 28 self.client2 = None |
29 | 29 |
30 def CreateClient(self): | 30 def CreateClient(self): |
31 """Create a client object and set the proper values.""" | 31 """Create a client object and set the proper values.""" |
32 client = self.NewClient( | 32 client = self.NewClient( |
33 isolate_file='client_test.isolate', | 33 isolate_file='client_test.isolate', |
34 config_vars={'multi_machine': '1'}, | 34 config_vars={'multi_machine': '1'}, |
35 dimensions={'os': 'Linux', 'pool': 'legion'}, priority=200, | 35 dimensions={'os': 'legion-linux'}, priority=200, |
36 idle_timeout_secs=90, connection_timeout_secs=90, | 36 idle_timeout_secs=90, connection_timeout_secs=90, |
37 verbosity=logging.INFO) | 37 verbosity=logging.INFO) |
38 client.Create() | 38 client.Create() |
39 return client | 39 return client |
40 | 40 |
41 def SetUp(self): | 41 def SetUp(self): |
42 """Create the client machines and wait until they connect. | 42 """Create the client machines and wait until they connect. |
43 | 43 |
44 In this call the actual creation of the client machines is done in parallel | 44 In this call the actual creation of the client machines is done in parallel |
45 by the system. The WaitForConnect calls are performed in series but will | 45 by the system. The WaitForConnect calls are performed in series but will |
46 return as soon as the clients connect. | 46 return as soon as the clients connect. |
47 """ | 47 """ |
48 self.client1 = self.CreateClient() | 48 self.client1 = self.CreateClient() |
49 self.client2 = self.CreateClient() | 49 self.client2 = self.CreateClient() |
50 self.client1.WaitForConnection() | 50 self.client1.WaitForConnection() |
51 self.client2.WaitForConnection() | 51 self.client2.WaitForConnection() |
52 | 52 |
53 def Task(self): | 53 def Task(self): |
54 """Main method to run the task code.""" | 54 """Main method to run the task code.""" |
55 self.CallEcho(self.client1) | 55 self.CallEcho(self.client1) |
56 self.CallEcho(self.client2) | 56 self.CallEcho(self.client2) |
57 self.CallClientTest(self.client1) | 57 self.CallClientTest(self.client1) |
58 self.CallClientTest(self.client2) | 58 self.CallClientTest(self.client2) |
59 | 59 |
60 def CallEcho(self, client): | 60 def CallEcho(self, client): |
61 """Call rpc.Echo on a client.""" | 61 """Call rpc.Echo on a client.""" |
62 logging.info('Calling Echo on %s', client.name) | 62 logging.info('Calling Echo on %s', client.name) |
63 logging.info(self.client1.rpc.Echo(client.name)) | 63 logging.info(client.rpc.Echo(client.name)) |
64 | 64 |
65 def CallClientTest(self, client): | 65 def CallClientTest(self, client): |
66 """Call client_test.py name on a client.""" | 66 """Call client_test.py name on a client.""" |
67 logging.info('Calling Subprocess to run "./client_test.py %s"', client.name) | 67 logging.info('Calling Subprocess to run "./client_test.py %s"', client.name) |
68 retcode, stdout, stderr = client.rpc.Subprocess( | 68 proc = client.rpc.subprocess.Popen(['./client_test.py', client.name]) |
69 ['./client_test.py', client.name]) | 69 client.rpc.subprocess.Wait(proc) |
| 70 retcode = client.rpc.subprocess.GetReturncode(proc) |
| 71 stdout = client.rpc.subprocess.ReadStdout(proc) |
| 72 stderr = client.rpc.subprocess.ReadStderr(proc) |
70 logging.info('retcode: %s, stdout: %s, stderr: %s', retcode, stdout, stderr) | 73 logging.info('retcode: %s, stdout: %s, stderr: %s', retcode, stdout, stderr) |
71 | 74 |
72 | 75 |
73 if __name__ == '__main__': | 76 if __name__ == '__main__': |
74 ExampleController().RunController() | 77 ExampleController().RunController() |
OLD | NEW |