heliox/old-monorepo
Archived
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Fix 'Too many messages queued'

Browse source
This commit is contained in:
GHOSCHT 2022-04-10 17:20:40 +02:00
parent f2a290af30
commit 887b64ddf2
No known key found for this signature in database
GPG key ID: A35BD466B8871994
1 changed files with 34 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
modules/control/Firmware/src/main.cpp
View file

@ -9,7 +9,7 @@
#include <ESPAsyncWebServer.h>
#include <Credentials/Credentials.h>
const int STEPS = 5;
int STEPS = 5;
BluetoothSerial bt;
AsyncWebServer server(80);
@ -23,37 +23,57 @@ LightController *light;
void TaskBlink(void *pvParameters);
void TaskAnalogRead(void *pvParameters);
void setup()
void websocketTask(void *parameter)
{
while (true)
{
websocket->sendMessage(light->getBjtState(), light->getBjtCount());
websocket->clearBuffer();
int bjtCount = 4;
const int bjtPin[bjtCount] = {SIG1A, SIG1B, SIG2A, SIG2B};
computer = new SerialCommunicator(Serial, 9600, 5, 50);
phone = new BluetoothCommunicator(bt, 5, 50);
light = new LightController(bjtPin, bjtCount);
vTaskDelay(90 / portTICK_PERIOD_MS);
}
vTaskDelete(NULL);
}
void registerTasks()
{
xTaskCreate(websocketTask, "websocketTask", 10000, NULL, 1, NULL);
}
void connectWifi()
{
WiFi.begin(WIFI_SSID, WIFI_PW);
Serial.println("Connecting to WiFi");
Serial.print("Connecting to WiFi");
while (WiFi.status() != WL_CONNECTED)
{
Serial.print(".");
delay(1000);
}
Serial.println("");
Serial.println(WiFi.localIP());
}
void setup()
{
int bjtCount = 4;
const int bjtPin[bjtCount] = {SIG1A, SIG1B, SIG2A, SIG2B};
computer = new SerialCommunicator(Serial, 9600, 5, 50);
phone = new BluetoothCommunicator(bt, 5, 50);
light = new LightController(bjtPin, bjtCount);
websocket = new WebsocketCommunicator(ws, server, 50);
connectWifi();
registerTasks();
}
void loop()
{
light->updateState(computer->receiveMessage(), STEPS);
light->updateState(phone->receiveMessage(), STEPS);
websocket->sendMessage(light->getBjtState(), light->getBjtCount());
websocket->clearBuffer();
// computer->sendMessage(light->getBjtState(), light->getBjtCount());
// computer->clearBuffer();
// phone->sendMessage(light->getBjtState(), light->getBjtCount());
// phone->clearBuffer();
computer->sendMessage(light->getBjtState(), light->getBjtCount());
computer->clearBuffer();
phone->sendMessage(light->getBjtState(), light->getBjtCount());
phone->clearBuffer();
ws.cleanupClients();
server.begin();