sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-10-03 02:22:25 +01:00
Code Issues Releases Wiki Activity

Merge branch 'bound_tx_buf' into integration

Browse Source
This commit is contained in:
J. Nick Koston
2025-10-01 20:47:21 +02:00
parent cc5b9ba4d6 4b10bf09be
commit fa548e20da
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
esphome/components/api/api_frame_helper.cpp
View File

@@ -110,9 +110,13 @@ void APIFrameHelper::buffer_data_from_iov_(const struct iovec *iov, int iovcnt,
return; return;
} }
auto buffer = std::make_unique<SendBuffer>(); uint16_t buffer_size = total_write_len - offset;
buffer->size = total_write_len - offset; auto &buffer = this->tx_buf_[this->tx_buf_tail_];
buffer->data = std::make_unique<uint8_t[]>(buffer->size); buffer = std::make_unique<SendBuffer>(SendBuffer{
.data = std::make_unique<uint8_t[]>(buffer_size),
.size = buffer_size,
.offset = 0,
});
uint16_t to_skip = offset; uint16_t to_skip = offset;
uint16_t write_pos = 0; uint16_t write_pos = 0;
@@ -131,8 +135,7 @@ void APIFrameHelper::buffer_data_from_iov_(const struct iovec *iov, int iovcnt,
} }
} }
// Add to circular buffer // Update circular buffer tracking
this->tx_buf_[this->tx_buf_tail_] = std::move(buffer);
this->tx_buf_tail_ = (this->tx_buf_tail_ + 1) % API_MAX_SEND_QUEUE; this->tx_buf_tail_ = (this->tx_buf_tail_ + 1) % API_MAX_SEND_QUEUE;
this->tx_buf_count_++; this->tx_buf_count_++;
} }