Ber block mit socket ergänzt

2 files changed, 43 insertions, 5 deletions

diff --git a/src/gr-fadingui/grc/fadingui_ber.block.yml b/src/gr-fadingui/grc/fadingui_ber.block.yml
index 3070311..477f9ff 100644
--- a/src/gr-fadingui/grc/fadingui_ber.block.yml
+++ b/src/gr-fadingui/grc/fadingui_ber.block.yml
@@ -4,7 +4,7 @@ category: '[fadingui]'
 
 templates:
   imports: import fadingui
-  make: fadingui.ber(vgl=${vgl}, vlen=${vlen})
+  make: fadingui.ber(vgl=${vgl}, vlen=${vlen},address=${address})
 
 #  Make one 'parameters' list entry for every parameter you want settable from the GUI.
 #     Keys include:
@@ -18,6 +18,11 @@ parameters:
 - id: vlen
   label: Vec Length
   dtype: int
+- id: address
+  label: Address
+  dtype: string
+  default: "udp://localhost:31415"
+
 
 #  Make one 'inputs' list entry per input and one 'outputs' list entry per output.
 #  Keys include:
diff --git a/src/gr-fadingui/python/ber.py b/src/gr-fadingui/python/ber.py
index 5b71f35..205dcd4 100644
--- a/src/gr-fadingui/python/ber.py
+++ b/src/gr-fadingui/python/ber.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
@@ -32,7 +34,7 @@ class ber(gr.sync_block):
     """
     docstring for block ber
     """
-    def __init__(self, vgl, vlen):
+    def __init__(self, vgl, vlen, address):
         gr.sync_block.__init__(self,
             name="ber",
             in_sig=[np.dtype(str(vlen) + "b")],
@@ -40,9 +42,34 @@ class ber(gr.sync_block):
         self.vgl=vgl
         self.vlen=vlen
 
+        # Create a socket and parse remote machine url
+        self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+        self.url = urlparse(address)
+        self.srv = (self.url.hostname, self.url.port)
+
+
+    def send(self, data):
+        """
+        Send the data to self.srv
+
+        @param data Data as python bytes
+        @return Number of bytes that were actually sent
+        """
+        assert type(data) == bytes
+        return self.socket.sendto(data, self.srv)
+
+    def encode(self, data):
+        """
+        Encode the data into a dead simple format
+        """
+        # FIXME: this could be (very) slow, is there a faster way with numpy?
+        # Maybe numpy.array2string
+        return bytes(str(data) + "\n", "ascii")
+    
+
     def work(self, input_items, output_items):
-        
         inp = input_items[0]
+
         log.debug(f"Length: {len(inp)}")
         log.debug(f"Inp_vector:{inp}")
         
@@ -52,7 +79,13 @@ class ber(gr.sync_block):
             ber = sum(np.unpackbits(v))
 
             trueber = ber - 32
-            log.debug(f"BER {trueber if trueber > 0 else 0} in Paket {i}")
+            if trueber < 0:
+                trueber = 0
+            log.debug(f"BER {trueber} in Paket {i}")
+        
+            self.send(self.encode(trueber))
+
+        return len(inp)
 
-        return len(input_items[0])
+        #return len(input_items[0])