Don't reset the buffer if an invalid pulse length occurs

This allows compatibility with some aftermarket transmitters.
argilo · Jan 16, 2024 · 17ca0a3 · 17ca0a3
1 parent 602269b
commit 17ca0a3
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 13 deletions.
diff --git a/secplus_rx.grc b/secplus_rx.grc
@@ -743,16 +743,15 @@ blocks:
       \                self.process_buffer(current_sample)\n                self.buffer\
       \ = []\n            self.last_sample = sample\n        return len(input_items[0])\n\
       \n    def process_edge(self, rising, samples):\n        if samples < 0.125e-3\
-      \ * self.samp_rate:\n            self.buffer = []\n        elif samples < 0.375e-3\
-      \ * self.samp_rate:\n            self.buffer.append(0 if rising else 1)\n  \
-      \      elif samples < 0.625e-3 * self.samp_rate:\n            self.buffer.append(0\
-      \ if rising else 1)\n            self.buffer.append(0 if rising else 1)\n  \
-      \      else:\n            self.buffer = []\n\n    def process_buffer(self, current_sample):\n\
-      \        manchester = \"\".join(str(b) for b in self.buffer)\n        start\
-      \ = manchester.find(\"1010101001010101\")\n        if start == -1:\n       \
-      \     return\n\n        if manchester[start+20:start+24] == \"1010\":\n    \
-      \        packet_length = 40\n        elif manchester[start+20:start+24] == \"\
-      1001\":\n            packet_length = 64\n        else:\n            return\n\
+      \ * self.samp_rate:\n            pass\n        elif samples < 0.375e-3 * self.samp_rate:\n\
+      \            self.buffer.append(0 if rising else 1)\n        elif samples <\
+      \ 0.625e-3 * self.samp_rate:\n            self.buffer.append(0 if rising else\
+      \ 1)\n            self.buffer.append(0 if rising else 1)\n\n    def process_buffer(self,\
+      \ current_sample):\n        manchester = \"\".join(str(b) for b in self.buffer)\n\
+      \        start = manchester.find(\"1010101001010101\")\n        if start ==\
+      \ -1:\n            return\n\n        if manchester[start+20:start+24] == \"\
+      1010\":\n            packet_length = 40\n        elif manchester[start+20:start+24]\
+      \ == \"1001\":\n            packet_length = 64\n        else:\n            return\n\
       \n        manchester = manchester[start+16:start+20+(packet_length*2)]\n   \
       \     baseband = []\n        for i in range(0, len(manchester), 2):\n      \
       \      if manchester[i:i+2] == \"01\":\n                baseband.append(1)\n\

diff --git a/secplus_rx_secplus_v2_decode.py b/secplus_rx_secplus_v2_decode.py
@@ -62,14 +62,12 @@ def work(self, input_items, output_items):
 
     def process_edge(self, rising, samples):
         if samples < 0.125e-3 * self.samp_rate:
-            self.buffer = []
+            pass
         elif samples < 0.375e-3 * self.samp_rate:
             self.buffer.append(0 if rising else 1)
         elif samples < 0.625e-3 * self.samp_rate:
             self.buffer.append(0 if rising else 1)
             self.buffer.append(0 if rising else 1)
-        else:
-            self.buffer = []
 
     def process_buffer(self, current_sample):
         manchester = "".join(str(b) for b in self.buffer)