3D-Druck/Filaman
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 183 Wiki Activity

refactor: improve task synchronization in vendor, filament, and spool creation functions

Browse Source
This commit is contained in:
Manuel Weiser
2025-08-29 10:02:48 +02:00
parent 54275f2ac9
commit 95433b4842
2 changed files with 43 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
src/api.cpp
View File

@@ -616,6 +616,7 @@ bool updateSpoolBambuData(String payload) {
uint16_t createVendor(String vendor) { uint16_t createVendor(String vendor) {
// Create new vendor in Spoolman database using task system // Create new vendor in Spoolman database using task system
// Note: Due to async nature, the ID will be stored in createdVendorId global variable // Note: Due to async nature, the ID will be stored in createdVendorId global variable
// Note: This function assumes that the caller has already ensured API is IDLE
createdVendorId = 0; // Reset previous value createdVendorId = 0; // Reset previous value
String spoolsUrl = spoolmanUrl + apiUrl + "/vendor"; String spoolsUrl = spoolmanUrl + apiUrl + "/vendor";
@@ -645,19 +646,18 @@ uint16_t createVendor(String vendor) {
params->spoolsUrl = spoolsUrl; params->spoolsUrl = spoolsUrl;
params->updatePayload = vendorPayload; params->updatePayload = vendorPayload;
// Check if API is idle before creating task // Create task without additional API state check since caller ensures synchronization
if(spoolmanApiState == API_IDLE){ BaseType_t result = xTaskCreate(
// Erstelle die Task sendToApi, // Task-Funktion
BaseType_t result = xTaskCreate( "SendToApiTask", // Task-Name
sendToApi, // Task-Funktion 6144, // Stackgröße in Bytes
"SendToApiTask", // Task-Name (void*)params, // Parameter
6144, // Stackgröße in Bytes 0, // Priorität
(void*)params, // Parameter NULL // Task-Handle (nicht benötigt)
0, // Priorität );
NULL // Task-Handle (nicht benötigt)
); if (result != pdPASS) {
} else { Serial.println("Failed to create vendor task!");
Serial.println("Not spawning new task, API still active!");
delete params; delete params;
vendorDoc.clear(); vendorDoc.clear();
return 0; return 0;
@@ -736,6 +736,7 @@ uint16_t checkVendor(String vendor) {
uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) { uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) {
// Create new filament in Spoolman database using task system // Create new filament in Spoolman database using task system
// Note: Due to async nature, the ID will be stored in createdFilamentId global variable // Note: Due to async nature, the ID will be stored in createdFilamentId global variable
// Note: This function assumes that the caller has already ensured API is IDLE
createdFilamentId = 0; // Reset previous value createdFilamentId = 0; // Reset previous value
String spoolsUrl = spoolmanUrl + apiUrl + "/filament"; String spoolsUrl = spoolmanUrl + apiUrl + "/filament";
@@ -790,19 +791,18 @@ uint16_t createFilament(uint16_t vendorId, const JsonDocument& payload) {
params->spoolsUrl = spoolsUrl; params->spoolsUrl = spoolsUrl;
params->updatePayload = filamentPayload; params->updatePayload = filamentPayload;
// Check if API is idle before creating task // Create task without additional API state check since caller ensures synchronization
if(spoolmanApiState == API_IDLE){ BaseType_t result = xTaskCreate(
// Erstelle die Task sendToApi, // Task-Funktion
BaseType_t result = xTaskCreate( "SendToApiTask", // Task-Name
sendToApi, // Task-Funktion 6144, // Stackgröße in Bytes
"SendToApiTask", // Task-Name (void*)params, // Parameter
6144, // Stackgröße in Bytes 0, // Priorität
(void*)params, // Parameter NULL // Task-Handle (nicht benötigt)
0, // Priorität );
NULL // Task-Handle (nicht benötigt)
); if (result != pdPASS) {
} else { Serial.println("Failed to create filament task!");
Serial.println("Not spawning new task, API still active!");
delete params; delete params;
filamentDoc.clear(); filamentDoc.clear();
return 0; return 0;
@@ -881,6 +881,7 @@ uint16_t checkFilament(uint16_t vendorId, const JsonDocument& payload) {
uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& payload, String uidString) { uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& payload, String uidString) {
// Create new spool in Spoolman database using task system // Create new spool in Spoolman database using task system
// Note: Due to async nature, the ID will be stored in createdSpoolId global variable // Note: Due to async nature, the ID will be stored in createdSpoolId global variable
// Note: This function assumes that the caller has already ensured API is IDLE
createdSpoolId = 0; // Reset previous value createdSpoolId = 0; // Reset previous value
String spoolsUrl = spoolmanUrl + apiUrl + "/spool"; String spoolsUrl = spoolmanUrl + apiUrl + "/spool";
@@ -918,19 +919,18 @@ uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& paylo
params->spoolsUrl = spoolsUrl; params->spoolsUrl = spoolsUrl;
params->updatePayload = spoolPayload; params->updatePayload = spoolPayload;
// Check if API is idle before creating task // Create task without additional API state check since caller ensures synchronization
if(spoolmanApiState == API_IDLE){ BaseType_t result = xTaskCreate(
// Erstelle die Task sendToApi, // Task-Funktion
BaseType_t result = xTaskCreate( "SendToApiTask", // Task-Name
sendToApi, // Task-Funktion 6144, // Stackgröße in Bytes
"SendToApiTask", // Task-Name (void*)params, // Parameter
6144, // Stackgröße in Bytes 0, // Priorität
(void*)params, // Parameter NULL // Task-Handle (nicht benötigt)
0, // Priorität );
NULL // Task-Handle (nicht benötigt)
); if (result != pdPASS) {
} else { Serial.println("Failed to create spool task!");
Serial.println("Not spawning new task, API still active!");
delete params; delete params;
return 0; return 0;
} }
@@ -941,7 +941,7 @@ uint16_t createSpool(uint16_t vendorId, uint16_t filamentId, JsonDocument& paylo
vTaskDelay(100 / portTICK_PERIOD_MS); vTaskDelay(100 / portTICK_PERIOD_MS);
} }
// daten mit startWriteJsonToTag schreiben // Write data to tag with startWriteJsonToTag
// void startWriteJsonToTag(const bool isSpoolTag, const char* payload); // void startWriteJsonToTag(const bool isSpoolTag, const char* payload);
payload["sm_id"].set(String(createdSpoolId)); payload["sm_id"].set(String(createdSpoolId));

4
src/scale.cpp
View File

@@ -48,8 +48,10 @@ void scale_loop(void * parameter) {
Serial.println("Scale Loop started"); Serial.println("Scale Loop started");
Serial.println("++++++++++++++++++++++++++++++"); Serial.println("++++++++++++++++++++++++++++++");
vTaskDelay(pdMS_TO_TICKS(500));
scale.tare(); scale.tare();
vTaskDelay(pdMS_TO_TICKS(500));
for(;;) { for(;;) {
if (scale.is_ready()) if (scale.is_ready())
{ {