example-thread.cpp

//#define USE_WIFI
#ifdef USE_WIFI
  const char* wifi_ssid     = "MyWiFi";
  const char* wifi_password = "00000000001";
  const char* wifi_hostname = "myesp32";

  #include <WiFi.h>

  #define DEBUG_WIFI
#endif

#include <Arduino.h>
#include <esp32-hal.h>
#include <esp_system.h>

// #include <Arduino_FreeRTOS.h>
// #include <task.h>

portMUX_TYPE qam_rx_mux = portMUX_INITIALIZER_UNLOCKED;

TaskHandle_t Task1;

#include "main.h"

// ########################################################################################
//
// Delcare and initialise the various classes
//
// Initialize variables
volatile PULSE rawBitBuffer[RAWBITBUFFERSIZE];
volatile unsigned int rawBitBufferPosition  = 0;

volatile unsigned long lastRedTime = 0;
volatile unsigned long lastRedTimeloop2 = 0;
volatile unsigned long lastRedTimeloop3 = 0;

volatile uint32_t intOnCoreNum = 9;

volatile byte baseProtocolState = BASEPROTOCOL433_RX_LISTENMODE;
volatile byte wifiSetupState = 1;

#ifdef EXAMPLE_THREAD
void IRAM_ATTR qam_rx() {

  static unsigned int prevTime = 0; // lastTime
  unsigned int newTime = micros();  // now

  // Calculate the duration of the current signal state
  unsigned int duration = newTime - prevTime;

  bool state = digitalRead(35);

  portENTER_CRITICAL_ISR(&qam_rx_mux);
  //portENTER_CRITICAL(&qam_rx_mux);

  // If we find the preample (4.5ms < x < 12.5ms) trigger baseProtocolState to receiving mode
  if ((duration > BASEPROTOCOL433_RX_PREAMPLE_THRESOLD_MIN) && (duration < BASEPROTOCOL433_RX_PREAMPLE_THRESOLD_MAX) ) {
    if (baseProtocolState == BASEPROTOCOL433_RX_RECEIVEMODE) {
        baseProtocolState = BASEPROTOCOL433_RX_MESSAGERECEIVED;
    } else {
        baseProtocolState = BASEPROTOCOL433_RX_RECEIVEMODE;
    }
  }

	if (baseProtocolState == BASEPROTOCOL433_RX_RECEIVEMODE) {
		// Store the duration of the received pulse
    rawBitBuffer[rawBitBufferPosition].state = !state;
    rawBitBuffer[rawBitBufferPosition].duration = duration;
    rawBitBufferPosition++;
	}

	if (rawBitBufferPosition == (RAWBITBUFFERSIZE - 1)) {
		baseProtocolState =BASEPROTOCOL433_RX_LISTENMODE;
		rawBitBufferPosition = 0;
	}

  prevTime = newTime;

  portEXIT_CRITICAL_ISR(&qam_rx_mux);
  //portEXIT_CRITICAL(&qam_rx_mux);
}

void qam_rx_task(void *pvParameters) {
  pinMode(35, INPUT);
  attachInterrupt(digitalPinToInterrupt(35), qam_rx, CHANGE);
  vTaskDelete(NULL);
}

#endif

void setup() {
  Serial.begin(115200);

  rawBitBufferPosition = 0;
  baseProtocolState = BASEPROTOCOL433_SETUP;

  // Configure QAM-RX4 data pin as an input pin
  pinMode(35, INPUT);

  // Start the qam_rx task on Core 1
  xTaskCreatePinnedToCore(qam_rx_task, "qam_rx_task", 10000, NULL, 1, NULL, 1);
  //attachInterrupt(digitalPinToInterrupt(35), qam_rx, CHANGE);

  // qam_rx_thread.onRun(qam_rx_thread_fn);
  // qam_rx_thread.setStackSize(2048);
  // qam_rx_thread.setPriority(2);
  // qam_rx_thread.start();

  #ifdef USE_WIFI
    //Serial.println("calling setup_wifi()");
    
    //setup_wifi();
  #endif

  Serial.println("Setup() done");

}

