in a project, I got to send sensor data over WiFi while i scan the Sensor with 10kHz simultaneously.
If I scan first an send afterwards, i get sampling rates up to 90kHz. But if I separate the Read and Send tasks on Core 0 and 1 so I can scan "forever" without running out of storage, I just get a maximum sampling rate of 950Hz.
There is another article on this topic here: viewtopic.php?f=19&t=10084&p=41613
but unfortunately it has no answers.
Here is my Code:
Code: Select all
#include <Arduino.h> //Declaration of extern libraries
#include <CircularBuffer.h>
#include <WiFi.h>
CircularBuffer <uint8_t, 4096*10> Buffer; //Buffer Declaration of Type uint8_t and size of 1024 places
TaskHandle_t WriteInBuffer; //Declaration of separate tasks to run on Core 0 and 1
TaskHandle_t ReadFromBuffer;
int analogPin = 32; //Declaration of Pin where analog Data is read
const char *ssid = "ESP32ap"; //set WiFi settings
const char *password = "12345678";
WiFiServer wifiServer(80); //WiFi Server on Port 80
uint8_t value = 0; // = value from ADC before Buffer
uint8_t element = 0; // = value from ADC after Buffer
int packSize = 4096; // = number of Data Points send in 1 Package
int nPacks = 4; // = number of Packs send after each other
bool connect = false; // = variable neccesary to communicate between Tasks
void WriteIn(void * pvParameters){ //Task to write in buffer
for(;;){ //never ending loop
if (connect == true){ //read analog value as long as the client is connected
analogReadResolution(8);
value = analogRead(analogPin);
Buffer.unshift(value); //write at the beginning of the buffer --> [here,3,2,1]
vTaskDelay(1);
}
else{
vTaskDelay(5); //neccesary to not trigger the WatchDog
}
}
}
void ReadFrom( void * pvParameters){ //Task to Read from Buffer and Send over WiFi
for(;;){ //never ending loop
WiFiClient client = wifiServer.available(); //Declaration of client
if (client){ //if client is connected
int Bytes = 0; // = Bytes send in this session
int i = 0; // = counter for loop
connect = true; //let other Task know that client is connected
Serial.println("Client connected");
while(client.connected()){ //Maybe this loop is not neccesary?
while(i < nPacks){ //while not all Packs are sent
//Serial.println(Buffer.size()); // this command is neccesary in a strange way
if(Buffer.size() >= packSize){ //if Buffer is bigger than the Pack size, send a Pack
for (int j = 0; j < packSize; j++){
element = Buffer.pop(); //get entry fom Buffers end [4,3,2,1(here)] --> FIFO principle
Bytes += client.write(element); //send elements over WiFi
}
i ++; //increment the Packs Loop after sending a Pack
Serial.println("Test");
}
vTaskDelay(5);
}
client.stop(); //Disconnect Client after sending all Data
connect = false; //let other Task know about it
Serial.println("Client disconnected");
Serial.print("Bytes sent: ");
Serial.println(Bytes); //number of Bytes sent
Serial.println(Buffer.size());
Buffer.clear();
}
connect = false;
}
vTaskDelay(10); //neccesary to not trigger the WatchDog
}
}
void setup() {
Serial.begin(9600); //Configuring Serial Monitor
Serial.println("Configuring access point...");
WiFi.softAP(ssid, password); //opening Access Point
IPAddress myIP = WiFi.softAPIP();
Serial.print("AP IP address: ");
Serial.println(myIP); //Print IP-Adress of ESP
wifiServer.begin(); //Start WiFi Server
xTaskCreatePinnedToCore(
WriteIn, /* Task function. */
"WriteInBuffer", /* name of task. */
10000, /* Stack size of task */
NULL, /* parameter of the task */
1, /* priority of the task */
&WriteInBuffer, /* Task handle to keep track of created task */
0);
xTaskCreatePinnedToCore(
ReadFrom, /* Task function. */
"ReadFromBuffer", /* name of task. */
10000, /* Stack size of task */
NULL, /* parameter of the task */
1, /* priority of the task */
&ReadFromBuffer, /* Task handle to keep track of created task */
1);
}
void loop() {
}Thanks in advance!