diff options
| -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); |