From: Uwe Hermann <redacted>
Date: Wed, 23 Nov 2011 22:08:39 +0000 (+0100)
Subject: transitioncounter.py: Convert to new API.
X-Git-Tag: libsigrokdecode-0.1.0~266
X-Git-Url: https://sigrok.org/gitweb/?p=libsigrokdecode.git;a=commitdiff_plain;h=b41ae47fa350bc0b6c81f0411cc12b9741a7e4e0;ds=sidebyside

transitioncounter.py: Convert to new API.

This is still work-in-progress, but at least it runs and outputs stuff now.
---

diff --git a/decoders/transitioncounter.py b/decoders/transitioncounter.py
index d3fa732..1b10518 100644
--- a/decoders/transitioncounter.py
+++ b/decoders/transitioncounter.py
@@ -18,81 +18,95 @@
 ## Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
 ##
 
-import sigrok
+class Sample():
+    def __init__(self, data):
+        self.data = data
+    def probe(self, probe):
+        s = ord(self.data[probe / 8]) & (1 << (probe % 8))
+        return True if s else False
+
+def sampleiter(data, unitsize):
+    for i in range(0, len(data), unitsize):
+        yield(Sample(data[i:i+unitsize]))
+
+class Decoder():
+    name = 'Transition counter'
+    longname = '...'
+    desc = 'Counts rising/falling edges in the signal.'
+    longdesc = '...'
+    author = 'Uwe Hermann'
+    email = 'uwe@hermann-uwe.de'
+    license = 'gplv2+'
+    inputs = ['logic']
+    outputs = ['transitioncounts']
+    probes = {}
+    options = {}
+
+    def __init__(self, unitsize, **kwargs):
+        # Metadata comes in here, we don't care for now.
+        # print kwargs
+        self.unitsize = unitsize
+
+        self.probes = Decoder.probes.copy()
+
+        # TODO: Don't hardcode the number of channels.
+        self.channels = 8
+
+        self.lastsample = None
+        self.oldbit = [0] * self.channels
+        self.transitions = [0] * self.channels
+        self.rising = [0] * self.channels
+        self.falling = [0] * self.channels
+
+    def report(self):
+        pass
+
+    def decode(self, data):
+        """Counts the low->high and high->low transitions in the specified
+           channel(s) of the signal."""
 
-lastsample = None
-oldbit = None
-transitions = None
-rising = None
-falling = None
-
-def decode(sampledata):
-    """Counts the low->high and high->low transitions in the specified
-       channel(s) of the signal."""
-    global lastsample
-    global oldbit, transitions, rising, falling
-
-    # TODO: Don't hardcode the number of channels.
-    channels = 8
-
-    # FIXME: Get the data in the correct format in the first place.
-    inbuf = [ord(x) for x in sampledata['data']]
-
-    if lastsample == None:
-        oldbit = [0] * channels
-        transitions = [0] * channels
-        rising = [0] * channels
-        falling = [0] * channels
-
-        # Initial values.
-        lastsample = inbuf[0]
-        for i in range(channels):
-            oldbit[i] = (lastsample & (1 << i)) >> i
-
-    # TODO: Handle LAs with more/less than 8 channels.
-    for s in inbuf:
-        # Optimization: Skip identical bytes (no transitions).
-        if lastsample != s:
-            for i in range(channels):
+        # We should accept a list of samples and iterate...
+        for sample in sampleiter(data["data"], self.unitsize):
+
+            # TODO: Eliminate the need for ord().
+            s = ord(sample.data)
+
+            # Optimization: Skip identical samples (no transitions).
+            if self.lastsample == s:
+                continue
+
+            # Upon the first sample, store the initial values.
+            if self.lastsample == None:
+                self.lastsample = s
+                for i in range(self.channels):
+                    self.oldbit[i] = (self.lastsample & (1 << i)) >> i
+
+            # Iterate over all channels/probes in this sample.
+            # Count rising and falling edges for each channel.
+            for i in range(self.channels):
                 curbit = (s & (1 << i)) >> i
                 # Optimization: Skip identical bits (no transitions).
-                if oldbit[i] == curbit:
+                if self.oldbit[i] == curbit:
                     continue
-                elif (oldbit[i] == 0 and curbit == 1):
-                    rising[i] += 1
-                elif (oldbit[i] == 1 and curbit == 0):
-                    falling[i] += 1
-                oldbit[i] = curbit
-
-            # Total number of transitions is the sum of rising and falling edges.
-            for i in range(channels):
-                transitions[i] = rising[i] + falling[i]
-
-            lastsample = s
-            print(transitions)
-
-    sigrok.put(sampledata)
-
-register = {
-    'id': 'transitioncounter',
-    'name': 'Transition counter',
-    'longname': '...',
-    'desc': 'Counts rising/falling edges in the signal.',
-    'longdesc': '...',
-    'author': 'Uwe Hermann',
-    'email': 'uwe@hermann-uwe.de',
-    'license': 'gplv2+',
-    'in': ['logic'],
-    'out': ['transitioncounts'],
-    'probes': [
-        # All probes.
-    ],
-    'options': {
-        # No options so far.
-    },
-    # 'start': start,
-    # 'report': report,
-}
+                elif (self.oldbit[i] == 0 and curbit == 1):
+                    self.rising[i] += 1
+                elif (self.oldbit[i] == 1 and curbit == 0):
+                    self.falling[i] += 1
+                self.oldbit[i] = curbit
+
+            # Save the current sample as 'lastsample' for the next round.
+            self.lastsample = s
+
+        # Total number of transitions = rising + falling edges.
+        for i in range(self.channels):
+            self.transitions[i] = self.rising[i] + self.falling[i]
+
+        # TODO: Which output format?
+        # TODO: How to only output something after the last chunk of data?
+        outdata = []
+        for i in range(self.channels):
+            outdata += [[self.transitions[i], self.rising[i], self.falling[i]]]
+        sigrok.put(outdata)
 
 # Use psyco (if available) as it results in huge performance improvements.
 try:
@@ -101,3 +115,5 @@ try:
 except ImportError:
     pass
 
+import sigrok
+