Change in osmo-e1d[master]: e1-prbs-test: Add initial code for checking ICE40-E1 traces

This is merely a historical archive of years 2008-2021, before the migration to mailman3.

A maintained and still updated list archive can be found at https://lists.osmocom.org/hyperkitty/list/gerrit-log@lists.osmocom.org/.

laforge gerrit-no-reply at lists.osmocom.org
Mon Jan 6 16:39:51 UTC 2020 

laforge has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-e1d/+/16741 )


Change subject: e1-prbs-test: Add initial code for checking ICE40-E1 traces
......................................................................

e1-prbs-test: Add initial code for checking ICE40-E1 traces

The idea of this code is to check captures made by ICE40 against
the known transmitted per-timeslots PRBS sequences.

Change-Id: I084a9737c9e051dcadf971e39e32f10f89aecfbd
---
M contrib/e1-prbs-test/Makefile
A contrib/e1-prbs-test/ice40-rx.c
M contrib/e1-prbs-test/internal.h
3 files changed, 239 insertions(+), 3 deletions(-)



  git pull ssh://gerrit.osmocom.org:29418/osmo-e1d refs/changes/41/16741/1

diff --git a/contrib/e1-prbs-test/Makefile b/contrib/e1-prbs-test/Makefile
index 726befc..172847f 100644
--- a/contrib/e1-prbs-test/Makefile
+++ b/contrib/e1-prbs-test/Makefile
@@ -4,13 +4,16 @@
 CFLAGS=-O2 -g -Wall -Werror $(LIBOSMO_CFLAGS)
 LIBS=$(LIBOSMO_LIBS)
 
-all: e1-prbs-test
+all: e1-prbs-test ice40-e1-prbs-check
 
 e1-prbs-test: main.o rx.o tx.o prbs.o utils.o
 	$(CC) $(LDFLAGS) -o $@ $^ $(LIBS)
 
+ice40-e1-prbs-check: ice40-rx.o rx.o prbs.o utils.o
+	$(CC) $(LDFLAGS) -o $@ $^ $(LIBS)
+
 %.o: %.c
 	$(CC) $(CFLAGS) -o $@ -c $^
 
 clean:
