Mirrors_Framework/PX4-Autopilot
1
0
Fork 0
mirror of https://github.com/PX4/PX4-Autopilot.git synced 2026-05-22 22:32:11 +08:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

platform: serial: add bytesAvailable() function

Browse Source
This commit is contained in:
Jacob Dahl
2025-07-28 20:16:13 -08:00
committed by Daniel Agar
parent 42dccca8fc
commit 399512571b
8 changed files with 40 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platforms/common/Serial.cpp
+5
View File
@@ -69,6 +69,11 @@ bool Serial::close()
return _impl.close();
}
ssize_t Serial::bytesAvailable()
{
return _impl.bytesAvailable();
}
ssize_t Serial::read(uint8_t *buffer, size_t buffer_size)
{
return _impl.read(buffer, buffer_size);
platforms/common/include/px4_platform_common/Serial.hpp
+1
View File
@@ -61,6 +61,7 @@ public:
bool close();
ssize_t bytesAvailable();
ssize_t read(uint8_t *buffer, size_t buffer_size);
ssize_t readAtLeast(uint8_t *buffer, size_t buffer_size, size_t character_count = 1, uint32_t timeout_ms = 0);
platforms/nuttx/src/px4/common/SerialImpl.cpp
+12
View File
@@ -259,6 +259,18 @@ bool SerialImpl::close()
return true;
}
ssize_t SerialImpl::bytesAvailable()
{
if (!_open) {
PX4_ERR("Device not open!");
return -1;
}
ssize_t bytes_available = 0;
int ret = ioctl(_serial_fd, FIONREAD, &bytes_available);
return ret >= 0 ? bytes_available : 0;
}
ssize_t SerialImpl::read(uint8_t *buffer, size_t buffer_size)
{
if (!_open) {
platforms/nuttx/src/px4/common/include/SerialImpl.hpp
+1
View File
@@ -59,6 +59,7 @@ public:
bool close();
ssize_t bytesAvailable();
ssize_t read(uint8_t *buffer, size_t buffer_size);
ssize_t readAtLeast(uint8_t *buffer, size_t buffer_size, size_t character_count = 1, uint32_t timeout_us = 0);
platforms/posix/include/SerialImpl.hpp
+1
View File
@@ -59,6 +59,7 @@ public:
bool close();
ssize_t bytesAvailable();
ssize_t read(uint8_t *buffer, size_t buffer_size);
ssize_t readAtLeast(uint8_t *buffer, size_t buffer_size, size_t character_count = 1, uint32_t timeout_us = 0);
platforms/posix/src/px4/common/SerialImpl.cpp
+12
View File
@@ -251,6 +251,18 @@ bool SerialImpl::close()
return true;
}
ssize_t SerialImpl::bytesAvailable()
{
if (!_open) {
PX4_ERR("Device not open!");
return -1;
}
ssize_t bytes_available = 0;
int ret = ioctl(_serial_fd, FIONREAD, &bytes_available);
return ret >= 0 ? bytes_available : 0;
}
ssize_t SerialImpl::read(uint8_t *buffer, size_t buffer_size)
{
if (!_open) {
platforms/qurt/include/SerialImpl.hpp
+1
View File
@@ -58,6 +58,7 @@ public:
bool close();
ssize_t bytesAvailable();
ssize_t read(uint8_t *buffer, size_t buffer_size);
ssize_t readAtLeast(uint8_t *buffer, size_t buffer_size, size_t character_count = 1, uint32_t timeout_us = 0);
platforms/qurt/src/px4/SerialImpl.cpp
+7
View File
@@ -158,6 +158,13 @@ bool SerialImpl::close()
return true;
}
ssize_t SerialImpl::bytesAvailable()
{
// TODO:
PX4_WARN("bytesAvailable not implemented!");
return 0;
}
ssize_t SerialImpl::read(uint8_t *buffer, size_t buffer_size)
{
if (!_open) {