diff options
author | Andrej Rode <andrej.rode@ettus.com> | 2017-03-27 17:07:44 -0700 |
---|---|---|
committer | Martin Braun <martin.braun@ettus.com> | 2017-12-22 15:03:44 -0800 |
commit | 8ac9014d5c30836665378d2d088b5c602162f8ac (patch) | |
tree | 21708ce88f72da4818e73afe054b89e7f1589fdd /mpm/python/test_rpc.py | |
parent | 6d332e5ca4a7311406ac285f827c31c9e5b94280 (diff) | |
download | uhd-8ac9014d5c30836665378d2d088b5c602162f8ac.tar.gz uhd-8ac9014d5c30836665378d2d088b5c602162f8ac.tar.bz2 uhd-8ac9014d5c30836665378d2d088b5c602162f8ac.zip |
mpm: CMake cleanup, Python code enhancements
- Send user defined data in ping
- Improve rpc_shell, add mpm_debug.py, fix tracebacks in multiprocessing
Diffstat (limited to 'mpm/python/test_rpc.py')
-rwxr-xr-x | mpm/python/test_rpc.py | 63 |
1 files changed, 0 insertions, 63 deletions
diff --git a/mpm/python/test_rpc.py b/mpm/python/test_rpc.py deleted file mode 100755 index 1a97a103c..000000000 --- a/mpm/python/test_rpc.py +++ /dev/null @@ -1,63 +0,0 @@ -#!/usr/bin/env python -import socket -from mprpc import RPCClient -import usrp_mpm as mpm -import argparse - - -def parse_args(): - parser = argparse.ArgumentParser() - parser.add_argument("-a", "--address", default="0.0.0.0", type=str, help="Destination address") - parser.add_argument("-p", "--port", default=0, type=int, help="Destination port") - sub_parsers = parser.add_subparsers(dest="command") - - rpc_parser = sub_parsers.add_parser("rpc", help="Issue RPC") - rpc_parser.add_argument("-c", "--call", required=True, help="command to issue") - rpc_parser.add_argument("arguments", nargs="*") - - disc_parser = sub_parsers.add_parser("disc", help="Issue discovery") - return parser.parse_args() - - -def rpc(address, port, command, *args): - if not port: - port = mpm.types.MPM_RPC_PORT - client = RPCClient(address, port) - if args: - result = client.call(command, *args) - else: - result = client.call(command) - return result - - -def discovery(address, port): - if not port: - port = mpm.types.MPM_DISCOVERY_PORT - sock = socket.socket( - socket.AF_INET, - socket.SOCK_DGRAM) - sock.sendto(mpm.types.MPM_DISCOVERY_MESSAGE, (address, port)) - sock.settimeout(1.0) # wait max 1 second - while True: - try: - data, sender = sock.recvfrom(4096) - print("Received respons from: {}".format(sender[0])) - print("Dicovery data: {}".format(data)) - except: - break - - -def main(): - args = parse_args() - if args.command == "rpc": - if args.arguments: - result = rpc(args.address, args.port, args.call, *args.arguments) - else: - result = rpc(args.address, args.port, args.call) - print(result) - elif args.command == "disc": - discovery(args.address, args.port) - - -if __name__ == "__main__": - exit(not(main())) |