moving thread helpers

Author: caiodasilva2005

threadX/inc/threadX_utils.h

@@ -0,0 +1,11 @@
+
+#ifndef __U_THREADX_H
+#define __U_THREADX_H
+
+#include "tx_api.h"
+#include "u_threads.h"
+#include <stdint.h>
+
+uint8_t _create_thread(TX_BYTE_POOL *byte_pool, thread_t *thread);
+
+#endif

threadX/inc/u_general.h

@@ -0,0 +1,14 @@
+
+#ifndef __U_GENERAL_H
+#define __U_GENERAL_H
+
+#include <string.h>
+#include <stdio.h>
+/* This file (and u_general.c) contain miscellaneous macros, functions, and configuration settings that can be used throughout the project. */
+
+/* General-purpose status macros. */
+#define U_SUCCESS     0
+#define U_ERROR       1
+#define U_QUEUE_EMPTY 2
+
+#endif

threadX/inc/u_threads.h

@@ -0,0 +1,24 @@
+#include "tx_api.h"
+#include <stdint.h>
+#include <stdio.h>
+
+/* Initializes all threads. Called from app_threadx.c */
+uint8_t threads_init(TX_BYTE_POOL *byte_pool);
+
+typedef struct {
+    /* PUBLIC: Thread Configuration Settings */
+    /* Set these when defining an instance of this struct. */
+    const CHAR      *name;                /* Name of Thread */
+    const ULONG     thread_input;         /* Thread Input. You can put whatever you want in here. Defaults to zero. */
+    const ULONG     size;                 /* Stack Size (in bytes) */
+    const UINT      priority;             /* Priority */
+    const UINT      threshold;            /* Preemption Threshold */
+    const ULONG     time_slice;           /* Time Slice */
+    const UINT      auto_start;           /* Auto Start */
+    const UINT      sleep;                /* Sleep (in ticks) */
+    VOID            (*function)(ULONG);   /* Thread Function */
+
+    /* PRIVATE: Internal implementation - DO NOT ACCESS DIRECTLY */
+    /* (should only be accessed by functions in u_threads.c) */
+    TX_THREAD _TX_THREAD;
+} thread_t;

threadX/src/threadX_utils.c

@@ -0,0 +1,46 @@
+
+#include "threadX_utils.h"
+#include "u_threads.h"
+#include "u_threads.h"
+#include "u_general.h"
+
+uint8_t _create_thread(TX_BYTE_POOL *byte_pool, thread_t *thread) {
+     /* Create Threads */
+    //CATCH_ERROR(_create_thread(byte_pool, &_default_thread), 0);            // Create Default thread.
+    
+    /*
+    CATCH_ERROR(_create_thread(byte_pool, &_can_thread), U_SUCCESS);                
+    CATCH_ERROR(_create_thread(byte_pool, &_faults_thread), U_SUCCESS);             
+    CATCH_ERROR(_create_thread(byte_pool, &_statemachine_thread), U_SUCCESS);    
+    CATCH_ERROR(_create_thread(byte_pool, &_nonfunctional_data_thread), U_SUCCESS); 
+    CATCH_ERROR(_create_thread(byte_pool, &_tsms_thread), U_SUCCESS);               
+    CATCH_ERROR(_create_thread(byte_pool, &_control_thread), U_SUCCESS);            
+    CATCH_ERROR(_create_thread(byte_pool, &_pedals_thread), U_SUCCESS);  
+    */        
+    // add more threads here if need
+
+    DEBUG_PRINTLN("Ran threads_init().");
+    return U_SUCCESS;
+}
+
+uint8_t threads_init(TX_BYTE_POOL *byte_pool);
+
+uint8_t threads_init(TX_BYTE_POOL *byte_pool) {
+
+    /* Create Threads */
+    //CATCH_ERROR(_create_thread(byte_pool, &_default_thread), U_SUCCESS);            // Create Default thread.
+    /*
+    CATCH_ERROR(_create_thread(byte_pool, &_can_thread), U_SUCCESS);                // Create CAN thread.
+    CATCH_ERROR(_create_thread(byte_pool, &_faults_thread), U_SUCCESS);             // Create Faults thread.
+    CATCH_ERROR(_create_thread(byte_pool, &_statemachine_thread), U_SUCCESS);       // Create State Machine thread.
+    CATCH_ERROR(_create_thread(byte_pool, &_nonfunctional_data_thread), U_SUCCESS); // Create Nonfunctional Data thread.
+    CATCH_ERROR(_create_thread(byte_pool, &_tsms_thread), U_SUCCESS);               // Create TSMS thread.
+    CATCH_ERROR(_create_thread(byte_pool, &_control_thread), U_SUCCESS);            // Create Control thread.
+    CATCH_ERROR(_create_thread(byte_pool, &_pedals_thread), U_SUCCESS);             // Create Pedals thread.
+    */
+    // add more threads here if need
+
+    DEBUG_PRINTLN("Ran threads_init().");
+    return U_SUCCESS;
+}
+