Added extra diagnostic in System.cpp

dds-bridge · Aug 20, 2018 · 1708bec · 1708bec
1 parent a4ca6fb
commit 1708bec
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/System.cpp b/src/System.cpp
@@ -570,7 +570,7 @@ int System::RunThreadsPPLIMPL()
   (* CallbackDuplList[runCat])(* bop, uniques, crossrefs);
 
   static atomic<int> thrIdNext = 0;
-  bool err = false;
+  bool err = false, err2 = false;
 
   threadMgr.Reset(numThreads);
 
@@ -590,14 +590,19 @@ int System::RunThreadsPPLIMPL()
       (* CallbackSingleList[runCat])(realThrId, bno);
 
     if (! threadMgr.Release(thrId))
-      err = true;
+      err2 = true;
   });
 
   if (err)
   {
     cout << "Too many threads, numThreads " << numThreads << endl;
     return RETURN_THREAD_INDEX;
   }
+  else if (err2)
+  {
+    cout << "Release failed, numThreads " << numThreads << endl;
+    return RETURN_THREAD_INDEX;
+  }
 
   (* CallbackCopyList[runCat])(crossrefs);
 #endif