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 #ifndef WIN32
  62   _NbThreads = std::thread::hardware_concurrency();
  63 #else
  64   _NbThreads = 0;
  65 #endif
  66   CreateTmpFolder();
  67 };
  68
  69 SMESH_ParallelMesh::~SMESH_ParallelMesh()
  70 {
  71   DeletePoolThreads();
  72   if(!MYDEBUG)
  73     DeleteTmpFolder();
  74 };
  75
  76
  77
  78 //=============================================================================
  79 /*!
  80  * \brief Build folder for parallel computation
  81  */
  82 //=============================================================================
  83 void SMESH_ParallelMesh::CreateTmpFolder()
  84 {
  85 #ifndef WIN32
  86   // Temporary folder that will be used by parallel computation
  87   tmp_folder = fs::temp_directory_path()/fs::unique_path(fs::path("SMESH_%%%%-%%%%"));
  88   fs::create_directories(tmp_folder);
  89 #endif
  90 }
  91 //
  92 //=============================================================================
  93 /*!
  94  * \brief Delete temporary folder used for parallel computation
  95  */
  96 //=============================================================================
  97 void SMESH_ParallelMesh::DeleteTmpFolder()
  98 {
  99 #ifndef WIN32
 100     fs::remove_all(tmp_folder);
 101 #endif
 102 }
 103
 104 bool SMESH_ParallelMesh::ComputeSubMeshes(
 105           SMESH_Gen* gen,
 106           SMESH_Mesh & aMesh,
 107           const TopoDS_Shape & aShape,
 108           const ::MeshDimension       aDim,
 109           TSetOfInt*                  aShapesId /*=0*/,
 110           TopTools_IndexedMapOfShape* allowedSubShapes,
 111           SMESH_subMesh::compute_event &computeEvent,
 112           const bool includeSelf,
 113           const bool complexShapeFirst,
 114           const bool   aShapeOnly)
 115 {
 116   InitPoolThreads();
 117   return gen->parallelComputeSubMeshes(
 118             aMesh, aShape, aDim,
 119             aShapesId, allowedSubShapes,
 120             computeEvent,
 121             includeSelf,
 122             complexShapeFirst,
 123             aShapeOnly);
 124 }