From 89b32316aa46f22a4f967ca7953089a3df0c16e7 Mon Sep 17 00:00:00 2001
From: jaseg <git-bigdata-wsl-arch@jaseg.de>
Date: Fri, 28 Feb 2020 18:29:41 +0100
Subject: embedded ldpc decoder 50% working

---
 controller/fw/ldpc_decoder.c | 197 +++++++++++++++++++++++++++++--------------
 1 file changed, 136 insertions(+), 61 deletions(-)

(limited to 'controller/fw/ldpc_decoder.c')

diff --git a/controller/fw/ldpc_decoder.c b/controller/fw/ldpc_decoder.c
index 5200e8f..10b5a08 100644
--- a/controller/fw/ldpc_decoder.c
+++ b/controller/fw/ldpc_decoder.c
@@ -1,86 +1,160 @@
-"""Decoding module."""
-
-/* H: decoding matrix as shape (m, n) array
- *      m: number of equations represented by H
- *      n: number of code words
- * y: received message in codeword space, length n
- *
- * out: output array of length n where the solutions in codeword space will be written
- *
- * maxiter: Maximum iteration number
- */
-int decode(uint8_t H[], const int m, n, uint8_t y[], uint8_t out[], int maxiter) {
-
-    /* fixme: preprocess the following.
-def bitsandnodes(H):
-    """Return bits and nodes of a parity-check matrix H."""
-    bits_indices, bits = scipy.sparse.find(H)[:2]
-    nodes_indices, nodes = scipy.sparse.find(H.T)[:2]
-    bits_histogram = np.bincount(bits_indices)
-    nodes_histogram = np.bincount(nodes_indices)
-    return bits_histogram, bits, nodes_histogram, nodes
-    bits_hist, bits_values, nodes_hist, nodes_values = utils.bitsandnodes(H)
-    */
 
+#include <stdint.h>
+#include <unistd.h>
+#include <stdbool.h>
+#include <math.h>
+#include <stdio.h>
+
+void inner_logbp(
+        size_t m, size_t n,
+        size_t bits_count, size_t nodes_count, const uint32_t bits_values[], const uint32_t nodes_values[],
+        int8_t Lc[],
+        float Lq[], float Lr[],
+        unsigned int n_iter,
+        float L_posteriori_out[]);
+
+//decode(384, 6, 8, ...)
+int decode(size_t n, size_t nodes_count, size_t bits_count, uint32_t bits[], int8_t y[], int8_t out[], unsigned int maxiter) {
+    const size_t m = n * nodes_count / bits_count;
     float Lq[m*n];
     float Lr[m*n];
     float L_posteriori[n];
 
-    for (int n_iter=0; n_iter<maxiter; n_iter++) {
-        Lq, Lr, L_posteriori = inner_logbp(bits_hist, bits_values, nodes_hist,
-                                            nodes_values, y, Lq, Lr, n_iter, L_posteriori)
+    /* Calculate column bit positions from row bit positions */
+    int32_t bits_transposed[nodes_count * n];
+    for (size_t i=0; i<nodes_count * n; i++)
+        bits_transposed[i] = -1;
+
+    for (size_t i=0; i<m; i++) {
+        for (size_t j=0; j<bits_count; j++) {
+            int32_t *base = bits_transposed + bits[i*bits_count + j] * nodes_count;
+            for (; *base != -1; base++)
+                ;
+            *base = i;
+        }
+    }
+
+    /*
+    printf("Row positions: [");
+    for (size_t i=0; i<m*bits_count; i++) {
+        if (i)
+            printf(", ");
+        if (i%32 == 0)
+            printf("\n    ");
+        printf("%4d", bits[i]);
+    }
+    printf("\n]\n");
+
+    printf("Column positions: [");
+    for (size_t i=0; i<n*nodes_count; i++) {
+        if (i)
+            printf(", ");
+        if (i%32 == 0)
+            printf("\n    ");
+        printf("%4d", bits_transposed[i]);
+    }
+    printf("\n]\n");
+    */
+
+    /* Run iterative optimization algorithm */
+    for (unsigned int n_iter=0; n_iter<maxiter; n_iter++) {
+        inner_logbp(m, n, bits_count, nodes_count, bits, (uint32_t*)bits_transposed, y, Lq, Lr, n_iter, L_posteriori);
+
+        float *arrs[3] = {Lq, Lr, L_posteriori};
+        const char *names[3] = {"Lq", "Lr", "L_posteriori"};
+        size_t lens[3] = {m*n, m*n, n};
+        const size_t head_tail = 10;
+        for (int j=0; j<3; j++) {
+            printf("%s=[", names[j]);
+            bool ellipsis = false;
+            const int w = 16;
+            for (size_t i=0; i<lens[j]; i++) {
+                if (lens[j] > 1000 && i/w > head_tail && i/w < m*n/w-head_tail) {
+                    if (!ellipsis) {
+                        ellipsis = true;
+                        printf("\n    ...");
+                    }
+                    continue;
+                }
+                if (i)
+                    printf(", ");
+                if (i%w == 0)
+                    printf("\n    ");
+                float outf = arrs[j][i];
+                char *s = outf < 0 ? "\033[91m" : (outf > 0 ? "\033[92m" : "\033[94m");
+                printf("%s% 012.6g\033[38;5;240m", s, outf);
+            }
+            printf("\n]\n");
+        }
+
         for (size_t i=0; i<n; i++)
             out[i] = L_posteriori[i] <= 0.0f;
 
         for (size_t i=0; i<m; i++) {
             bool sum = 0;
-
-            for (size_t j=0; j<n; j++)
-                sum ^= H[i*n + j] * out[j];
-
+            for (size_t j=0; j<bits_count; j++)
+                sum ^= out[bits[i*bits_count + j]];
             if (sum)
                 continue;
         }
 
-        return 1;
+        fflush(stdout);
+        return n_iter;
     }
-    
+
+    fflush(stdout);
     return -1;
 }
 
 /* Perform inner ext LogBP solver */
 void inner_logbp(
-        size_t m, n,
-        int bits_hist[], bits_values[], nodes_hist[], nodes_values[],
-        uint8_t Lc[],
-        float Lq[], Lr[],
-        int n_iter,
+        size_t m, size_t n,
+        size_t bits_count, size_t nodes_count, uint32_t const bits_values[], const uint32_t nodes_values[],
+        int8_t Lc[],
+        float Lq[], float Lr[],
+        unsigned int n_iter,
         float L_posteriori_out[]) {
 
+    /*
+    printf("Input data: [");
+    for (size_t i=0; i<n; i++) {
+        if (i)
+            printf(", ");
+        if (i%32 == 0)
+            printf("\n    ");
+        printf("%4d", Lc[i]);
+    }
+    printf("\n]\n");
+    */
+
     /* step 1 : Horizontal */
-    int bits_counter = 0;
-    int nodes_counter = 0;
+    unsigned int bits_counter = 0;
     for (size_t i=0; i<m; i++) {
-        int ff = bits_hist[i];
-        bits_counter += ff;
-        
-        for (size_t p=bits_counter; p<bits_counter+ff; p++) {
-            int j = bits_values[p];
+        printf("=== i=%zu\n", i);
+        for (size_t p=bits_counter; p<bits_counter+bits_count; p++) {
+            size_t j = bits_values[p];
+            printf("\033[38;5;240mj=%04zd ", j);
 
             float x = 1;
             if (n_iter == 0) {
-                for (size_t q=bits_counter; q<bits_counter+ff; q++) {
-                    if (bits_values[q] != j)
+                for (size_t q=bits_counter; q<bits_counter+bits_count; q++) {
+                    if (bits_values[q] != j) {
+                        int lcv = Lc[bits_values[q]];
+                        char *s = lcv < 0 ? "\033[91m" : (lcv > 0 ? "\033[92m" : "\033[94m");
+                        printf("nij=%04u Lc=%s%3d\033[38;5;240m ", bits_values[q], s, lcv);
                         x *= tanhf(0.5f * Lc[bits_values[q]]);
+                    }
                 }
 
             } else {
-                for (size_t q=bits_counter; q<bits_counter+ff; q++) {
+                for (size_t q=bits_counter; q<bits_counter+bits_count; q++) {
                     if (bits_values[q] != j)
-                        x *= tanhf(0.5f * Lq[i, bits_values[q]]);
+                        x *= tanhf(0.5f * Lq[i*n + bits_values[q]]);
                 }
             }
 
+            printf("\n==== i=%03zd p=%01zd x=%08f\n", i, p-bits_counter, x);
+
             float num = 1 + x;
             float denom = 1 - x;
             if (num == 0)
@@ -90,40 +164,40 @@ void inner_logbp(
             else
                 Lr[i*n + j] = logf(num/denom);
         }
+
+        bits_counter += bits_count;
     }
 
     /* step 2 : Vertical */
+    unsigned int nodes_counter = 0;
     for (size_t j=0; j<n; j++) {
-        ff = nodes_hist[j];
-
-        for (size_t p=bits_counter; p<nodes_counter+ff; p++) {
-            int i = nodes_values[p];
+        for (size_t p=bits_counter; p<nodes_counter+nodes_count; p++) {
+            size_t i = nodes_values[p];
 
-            Lq[i, j] = Lc[j]
+            Lq[i*n + j] = Lc[j];
 
-            for (size_t q=bits_counter; q<nodes_counter+ff; q++) {
+            for (size_t q=bits_counter; q<nodes_counter+nodes_count; q++) {
                 if (nodes_values[q] != i)
-                    Lq[i, j] += Lr[nodes_values[q], j];
+                    Lq[i*n + j] += Lr[nodes_values[q]*n + j];
             }
         }
 
-        nodes_counter += ff;
+        nodes_counter += nodes_count;
     }
 
     /* LLR a posteriori */
-    size_t nodes_counter = 0;
+    nodes_counter = 0;
     for (size_t j=0; j<n; j++) {
-        size_t ff = nodes_hist[j];
         float sum = 0;
-        for (size_t k=bits_counter; k<nodes_counter+ff; k++)
+        for (size_t k=bits_counter; k<nodes_counter+nodes_count; k++)
             sum += Lr[nodes_values[k]*n + j];
-        nodes_counter += ff;
+        nodes_counter += nodes_count;
 
         L_posteriori_out[j] = Lc[j] + sum;
     }
 }
 
-
+/* TODO
 def get_message(tG, x):
     """Compute the original `n_bits` message from a `n_code` codeword `x`.
 
@@ -150,3 +224,4 @@ def get_message(tG, x):
                                           message[list(range(i+1, k))])
 
     return abs(message)
+*/
-- 
cgit