sovereign-rf/OpenRTX
1
0
Fork 0
mirror of https://github.com/OpenRTX/OpenRTX synced 2026-08-08 12:29:06 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

test: format all unit tests

Browse source 
Signed-off-by: Ryan Turner <ryan@turnrye.com
This commit is contained in:
Ryan Turner 2026-02-24 19:33:36 -06:00 • committed by silseva
parent 778e5b6d4b
commit b0493aedae
12 changed files with 237 additions and 241 deletions
Download patch file Download diff file Expand all files Collapse all files

91
tests/unit/linux_inputStream_test.cpp
View file

@ -14,13 +14,11 @@
#include "core/audio_stream.h"
static const char* files[] = {"MIC.raw", "RTX.raw", "MCU.raw"};
static const char *files[] = { "MIC.raw", "RTX.raw", "MCU.raw" };
#define CHECK(x) \
do \
{ \
if (!(x)) \
{ \
do { \
if (!(x)) { \
puts("Failed assertion: " #x "\n"); \
abort(); \
} \
@ -28,13 +26,11 @@ static const char* files[] = {"MIC.raw", "RTX.raw", "MCU.raw"};
void test_linear()
{
for (int fn = 0; fn < 3; fn++)
{
for (int fn = 0; fn < 3; fn++) {
// Write a mock audio file
FILE* fp = fopen(files[fn], "wb");
FILE *fp = fopen(files[fn], "wb");
CHECK(fp);
for (int i = 0; i < 13; i++)
{
for (int i = 0; i < 13; i++) {
CHECK(fputc(i, fp) == i);
CHECK(fputc(0, fp) == 0);
}
@ -42,26 +38,30 @@ void test_linear()
// Start inputStream using that file as source
stream_sample_t tmp[128];
auto id = inputStream_start(
static_cast<AudioSource>(fn), AudioPriority::PRIO_PROMPT, tmp,
sizeof(tmp) / sizeof(tmp[0]), BufMode::BUF_LINEAR, 44100);
auto id = inputStream_start(static_cast<AudioSource>(fn),
AudioPriority::PRIO_PROMPT, tmp,
sizeof(tmp) / sizeof(tmp[0]),
BufMode::BUF_LINEAR, 44100);
CHECK(id != -1);
// Should fail
auto id_2 = inputStream_start(
static_cast<AudioSource>(fn), AudioPriority::PRIO_BEEP, tmp,
sizeof(tmp) / sizeof(tmp[0]), BufMode::BUF_LINEAR, 44100);
auto id_2 = inputStream_start(static_cast<AudioSource>(fn),
AudioPriority::PRIO_BEEP, tmp,
sizeof(tmp) / sizeof(tmp[0]),
BufMode::BUF_LINEAR, 44100);
CHECK(id_2 == -1);
auto id_3 = inputStream_start(
static_cast<AudioSource>(fn), AudioPriority::PRIO_RX, tmp,
sizeof(tmp) / sizeof(tmp[0]), BufMode::BUF_LINEAR, 44100);
auto id_3 = inputStream_start(static_cast<AudioSource>(fn),
AudioPriority::PRIO_RX, tmp,
sizeof(tmp) / sizeof(tmp[0]),
BufMode::BUF_LINEAR, 44100);
CHECK(id_3 == -1);
// This should work, as it has higher priority
auto id_4 = inputStream_start(
static_cast<AudioSource>(fn), AudioPriority::PRIO_TX, tmp,
sizeof(tmp) / sizeof(tmp[0]), BufMode::BUF_LINEAR, 44100);
auto id_4 = inputStream_start(static_cast<AudioSource>(fn),
AudioPriority::PRIO_TX, tmp,
sizeof(tmp) / sizeof(tmp[0]),
BufMode::BUF_LINEAR, 44100);
CHECK(id_4 != -1);
{
@ -76,12 +76,11 @@ void test_linear()
int c_ptr = 0;
// getData multiple times
for (int i = 0; i < 20; i++)
{
for (int i = 0; i < 20; i++) {
using namespace std::chrono;
auto t1 = steady_clock::now();
auto db = inputStream_getData(id);
auto t2 = steady_clock::now();
auto t1 = steady_clock::now();
auto db = inputStream_getData(id);
auto t2 = steady_clock::now();
const uint64_t delta = duration_cast<microseconds>(t2 - t1).count();
const uint64_t expected = (128 * 1000000 / 44100);
@ -90,8 +89,7 @@ void test_linear()
// Check the contents
CHECK(db.len == 128);
for (int i = 0; i < 128; i++)
{
for (int i = 0; i < 128; i++) {
CHECK(tmp[i] == (c_ptr % 13));
CHECK(db.data[i] == (c_ptr % 13));
c_ptr++;
@ -104,28 +102,26 @@ void test_linear()
}
}
void test_ring_buffer(uint64_t n_bytes,
uint64_t n_iter,
void test_ring_buffer(uint64_t n_bytes, uint64_t n_iter,
const uint64_t buf_size)
{
for (int fn = 0; fn < 3; fn++)
{
FILE* fp = fopen(files[fn], "wb");
for (int fn = 0; fn < 3; fn++) {
FILE *fp = fopen(files[fn], "wb");
CHECK(fp);
for (uint64_t i = 0; i < n_bytes; i++)
{
uint16_t j = i;
uint8_t* buf = (uint8_t*)&j;
for (uint64_t i = 0; i < n_bytes; i++) {
uint16_t j = i;
uint8_t *buf = (uint8_t *)&j;
CHECK(fputc(buf[0], fp) == buf[0]);
CHECK(fputc(buf[1], fp) == buf[1]);
}
fclose(fp);
std::vector<stream_sample_t> tmp(buf_size);
auto id = inputStream_start(
static_cast<AudioSource>(fn), AudioPriority::PRIO_BEEP, tmp.data(),
tmp.size(), BufMode::BUF_CIRC_DOUBLE, 44100);
auto id = inputStream_start(static_cast<AudioSource>(fn),
AudioPriority::PRIO_BEEP, tmp.data(),
tmp.size(), BufMode::BUF_CIRC_DOUBLE,
44100);
CHECK(id != -1);
using namespace std::chrono;
@ -133,16 +129,14 @@ void test_ring_buffer(uint64_t n_bytes,
uint64_t ctr = 0;
std::vector<stream_sample_t> tmp2(buf_size / 2);
for (uint64_t i = 0; i < n_iter; i++)
{
for (uint64_t i = 0; i < n_iter; i++) {
{
auto db = inputStream_getData(id);
CHECK(db.len > 0);
CHECK(db.data == &tmp[0]);
memcpy(tmp2.data(), db.data, db.len * sizeof(stream_sample_t));
for (uint64_t i = 0; i < db.len; i++)
{
for (uint64_t i = 0; i < db.len; i++) {
CHECK(uint16_t(tmp2[i]) == uint16_t(ctr % n_bytes));
ctr++;
}
@ -154,16 +148,15 @@ void test_ring_buffer(uint64_t n_bytes,
CHECK(db.len > 0);
CHECK(db.data == &tmp[buf_size / 2]);
memcpy(tmp2.data(), db.data, db.len * sizeof(stream_sample_t));
for (uint64_t i = 0; i < db.len; i++)
{
for (uint64_t i = 0; i < db.len; i++) {
CHECK(uint16_t(tmp2[i]) == uint16_t(ctr % n_bytes));
ctr++;
}
}
}
auto t2 = steady_clock::now();
const uint64_t delta = duration_cast<microseconds>(t2 - t0).count();
auto t2 = steady_clock::now();
const uint64_t delta = duration_cast<microseconds>(t2 - t0).count();
const uint64_t expected = (buf_size * n_iter * 1000000lu / 44100);
CHECK(delta > expected && delta < expected * 2);