Brandon Ling - FW102 Onboarding

projects/task1/README.md

@@ -0,0 +1,15 @@
+<!--
+General guidelines
+These are just guidelines, not strict rules - document however seems best.
+A README for a firmware-only project (e.g. Babydriver, MPXE, bootloader, CAN explorer) should answer the following questions:
+ - What is it?
+ - What problem does it solve?
+ - How do I use it? (with usage examples / example commands, etc)
+ - How does it work? (architectural overview)
+A README for a board project (powering a hardware board, e.g. power distribution, centre console, charger, BMS carrier) should answer the following questions:
+ - What is the purpose of the board?
+ - What are all the things that the firmware needs to do?
+ - How does it fit into the overall system?
+ - How does it work? (architectural overview, e.g. what each module's purpose is or how data flows through the firmware)
+-->
+# task1

projects/task1/config.json

@@ -0,0 +1,6 @@
+{
+ "libs": [
+ "FreeRTOS",
+ "ms-common"
+ ]
+}

projects/task1/src/queues1.c

@@ -0,0 +1,66 @@
+#include <stdbool.h>
+#include <stdint.h>
+
+#include "FreeRTOS.h"
+#include "delay.h"
+#include "log.h"
+#include "misc.h"
+#include "queues.h"
+#include "status.h"
+#include "tasks.h"
+#define ITEM_SZ 6
+#define QUEUE_LEN 5
+#define BUF_SIZE (QUEUE_LEN * ITEM_SZ)
+static const char s_list[QUEUE_LEN][ITEM_SZ] = { "Item1", "Item2", "Item3", "Item4", "Item5" };
+// Task static entities
+static uint8_t s_queue1_buf[BUF_SIZE];
+static Queue s_queue1 = {
+ .num_items = QUEUE_LEN,
+ .item_size = ITEM_SZ,
+ .storage_buf = s_queue1_buf,
+};
+TASK(task1, TASK_STACK_512) {
+ LOG_DEBUG("Task 1 initialized!\n");
+ StatusCode ret;
+ int i = 0;
+ while (true) {
+ if (i < QUEUE_LEN) {
+ ret = queue_send(&s_queue1, s_list[i], 0);
+ if (ret != STATUS_CODE_OK) {
+ LOG_DEBUG("write to queue failed\n");
+ } else {
+ LOG_DEBUG("write to queue successful\n");
+ }
+ i++;
+ delay_ms(100);
+ } else {
+ continue;
+ }
+ }
+}
+TASK(task2, TASK_STACK_512) {
+ LOG_DEBUG("Task 2 initialized!\n");
+ const char outstr[ITEM_SZ];
+ StatusCode ret;
+ while (true) {
+ // Your code goes here
+ ret = queue_receive(&s_queue1, outstr, 0);
+ if (ret != STATUS_CODE_OK) {
+ LOG_DEBUG("read from queue failed\n");
+ } else {
+ LOG_DEBUG("%s\n", outstr);
+ }
+ delay_ms(100);
+ }
+}
+int main(void) {
+ log_init();
+ tasks_init();
+ queue_init(&s_queue1);
+ // Initialize queues here
+ tasks_init_task(task1, TASK_PRIORITY(2), NULL);
+ tasks_init_task(task2, TASK_PRIORITY(2), NULL);
+ LOG_DEBUG("Program start...\n");
+ tasks_start();
+ return 0;
+}

projects/task1/src/tasks/tasks.c

@@ -0,0 +1,43 @@
+#include "tasks.h"
+
+#include <stdbool.h>
+#include <stdint.h>
+
+#include "FreeRTOS.h"
+#include "delay.h"
+#include "gpio.h"
+#include "log.h"
+#include "misc.h"
+// Non blocking delay. Simply consumes cpu cycles until a given time has passed
+static void prv_delay(const TickType_t delay_ms) {
+ TickType_t curr_tick = xTaskGetTickCount();
+ while (xTaskGetTickCount() - curr_tick < pdMS_TO_TICKS(delay_ms)) {
+ }
+}
+TASK(task1, TASK_STACK_512) {
+ int counter1 = 0;
+ while (true) {
+ LOG_DEBUG("Task 1: %d\n", counter1);
+ counter1++;
+ delay_ms(1000);
+ }
+}
+TASK(task2, TASK_STACK_512) {
+ int counter2 = 0;
+ while (true) {
+ LOG_DEBUG("Task 2: %d\n", counter2);
+ counter2++;
+ prv_delay(1000);
+ }
+}
+int main(void) {
+ log_init();
+ tasks_init();
+ // Create tasks here
+ tasks_init_task(task1, TASK_PRIORITY(2), NULL); // max priority is 4
+ tasks_init_task(task2, TASK_PRIORITY(1), NULL);
+ LOG_DEBUG("Program start...\n");
+ // Start the scheduler
+ tasks_start();
+ return 0;
+}