From e776d673aa51b5ef19e16cfb6d22098c0b14a679 Mon Sep 17 00:00:00 2001
From: Josh Morman <jmorman@gnuradio.org>
Date: Wed, 24 Nov 2021 12:46:14 -0500
Subject: zeromq: pep8 formatting
Signed-off-by: Josh Morman <jmorman@gnuradio.org>
---
gr-zeromq/examples/python/client.py | 16 ++++++++++++----
1 file changed, 12 insertions(+), 4 deletions(-)
(limited to 'gr-zeromq/examples/python/client.py')
diff --git a/gr-zeromq/examples/python/client.py b/gr-zeromq/examples/python/client.py
index cabdbebee7..30a73254e8 100644
--- a/gr-zeromq/examples/python/client.py
+++ b/gr-zeromq/examples/python/client.py
@@ -25,6 +25,8 @@ import time
###############################################################################
# GNU Radio top_block
###############################################################################
+
+
class top_block(gr.top_block):
def __init__(self, options):
gr.top_block.__init__(self)
@@ -34,7 +36,7 @@ class top_block(gr.top_block):
# socket addresses
rpc_adr = "tcp://*:6667"
probe_adr = "tcp://*:5557"
- source_adr = "tcp://"+self.options.servername+":5555"
+ source_adr = "tcp://" + self.options.servername + ":5555"
# blocks
#self.zmq_source = zeromq.req_source(gr.sizeof_float, 1, source_adr)
@@ -49,8 +51,8 @@ class top_block(gr.top_block):
# ZeroMQ
self.rpc_manager = zeromq.rpc_manager()
self.rpc_manager.set_reply_socket(rpc_adr)
- self.rpc_manager.add_interface("start_fg",self.start_fg)
- self.rpc_manager.add_interface("stop_fg",self.stop_fg)
+ self.rpc_manager.add_interface("start_fg", self.start_fg)
+ self.rpc_manager.add_interface("stop_fg", self.stop_fg)
self.rpc_manager.start_watcher()
def start_fg(self):
@@ -68,23 +70,29 @@ class top_block(gr.top_block):
###############################################################################
# Options Parser
###############################################################################
+
+
def parse_args():
"""Argument parser."""
parser = ArgumentParser()
parser.add_argument("-s", "--servername", default="localhost",
- help="Server hostname")
+ help="Server hostname")
args = parser.parse_args()
return args
###############################################################################
# Waiter Thread
###############################################################################
+
+
class waiter(Thread):
""" To keep the program alive when flowgraph is stopped. """
+
def run(self):
while keep_running:
time.sleep(1)
+
###############################################################################
# Main
###############################################################################
--
cgit v1.2.3