Pleases pep8.
---
tests/test-jsonrpc.py | 14 ++++++++++----
1 files changed, 10 insertions(+), 4 deletions(-)
diff --git a/tests/test-jsonrpc.py b/tests/test-jsonrpc.py
index fda9a03..781f1f4 100644
--- a/tests/test-jsonrpc.py
+++ b/tests/test-jsonrpc.py
@@ -23,6 +23,7 @@ import ovs.jsonrpc
import ovs.poller
import ovs.stream
+
def handle_rpc(rpc, msg):
done = False
reply = None
@@ -43,11 +44,12 @@ def handle_rpc(rpc, msg):
else:
rpc.error(errno.EPROTO)
sys.stderr.write("unsolicited JSON-RPC reply or error\n")
-
+
if reply:
rpc.send(reply)
return done
+
def do_listen(name):
error, pstream = ovs.stream.PassiveStream.open(name)
if error:
@@ -98,6 +100,7 @@ def do_listen(name):
poller.block()
pstream.close()
+
def do_request(name, method, params_string):
params = ovs.json.from_string(params_string)
msg = ovs.jsonrpc.Message.create_request(method, params)
@@ -123,11 +126,12 @@ def do_request(name, method, params_string):
if error:
sys.stderr.write("error waiting for reply: %s\n" % os.strerror(error))
sys.exit(1)
-
+
print ovs.json.to_string(msg.to_json())
rpc.close()
-
+
+
def do_notify(name, method, params_string):
params = ovs.json.from_string(params_string)
msg = ovs.jsonrpc.Message.create_notify(method, params)
@@ -152,6 +156,7 @@ def do_notify(name, method, params_string):
rpc.close()
+
def main(argv):
try:
options, args = getopt.gnu_getopt(
@@ -198,6 +203,7 @@ def main(argv):
func(*args)
+
def usage():
sys.stdout.write("""\
%s: JSON-RPC test utility for Python
@@ -214,6 +220,6 @@ Other options:
""")
sys.exit(0)
+
if __name__ == '__main__':
main(sys.argv)
-
--
1.7.6.1
_______________________________________________
dev mailing list
[email protected]
http://openvswitch.org/mailman/listinfo/dev
