Function rxCmdProcessor

ESP32_AP-Flasher/src/serialap.cpp:407–456

Asynchronous command processor

// Asynchronous command processor
void rxCmdProcessor(void* parameter) {
    rxCmdQueue = xQueueCreate(30, sizeof(struct rxCmd*));
    txActive = xSemaphoreCreateBinary();
    xSemaphoreGive(txActive);
    while (1) {
        if (apInfo.isOnline) {
            struct rxCmd* rxcmd = nullptr;
            BaseType_t q = xQueueReceive(rxCmdQueue, &rxcmd, 10);
            if (q == pdTRUE) {
                switch (rxcmd->type) {
                    case RX_CMD_RQB:
                        processBlockRequest((struct espBlockRequest*)rxcmd->data);
#ifdef HAS_RGB_LED
                        // shortBlink(CRGB::Blue);
#endif
                        quickBlink(3);
                        break;
                    case RX_CMD_ADR:
                        processDataReq((struct espAvailDataReq*)rxcmd->data, true);
#ifdef HAS_RGB_LED
                        // shortBlink(CRGB::Aqua);
#endif
                        quickBlink(1);
                        break;
                    case RX_CMD_XFC:
                        processXferComplete((struct espXferComplete*)rxcmd->data, true);
#ifdef HAS_RGB_LED
                        // shortBlink(CRGB::Purple);
#endif
                        break;
                    case RX_CMD_XTO:
                        processXferTimeout((struct espXferComplete*)rxcmd->data, true);
                        break;
                    case RX_CMD_RSET:
                        Serial.println("AP did reset, resending pending\r\n");
                        refreshAllPending();
                        sendChannelPower(&curChannel);
                        break;
                    case RX_CMD_TRD:
                        // received tag return data
                        processTagReturnData((struct espTagReturnData*)rxcmd->data, rxcmd->len, true);
                        break;
                }
                if (rxcmd->data) free(rxcmd->data);
                if (rxcmd) free(rxcmd);
            }
        }
        vTaskDelay(1 / portTICK_PERIOD_MS);
    }
}
void rxSerialTask(void* parameter) {
    static char cmdbuffer[4] = {0};
    static uint8_t* packetp = nullptr;