fix status updates when multithreading is on

nil0x42 · Sep 4, 2020 · 0efd5a9 · 0efd5a9
1 parent df16fbb
commit 0efd5a9
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/chunk.c b/src/chunk.c
@@ -8,6 +8,7 @@
 #include "hash.h"
 #include "const.h"
 #include "config.h"
+#include "status.h"
 
 
 int         count_chunks(void)
@@ -87,4 +88,5 @@ void        cleanout_chunk(t_chunk *chunk)
         }
     }
     free(chunk);
+    update_status(CTASK_DONE);
 }
diff --git a/src/tag_duplicates.c b/src/tag_duplicates.c
@@ -33,6 +33,7 @@ static void     tag_subchunks(threadpool thpool, const t_chunk *parent)
             exit(1);
         chunk_id ++;
     }
+    update_status(CHUNK_DONE);
 }
 
 /** For each chunk, load it into hmap and remove all duplicates
@@ -53,6 +54,7 @@ void            tag_duplicates(void)
     while (get_next_chunk(&main_chunk, g_file))
     {
         populate_hmap(&main_chunk);
+        update_status(CTASK_DONE);
         tag_subchunks(thpool, &main_chunk);
         thpool_wait(thpool);
     }
@@ -79,8 +81,8 @@ static void     tag_subchunks(const t_chunk *parent)
         memcpy(heap_chunk, &chunk, sizeof(t_chunk));
 
         cleanout_chunk(heap_chunk);
-        update_status(CTASK_DONE);
     }
+    update_status(CHUNK_DONE);
 }
 
 /** For each chunk, load it into hmap and remove all duplicates
@@ -99,7 +101,6 @@ void            tag_duplicates(void)
         update_status(CTASK_DONE);
 
         tag_subchunks(&main_chunk);
-        update_status(CHUNK_DONE);
     }
 }