1 files changed, 3 insertions, 5 deletions
diff --git a/src/subscriber.c b/src/subscriber.c
index 27c9441..5c3703e 100644
--- a/src/subscriber.c
+++ b/src/subscriber.c
@@ -1,7 +1,5 @@
 #include <zmq.h>
 #include <assert.h>
-#include <time.h>
-#include <string.h>
 #include <signal.h>
 #include "utils.h"
 
@@ -68,15 +66,17 @@ int main (int argc, char *argv [])
         double size_mib=size/(1024*1024);
         printf("Data received: key=%s client=%s interval=%ld msgsize=%.2lfMiB\n",key, client, interval,size_mib);
         char path[STATIC_LEN]="";
-        //sprintf(path,"%s/%s_%s_%ld",cdatadir,key,client,interval);
+        // Create dir if not exists:
         sprintf(path,"%s/%s/%s/",cdatadir,key,client);
         if(!DIR_EXISTS(path)){
           mkdirp(path);
         }
+        // Now open output file:
         sprintf(path,"%s/%s/%s/%ld",cdatadir,key,client,interval);
         fptr=fopen(path,"a");
       }
 
+      // Write all the measurements:
       if(line>4){
         fwrite(token, strlen(token), 1, fptr);
         fwrite("\n",1,1,fptr);
@@ -88,8 +88,6 @@ int main (int argc, char *argv [])
     fclose(fptr);
   }
 
-
-
   zmq_close (subscriber);
   zmq_ctx_destroy (context);