Debugging and improvements

2 files changed, 13 insertions, 7 deletions

diff --git a/src/publisher.c b/src/publisher.c
index 03b3a1a..607c4d7 100644
--- a/src/publisher.c
+++ b/src/publisher.c
@@ -4,9 +4,12 @@
 #include <pthread.h>
 #include <signal.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <sys/stat.h>
 #include <unistd.h>
 #include <zmq.h>
+#include <fcntl.h>
+
 
 #ifndef LOG_DELAY
 #define LOG_DELAY 0
@@ -82,9 +85,9 @@ int main(int argc, char *argv[]) {
 
   //----- Init logging variables
   pthread_t zmq_thread;
-  FILE *regptr, *logptr;
+  FILE *logptr;
   char logfilepath[STATIC_LEN] = "";
-  regptr = fopen(regpower, "r");
+  int regfd = open(regpower, O_RDONLY);
   char buffer[STATIC_LEN];
   time_t interval;
   struct timespec power_ts;
@@ -116,14 +119,14 @@ int main(int argc, char *argv[]) {
       if (__stop)
         break;
       // Read power:
-      fgets(buffer, STATIC_LEN, regptr);
+      read(regfd, buffer, STATIC_LEN);
       // Get power measurement timestamp:
       clock_gettime(CLOCK_REALTIME, &power_ts);
       // Write measurement into msg buffer:
       char line[MAX_RECORD_LEN];
       if ((queues[queue_id].size + MAX_RECORD_LEN) > ZMQ_MSG_SIZE) {
         printf(
-            "To many measurements to publish. Please increase ZMQ_MSG_SIZE\n");
+            "Too many measurements to publish. Please increase ZMQ_MSG_SIZE\n");
       } else {
         sprintf(queues[queue_id].msg + queues[queue_id].size, "%ld,%ld,%d\n",
                 power_ts.tv_sec, power_ts.tv_nsec, atoi(buffer));
@@ -131,7 +134,7 @@ int main(int argc, char *argv[]) {
             strlen(queues[queue_id].msg + queues[queue_id].size);
       }
       // Reset power register file:
-      fseek(regptr, 0, SEEK_SET);
+       lseek(regfd,0,SEEK_SET);
 #if LOG_DELAY > 0
       usleep(LOG_DELAY * 1000);
 #endif
@@ -140,7 +143,7 @@ int main(int argc, char *argv[]) {
   }
 
   //----- Cleaning
-  fclose(regptr);
+  close(regfd);
   pthread_join(zmq_thread, NULL);
   zmq_close(zmq_publisher);
   zmq_ctx_destroy(zmq_context);
diff --git a/src/utils.h b/src/utils.h
index 5cf2b3c..3bcc09e 100644
--- a/src/utils.h
+++ b/src/utils.h
@@ -11,9 +11,12 @@
 #define INA260_POWER_REGISTER "registers/power"
 #define STATIC_LEN 255
 #define MAX_RECORD_LEN 100
-#define MAX_QUEUES 1
 #define CSV_HEADER "timestamp,nsecs,power"
 
+#ifndef MAX_QUEUES
+#define MAX_QUEUES 1
+#endif
+
 #ifndef ZMQ_TOKEN
 #define ZMQ_TOKEN "ina260-zmq-publisher"
 #endif