Mirror
/
ardupilot
mirror of https://github.com/ArduPilot/ardupilot
5
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AP_Networking: adjustable PORT buf size

This commit is contained in:
Tom Pittenger 2023-11-17 11:20:39 -08:00 committed by Tom Pittenger
parent d0bc7921f0
commit 30bccf6266
3 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libraries/AP_Networking/AP_Networking.h
View File

@ -206,11 +206,11 @@ private:
return false; return false;
} }
void udp_client_init(void); void udp_client_init(const uint32_t size_rx, const uint32_t size_tx);
void udp_client_loop(void); void udp_client_loop(void);
private: private:
bool init_buffers(uint32_t size); bool init_buffers(const uint32_t size_rx, const uint32_t size_tx);
uint32_t txspace() override; uint32_t txspace() override;
void _begin(uint32_t b, uint16_t rxS, uint16_t txS) override; void _begin(uint32_t b, uint16_t rxS, uint16_t txS) override;

8
libraries/AP_Networking/AP_Networking_Config.h
View File

@ -22,6 +22,14 @@
#define AP_NETWORKING_SOCKETS_ENABLED (HAL_OS_SOCKETS || AP_NETWORKING_BACKEND_CHIBIOS) #define AP_NETWORKING_SOCKETS_ENABLED (HAL_OS_SOCKETS || AP_NETWORKING_BACKEND_CHIBIOS)
#ifndef AP_NETWORKING_PORT_UDP_CLIENT_RX_BUF_DEFAULT_SIZE
#define AP_NETWORKING_PORT_UDP_CLIENT_RX_BUF_DEFAULT_SIZE 4096
#endif
#ifndef AP_NETWORKING_PORT_UDP_CLIENT_TX_BUF_DEFAULT_SIZE
#define AP_NETWORKING_PORT_UDP_CLIENT_TX_BUF_DEFAULT_SIZE 4096
#endif
// --------------------------- // ---------------------------
// IP Features // IP Features
// --------------------------- // ---------------------------

12
libraries/AP_Networking/AP_Networking_port.cpp
View File

@ -61,7 +61,7 @@ void AP_Networking::ports_init(void)
case NetworkPortType::NONE: case NetworkPortType::NONE:
break; break;
case NetworkPortType::UDP_CLIENT: case NetworkPortType::UDP_CLIENT:
p.udp_client_init(); p.udp_client_init(AP_NETWORKING_PORT_UDP_CLIENT_RX_BUF_DEFAULT_SIZE, AP_NETWORKING_PORT_UDP_CLIENT_TX_BUF_DEFAULT_SIZE);
break; break;
} }
if (p.sock != nullptr) { if (p.sock != nullptr) {
@ -73,9 +73,9 @@ void AP_Networking::ports_init(void)
/* /*
initialise a UDP client initialise a UDP client
*/ */
void AP_Networking::Port::udp_client_init(void) void AP_Networking::Port::udp_client_init(const uint32_t size_rx, const uint32_t size_tx)
{ {
if (!init_buffers(4096)) { if (!init_buffers(size_rx, size_tx)) {
return; return;
} }
sock = new SocketAPM(true); sock = new SocketAPM(true);
@ -171,10 +171,10 @@ bool AP_Networking::Port::_discard_input()
/* /*
initialise read/write buffers initialise read/write buffers
*/ */
bool AP_Networking::Port::init_buffers(uint32_t size) bool AP_Networking::Port::init_buffers(const uint32_t size_rx, const uint32_t size_tx)
{ {
readbuffer = new ByteBuffer(size); readbuffer = new ByteBuffer(size_rx);
writebuffer = new ByteBuffer(size); writebuffer = new ByteBuffer(size_tx);
return readbuffer != nullptr && writebuffer != nullptr; return readbuffer != nullptr && writebuffer != nullptr;
} }