diff options
Diffstat (limited to 'src/logger.c')
| -rw-r--r-- | src/logger.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/logger.c b/src/logger.c index 4258090..d09220e 100644 --- a/src/logger.c +++ b/src/logger.c @@ -114,14 +114,14 @@ int main (int argc, char *argv []) fgets(buffer,STATIC_LEN,regptr); // Get power measurement timestamp: clock_gettime(CLOCK_REALTIME,&power_ts); - char line[STATIC_LEN]; + char line[MAX_RECORD_LEN]; sprintf(line,"%ld,%ld,%d\n",power_ts.tv_sec,power_ts.tv_nsec,atoi(buffer)); int linelen=strlen(line); - if((queues[queue_id].size+linelen)>ZMQ_MSG_SIZE){ + if((queues[queue_id].size+MAX_RECORD_LEN)>ZMQ_MSG_SIZE){ printf("To many measurements to publish. Please increase ZMQ_MSG_SIZE\n"); } else { - memcpy(queues[queue_id].msg+queues[queue_id].size,line,linelen); - queues[queue_id].size+=linelen; + sprintf(queues[queue_id].msg+queues[queue_id].size,"%ld,%ld,%d\n",power_ts.tv_sec,power_ts.tv_nsec,atoi(buffer)); + queues[queue_id].size+=strlen(queues[queue_id].msg+queues[queue_id].size); } // Reset power register file: fseek(regptr,0,SEEK_SET); |
