---

PsMultiThreadedController.cxx

Go to the documentation of this file.

/*
 * This file is part of openMask © INRIA, CNRS, Universite de Rennes 1 1993-2002, thereinafter the Software
 * 
 * The Software has been developped within the Siames Project. 
 * INRIA, the University of Rennes 1 and CNRS jointly hold intellectual property rights
 * 
 * The Software has been registered with the Agence pour la Protection des
 * Programmes (APP) under registration number IDDN.FR.001.510008.00.S.P.2001.000.41200
 *  
 * This file may be distributed under the terms of the Q Public License
 * version 1.0 as defined by Trolltech AS of Norway and appearing in the file
 * LICENSE.QPL included in the packaging of this file.
 *
 * Licensees holding valid specific licenses issued by INRIA, CNRS or Université de Rennes 1 
 * for the software may use this file in accordance with that specific license
 *
 */
#include "PsMultiThreadedController.h"

#include "PsnMultiThreadedAsynchronousScheduler.h"
#include "PsnMultiThreadedScheduler.h"
#include "PsConfigurationParameterDescriptor.h"
#include "PsMultipleConfigurationParameter.h"
#include "PsNoRefCountingNameServer.h"
#include "PsnDescriptorMemoryManager.h"
#include "PsnThreadMemoryManager.h"
#include "PsnSystemMemoryManager.h"

PsMultiThreadedController::PsMultiThreadedController (PsObjectDescriptor & initialObjects,
                                                      const PsDate & initialDate,
                                                      unsigned int numberOfThreads) : 
   PsController(initialObjects,
                initialDate),
   _numberOfThreads (numberOfThreads) 
{
   //convert the actual name Server to non ref counting name server to avoid contention on the name server locks during ref counting operations
   PsNoRefCountingNameServer<STL_ALLOC> * nameServer = new PsNoRefCountingNameServer<STL_ALLOC> (PsName::getNameServer()->getCanonicalRepresentation () ) ;
   PsName::setNameServer (nameServer ) ;
}

PsMultiThreadedController::PsMultiThreadedController (PsObjectDescriptor & initialObjects,
                                                      const PsDate & initialDate ) : 
   PsController(initialObjects,
                initialDate),
   _numberOfThreads (2)
{
   //convert the actual name Server to non ref counting name server to avoid contention on the name server locks during ref counting operations
   PsNoRefCountingNameServer<STL_ALLOC> * nameServer = new PsNoRefCountingNameServer<STL_ALLOC> (PsName::getNameServer()->getCanonicalRepresentation () ) ;
   PsName::setNameServer (nameServer ) ;

   if (getObjectDescriptor().getSchedulingParameters() != NULL )
      {
         const PsConfigurationParameterDescriptor * param = getObjectDescriptor().getSchedulingParameters()->getSubDescriptorByName("NumberOfThreads") ;
         if (param != NULL )
            {
               _numberOfThreads = atoi (param->getAssociatedString().c_str() ) ; 
            }
      }
   
}

PsMultiThreadedController::~PsMultiThreadedController() {

}

PsnScheduler * PsMultiThreadedController::createScheduler() 
{
   return new PsnMultiThreadedScheduler( _nbStepsByCycle , _numberOfThreads, true ) ;
}

void PsMultiThreadedController::run ()
{
    PsnMemoryManager * currentMemoryManager = HeapStackTop::getSystemMemoryManager() ;

   assert ( currentMemoryManager != 0 ) ;

   size_t initialAllocatatedMemory = 1024 * 1024 ;

   void * startMemory = currentMemoryManager->allocateSizeRemembered ( initialAllocatatedMemory ) ;

   PsnDescriptorMemoryManager * descriptorMemoryManager = new PsnDescriptorMemoryManager ( *currentMemoryManager ) ;

   descriptorMemoryManager->init() ;
   
   PsnThreadMemoryManager * memoryManagerForThisThread ;
   
   memoryManagerForThisThread = new PsnThreadMemoryManager ( startMemory, 
                                                             initialAllocatatedMemory,
                                                             *currentMemoryManager,
                                                             *descriptorMemoryManager ) ;
   memoryManagerForThisThread -> init() ;

   HeapStackTop allocationContextForThisThread ( memoryManagerForThisThread ) ;
  
   PsController::run() ;
}

---