radio95/rds95
0
1
Fork 0
mirror of https://github.com/radio95-rnt/rds95.git synced 2026-02-27 04:43:52 +01:00
Code Issues Wiki Activity

bitstream mode

Browse Source
This commit is contained in:
KubaPro010
2025-12-28 19:59:55 +01:00
parent 1b64cdf091
commit 1d329fe308
1 changed files with 65 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

100
src/rds95.c
View File

@@ -41,6 +41,7 @@ static inline void show_help(char *name) {
"Usage: %s [options]\n" "Usage: %s [options]\n"
"\n" "\n"
"\t-c,--config\tSet the config path [default: %s]\n" "\t-c,--config\tSet the config path [default: %s]\n"
"\t-b,--bitstream\tEnable bitstream mode where the RDS modulator will be disabled and encoded RDS bits with checkwords will be sent from stderr\n"
"\n", "\n",
name, name,
DEFAULT_CONFIG_PATH DEFAULT_CONFIG_PATH
@@ -51,7 +52,8 @@ typedef struct
{ {
uint16_t udp_port; uint16_t udp_port;
char rds_device_name[48]; char rds_device_name[48];
uint8_t num_streams; uint8_t num_streams : 3;
uint8_t bitstream : 1;
} RDS95_Config; } RDS95_Config;
static int config_handler(void* user, const char* section, const char* name, const char* value) { static int config_handler(void* user, const char* section, const char* name, const char* value) {
@@ -67,6 +69,10 @@ static int config_handler(void* user, const char* section, const char* name, con
int streams = atoi(value); int streams = atoi(value);
if (streams > MAX_STREAMS || streams == 0) return 0; if (streams > MAX_STREAMS || streams == 0) return 0;
config->num_streams = (uint8_t)streams; config->num_streams = (uint8_t)streams;
} else if (MATCH("rds95", "bitstream")) {
int bitstream = atoi(value);
if (bitstream > 1 || bitstream < 0) return 0;
config->bitstream = (uint8_t)bitstream;
} else return 0; } else return 0;
return 1; return 1;
} }
@@ -78,7 +84,8 @@ int main(int argc, char **argv) {
RDS95_Config config = { RDS95_Config config = {
.udp_port = 0, .udp_port = 0,
.rds_device_name = "\0", .rds_device_name = "\0",
.num_streams = DEFAULT_STREAMS .num_streams = DEFAULT_STREAMS,
.bitstream = false
}; };
pa_simple *rds_device = NULL; pa_simple *rds_device = NULL;
@@ -88,11 +95,12 @@ int main(int argc, char **argv) {
pthread_attr_t attr; pthread_attr_t attr;
pthread_t udp_server_thread; pthread_t udp_server_thread;
const char *short_opt = "c:h"; const char *short_opt = "c:bh";
struct option long_opt[] = struct option long_opt[] =
{ {
{"config", required_argument, NULL, 'c'}, {"config", required_argument, NULL, 'c'},
{"bitstream", no_argument, NULL, 'b'},
{"help", no_argument, NULL, 'h'}, {"help", no_argument, NULL, 'h'},
{ 0, 0, 0, 0 } { 0, 0, 0, 0 }
}; };
@@ -102,7 +110,10 @@ int main(int argc, char **argv) {
switch (opt) { switch (opt) {
case 'c': case 'c':
memcpy(config_path, optarg, 62); memcpy(config_path, optarg, 62);
config_path[63] = '\0'; config_path[48] = '\0';
break;
case 'b':
config.bitstream = 1;
break; break;
case 'h': case 'h':
show_help(argv[0]); show_help(argv[0]);
@@ -144,30 +155,31 @@ int main(int argc, char **argv) {
buffer.prebuf = 0; buffer.prebuf = 0;
buffer.tlength = buffer.maxlength = NUM_MPX_FRAMES * config.num_streams; buffer.tlength = buffer.maxlength = NUM_MPX_FRAMES * config.num_streams;
rds_device = pa_simple_new( if(config.bitstream == 0) {
NULL, rds_device = pa_simple_new(
"rds95", NULL,
PA_STREAM_PLAYBACK, "rds95",
config.rds_device_name, PA_STREAM_PLAYBACK,
"RDS Generator", config.rds_device_name,
&format, "RDS Generator",
NULL, &format,
&buffer, NULL,
NULL &buffer,
); NULL
if (rds_device == NULL) { );
fprintf(stderr, "Error: cannot open sound device.\n"); if (rds_device == NULL) {
goto exit; fprintf(stderr, "Error: cannot open sound device.\n");
goto exit;
}
} }
RDSModulator rdsModulator; RDSModulator rdsModulator = {0};
init_lua(&rdsModulator); init_lua(&rdsModulator);
RDSEncoder rdsEncoder; RDSEncoder rdsEncoder = {0};
init_rds_modulator(&rdsModulator, &rdsEncoder, config.num_streams); init_rds_modulator(&rdsModulator, &rdsEncoder, config.num_streams);
init_rds_encoder(&rdsEncoder); init_rds_encoder(&rdsEncoder);
if(config.udp_port == 0) config.udp_port = 5000;
if(open_udp_server(config.udp_port, &rdsModulator) == 0) { if(open_udp_server(config.udp_port, &rdsModulator) == 0) {
fprintf(stderr, "Reading control commands on UDP:%d.\n", config.udp_port); fprintf(stderr, "Reading control commands on UDP:%d.\n", config.udp_port);
int r = pthread_create(&udp_server_thread, &attr, udp_server_worker, NULL); int r = pthread_create(&udp_server_thread, &attr, udp_server_worker, NULL);
@@ -181,25 +193,43 @@ int main(int argc, char **argv) {
config.udp_port = 0; config.udp_port = 0;
} }
int pulse_error; if(config.bitstream == 0) {
int pulse_error;
float *rds_buffer = (float*)malloc(NUM_MPX_FRAMES * config.num_streams * sizeof(float)); float *rds_buffer = (float*)malloc(NUM_MPX_FRAMES * config.num_streams * sizeof(float));
if (rds_buffer == NULL) { if (rds_buffer == NULL) {
fprintf(stderr, "Error: Could not allocate memory for RDS buffer\n"); fprintf(stderr, "Error: Could not allocate memory for RDS buffer\n");
goto exit; goto exit;
} }
while(!stop_rds) { while(!stop_rds) {
for (uint16_t i = 0; i < NUM_MPX_FRAMES * config.num_streams; i++) rds_buffer[i] = get_rds_sample(&rdsModulator, i % config.num_streams); for (uint16_t i = 0; i < NUM_MPX_FRAMES * config.num_streams; i++) rds_buffer[i] = get_rds_sample(&rdsModulator, i % config.num_streams);
if (pa_simple_write(rds_device, rds_buffer, NUM_MPX_FRAMES * config.num_streams * sizeof(float), &pulse_error) != 0) { if (pa_simple_write(rds_device, rds_buffer, NUM_MPX_FRAMES * config.num_streams * sizeof(float), &pulse_error) != 0) {
fprintf(stderr, "Error: could not play audio. (%s : %d)\n", pa_strerror(pulse_error), pulse_error); fprintf(stderr, "Error: could not play audio. (%s : %d)\n", pa_strerror(pulse_error), pulse_error);
break; break;
}
}
free(rds_buffer);
} else {
uint8_t bit_buffer[BITS_PER_GROUP] = {0};
#ifdef _WIN32
_setmode(_fileno(stderr), _O_BINARY);
#endif
setvbuf(stderr, NULL, _IONBF, 0);
while(!stop_rds) {
unsigned char end = 0xff;
for(uint8_t i = 0; i < config.num_streams; i++) {
get_rds_bits(&rdsEncoder, bit_buffer, i);
fwrite(&i, 1, 1, stderr);
fwrite(bit_buffer, 1, BITS_PER_GROUP, stderr);
fwrite(&end, 1, 1, stderr);
fflush(stderr);
}
} }
} }
free(rds_buffer);
exit: exit:
if(config.udp_port) { if(config.udp_port) {
fprintf(stderr, "Waiting for UDP thread to shut down.\n"); fprintf(stderr, "Waiting for UDP thread to shut down.\n");
@@ -212,7 +242,7 @@ exit:
cleanup_rds_modulator(&rdsModulator); cleanup_rds_modulator(&rdsModulator);
pthread_attr_destroy(&attr); pthread_attr_destroy(&attr);
if (rds_device != NULL) pa_simple_free(rds_device); if (rds_device != NULL && config.bitstream == 0) pa_simple_free(rds_device);
return 0; return 0;
} }