mirror of
https://github.com/ByteWelder/Tactility.git
synced 2026-08-17 23:55:04 +00:00
Fixes and improvements
This commit is contained in:
parent
52c1ec7060
commit
0e8d642448
@ -175,19 +175,25 @@ int32_t appMain(uint32_t appInstanceId, int argc, char* argv[]) {
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
ctx.timer = std::make_unique<Timer>(Timer::Type::Periodic, pdMS_TO_TICKS(1000), [&ctx] {
|
|
||||||
if (lvgl_is_running()) {
|
|
||||||
lvgl_lock();
|
|
||||||
updateViewState(&ctx);
|
|
||||||
lvgl_unlock();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
AppEventSubscription sub {};
|
AppEventSubscription sub {};
|
||||||
sub.app_instance_id = appInstanceId;
|
sub.app_instance_id = appInstanceId;
|
||||||
app_event_subscribe(&sub);
|
app_event_subscribe(&sub);
|
||||||
|
|
||||||
WindowId window = window_manager_create(appInstanceId, createWidgets, &ctx);
|
WindowId window = window_manager_create(appInstanceId, createWidgets, &ctx);
|
||||||
|
|
||||||
|
ctx.timer = std::make_unique<Timer>(Timer::Type::Periodic, pdMS_TO_TICKS(1000), [&ctx, window] {
|
||||||
|
if (lvgl_is_running()) {
|
||||||
|
lvgl_lock();
|
||||||
|
// Widgets only exist while this window is topmost - skip otherwise. Another app
|
||||||
|
// (started non-modally, e.g. via app_manager_start()) can bury this window without
|
||||||
|
// stopping this instance or notifying it; window_manager deletes a buried window's
|
||||||
|
// widgets, so touching ctx->statusLabel here would use-after-free it.
|
||||||
|
if (window_manager_get_state(window) == WINDOW_STATE_GRANTED) {
|
||||||
|
updateViewState(&ctx);
|
||||||
|
}
|
||||||
|
lvgl_unlock();
|
||||||
|
}
|
||||||
|
});
|
||||||
ctx.timer->start();
|
ctx.timer->start();
|
||||||
|
|
||||||
bool shouldClose = false;
|
bool shouldClose = false;
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
#include <tactility/device.h>
|
#include <tactility/device.h>
|
||||||
#include <tactility/drivers/display.h>
|
#include <tactility/drivers/display.h>
|
||||||
|
#include <tactility/drivers/sdcard.h>
|
||||||
#include <tactility/drivers/spi_controller.h>
|
#include <tactility/drivers/spi_controller.h>
|
||||||
#include <tactility/filesystem/file_mutex.h>
|
#include <tactility/filesystem/file_mutex.h>
|
||||||
#include <tactility/filesystem/file_system.h>
|
#include <tactility/filesystem/file_system.h>
|
||||||
@ -75,6 +76,29 @@ void initFileMutexForLvgl() {
|
|||||||
|
|
||||||
return true;
|
return true;
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// SDMMC-backed SD cards aren't parented under SPI_CONTROLLER_TYPE, so the pass above never
|
||||||
|
// sees them - but on some chips (classic ESP32) SDMMC and SPI still contend for DMA/bus
|
||||||
|
// access. Lock every SD card mount if a display exists anywhere, regardless of bus topology.
|
||||||
|
if (!device_exists_of_type(&DISPLAY_TYPE)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
file_system_for_each(nullptr, [](FileSystem* fs, void* context) {
|
||||||
|
char mount_path[64];
|
||||||
|
if (file_system_get_path(fs, mount_path, sizeof(mount_path)) != ERROR_NONE) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
auto* owner = file_system_get_owner(fs);
|
||||||
|
if (owner == nullptr || device_get_type(owner) != &SDCARD_TYPE) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
LOG_I(TAG, "Adding file mutex for %s (SD card) - a display is present and may contend for bus/DMA resources", mount_path);
|
||||||
|
file_mutex_register(&lvgl_mutex, mount_path);
|
||||||
|
return true;
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,8 +1,8 @@
|
|||||||
#include <Tactility/LogMessages.h>
|
#include <Tactility/LogMessages.h>
|
||||||
#include <Tactility/StringUtils.h>
|
#include <Tactility/StringUtils.h>
|
||||||
#include <Tactility/file/File.h>
|
|
||||||
#include <Tactility/network/HttpdReq.h>
|
#include <Tactility/network/HttpdReq.h>
|
||||||
|
|
||||||
|
#include <tactility/filesystem/file_mutex.h>
|
||||||
#include <tactility/log.h>
|
#include <tactility/log.h>
|
||||||
|
|
||||||
#include <memory>
|
#include <memory>
|
||||||
@ -186,30 +186,59 @@ size_t receiveFile(httpd_req_t* request, size_t length, const std::string& fileP
|
|||||||
char buffer[BUFFER_SIZE];
|
char buffer[BUFFER_SIZE];
|
||||||
size_t bytes_received = 0;
|
size_t bytes_received = 0;
|
||||||
|
|
||||||
file::FileMutexGuard guard(filePath);
|
// Locked only around each actual disk I/O call below, not across the httpd_req_recv() waits
|
||||||
|
// in between - this file's mutex may resolve to lvgl_lock() (see FileMutexLvgl.cpp), and
|
||||||
|
// holding that for the whole (potentially multi-second) network transfer starves LVGL's own
|
||||||
|
// task for the entire upload instead of just for each brief write.
|
||||||
|
FileMutex mutex {};
|
||||||
|
file_mutex_get(&mutex, filePath.c_str());
|
||||||
|
|
||||||
|
file_mutex_lock(&mutex);
|
||||||
auto* file = fopen(filePath.c_str(), "wb");
|
auto* file = fopen(filePath.c_str(), "wb");
|
||||||
|
file_mutex_unlock(&mutex);
|
||||||
if (file == nullptr) {
|
if (file == nullptr) {
|
||||||
LOG_E(TAG, "Failed to open file for writing: %s", filePath.c_str());
|
LOG_E(TAG, "Failed to open file for writing: %s", filePath.c_str());
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
constexpr int MAX_TIMEOUT_RETRIES = 5;
|
||||||
|
int timeout_retries = 0;
|
||||||
while (bytes_received < length) {
|
while (bytes_received < length) {
|
||||||
auto expected_chunk_size = std::min<size_t>(BUFFER_SIZE, length - bytes_received);
|
auto expected_chunk_size = std::min<size_t>(BUFFER_SIZE, length - bytes_received);
|
||||||
size_t receive_chunk_size = httpd_req_recv(request, buffer, expected_chunk_size);
|
int received = httpd_req_recv(request, buffer, expected_chunk_size);
|
||||||
if (receive_chunk_size <= 0) {
|
if (received == HTTPD_SOCK_ERR_TIMEOUT) {
|
||||||
|
// Timeout - retry with backoff, same as receiveByteArray(). A large file takes many
|
||||||
|
// more chunks (and much longer overall) than the small reads elsewhere in this file,
|
||||||
|
// so it's far more likely to hit at least one transient stall somewhere along the way.
|
||||||
|
timeout_retries++;
|
||||||
|
if (timeout_retries >= MAX_TIMEOUT_RETRIES) {
|
||||||
|
LOG_E(TAG, "Recv timeout after %d retries, wrote %zu/%zu bytes", timeout_retries, bytes_received, length);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
LOG_W(TAG, "Recv timeout, retry %d/%d", timeout_retries, MAX_TIMEOUT_RETRIES);
|
||||||
|
vTaskDelay(pdMS_TO_TICKS(100 * timeout_retries)); // Exponential backoff
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
if (received <= 0) {
|
||||||
LOG_E(TAG, "Receive failed, got 0 bytes but expected %zu more", length - bytes_received);
|
LOG_E(TAG, "Receive failed, got 0 bytes but expected %zu more", length - bytes_received);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
if (fwrite(buffer, 1, receive_chunk_size, file) != receive_chunk_size) {
|
timeout_retries = 0;
|
||||||
|
size_t receive_chunk_size = (size_t)received;
|
||||||
|
|
||||||
|
file_mutex_lock(&mutex);
|
||||||
|
bool write_ok = fwrite(buffer, 1, receive_chunk_size, file) == receive_chunk_size;
|
||||||
|
file_mutex_unlock(&mutex);
|
||||||
|
if (!write_ok) {
|
||||||
LOG_E(TAG, "Failed to write all bytes");
|
LOG_E(TAG, "Failed to write all bytes");
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
bytes_received += receive_chunk_size;
|
bytes_received += receive_chunk_size;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Write file
|
file_mutex_lock(&mutex);
|
||||||
fclose(file);
|
fclose(file);
|
||||||
|
file_mutex_unlock(&mutex);
|
||||||
return bytes_received;
|
return bytes_received;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -138,20 +138,24 @@ bool contains(const std::string& ssid) {
|
|||||||
bool load(const std::string& ssid, WifiApSettings& apSettings) {
|
bool load(const std::string& ssid, WifiApSettings& apSettings) {
|
||||||
auto service_context = findServiceContext();
|
auto service_context = findServiceContext();
|
||||||
if (service_context == nullptr) {
|
if (service_context == nullptr) {
|
||||||
|
LOG_E(TAG, "No service context");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
const auto file_path = getApPropertiesFilePath(service_context->getPaths(), ssid);
|
const auto file_path = getApPropertiesFilePath(service_context->getPaths(), ssid);
|
||||||
if (!file::isFile(file_path)) {
|
if (!file::isFile(file_path)) {
|
||||||
|
LOG_E(TAG, "Not a file: %s", file_path.c_str());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
std::map<std::string, std::string> map;
|
std::map<std::string, std::string> map;
|
||||||
if (!file::loadPropertiesFile(file_path, map)) {
|
if (!file::loadPropertiesFile(file_path, map)) {
|
||||||
|
LOG_E(TAG, "Failed to load properties from %s", file_path.c_str());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// SSID is required
|
// SSID is required
|
||||||
if (!map.contains(AP_PROPERTIES_KEY_SSID)) {
|
if (!map.contains(AP_PROPERTIES_KEY_SSID)) {
|
||||||
|
LOG_E(TAG, "File does not contain SSID: %s", file_path.c_str());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -166,6 +170,7 @@ bool load(const std::string& ssid, WifiApSettings& apSettings) {
|
|||||||
} else if (decrypt(ssid, encrypted_password, password_decrypted)) {
|
} else if (decrypt(ssid, encrypted_password, password_decrypted)) {
|
||||||
apSettings.password = password_decrypted;
|
apSettings.password = password_decrypted;
|
||||||
} else {
|
} else {
|
||||||
|
LOG_E(TAG, "Failed to decrypt password from %s", file_path.c_str());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user