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:17:07 +01:00
parent 1e8c15ca87
commit 72d6ef9ec6
2 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/publisher.c
View file

@ -37,7 +37,13 @@ void sighandler(int signo) {
void *publisher(void *zmq_publisher); void *publisher(void *zmq_publisher);
void askforbreak(){ void askforbreak(){
FILE * file;
file = fopen(__break_file, "r");
while(file){
usleep(BREAK_DURATION * 1000);
fclose(file);
file = fopen(__break_file, "r");
}
} }
typedef struct queue { typedef struct queue {
@ -70,7 +76,7 @@ int main(int argc, char *argv[]) {
strcat(regpower, INA260_POWER_OUTPUT); strcat(regpower, INA260_POWER_OUTPUT);
// __break_file // __break_file
strcat(__break_file, "/publisher_"); strcat(__break_file, "publisher_");
strcat(__break_file, key); strcat(__break_file, key);
strcat(__break_file, "_break"); strcat(__break_file, "_break");
printf("%s\n",__break_file); printf("%s\n",__break_file);
@ -116,6 +122,8 @@ int main(int argc, char *argv[]) {
//----- Start logging //----- Start logging
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
askforbreak();
// Busy wait: // Busy wait:
while (queues[queue_id].issending) {} while (queues[queue_id].issending) {}
// Get current interval // Get current interval

3
src/utils.h
View file

@ -12,6 +12,7 @@
#define STATIC_LEN 255 #define STATIC_LEN 255
#define MAX_RECORD_LEN 100 #define MAX_RECORD_LEN 100
#define CSV_HEADER "timestamp,nsecs,power" #define CSV_HEADER "timestamp,nsecs,power"
#define BREAK_DURATION 10
#ifndef MAX_QUEUES #ifndef MAX_QUEUES
#define MAX_QUEUES 1 #define MAX_QUEUES 1
@ -38,4 +39,4 @@
#define DIR_EXISTS(path) (dir_exists(path)) #define DIR_EXISTS(path) (dir_exists(path))
void mkdirp(char *path); void mkdirp(char *path);
unsigned char dir_exists(char *path); unsigned char dir_exists(char *path);