src/SMESH/SMESH_ParallelMesh.cxx

   1 // Copyright (C) 2007-2022  CEA/DEN, EDF R&D, OPEN CASCADE
   2 //
   3 // Copyright (C) 2003-2007  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
   4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
   5 //
   6 // This library is free software; you can redistribute it and/or
   7 // modify it under the terms of the GNU Lesser General Public
   8 // License as published by the Free Software Foundation; either
   9 // version 2.1 of the License, or (at your option) any later version.
  10 //
  11 // This library is distributed in the hope that it will be useful,
  12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14 // Lesser General Public License for more details.
  15 //
  16 // You should have received a copy of the GNU Lesser General Public
  17 // License along with this library; if not, write to the Free Software
  18 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
  19 //
  20 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
  21 //
  22
  23 //  File   : SMESH_ParallelMesh.cxx
  24 //  Author : Yoann AUDOUIN, EDF
  25 //  Module : SMESH
  26 //
  27 #include "SMESH_ParallelMesh.hxx"
  28
  29 #include "SMESH_Gen.hxx"
  30
  31 #ifdef WIN32
  32   #include <windows.h>
  33 #endif
  34
  35 #ifndef WIN32
  36 #include <boost/filesystem.hpp>
  37 namespace fs=boost::filesystem;
  38 #endif
  39
  40 #ifndef WIN32
  41 #include <boost/asio.hpp>
  42 #endif
  43
  44 #include <utilities.h>
  45
  46 #ifdef _DEBUG_
  47 static int MYDEBUG = 1;
  48 #else
  49 static int MYDEBUG = 0;
  50 #endif
  51
  52 SMESH_ParallelMesh::SMESH_ParallelMesh(int               theLocalId,
  53                        SMESH_Gen*        theGen,
  54                        bool              theIsEmbeddedMode,
  55                        SMESHDS_Document* theDocument) :SMESH_Mesh(theLocalId,
  56                                                                   theGen,
  57                                                                   theIsEmbeddedMode,
  58                                                                   theDocument)
  59 {
  60   MESSAGE("SMESH_ParallelMesh::SMESH_ParallelMesh(int localId)");
  61   _NbThreads = std::thread::hardware_concurrency();
  62   CreateTmpFolder();
  63 };
  64
  65 SMESH_ParallelMesh::~SMESH_ParallelMesh()
  66 {
  67   DeletePoolThreads();
  68   if(!MYDEBUG)
  69     DeleteTmpFolder();
  70 };
  71
  72
  73
  74 //=============================================================================
  75 /*!
  76  * \brief Build folder for parallel computation
  77  */
  78 //=============================================================================
  79 void SMESH_ParallelMesh::CreateTmpFolder()
  80 {
  81 #ifndef WIN32
  82   // Temporary folder that will be used by parallel computation
  83   tmp_folder = fs::temp_directory_path()/fs::unique_path(fs::path("SMESH_%%%%-%%%%"));
  84   fs::create_directories(tmp_folder);
  85 #endif
  86 }
  87 //
  88 //=============================================================================
  89 /*!
  90  * \brief Delete temporary folder used for parallel computation
  91  */
  92 //=============================================================================
  93 void SMESH_ParallelMesh::DeleteTmpFolder()
  94 {
  95 #ifndef WIN32
  96     fs::remove_all(tmp_folder);
  97 #endif
  98 }
  99
 100 bool SMESH_ParallelMesh::ComputeSubMeshes(
 101           SMESH_Gen* gen,
 102           SMESH_Mesh & aMesh,
 103           const TopoDS_Shape & aShape,
 104           const ::MeshDimension       aDim,
 105           TSetOfInt*                  aShapesId /*=0*/,
 106           TopTools_IndexedMapOfShape* allowedSubShapes,
 107           SMESH_subMesh::compute_event &computeEvent,
 108           const bool includeSelf,
 109           const bool complexShapeFirst,
 110           const bool   aShapeOnly)
 111 {
 112   InitPoolThreads();
 113   return gen->parallelComputeSubMeshes(
 114             aMesh, aShape, aDim,
 115             aShapesId, allowedSubShapes,
 116             computeEvent,
 117             includeSelf,
 118             complexShapeFirst,
 119             aShapeOnly);
 120 }