Raspberry Pico Maple Bus TX/RX implemetation

rp2040/futures/CMakeLists.txt

@@ -0,0 +1,6 @@
+add_library(futures INTERFACE)
+target_include_directories(futures INTERFACE ${CMAKE_CURRENT_LIST_DIR}/include)
+target_sources(futures INTERFACE
+        futures.c
+)
+# target_link_libraries(futures INTERFACE <libs>)

rp2040/futures/futures.c

@@ -0,0 +1,19 @@
+/*
+ * Copyright (c) 2022 Raul E Rangel
+ *
+ * SPDX-License-Identifier: BSD-3-Clause
+ */
+
+#include <futures.h>
+#include <pico/platform.h>
+
+static inline enum future_state future_complete(
+    __unused struct future *future, __unused struct wait_context *ctx)
+{
+  return FUTURE_DONE;
+}
+
+void complete_future(struct future *future)
+{
+	future->poll = future_complete;
+}

rp2040/futures/include/futures.h

@@ -0,0 +1,27 @@
+/*
+ * Copyright (c) 2022 Raul E Rangel
+ *
+ * SPDX-License-Identifier: BSD-3-Clause
+ */
+
+#ifndef _FUTURES_H
+#define _FUTURES_H
+
+#include "pico/types.h"
+
+enum future_state {
+    FUTURE_PENDING,
+    FUTURE_DONE,
+};
+
+struct wait_context {
+    /* TODO */
+};
+
+struct future {
+    enum future_state (*poll)(struct future *future, struct wait_context *ctx);
+};
+
+void complete_future(struct future *future);
+
+#endif /* _FUTURES_H */

rp2040/maplebus/CMakeLists.txt

@@ -0,0 +1,34 @@
+# Copyright (c) 2021 Raul E Rangel
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
+cmake_minimum_required(VERSION 3.13)
+
+set(PICO_SDK_PATH ../../pico-sdk)
+include(pico_sdk_import.cmake)
+
+add_subdirectory(../futures build-futures)
+
+project(maplebus)
+
+pico_sdk_init()
+
+add_executable(maplebus)
+
+pico_enable_stdio_uart(maplebus 1)
+
+pico_generate_pio_header(maplebus ${CMAKE_CURRENT_LIST_DIR}/maplebus.pio)
+
+target_sources(maplebus PRIVATE
+        main.c
+        maplebus.c
+        )
+
+target_link_libraries(maplebus PRIVATE pico_stdlib hardware_pio futures)
+target_compile_options(maplebus PRIVATE -Wall -Wextra -Wconversion -Werror)
+target_compile_definitions(maplebus PRIVATE
+        PARAM_ASSERTIONS_ENABLE_ALL=1 # want to check all the assertions for compilation warnings
+)
+
+pico_add_extra_outputs(maplebus)
+

rp2040/maplebus/load.gdb

@@ -0,0 +1,3 @@
+target remote localhost:3333
+load
+monitor reset init

rp2040/maplebus/main.c

@@ -0,0 +1,114 @@
+/*
+ * Copyright (c) 2021 Raul E Rangel
+ *
+ * SPDX-License-Identifier: GPL-2.0-or-later
+ */
+
+#include <stdio.h>
+#include <string.h>
+
+#include "pico/stdlib.h"
+#include "maplebus.h"
+
+#define PIN_HEARTBEAT 4
+#define PIN_SDCKA 3
+#define PIN_SDCKB 2
+
+struct {
+	struct maplebus_header header;
+	// Max number of additional frames
+	uint32_t data[255];
+} rx_buffer;
+
+_Static_assert (sizeof(rx_buffer) == 1024, "rx_buffer is not 1024 bytes long");
+
+struct maplebus_header device_info_request = {
+	.command = 0x01,
+	.destination = 0x20,
+	.source = 0x00,
+	.length = 0x00,
+};
+
+struct test_packet {
+	struct maplebus_header header;
+	uint32_t data[4];
+} test_packet = {
+	.header = {
+		.command = 0x99,
+		.destination = 0x88,
+		.source = 0x77,
+		.length = sizeof(struct test_packet) / 4 - 1,
+	},
+	.data = {
+		0x66 << 0,
+		0x55 << 8,
+		0x44 << 16,
+		0x33 << 24
+	}
+};
+
+int main() {
+	stdio_init_all();
+
+	printf("Maple Bus starting!\n");
+
+	// gpio_init(PIN_HEARTBEAT);
+	// gpio_set_dir(PIN_HEARTBEAT, GPIO_OUT);
+
+	maplebus_tx_id_t tx_id;
+	maplebus_rx_id_t rx_id;
+
+	struct future tx_future;
+	struct maplebus_rx_future rx_future;
+
+	maplebus_tx_pio_init(pio0);
+	maplebus_rx_pio_init(pio1);
+
+	tx_id = maplebus_tx_init(PIN_SDCKA, PIN_SDCKB);
+	rx_id = maplebus_rx_init(PIN_SDCKA, PIN_SDCKB);
+
+	uint iteration = 0;
+
+	while (true) {
+		printf("Maple Bus iteration %u\n", iteration);
+
+		//gpio_put(PIN_HEARTBEAT, 1);
+		maplebux_tx(tx_id, &tx_future, &test_packet.header, sizeof(test_packet));
+		maplebus_rx(rx_id, &rx_future, &rx_buffer.header, sizeof(rx_buffer));
+		while (tx_future.poll(&tx_future, NULL) != FUTURE_DONE || rx_future.future.poll(&rx_future.future, NULL) != FUTURE_DONE)
+			;
+
+		switch (rx_future.status) {
+		case MAPLEBUS_OK:
+			maplebus_print(&rx_buffer.header);
+			break;
+		case MAPLEBUS_UNKNOWN_FRAME_TYPE:
+			printf("invalid frame type\n");
+			break;
+		case MAPLEBUS_INVALID_ARGS:
+			printf("invalid args\n");
+			break;
+		case MAPLEBUS_CRC_ERROR:
+			printf("crc error\n");
+			break;
+		case MAPLEBUS_MESSAGE_TRUNCATED:
+			printf("rx truncated\n");
+			break;
+		case MAPLEBUS_TIMEOUT:
+			printf("rx timeout\n");
+			break;
+		default:
+			printf("Unknown return code %d\n", rx_future.status);
+		}
+		//gpio_put(PIN_HEARTBEAT, 0);
+
+		if (memcmp(&test_packet, &rx_buffer, sizeof(test_packet)))
+			printf("Packet doesn't match!\n");
+
+		iteration++;
+
+		sleep_ms(1000);
+	}
+
+	return 0;
+}