portersky
a1ea02771c
Drop timeout_ms; read now returns immediately with whatever data is available (0 if none), so callers don't block the rest of their loop waiting on serial I/O. telemetry's poll loop now sleeps interval_ms itself between empty reads via a small sleep_ms helper.
107 lines
3.1 KiB
C
107 lines
3.1 KiB
C
#include <stdlib.h>
|
|
|
|
#include "unity.h"
|
|
#include "celrs/serial.h"
|
|
#include "Mockserial_internal.h"
|
|
|
|
void setUp(void) { Mockserial_internal_Init(); }
|
|
void tearDown(void) { Mockserial_internal_Verify(); Mockserial_internal_Destroy(); }
|
|
|
|
void test_open_valid_path(void) {
|
|
cel_serial_port* port = cel_serial_open("COM3", 400000);
|
|
TEST_ASSERT_NOT_NULL(port);
|
|
cel_serial_close(port);
|
|
}
|
|
|
|
void test_open_null_path(void) {
|
|
TEST_ASSERT_NULL(cel_serial_open(NULL, 400000));
|
|
}
|
|
|
|
void test_open_preserves_path(void) {
|
|
cel_serial_port* port = cel_serial_open("/dev/ttyUSB0", 400000);
|
|
TEST_ASSERT_NOT_NULL(port);
|
|
/* path is stored internally; verify by roundtrip behavior */
|
|
cel_serial_close(port);
|
|
}
|
|
|
|
void test_close_null(void) {
|
|
/* Should not crash */
|
|
cel_serial_close(NULL);
|
|
}
|
|
|
|
void test_read_returns_zero_stub(void) {
|
|
cel_serial_port* port = cel_serial_open("COM3", 400000);
|
|
TEST_ASSERT_NOT_NULL(port);
|
|
uint8_t buf[16];
|
|
/* Stub implementation returns 0 */
|
|
size_t n = cel_serial_read(port, buf, sizeof(buf));
|
|
TEST_ASSERT_EQUAL_UINT(0, n);
|
|
cel_serial_close(port);
|
|
}
|
|
|
|
void test_write_returns_zero_stub(void) {
|
|
cel_serial_port* port = cel_serial_open("COM3", 400000);
|
|
TEST_ASSERT_NOT_NULL(port);
|
|
uint8_t buf[4] = {0xC8, 0x10, 0x80, 0x03};
|
|
/* Stub implementation returns 0 */
|
|
size_t n = cel_serial_write(port, buf, sizeof(buf));
|
|
TEST_ASSERT_EQUAL_UINT(0, n);
|
|
cel_serial_close(port);
|
|
}
|
|
|
|
void test_flush_no_crash(void) {
|
|
cel_serial_port* port = cel_serial_open("COM3", 400000);
|
|
TEST_ASSERT_NOT_NULL(port);
|
|
cel_serial_flush(port); /* should not crash */
|
|
cel_serial_close(port);
|
|
}
|
|
|
|
void test_flush_null(void) {
|
|
cel_serial_flush(NULL); /* should not crash */
|
|
}
|
|
|
|
void test_list_ports_null_out(void) {
|
|
TEST_ASSERT_EQUAL_INT(-1, cel_serial_list_ports(NULL, 16));
|
|
}
|
|
|
|
void test_list_ports_passes_max_ports_through(void) {
|
|
char** ports = NULL;
|
|
cel_serial_platform_list_ports_ExpectAndReturn(&ports, 16, 2);
|
|
int count = cel_serial_list_ports(&ports, 16);
|
|
TEST_ASSERT_EQUAL_INT(2, count);
|
|
}
|
|
|
|
void test_list_ports_zero_max_uses_default(void) {
|
|
char** ports = NULL;
|
|
cel_serial_platform_list_ports_ExpectAndReturn(&ports, 64, 0);
|
|
int count = cel_serial_list_ports(&ports, 0);
|
|
TEST_ASSERT_EQUAL_INT(0, count);
|
|
}
|
|
|
|
void test_free_ports_null(void) {
|
|
cel_serial_free_ports(NULL, 0); /* should not crash */
|
|
}
|
|
|
|
void test_free_ports_zero_count(void) {
|
|
char** empty = (char**)calloc(1, sizeof(char*));
|
|
cel_serial_free_ports(empty, 0); /* should not crash */
|
|
}
|
|
|
|
int main(void) {
|
|
UNITY_BEGIN();
|
|
RUN_TEST(test_open_valid_path);
|
|
RUN_TEST(test_open_null_path);
|
|
RUN_TEST(test_open_preserves_path);
|
|
RUN_TEST(test_close_null);
|
|
RUN_TEST(test_read_returns_zero_stub);
|
|
RUN_TEST(test_write_returns_zero_stub);
|
|
RUN_TEST(test_flush_no_crash);
|
|
RUN_TEST(test_flush_null);
|
|
RUN_TEST(test_list_ports_null_out);
|
|
RUN_TEST(test_list_ports_passes_max_ports_through);
|
|
RUN_TEST(test_list_ports_zero_max_uses_default);
|
|
RUN_TEST(test_free_ports_null);
|
|
RUN_TEST(test_free_ports_zero_count);
|
|
return UNITY_END();
|
|
}
|