loic/ina260-zmq-publisher
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/ina260-zmq-publisher.git synced 2025-04-06 03:46:25 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Minor changes

Browse source
This commit is contained in:
Loïc Guégan 2024-02-02 13:24:18 +01:00
parent 4224cb1d6c
commit aedbeb3bc5
1 changed files with 10 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/publisher.c
View file

@ -19,9 +19,6 @@
unsigned char __stop = 0; unsigned char __stop = 0;
unsigned char __stop_zmq_thread = 0; unsigned char __stop_zmq_thread = 0;
/// @brief Path of the break file (if found, publisher will stop publishing)
char __break_file[STATIC_LEN];
/** /**
* @brief Stop process properly on SIGINT * @brief Stop process properly on SIGINT
* *
@ -36,14 +33,14 @@ void sighandler(int signo) {
void *publisher(void *zmq_publisher); void *publisher(void *zmq_publisher);
void askforbreak(){ void askforbreak(char *break_file){
FILE * file; FILE * file;
file = fopen(__break_file, "r"); file = fopen(break_file, "r");
while(file){ while(file){
printf("I am doing a break for %ds", BREAK_DURATION); printf("I am doing a break for %ds", BREAK_DURATION);
usleep(BREAK_DURATION * 1000); usleep(BREAK_DURATION * 1000);
fclose(file); fclose(file);
file = fopen(__break_file, "r"); file = fopen(break_file, "r");
} }
} }
@ -76,11 +73,12 @@ int main(int argc, char *argv[]) {
strcat(regpower, "/"); strcat(regpower, "/");
strcat(regpower, INA260_POWER_OUTPUT); strcat(regpower, INA260_POWER_OUTPUT);
// __break_file // Path of the break file (if found, publisher will stop publishing)
strcat(__break_file, "publisher_"); char break_file[STATIC_LEN];
strcat(__break_file, key); strcat(break_file, "publisher_");
strcat(__break_file, "_break"); strcat(break_file, key);
printf("%s\n",__break_file); strcat(break_file, "_break");
printf("Create to following file to stop publishing (max wakeup latency will be %ds): %s\n",BREAK_DURATION,break_file);
//----- Sanity checks //----- Sanity checks
signal(SIGINT, sighandler); signal(SIGINT, sighandler);
@ -124,7 +122,7 @@ int main(int argc, char *argv[]) {
printf("Logger started [client=%s,interval=%ds]\n", client, loginterval); printf("Logger started [client=%s,interval=%ds]\n", client, loginterval);
while (!__stop) { while (!__stop) {
// Check whether logging must be stopped // Check whether logging must be stopped
askforbreak(); askforbreak(break_file);
// Busy wait: // Busy wait:
while (queues[queue_id].issending) {} while (queues[queue_id].issending) {}
// Get current interval // Get current interval