0022735: Data races in BRepMesh working in parallel mode

diff --git a/src/BRepMesh/BRepMesh_IncrementalMesh.cxx b/src/BRepMesh/BRepMesh_IncrementalMesh.cxx
index 74cb77ca3127e60693bf67fa3fca14d7ce063530..f28765b21470eda84d0512a426ad38c62381e076 100755 (executable)
--- a/src/BRepMesh/BRepMesh_IncrementalMesh.cxx
+++ b/src/BRepMesh/BRepMesh_IncrementalMesh.cxx
@@ -213,22 +213,31 @@ void BRepMesh_IncrementalMesh::Update(const TopoDS_Shape& S)
   }
 
   // get list of faces
-  TopTools_ListOfShape LF;
-  BRepLib::ReverseSortFaces(S,LF);
-
-  // make array of faces suitable for processing (excluding faces without surface)
   std::vector<TopoDS_Face> aFaces;
-  for (TopTools_ListIteratorOfListOfShape it(LF); it.More(); it.Next()) 
   {
-    TopoDS_Face F = TopoDS::Face(it.Value());
-
-    TopLoc_Location L1;
-    const Handle(Geom_Surface)& Surf = BRep_Tool::Surface(F, L1);
-    if(Surf.IsNull())
-      continue;
-    
-    Update (F);
-    aFaces.push_back (F);
+    TopTools_ListOfShape aFaceList;
+    BRepLib::ReverseSortFaces (S, aFaceList);
+    TopTools_MapOfShape aFaceMap;
+    aFaces.reserve (aFaceList.Extent());
+
+    // make array of faces suitable for processing (excluding faces without surface)
+    TopLoc_Location aDummyLoc;
+    const TopLoc_Location anEmptyLoc;
+    for (TopTools_ListIteratorOfListOfShape aFaceIter (aFaceList); aFaceIter.More(); aFaceIter.Next())
+    {
+      TopoDS_Shape aFaceNoLoc = aFaceIter.Value();
+      aFaceNoLoc.Location (anEmptyLoc);
+      if (!aFaceMap.Add (aFaceNoLoc))
+        continue; // already processed
+
+      TopoDS_Face aFace = TopoDS::Face (aFaceIter.Value());
+      const Handle(Geom_Surface)& aSurf = BRep_Tool::Surface (aFace, aDummyLoc);
+      if (aSurf.IsNull())
+        continue;
+
+      Update (aFace);
+      aFaces.push_back (aFace);
+    }
   }
 
   if (myInParallel)

diff --git a/src/IFSelect/IFSelect_WorkSession.cxx b/src/IFSelect/IFSelect_WorkSession.cxx
index c0a7d21470d09a8268e9f3218638e12a89891ff3..06f5beaeb5552c0315c2910c50430d4b5cd2581d 100755 (executable)
--- a/src/IFSelect/IFSelect_WorkSession.cxx
+++ b/src/IFSelect/IFSelect_WorkSession.cxx
@@ -2488,7 +2488,11 @@ IFSelect_ReturnStatus IFSelect_WorkSession::SendAll
     }
   }
   else checks = thecopier->SendAll(filename,thegraph->Graph(),thelibrary,theprotocol);
-
+  Handle_Interface_Check aMainFail = checks.CCheck(0);
+  if (!aMainFail.IsNull() && aMainFail->HasFailed ())
+  {
+        return IFSelect_RetStop;
+  }
   if (theloaded.Length() == 0) theloaded.AssignCat(filename);
   thecheckrun = checks;
   if (checks.IsEmpty(Standard_True)) return IFSelect_RetDone;

diff --git a/src/MeshTest/MeshTest_PluginCommands.cxx b/src/MeshTest/MeshTest_PluginCommands.cxx
index a60454c0c09cadddb90910e19656b32a34feea1b..0bd9cf4634d920c95956ea4082207072e52afea0 100755 (executable)
--- a/src/MeshTest/MeshTest_PluginCommands.cxx
+++ b/src/MeshTest/MeshTest_PluginCommands.cxx
@@ -28,6 +28,7 @@
 #include <TColgp_Array1OfPnt2d.hxx>
 #include <Poly_Polygon3D.hxx>
 #include <Poly_Polygon2D.hxx>
+#include <Standard.hxx>
 
 static Standard_Integer mpnames           (Draw_Interpretor& , Standard_Integer , const char** );
 static Standard_Integer mpsetdefaultname  (Draw_Interpretor& , Standard_Integer , const char** );
@@ -422,6 +423,8 @@ static int mpparallel (Draw_Interpretor& di, Standard_Integer argc, const char**
   {
     Standard_Boolean isParallelOn = atoi (argv[1]) == 1;
     BRepMesh_IncrementalMesh::SetParallelDefault (isParallelOn);
+    if (isParallelOn)
+      Standard::SetReentrant(Standard_True);
   }
   std::cout << "Incremental Mesh, multi-threading "
             << (BRepMesh_IncrementalMesh::IsParallelDefault() ? "ON\n" : "OFF\n");