Fix some sync issue

martin-steinegger · martin-steinegger · commit 20d3afc742a9 · 2023-04-29T23:15:37.000+09:00
diff --git a/src/prefiltering/ungappedprefilter.cpp b/src/prefiltering/ungappedprefilter.cpp
@@ -81,6 +81,10 @@ int ungappedprefilter(int argc, const char **argv, const Command &command) {
     std::vector<hit_t> shortResults;
     shortResults.reserve(tdbr->getSize()/2);
 
+#ifdef OPENMP
+    omp_set_nested(1);
+#endif
+
 #pragma omp parallel
     {
         unsigned int thread_idx = 0;
@@ -162,6 +166,7 @@ int ungappedprefilter(int argc, const char **argv, const Command &command) {
                 shortResults.clear();
                 progress.updateProgress();
             }
+#pragma omp barrier
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -81,6 +81,10 @@ int ungappedprefilter(int argc, const char **argv, const Command &command) {`
`81`	`81`	`std::vector<hit_t> shortResults;`
`82`	`82`	`shortResults.reserve(tdbr->getSize()/2);`
`83`	`83`
	`84`	`+#ifdef OPENMP`
	`85`	`+ omp_set_nested(1);`
	`86`	`+#endif`
	`87`	`+`
`84`	`88`	`#pragma omp parallel`
`85`	`89`	`{`
`86`	`90`	`unsigned int thread_idx = 0;`
`@@ -162,6 +166,7 @@ int ungappedprefilter(int argc, const char **argv, const Command &command) {`
`162`	`166`	`shortResults.clear();`
`163`	`167`	`progress.updateProgress();`
`164`	`168`	`}`
	`169`	`+#pragma omp barrier`
`165`	`170`	`}`
`166`	`171`	`}`
`167`	`172`