loic/ina260-zmq-publisher
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/ina260-zmq-publisher.git synced 2025-04-05 11:26: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:39:57 +01:00
parent cab15f605e
commit 9ba1763b4f
3 changed files with 15 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/publisher.c
View file

@ -33,17 +33,6 @@ void sighandler(int signo) {
void *publisher(void *zmq_publisher);
void askforbreak(char *break_file){
FILE * file;
file = fopen(break_file, "r");
while(file){
printf("I am doing a break for %ds\n", BREAK_DURATION);
sleep(BREAK_DURATION);
fclose(file);
file = fopen(break_file, "r");
}
}
typedef struct queue {
int size;
char issending;

15
src/utils.c
View file

@ -1,4 +1,6 @@
#include "utils.h"
#include <stdio.h>
#include <unistd.h>
void mkdirp(char *path){
char buffer[255]="mkdir -p ";
@ -14,4 +16,15 @@ unsigned char dir_exists(char *path){
return 1;
}
return 0;
}
}
void askforbreak(char *break_file){
FILE * file;
file = fopen(break_file, "r");
while(file){
printf("I am doing a break for %ds\n", BREAK_DURATION);
sleep(BREAK_DURATION);
fclose(file);
file = fopen(break_file, "r");
}
}

1
src/utils.h
View file

@ -40,3 +40,4 @@
void mkdirp(char *path);
unsigned char dir_exists(char *path);
void askforbreak(char *break_file);