mirror of
https://github.com/esphome/esphome.git
synced 2026-09-16 09:38:42 +00:00
[socket] Document safety of unlocked reads in wait_for_data_/read/readv
This commit is contained in:
@@ -517,10 +517,16 @@ err_t LWIPRawImpl::recv_fn(struct pbuf *pb, err_t err) {
|
||||
|
||||
void LWIPRawImpl::wait_for_data_() {
|
||||
// Wait for data without holding LWIP_LOCK so recv_fn() can run on RP2040
|
||||
// (needs async_context lock). Unlocked reads of rx_buf_/rx_closed_/pcb_ are
|
||||
// safe (atomic pointer/bool on ARM/Xtensa) — they're just hints to avoid
|
||||
// unnecessary sleeping; the authoritative check happens under LWIP_LOCK
|
||||
// in the caller after this returns.
|
||||
// (needs async_context lock).
|
||||
//
|
||||
// IMPORTANT: This method only null-checks rx_buf_/pcb_ and reads rx_closed_.
|
||||
// It never dereferences pointers or modifies any state. All fields are only
|
||||
// modified by recv_fn()/err_fn() (which set rx_buf_, rx_closed_, pcb_) and
|
||||
// by the locked read path (which consumes rx_buf_). Since we haven't entered
|
||||
// the locked section yet, only callbacks can change these fields, and pointer/
|
||||
// bool reads are atomic on ARM/Xtensa — so a stale value at worst causes an
|
||||
// unnecessary sleep or early exit, both handled by the LWIP_LOCK recheck.
|
||||
//
|
||||
// Loop until data arrives, connection closes, or the full timeout elapses.
|
||||
// socket_delay() may return early due to other sockets waking the global
|
||||
// socket_wake() flag, so we re-enter for the remaining time.
|
||||
@@ -535,6 +541,14 @@ void LWIPRawImpl::wait_for_data_() {
|
||||
}
|
||||
|
||||
ssize_t LWIPRawImpl::read(void *buf, size_t len) {
|
||||
// Unlocked pre-check: these fields are modified by recv_fn()/err_fn() which
|
||||
// run from IRQ context on RP2040. Pointer and bool reads are atomic on
|
||||
// ARM/Xtensa, so we never see a torn value — just possibly stale:
|
||||
// - rx_buf_ stale null: unnecessary wait, but wait_for_data_() re-checks
|
||||
// and returns immediately when data is found
|
||||
// - rx_buf_ stale non-null: skip wait, locked section below handles it
|
||||
// - rx_closed_/pcb_ stale: wait_for_data_() loop re-checks each iteration
|
||||
// All state is authoritatively rechecked under LWIP_LOCK below.
|
||||
if (this->recv_timeout_cs_ > 0 && this->rx_buf_ == nullptr && !this->rx_closed_ && this->pcb_ != nullptr) {
|
||||
this->wait_for_data_();
|
||||
}
|
||||
@@ -599,6 +613,7 @@ ssize_t LWIPRawImpl::read(void *buf, size_t len) {
|
||||
}
|
||||
|
||||
ssize_t LWIPRawImpl::readv(const struct iovec *iov, int iovcnt) {
|
||||
// See read() for safety analysis of these unlocked reads.
|
||||
if (this->recv_timeout_cs_ > 0 && this->rx_buf_ == nullptr && !this->rx_closed_ && this->pcb_ != nullptr) {
|
||||
this->wait_for_data_();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user