high priority thread start postpone

Author: mvladic

src/eez/firmware.cpp

@@ -106,10 +106,9 @@ void boot() {
 #if OPTION_ETHERNET
     mcu::ethernet::initMessageQueue();
 #endif
+    initHighPriorityMessageQueue();
     initLowPriorityMessageQueue();
 
-    startHighPriorityThread();
-
     // INIT
     psu::init();
 
@@ -207,6 +206,8 @@ void boot() {
 #if OPTION_ETHERNET
     mcu::ethernet::startThread();
 #endif
+
+    startHighPriorityThread();
     startLowPriorityThread();
 
     mp::initMessageQueue();

src/eez/platform/stm32/spi.cpp

@@ -105,12 +105,6 @@ void deselect(uint8_t slotIndex) {
 }
 
 HAL_StatusTypeDef SPI_TransmitReceive(SPI_HandleTypeDef *hspi, uint8_t *pTxData, uint8_t *pRxData, uint16_t Size) {
-    /* Process Locked */
-    __HAL_LOCK(hspi);
-    if (hspi->State != HAL_SPI_STATE_BUSY_RX) {
-        hspi->State = HAL_SPI_STATE_BUSY_TX_RX;
-    }
-
     // Variable used to alternate Rx and Tx during transfer
     bool txAllowed = true;
 
@@ -197,9 +191,6 @@ HAL_StatusTypeDef SPI_TransmitReceive(SPI_HandleTypeDef *hspi, uint8_t *pTxData,
 
     // Control if the RX fifo is empty
     while ((hspi->Instance->SR & SPI_FLAG_FRLVL) != SPI_FTLVL_EMPTY);
-    
-    hspi->State = HAL_SPI_STATE_READY;
-    __HAL_UNLOCK(hspi);
 
     return HAL_OK;
 }

src/eez/tasks.cpp

@@ -77,7 +77,7 @@ osThreadDef(g_highPriorityThread, highPriorityThreadMainLoop, osPriorityAboveNor
 osThreadId g_highPriorityThreadHandle;
 
 #if defined(EEZ_PLATFORM_STM32)
-#define HIGH_PRIORITY_QUEUE_SIZE 10
+#define HIGH_PRIORITY_QUEUE_SIZE 50
 #endif
 
 #if defined(EEZ_PLATFORM_SIMULATOR)
@@ -117,9 +117,12 @@ static uint32_t g_timer1LastTickCount;
 
 ////////////////////////////////////////////////////////////////////////////////
 
-void startHighPriorityThread() {
+void initHighPriorityMessageQueue() {
     g_highPriorityMessageQueueId = osMessageCreate(osMessageQ(g_highPriorityMessageQueue), NULL);
-    g_highPriorityThreadHandle = osThreadCreate(osThread(g_highPriorityThread), nullptr);
+}
+
+void startHighPriorityThread() {
+	g_highPriorityThreadHandle = osThreadCreate(osThread(g_highPriorityThread), nullptr);
 }
 
 void highPriorityThreadOneIter();
@@ -128,6 +131,8 @@ void highPriorityThreadMainLoop(const void *) {
 #ifdef __EMSCRIPTEN__
     highPriorityThreadOneIter();
 #else
+    g_highPriorityThreadHandle = osThreadGetId();
+
     while (1) {
         highPriorityThreadOneIter();
     }
@@ -143,11 +148,6 @@ void highPriorityThreadOneIter() {
         psu::onThreadMessage(type, param);
     } else {
         WATCHDOG_RESET();
-
-        if (!g_isBooted) {
-            return;
-        }
-
         for (int i = 0; i < NUM_SLOTS; i++) {
             g_slots[i]->tick();
         }
@@ -157,7 +157,7 @@ void highPriorityThreadOneIter() {
 }
 
 bool isPsuThread() {
-    return osThreadGetId() == g_highPriorityThreadHandle;
+    return !g_isBooted || osThreadGetId() == g_highPriorityThreadHandle;
 }
 
 void sendMessageToPsu(HighPriorityThreadMessage messageType, uint32_t messageParam, uint32_t timeoutMillisec) {
@@ -184,6 +184,8 @@ void lowPriorityThreadMainLoop(const void *) {
         lowPriorityThreadOneIter();
     }
 #else
+    g_lowPriorityTaskHandle = osThreadGetId();
+
     while (g_isLowPriorityThreadAlive) {
     	lowPriorityThreadOneIter();
     }

src/eez/tasks.h

@@ -97,6 +97,7 @@ enum LowPriorityThreadMessage {
 
 extern bool g_screenshotGenerating;
 
+void initHighPriorityMessageQueue();
 void startHighPriorityThread();
 
 bool isPsuThread();