00001 /****************************************************************************** 00002 * SOFA, Simulation Open-Framework Architecture, version 1.0 beta 3 * 00003 * (c) 2006-2008 MGH, INRIA, USTL, UJF, CNRS * 00004 * * 00005 * This library is free software; you can redistribute it and/or modify it * 00006 * under the terms of the GNU Lesser General Public License as published by * 00007 * the Free Software Foundation; either version 2.1 of the License, or (at * 00008 * your option) any later version. * 00009 * * 00010 * This library is distributed in the hope that it will be useful, but WITHOUT * 00011 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * 00012 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License * 00013 * for more details. * 00014 * * 00015 * You should have received a copy of the GNU Lesser General Public License * 00016 * along with this library; if not, write to the Free Software Foundation, * 00017 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. * 00018 ******************************************************************************* 00019 * SOFA :: Modules * 00020 * * 00021 * Authors: The SOFA Team and external contributors (see Authors.txt) * 00022 * * 00023 * Contact information: contact@sofa-framework.org * 00024 ******************************************************************************/ 00025 #include <sofa/simulation/tree/ParallelVisitorScheduler.h> 00026 #include <sofa/simulation/common/Node.h> 00027 #include <sofa/simulation/common/Visitor.h> 00028 00029 namespace sofa 00030 { 00031 00032 namespace simulation 00033 { 00034 00035 namespace tree 00036 { 00037 00038 ParallelVisitorScheduler::ParallelVisitorScheduler(bool propagate) 00039 : propagate(propagate) 00040 { 00041 } 00042 00043 void ParallelVisitorScheduler::executeVisitor(GNode* node, simulation::Visitor* action) 00044 { 00045 // first make sure all child nodes have schedulers 00046 if (propagate) 00047 recursiveClone(node); 00048 // then execute sequentially non-threadsafe actions 00049 if (!action->isThreadSafe()) 00050 doExecuteVisitor(node, action); 00051 else // or launch Cilk tasks for threadsafe actions 00052 { 00053 executeParallelVisitor(node, action); 00054 } 00055 } 00056 00057 void ParallelVisitorScheduler::recursiveClone(GNode* node) 00058 { 00059 if (!node->actionScheduler) 00060 node->addObject( this->clone() ); 00061 for (unsigned int i=0;i<node->child.size();i++) 00062 recursiveClone(node->child[i]); 00063 } 00064 00065 } // namespace tree 00066 00067 } // namespace simulation 00068 00069 } // namespace sofa 00070
1.5.7.1