sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-11-01 07:31:51 +00:00
Code Issues Releases Wiki Activity

Merge branch 'integration' into memory_api

Browse Source
This commit is contained in:
J. Nick Koston
2025-10-25 14:12:28 -07:00
parent 6ad33a5a52 698ee9cfdb
commit 1531b3c0d2
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
esphome/components/usb_uart/usb_uart.cpp
View File

@@ -256,8 +256,9 @@ void USBUartComponent::start_input(USBUartChannel *channel) {
ESP_LOGV(TAG, "Transfer result: length: %u; status %X", status.data_len, status.error_code); ESP_LOGV(TAG, "Transfer result: length: %u; status %X", status.data_len, status.error_code);
if (!status.success) { if (!status.success) {
ESP_LOGE(TAG, "Control transfer failed, status=%s", esp_err_to_name(status.error_code)); ESP_LOGE(TAG, "Control transfer failed, status=%s", esp_err_to_name(status.error_code));
// On failure, defer retry to main loop // Transfer failed, slot already released
this->defer_input_retry_(channel); // Mark input as not started so normal operations can restart later
channel->input_started_.store(false);
return; return;
} }
@@ -265,9 +266,10 @@ void USBUartComponent::start_input(USBUartChannel *channel) {
// Allocate a chunk from the pool // Allocate a chunk from the pool
UsbDataChunk *chunk = this->chunk_pool_.allocate(); UsbDataChunk *chunk = this->chunk_pool_.allocate();
if (chunk == nullptr) { if (chunk == nullptr) {
// No chunks available - defer retry to main loop for backpressure // No chunks available - queue is full, data dropped, slot already released
this->usb_data_queue_.increment_dropped_count(); this->usb_data_queue_.increment_dropped_count();
this->defer_input_retry_(channel); // Mark input as not started so normal operations can restart later
channel->input_started_.store(false);
return; return;
} }