void loop() {
  unsigned long now = millis();

  if (now - lastRedTime > 2000) {
    Serial.print("loop()  - core# ");
    Serial.println(xPortGetCoreID());
    lastRedTime = now;
  }

  vTaskDelay(1);

}

void loop2(void * parameter) {
  int x;

  while(true) {

    if (baseProtocolState == BASEPROTOCOL433_SETUP) {
      attachInterrupt(digitalPinToInterrupt(35), qam_rx4_isr, CHANGE);
      baseProtocolState = BASEPROTOCOL433_RX_LISTENMODE;
    }

    if (baseProtocolState == BASEPROTOCOL433_RX_MESSAGERECEIVED) {
      sleep(1);
        Serial.print("rBBP = ");
        Serial.println(rawBitBufferPosition);
        Serial.print("bPS = ");
        Serial.println(baseProtocolState);
      for (x = 0; x <= rawBitBufferPosition; x++) {
        Serial.print("x = ");
        Serial.print(x);
        Serial.print(", S = ");
        Serial.print(rawBitBuffer[x].state);
        Serial.print(", D = ");
        Serial.println(rawBitBuffer[x].duration);
      }
      Serial.print("loop2() - core# ");
      Serial.println(xPortGetCoreID());
      Serial.print("intOn  - core# ");
      Serial.println(intOnCoreNum);
    
      baseProtocolState = BASEPROTOCOL433_RX_LISTENMODE;
      attachInterrupt(digitalPinToInterrupt(35), qam_rx4_isr, CHANGE);
    }

    vTaskDelay(1);

  }
}

void loop3(void * parameter) {
  int x;

  while(true) {

    unsigned long now = millis();
  
    if (now - lastRedTimeloop3 > 2000) {
      Serial.print("loop3()  - core# ");
      Serial.println(xPortGetCoreID());
      lastRedTimeloop3 = now;
    }

    #ifdef USE_WIFI
    if (wifiSetupState == 1) {
      setup_wifi();
      wifiSetupState = 0;
      Serial.print("loop3() - core# ");
      Serial.println(xPortGetCoreID());
    }
    #endif

    vTaskDelay(1);
  }
}




/*
 *
 * WiFi Functions
 * 
 */
#ifdef USE_WIFI

void setup_wifi() {
    // delete old config
    WiFi.disconnect(true);
    delay(1000);

    // We start by connecting to a WiFi network
    #ifdef DEBUG_WIFI
        Serial.println();
        Serial.print("setup_wifi() - core# ");
        Serial.println(xPortGetCoreID());
        Serial.print("Connecting to ");
        Serial.print(wifi_ssid);
        Serial.print(" with ");
        Serial.println(wifi_password);
        Serial.print("MAC ");
        Serial.println(WiFi.macAddress());
        Serial.print("WL_CONNECTED ");
        Serial.println(WL_CONNECTED);
    #endif

    // Set the WiFi into Station Mode
    WiFi.mode(WIFI_STA);

    // Set the hostname
    WiFi.setHostname(wifi_hostname);
    //WiFi.setHostname(hostname.c_str());
    //WiFi.encryptionType(WIFI_AUTH_WPA_PSK);

    // Start the WiFi
    WiFi.begin(wifi_ssid, wifi_password);

    // Wait for WiFi to connect
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        #ifdef DEBUG_WIFI
            Serial.print(WiFi.status());
        #endif
    }

    

    #ifdef DEBUG_WIFI
        // Display the IP Address and Details
        displayWifiDetails();
    #endif
}


void displayWifiDetails(){
      Serial.println("");
      Serial.print("displayWifiDetails() - core# ");
      Serial.println(xPortGetCoreID());
    if (WiFi.status() == WL_CONNECTED) {
        Serial.println("WiFi connected");
        Serial.print("SSID       : ");
        Serial.print(wifi_ssid);
        Serial.print(" , key ");
        Serial.println(wifi_password);
        Serial.print("IP address : ");
        Serial.println(WiFi.localIP());
        Serial.print("RSSI       : ");
        Serial.println(WiFi.RSSI());
    } else {
        Serial.println("WiFi disconnected");
        Serial.print("WiFi Status: ");
        Serial.println(WiFi.status());        
    }
        Serial.print("MAC        : ");
        Serial.println(WiFi.macAddress());
}

#endif