summaryrefslogtreecommitdiff
path: root/src/logger.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/logger.c')
-rw-r--r--src/logger.c8
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);