mirror of
https://github.com/esphome/esphome.git
synced 2026-10-14 10:12:52 +00:00
Satisfy clang-tidy naming: static helpers without a trailing underscore, lwIP headers instead of forward declarations
This commit is contained in:
@@ -25,8 +25,8 @@
|
||||
(defined(USE_ESP32) && defined(CONFIG_LWIP_TCPIP_CORE_LOCKING))
|
||||
#define ESPHOME_OTA_UDP
|
||||
#include "lwip/ip_addr.h"
|
||||
struct pbuf;
|
||||
struct udp_pcb;
|
||||
#include "lwip/pbuf.h"
|
||||
#include "lwip/udp.h"
|
||||
#endif
|
||||
|
||||
namespace esphome {
|
||||
@@ -112,9 +112,9 @@ class ESPHomeOTAComponent final : public ota::OTAComponent {
|
||||
bool udp_send_(const uint8_t *data, size_t len);
|
||||
// In a UDP session, keeps answering until the client has our responses (an error code), briefly
|
||||
void udp_linger_();
|
||||
static void udp_recv_cb_(void *arg, struct udp_pcb *pcb, struct pbuf *p, const ip_addr_t *addr, uint16_t port);
|
||||
static void udp_recv_cb(void *arg, struct udp_pcb *pcb, struct pbuf *p, const ip_addr_t *addr, uint16_t port);
|
||||
// Caller holds the lwIP lock (or runs in the receive callback)
|
||||
static void udp_send_ack_(UdpLink &link, uint16_t prompted_by);
|
||||
static void udp_send_ack(UdpLink &link, uint16_t prompted_by);
|
||||
#endif
|
||||
// The data phase reads TCP or, once committed, the UDP stream
|
||||
inline ssize_t transport_read_(uint8_t *buf, size_t len) {
|
||||
|
||||
@@ -71,7 +71,7 @@ void ESPHomeOTAComponent::UdpLink::release() {
|
||||
}
|
||||
}
|
||||
|
||||
void ESPHomeOTAComponent::udp_send_ack_(UdpLink &link, uint16_t prompted_by) {
|
||||
void ESPHomeOTAComponent::udp_send_ack(UdpLink &link, uint16_t prompted_by) {
|
||||
const uint16_t len = UDP_ACK_HEADER_SIZE + link.out_len;
|
||||
struct pbuf *p = pbuf_alloc(PBUF_TRANSPORT, len, PBUF_RAM);
|
||||
if (p == nullptr)
|
||||
@@ -94,8 +94,8 @@ void ESPHomeOTAComponent::udp_send_ack_(UdpLink &link, uint16_t prompted_by) {
|
||||
}
|
||||
|
||||
// lwIP context: the tcpip thread (ESP32, LibreTiny), SYS (ESP8266) or an IRQ (RP2040)
|
||||
void ESPHomeOTAComponent::udp_recv_cb_(void *arg, struct udp_pcb * /*pcb*/, struct pbuf *p, const ip_addr_t *addr,
|
||||
uint16_t port) {
|
||||
void ESPHomeOTAComponent::udp_recv_cb(void *arg, struct udp_pcb * /*pcb*/, struct pbuf *p, const ip_addr_t *addr,
|
||||
uint16_t port) {
|
||||
auto &link = *static_cast<UdpLink *>(arg);
|
||||
uint8_t hdr[UDP_HEADER_SIZE];
|
||||
if (!ip_addr_cmp(addr, &link.peer_ip) || pbuf_copy_partial(p, hdr, UDP_HEADER_SIZE, 0) != UDP_HEADER_SIZE ||
|
||||
@@ -124,7 +124,7 @@ void ESPHomeOTAComponent::udp_recv_cb_(void *arg, struct udp_pcb * /*pcb*/, stru
|
||||
} else {
|
||||
pbuf_free(p);
|
||||
}
|
||||
udp_send_ack_(link, seq);
|
||||
udp_send_ack(link, seq);
|
||||
}
|
||||
|
||||
void ESPHomeOTAComponent::udp_open_(UdpLink &link) {
|
||||
@@ -161,7 +161,7 @@ void ESPHomeOTAComponent::udp_open_(UdpLink &link) {
|
||||
// Below the error codes (0x80 and up) the client checks the first byte against, and never all zero
|
||||
token[0] = (token[0] & 0x7F) | 0x01;
|
||||
memcpy(link.reply, token, sizeof(token));
|
||||
udp_recv(link.pcb, udp_recv_cb_, &link);
|
||||
udp_recv(link.pcb, udp_recv_cb, &link);
|
||||
#endif
|
||||
}
|
||||
|
||||
@@ -227,7 +227,7 @@ ssize_t ESPHomeOTAComponent::udp_read_(uint8_t *buf, size_t len) {
|
||||
link.consumed++;
|
||||
link.read_offset = 0;
|
||||
if (was_full)
|
||||
udp_send_ack_(link, link.received - 1);
|
||||
udp_send_ack(link, link.received - 1);
|
||||
}
|
||||
if (got == len)
|
||||
return got;
|
||||
@@ -244,7 +244,7 @@ bool ESPHomeOTAComponent::udp_send_(const uint8_t *data, size_t len) {
|
||||
memcpy(link.out + link.out_len, data, len);
|
||||
link.out_len += len;
|
||||
// Prompted by nothing new, so the client takes no round trip sample from it
|
||||
udp_send_ack_(link, link.received - 1);
|
||||
udp_send_ack(link, link.received - 1);
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user