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 task entrypoint.""" | 6 """The main task entrypoint.""" |
7 | 7 |
8 import argparse | 8 import argparse |
9 import logging | 9 import logging |
10 import socket | 10 import socket |
(...skipping 16 matching lines...) Expand all Loading... |
27 parser.add_argument('--controller', | 27 parser.add_argument('--controller', |
28 help='The ip address of the controller machine') | 28 help='The ip address of the controller machine') |
29 parser.add_argument('--idle-timeout', type=int, | 29 parser.add_argument('--idle-timeout', type=int, |
30 default=common_lib.DEFAULT_TIMEOUT_SECS, | 30 default=common_lib.DEFAULT_TIMEOUT_SECS, |
31 help='The idle timeout for the rpc server in seconds') | 31 help='The idle timeout for the rpc server in seconds') |
32 args, _ = parser.parse_known_args() | 32 args, _ = parser.parse_known_args() |
33 | 33 |
34 logging.info( | 34 logging.info( |
35 'Registering with registration server at %s using OTP "%s"', | 35 'Registering with registration server at %s using OTP "%s"', |
36 args.controller, args.otp) | 36 args.controller, args.otp) |
37 server = common_lib.ConnectToServer(args.controller).RegisterTask( | 37 common_lib.ConnectToServer(args.controller).RegisterTask( |
38 args.otp, common_lib.MY_IP) | 38 args.otp, common_lib.MY_IP) |
39 | 39 |
40 server = rpc_server.RPCServer(args.controller, args.idle_timeout) | 40 server = rpc_server.RPCServer(args.controller, args.idle_timeout) |
41 | 41 |
42 server.serve_forever() | 42 server.serve_forever() |
| 43 logging.info('Server shutdown complete') |
43 return 0 | 44 return 0 |
44 | 45 |
45 | 46 |
46 if __name__ == '__main__': | 47 if __name__ == '__main__': |
47 sys.exit(main()) | 48 sys.exit(main()) |
OLD | NEW |