Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(14)

Side by Side Diff: testing/legion/examples/hello_world/host_test.py

Issue 935333002: Update from https://crrev.com/316786 (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « testing/legion/common_lib.py ('k') | testing/legion/examples/subprocess/client.isolate » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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()
OLDNEW
« no previous file with comments | « testing/legion/common_lib.py ('k') | testing/legion/examples/subprocess/client.isolate » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698