| 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 """The main client_controller code. | 6 """The main task entrypoint.""" |
| 7 | |
| 8 This code is the main entry point for the client machines and handles | |
| 9 registering with the host server and running the local RPC server. | |
| 10 """ | |
| 11 | 7 |
| 12 import argparse | 8 import argparse |
| 13 import logging | 9 import logging |
| 14 import socket | 10 import socket |
| 15 import sys | 11 import sys |
| 16 import time | 12 import time |
| 17 | 13 |
| 18 #pylint: disable=relative-import | 14 #pylint: disable=relative-import |
| 19 import client_rpc_server | |
| 20 import common_lib | 15 import common_lib |
| 16 import rpc_server |
| 21 | 17 |
| 22 | 18 |
| 23 def main(): | 19 def main(): |
| 24 print ' '.join(sys.argv) | 20 print ' '.join(sys.argv) |
| 25 common_lib.InitLogging() | 21 common_lib.InitLogging() |
| 26 logging.info('Client controller starting') | 22 logging.info('Task starting') |
| 27 | 23 |
| 28 parser = argparse.ArgumentParser() | 24 parser = argparse.ArgumentParser() |
| 29 parser.add_argument('--otp', | 25 parser.add_argument('--otp', |
| 30 help='One time token used to authenticate with the host') | 26 help='One time token used to authenticate with the host') |
| 31 parser.add_argument('--host', | 27 parser.add_argument('--controller', |
| 32 help='The ip address of the host') | 28 help='The ip address of the controller machine') |
| 33 parser.add_argument('--idle-timeout', type=int, | 29 parser.add_argument('--idle-timeout', type=int, |
| 34 default=common_lib.DEFAULT_TIMEOUT_SECS, | 30 default=common_lib.DEFAULT_TIMEOUT_SECS, |
| 35 help='The idle timeout for the rpc server in seconds') | 31 help='The idle timeout for the rpc server in seconds') |
| 36 args, _ = parser.parse_known_args() | 32 args, _ = parser.parse_known_args() |
| 37 | 33 |
| 38 logging.info( | 34 logging.info( |
| 39 'Registering with discovery server at %s using OTP %s', args.host, | 35 'Registering with registration server at %s using OTP "%s"', |
| 40 args.otp) | 36 args.controller, args.otp) |
| 41 server = common_lib.ConnectToServer(args.host).RegisterClient( | 37 server = common_lib.ConnectToServer(args.controller).RegisterTask( |
| 42 args.otp, common_lib.MY_IP) | 38 args.otp, common_lib.MY_IP) |
| 43 | 39 |
| 44 server = client_rpc_server.RPCServer(args.host, args.idle_timeout) | 40 server = rpc_server.RPCServer(args.controller, args.idle_timeout) |
| 45 | 41 |
| 46 server.serve_forever() | 42 server.serve_forever() |
| 47 return 0 | 43 return 0 |
| 48 | 44 |
| 49 | 45 |
| 50 if __name__ == '__main__': | 46 if __name__ == '__main__': |
| 51 sys.exit(main()) | 47 sys.exit(main()) |
| OLD | NEW |