OMKProcess.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 <cassert>
#include <OMKProcess.h>
#include <OMKSvmLink.h>
#include "OMKController.h"
using namespace OMK ;

//-----------------------------------------------------------------------------
Process::Process (const std::string & np, const std::string & mac)
  : Packable(),
    _dateOfLastMessage ( Controller::initialSimulationDate ), //why not ?
    _processName(np),
    _machineName(mac),
    _processFrequency (1), //give a stable point when calculing least common
    _maxHostedFrequency (0), //gives a stable point in calculating max
    // multiplier 
    _iterationFlag(0)
{
   assert ( Controller::lcm ( 13 , 1 ) == 13 ) ; //make sure lcm implementation has 1 as stable point.
}

//-----------------------------------------------------------------------------

Process::~Process () {

}

//-----------------------------------------------------------------------------

void Process::pack (OutgoingSynchronisationMessage & out) const
{
   _processName.pack(out) ;
   _svmLink->pack(out) ;
}

//-----------------------------------------------------------------------------

void Process::unpack (IncomingSynchronisationMessage & in) 
{
#ifdef _DEBUGPVMMESS 
  std::cerr<<"Process::extract "<<std::endl;
#endif
   in >> _processName >> *_svmLink ;

#ifdef _DEBUGPVMMESS 
   std::cerr<<"process named "<<_processName<<std::endl;
#endif
}


//-----------------------------------------------------------------------------

const Name & Process::getProcessName () const 
{
   return _processName ;
}
 
//-----------------------------------------------------------------------------

const Name & Process::getHostMachineName () const 
{
   return _machineName ;
}


//-----------------------------------------------------------------------------

const Frequency & Process::getFrequency () const 
{
  return _processFrequency ;
}

//-----------------------------------------------------------------------------

const Frequency & Process::getMaxFrequencyOfHostedObjects () const 
{
   return _maxHostedFrequency ;
}

//-----------------------------------------------------------------------------

SvmLink * Process::getSvmLink () const 
{
   return _svmLink ;
}

//-----------------------------------------------------------------------------

void Process::setFrequency (const Frequency & val) 
{
   _processFrequency = val ;
   _period = static_cast< double>( 1. / val ) ;
}

//-----------------------------------------------------------------------------

void Process::setMaxHostedFrequency (const Frequency & val) 
{
   _maxHostedFrequency = val ;
} 

//-----------------------------------------------------------------------------

void Process::setSvmLink (SvmLink * val) 
{
   _svmLink = val ;
}



void Process::setDateOfLastMessage ( const Date & d )
{
   _dateOfLastMessage = d ;
}



const Date & Process::getDateOfLastMessage () const 
{
   return _dateOfLastMessage ;
}


const Date & Process::getPeriod () const 
{
   return _period ;
}

void Process::incrementeIterationFlag() 
{
  _iterationFlag++;
}

int Process::getIterationFlag()
{
  return _iterationFlag;
}

void Process::resetIterationFlag() 
{
  _iterationFlag=0;
}

bool  Process::disconnectedProcess()
{
  if( getIterationFlag() >= 50000)
    {return true;}
  else  return false;
}

---