summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorLoic Guegan <manzerbredes@mailbox.org>2023-07-17 15:14:37 +0200
committerLoic Guegan <manzerbredes@mailbox.org>2023-07-17 15:14:37 +0200
commit0c08c2f0d879b0153ee6d8a0861882c3a91347bb (patch)
treec55ab95274c6eb3926e5fd3206c0ac58d229c65e /src
parent5f0585f4d431247fb93e6920b0388cb6d236c50d (diff)
Minor changes
Diffstat (limited to 'src')
-rw-r--r--src/logger.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/logger.c b/src/logger.c
index 73c85ca..cf379c6 100644
--- a/src/logger.c
+++ b/src/logger.c
@@ -1,3 +1,4 @@
+#include <stdio.h>
#include <zmq.h>
#include <assert.h>
#include <libgen.h>
@@ -39,7 +40,7 @@ typedef struct record {
typedef struct queue {
int length;
- int interval;
+ long interval;
record records[RECORD_MAX];
} queue;
@@ -149,13 +150,14 @@ void publish(int queue_id){
// Build message header:
char buffer[ZMQ_MSG_SIZE];
sprintf(buffer,"%s\n%s\n%s\n%ld\n",ZMQ_TOKEN,__key,__client,queues[queue_id].interval);
+ printf(buffer);
int msglen=strlen(buffer);
// Put every lines in the buffer and send it
char line[STATIC_LEN];
for(int record=0;record<queues[queue_id].length;record++){
*line='\0';
- sprintf(line,"%d,%ld,%d",queues[queue_id].records[record].secs,queues[queue_id].records[record].nsecs,queues[queue_id].records[record].power);
+ sprintf(line,"%ld,%ld,%d",queues[queue_id].records[record].secs,queues[queue_id].records[record].nsecs,queues[queue_id].records[record].power);
int linelength=strlen(line);
if((linelength+msglen) <ZMQ_MSG_SIZE){
strcat(buffer,line);