aboutsummaryrefslogtreecommitdiffstats
path: root/src/gr-fadingui/python/dearpygui_sink.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/gr-fadingui/python/dearpygui_sink.py')
-rw-r--r--src/gr-fadingui/python/dearpygui_sink.py15
1 files changed, 13 insertions, 2 deletions
diff --git a/src/gr-fadingui/python/dearpygui_sink.py b/src/gr-fadingui/python/dearpygui_sink.py
index 2b8e9fb..353f2d9 100644
--- a/src/gr-fadingui/python/dearpygui_sink.py
+++ b/src/gr-fadingui/python/dearpygui_sink.py
@@ -19,6 +19,8 @@
# Boston, MA 02110-1301, USA.
#
+import socket
+from urllib.parse import urlparse
import numpy as np
from gnuradio import gr
@@ -27,15 +29,24 @@ class dearpygui_sink(gr.sync_block):
"""
docstring for block dearpygui_sink
"""
- def __init__(self):
+ def __init__(self, sock_addr, ui_element_id):
gr.sync_block.__init__(self,
name="dearpygui_sink",
in_sig=[np.complex64],
out_sig=None)
+ # sockets
+ self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+ self.srv = urlparse(sock_addr)
+
+ def send(self, value):
+ data = bytes(repr(value), "ascii")
+ sent = self.socket.sendto(data, (self.srv.hostname, self.srv.port))
+
+ return len(data) == sent
def work(self, input_items, output_items):
in0 = input_items[0]
- # <+signal processing here+>
+ self.send(in0)
return len(input_items[0])