Minor changes

1 files changed, 17 insertions, 2 deletions

diff --git a/src/publisher.c b/src/publisher.c
index 8764294..1416738 100644
--- a/src/publisher.c
+++ b/src/publisher.c
@@ -24,15 +24,30 @@ int main (int argc, char *argv [])
     __logdir=argv[1];
     __loginterval=atoi(argv[2]);
 
+
+    //----- Start publisher
     DIR *dr = opendir(__logdir);
     struct dirent *de;  // Pointer for directory entry
-    for(int i=0;i<0;i++){
+    for(int i=0;i<=0;i++){
         int interval=INTERVAL(__loginterval);
         int interval_next=INTERVAL_NEXT(__loginterval);
         while ((de = readdir(dr)) != NULL){
             if(strcmp(de->d_name,".") && strcmp(de->d_name,"..")){
                 char *client=de->d_name;
-                printf("aa%s\n",client);
+                char logfile[255];
+                char logfile_next[255];
+                sprintf(logfile,"%s/%s/%ld",__logdir,client,interval);
+                sprintf(logfile_next,"%s/%s/%ld",__logdir,client,interval_next);
+                // As long as next logfile is not available, we should wait
+                // for sending the current one
+                printf("Waiting for %s...%s\n",client,logfile_next);
+                while(!FILE_EXISTS(logfile_next)){
+                    sleep(1);
+                }
+                // Send current one
+                if(FILE_EXISTS(logfile)){
+                    printf("Sending....\n");
+                }
             }
         }
     }