diff options
author | ahothan <ahothan@cisco.com> | 2019-04-13 09:31:08 -0700 |
---|---|---|
committer | ahothan <ahothan@cisco.com> | 2019-04-13 09:31:08 -0700 |
commit | aed21dc7520fa195f6131c78d15c222970b7fab7 (patch) | |
tree | a8215c02783df89090a740a223bdec5ff6fc68bf /client/client.py | |
parent | 8ae0abbe6ecc32af01d755a3f3eab38bfa631b6b (diff) |
Remove socketio from python client
Change-Id: I5c5e0e24621b450c05f1f94fd34eab9e101c75b6
Signed-off-by: ahothan <ahothan@cisco.com>
Diffstat (limited to 'client/client.py')
-rw-r--r-- | client/client.py | 36 |
1 files changed, 1 insertions, 35 deletions
diff --git a/client/client.py b/client/client.py index 5cbc733..b1be69c 100644 --- a/client/client.py +++ b/client/client.py @@ -17,8 +17,6 @@ import requests import time -from socketIO_client import SocketIO - class TimeOutException(Exception): pass @@ -32,42 +30,14 @@ class NfvbenchClient(object): """Python client class to control a nfvbench server The nfvbench server must run in background using the --server option. - Since HTML pages are not required, the path to pass to --server can be - any directory on the host. """ - def __init__(self, nfvbench_url, use_socketio): + def __init__(self, nfvbench_url): """Client class to send requests to the nfvbench server Args: nfvbench_url: the URL of the nfvbench server (e.g. 'http://127.0.0.1:7555') """ self.url = nfvbench_url - self.use_socketio = use_socketio - - def socketio_send(self, send_event, receive_event, config, timeout): - class Exec(object): - socketIO = None - socketio_result = None - - def close_socketio(result): - Exec.socketio_result = result - Exec.socketIO.disconnect() - - def on_response(*args): - close_socketio(args[0]) - - def on_error(*args): - raise NfvbenchException(args[0]) - - Exec.socketIO = SocketIO(self.url) - Exec.socketIO.on(receive_event, on_response) - Exec.socketIO.on('error', on_error) - Exec.socketIO.emit(send_event, config) - Exec.socketIO.wait(seconds=timeout) - - if timeout and not Exec.socketio_result: - raise TimeOutException() - return Exec.socketio_result def http_get(self, command, config): url = self.url + '/' + command @@ -102,8 +72,6 @@ class NfvbenchClient(object): TimeOutException: the request timed out (and might still being executed by the server) """ - if self.use_socketio: - return self.socketio_send('echo', 'echo', config, timeout) return self.http_get('echo', config) def run_config(self, config, timeout=300, poll_interval=5): @@ -132,8 +100,6 @@ class NfvbenchClient(object): the exception contains the description of the failure. TimeOutException: the request timed out but will still be executed by the server. """ - if self.use_socketio: - return self.socketio_send('start_run', 'run_end', config, timeout) res = self.http_post('start_run', config) if res['status'] != 'PENDING': raise NfvbenchException(res['error_message']) |