sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-09-29 00:22:21 +01:00
Code Issues Releases Wiki Activity

stack it

Browse Source
This commit is contained in:
J. Nick Koston
2025-09-26 23:56:11 -05:00
parent c789fbf9f3
commit 9875e96b13
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
esphome/components/esphome/ota/ota_esphome.cpp
View File

@@ -28,6 +28,7 @@ namespace esphome {
static const char *const TAG = "esphome.ota"; static const char *const TAG = "esphome.ota";
static constexpr uint16_t OTA_BLOCK_SIZE = 8192; static constexpr uint16_t OTA_BLOCK_SIZE = 8192;
static constexpr size_t OTA_BUFFER_SIZE = 1024; // buffer size for OTA data transfer
static constexpr uint32_t OTA_SOCKET_TIMEOUT_HANDSHAKE = 10000; // milliseconds for initial handshake static constexpr uint32_t OTA_SOCKET_TIMEOUT_HANDSHAKE = 10000; // milliseconds for initial handshake
static constexpr uint32_t OTA_SOCKET_TIMEOUT_DATA = 90000; // milliseconds for data transfer static constexpr uint32_t OTA_SOCKET_TIMEOUT_DATA = 90000; // milliseconds for data transfer
@@ -276,7 +277,8 @@ void ESPHomeOTAComponent::handle_data_() {
bool update_started = false; bool update_started = false;
size_t total = 0; size_t total = 0;
uint32_t last_progress = 0; uint32_t last_progress = 0;
uint8_t buf[1024]; uint8_t buf[OTA_BUFFER_SIZE];
const size_t buf_size = sizeof(buf);
char *sbuf = reinterpret_cast<char *>(buf); char *sbuf = reinterpret_cast<char *>(buf);
size_t ota_size; size_t ota_size;
#if USE_OTA_VERSION == 2 #if USE_OTA_VERSION == 2
@@ -342,7 +344,6 @@ void ESPHomeOTAComponent::handle_data_() {
while (total < ota_size) { while (total < ota_size) {
// TODO: timeout check // TODO: timeout check
size_t remaining = ota_size - total; size_t remaining = ota_size - total;
const size_t buf_size = sizeof(buf);
size_t requested = remaining < buf_size ? remaining : buf_size; size_t requested = remaining < buf_size ? remaining : buf_size;
ssize_t read = this->client_->read(buf, requested); ssize_t read = this->client_->read(buf, requested);
if (read == -1) { if (read == -1) {