diff options
| author | Loic Guegan <manzerbredes@mailbox.org> | 2023-07-17 15:14:37 +0200 |
|---|---|---|
| committer | Loic Guegan <manzerbredes@mailbox.org> | 2023-07-17 15:14:37 +0200 |
| commit | 0c08c2f0d879b0153ee6d8a0861882c3a91347bb (patch) | |
| tree | c55ab95274c6eb3926e5fd3206c0ac58d229c65e /src | |
| parent | 5f0585f4d431247fb93e6920b0388cb6d236c50d (diff) | |
Minor changes
Diffstat (limited to 'src')
| -rw-r--r-- | src/logger.c | 6 |
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); |