-	@rm -f e1-prbs-test e1-prbs-test *.o
+	@rm -f e1-prbs-test ice40-e1-prbs-check *.o
diff --git a/contrib/e1-prbs-test/ice40-rx.c b/contrib/e1-prbs-test/ice40-rx.c
new file mode 100644
index 0000000..de0e4f1
--- /dev/null
+++ b/contrib/e1-prbs-test/ice40-rx.c
@@ -0,0 +1,233 @@
+/* (C) 2019 by Harald Welte <laforge at gnumonks.org>
+ * All Rights Reserved
+ *
+ * SPDX-License-Identifier: GPL-2.0-or-later
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
+
+#define _GNU_SOURCE
+#include <string.h>
+
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/ioctl.h>
+#include <dirent.h>
+#include <fcntl.h>
+#include <stdint.h>
+#include <stdlib.h>
+#include <getopt.h>
+#include <unistd.h>
+#include <errno.h>
+#include <time.h>
+#include <signal.h>
+#include <dahdi/user.h>
+
+#include <osmocom/core/select.h>
+#include <osmocom/core/utils.h>
+#include <osmocom/core/bits.h>
+#include <osmocom/core/prbs.h>
+
+#include "internal.h"
+
+static struct test_state g_tst;
+static int g_prbs_offs_rx;
+static uint8_t g_usb_endpoint = 0x81;
+
+#define E1_CHUNK_HDR_MAGIC	0xe115600d /* E1 is good */
+struct e1_chunk_hdr {
+	uint32_t magic;
+	struct {
+		uint64_t sec;
+		uint64_t usec;
+	} time;
+	uint16_t len;		/* length of following payload */
+	uint8_t ep;		/* USB endpoint */
+} __attribute__((packed));
+
+struct ts_buf {
+	uint8_t bytes[1024];
+};
+struct line_ts_buf {
+	struct ts_buf ts_buf[32];
+	unsigned int next_offset;
+};
+static struct line_ts_buf g_line_ts_buf;
+
+static int demux_in(struct test_state *tst, const uint8_t *data, size_t len)
+{
+	int i;
+
+	if (len % 32)
+		fprintf(stderr, "Length %zu is not multiple of 32\n", len);
+
+	for (i = 0; i < len; i++) {
+		uint32_t ts_nr = i % 32;
+		g_line_ts_buf.ts_buf[ts_nr].bytes[g_line_ts_buf.next_offset] = data[i];
+
+		/* go to next offset in all per-timeslot buffers */
+		if (ts_nr == 31)
+			g_line_ts_buf.next_offset++;
+
+		/* if per-ts buffers are full, hand them to decoder */
+		if (g_line_ts_buf.next_offset >= sizeof(g_line_ts_buf.ts_buf[0].bytes)) {
+			uint8_t j;
+			for (j = 0; j < 32; j++) {
+				struct timeslot_state *ts = &tst->ts[j];
+				//printf("process_rx(%u, %s)\n", j, osmo_hexdump(g_line_ts_buf.ts_buf[j].bytes, g_line_ts_buf.next_offset));
+				process_rx(&ts->rx, j, g_line_ts_buf.ts_buf[j].bytes, g_line_ts_buf.next_offset);
+			}
+			memset(&g_line_ts_buf, 0, sizeof(g_line_ts_buf));
+			g_line_ts_buf.next_offset = 0;
+		}
+	}
+	return 0;
+}
+
+
+static int process_file(struct test_state *tst, int fd)
+{
+	struct e1_chunk_hdr hdr;
+	unsigned long offset = 0;
+	uint8_t buf[65535];
+	int rc;
+
+	while (1) {
+		/* first read header */
+		rc = read(fd, &hdr, sizeof(hdr));
+		if (rc < 0)
+			return rc;
+		if (rc != sizeof(hdr)) {
+			fprintf(stderr, "%d is less than header size (%zd)\n", rc, sizeof(hdr));
+			return -1;
+		}
+		offset += rc;
+		if (hdr.magic != E1_CHUNK_HDR_MAGIC) {
+			fprintf(stderr, "offset %lu: Wrong magic 0x%08x\n", offset, hdr.magic);
+			return -1;
+		}
+
+		/* then read payload */
+		rc = read(fd, buf, hdr.len);
+		if (rc < 0)
+			return rc;
+		offset += rc;
+		if (rc != hdr.len) {
+			fprintf(stderr, "%d is less than payload size (%d)\n", rc, hdr.len);
+			return -1;
+		}
+
+		/* filter on the endpoint (direction) specified by the user */
+		if (hdr.ep != g_usb_endpoint)
+			continue;
+
+		if (hdr.len <= 4)
+			continue;
+
+		//printf("> %s\n", osmo_hexdump(buf, hdr.len));
+		demux_in(tst, buf+4, hdr.len-4);
+	}
+}
+
+static int open_file(struct test_state *tst, const char *fname)
+{
+	int i;
+	for (i = 0; i < 32; i++) {
+		struct timeslot_state *ts = &tst->ts[i];
+		ts->ofd.priv_nr = i;
+		ts_init_prbs_rx(ts, g_prbs_offs_rx);
+	}
+
+	return open(fname, O_RDONLY);
+}
+
+static void print_report(void)
+{
+	struct timespec ts_now;
+	int i;
+
+	clock_gettime(CLOCK_MONOTONIC, &ts_now);
+
+	for (i = 0; i < ARRAY_SIZE(g_tst.ts); i++) {
+		const struct timeslot_state *ts = &g_tst.ts[i];
+		printf("E1TS(%02u) STATS: sync_losses=%u, bit_errs=%u in %lu seconds\n",
+			ts->ofd.priv_nr, ts->rx.sync_state.num_sync_loss, ts->rx.sync_state.num_bit_err,
+			ts_now.tv_sec - ts->rx.sync_state.ts_sync.tv_sec);
+	}
+}
+
+static void sig_handler(int signal)
+{
+	switch (signal) {
+	case SIGINT:
+		print_report();
+		exit(0);
+		break;
+	case SIGHUP:
+		print_report();
+		break;
+	}
+}
+
+static void handle_options(int argc, char **argv)
+{
+	while (1) {
+		int c;
+		static const struct option long_opts[] = {
+			{ "rx-prbs-offset", 1, 0, 'r' },
+			{ "endpoint", 1, 0, 'e' },
+			{ 0, 0, 0, 0 }
+		};
+		c = getopt_long(argc, argv, "r:e:", long_opts, NULL);
+		if (c == -1)
+			break;
+
+		switch (c) {
+		case 'r':
+			g_prbs_offs_rx = atoi(optarg);
+			break;
+		case 'e':
+			g_usb_endpoint = strtoul(optarg, NULL, 16);
+			break;
+		default:
+			exit(1);
+		}
+	}
+}
+
+int main(int argc, char **argv)
+{
+	char *fname;
+	int rc;
+
+	handle_options(argc, argv);
+
+	if (argc <= optind) {
+		fprintf(stderr, "You must specify the file name of the ICE40-E1 capture\n");
+		exit(1);
+	}
+	fname = argv[optind];
+
+	signal(SIGINT, sig_handler);
+	signal(SIGHUP, sig_handler);
+
+	rc = open_file(&g_tst, fname);
+	if (rc < 0) {
+		fprintf(stderr, "Error opening %s: %s\n", fname, strerror(errno));
+		exit(1);
+	}
+	process_file(&g_tst, rc);
+	print_report();
+}
diff --git a/contrib/e1-prbs-test/internal.h b/contrib/e1-prbs-test/internal.h
index 681648a..a2c4ef5 100644
--- a/contrib/e1-prbs-test/internal.h
+++ b/contrib/e1-prbs-test/internal.h
@@ -4,7 +4,7 @@
 #include <osmocom/core/prbs.h>
 #include <osmocom/core/select.h>
 
-#define MAX_NR_TS	31
+#define MAX_NR_TS	32
 #define PRBS_LEN	2048
 
 /* prbs.c */

-- 
To view, visit https://gerrit.osmocom.org/c/osmo-e1d/+/16741
To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings

Gerrit-Project: osmo-e1d
Gerrit-Branch: master
Gerrit-Change-Id: I084a9737c9e051dcadf971e39e32f10f89aecfbd
Gerrit-Change-Number: 16741
Gerrit-PatchSet: 1
Gerrit-Owner: laforge <laforge at osmocom.org>
Gerrit-MessageType: newchange
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.osmocom.org/pipermail/gerrit-log/attachments/20200106/4fdf447d/attachment.htm>

More information about the gerrit-log mailing list