OMK::Process Class Reference

How the distributed kernel for a message passing architecture sees processes. More...

#include <OMKProcess.h>

Inheritance diagram for OMK::Process:

[legend]Collaboration diagram for OMK::Process:

[legend]List of all members.

Public Member Functions
	Process (const std::string &np, const std::string &mac)
	Constructor.
virtual	~Process ()
	Destructor.
virtual void	unpack (IncomingSynchronisationMessage &)
	unpack from a message
virtual void	pack (OutgoingSynchronisationMessage &) const
	pack in a message
const Name &	getProcessName () const
	name of the process
const Name &	getHostMachineName () const
	name of the machine associated to this process
const Frequency &	getFrequency () const
	Frequency of the controller of the process.
const Frequency &	getMaxFrequencyOfHostedObjects () const
	maximum frequency of the hosted simulated objects
SvmLink *	getSvmLink () const
	link to the global controller
const Date &	getDateOfLastMessage () const
	Date of the last received message from that process.
const Date &	getPeriod () const
	get the period (in seconds) of the process
void	setDateOfLastMessage (const Date &d)
	change the date of last message received for this process in this adress space
void	setFrequency (const Frequency &val)
	change the frequency of this process
void	setMaxHostedFrequency (const Frequency &val)
	maximum frequency of hosted referentials
void	setSvmLink (SvmLink *val)
	change the link to the global controller
void	incrementeIterationFlag ()
	CHADI.
int	getIterationFlag ()
void	resetIterationFlag ()
bool	disconnectedProcess ()
Protected Attributes
Date	_dateOfLastMessage
	date of last reception of a message from this process
Date	_period
	time interval between two supposed receptions from this process.
Name	_processName
	name of the process
Name	_machineName
	machine hosting the process
Frequency	_processFrequency
	frequency of the process
Frequency	_maxHostedFrequency
	highest frequency of the process
SvmLink *	_svmLink
	pointer to the link to the global controller
int	_iterationFlag
	CHADI.

---

Detailed Description

How the distributed kernel for a message passing architecture sees processes.

Author:

Siames

Version:

1.0

Definition at line 32 of file OMKProcess.h.

---

Constructor & Destructor Documentation

Process::Process	(	const std::string &	np,
		const std::string &	mac
	)

Constructor.

Definition at line 25 of file OMKProcess.cxx.

References OMK::Controller::lcm().

  : 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

(

)

[virtual]

Destructor.

Definition at line 42 of file OMKProcess.cxx.

                   {

}

---

Member Function Documentation

void Process::unpack

(

IncomingSynchronisationMessage &

)

[virtual]

unpack from a message

Implements OMK::Packable.

Definition at line 56 of file OMKProcess.cxx.

References _processName, and _svmLink.

{
#ifdef _DEBUGPVMMESS 
  std::cerr<<"Process::extract "<<std::endl;
#endif
   in >> _processName >> *_svmLink ;

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

void Process::pack

(

OutgoingSynchronisationMessage &

)

const [virtual]

pack in a message

Implements OMK::Packable.

Definition at line 48 of file OMKProcess.cxx.

References _processName, _svmLink, OMK::Packable::pack(), and OMK::Name::pack().

{
   _processName.pack(out) ;
   _svmLink->pack(out) ;
}

const Name & Process::getProcessName

(

)

const

name of the process

Definition at line 71 of file OMKProcess.cxx.

References _processName.

Referenced by OMK::Svm::addNewSiteToSimulation(), OMK::Svm::relaxedSynchroniseReceiveAndProcessMessages(), OMK::Svm::synchroniseReceiveAndProcessMessages(), and OMK::Svm::testIfNewProcessAdded().

{
   return _processName ;
}

const Name & Process::getHostMachineName

(

)

const

name of the machine associated to this process

Definition at line 78 of file OMKProcess.cxx.

References _machineName.

Referenced by OMK::Svm::addNewSiteToSimulation(), OMK::PvmSvm::spawnProcess(), and OMK::PvmSvm::testIfSiteRecovered().

{
   return _machineName ;
}

const Frequency & Process::getFrequency

(

)

const

Frequency of the controller of the process.

Definition at line 86 of file OMKProcess.cxx.

References _processFrequency.

Referenced by OMK::PvmController::PvmController().

{
  return _processFrequency ;
}

const Frequency & Process::getMaxFrequencyOfHostedObjects

(

)

const

maximum frequency of the hosted simulated objects

Definition at line 93 of file OMKProcess.cxx.

References _maxHostedFrequency.

Referenced by OMK::PvmController::PvmController().

{
   return _maxHostedFrequency ;
}

SvmLink * Process::getSvmLink

(

)

const

link to the global controller

Definition at line 100 of file OMKProcess.cxx.

References _svmLink.

Referenced by OMK::Svm::addNewSiteToSimulation(), OMK::Svm::createDistributedSimulation(), OMK::Svm::relaxedSynchroniseReceiveAndProcessMessages(), OMK::Svm::synchroniseReceiveAndProcessMessages(), and OMK::PvmSvm::testIfSiteRecovered().

{
   return _svmLink ;
}

const Date & Process::getDateOfLastMessage

(

)

const

Date of the last received message from that process.

Definition at line 136 of file OMKProcess.cxx.

References _dateOfLastMessage.

{
   return _dateOfLastMessage ;
}

const Date & Process::getPeriod

(

)

const

get the period (in seconds) of the process

Definition at line 142 of file OMKProcess.cxx.

References _period.

{
   return _period ;
}

void Process::setDateOfLastMessage

(

const Date &

d

)

change the date of last message received for this process in this adress space

Definition at line 129 of file OMKProcess.cxx.

References _dateOfLastMessage.

Referenced by OMK::Svm::relaxedSynchroniseReceiveAndProcessMessages(), and OMK::Svm::synchroniseReceiveAndProcessMessages().

{
   _dateOfLastMessage = d ;
}

void Process::setFrequency

(

const Frequency &

val

)

change the frequency of this process

Definition at line 107 of file OMKProcess.cxx.

References _period, and _processFrequency.

Referenced by OMK::PvmController::PvmController().

{
   _processFrequency = val ;
   _period = static_cast< double>( 1. / val ) ;
}

void Process::setMaxHostedFrequency

(

const Frequency &

val

)

maximum frequency of hosted referentials

Definition at line 115 of file OMKProcess.cxx.

References _maxHostedFrequency.

Referenced by OMK::PvmController::PvmController().

{
   _maxHostedFrequency = val ;
} 

void Process::setSvmLink

(

SvmLink *

val

)

change the link to the global controller

Definition at line 122 of file OMKProcess.cxx.

References _svmLink.

Referenced by OMK::Svm::addNewSiteToSimulation(), OMK::Svm::connectToDistributedSimulation(), OMK::Svm::createDistributedSimulation(), and OMK::Svm::testIfNewProcessAdded().

{
   _svmLink = val ;
}

void Process::incrementeIterationFlag

(

)

CHADI.

Definition at line 149 of file OMKProcess.cxx.

References _iterationFlag.

{
  _iterationFlag++;
}

int Process::getIterationFlag

(

)

Definition at line 154 of file OMKProcess.cxx.

References _iterationFlag.

Referenced by disconnectedProcess().

{
  return _iterationFlag;
}

void Process::resetIterationFlag

(

)

Definition at line 159 of file OMKProcess.cxx.

References _iterationFlag.

{
  _iterationFlag=0;
}

bool Process::disconnectedProcess

(

)

Definition at line 164 of file OMKProcess.cxx.

References getIterationFlag().

{
  if( getIterationFlag() >= 50000)
    {return true;}
  else  return false;
}

---

Member Data Documentation

Date OMK::Process::_dateOfLastMessage [protected]

date of last reception of a message from this process

Definition at line 95 of file OMKProcess.h.

Referenced by getDateOfLastMessage(), and setDateOfLastMessage().

Date OMK::Process::_period [protected]

time interval between two supposed receptions from this process.

should be equal to 1/frequency

Definition at line 101 of file OMKProcess.h.

Referenced by getPeriod(), and setFrequency().

Name OMK::Process::_processName [protected]

name of the process

Definition at line 104 of file OMKProcess.h.

Referenced by getProcessName(), pack(), and unpack().

Name OMK::Process::_machineName [protected]

machine hosting the process

Definition at line 107 of file OMKProcess.h.

Referenced by getHostMachineName().

Frequency OMK::Process::_processFrequency [protected]

frequency of the process

Definition at line 110 of file OMKProcess.h.

Referenced by getFrequency(), and setFrequency().

Frequency OMK::Process::_maxHostedFrequency [protected]

highest frequency of the process

Definition at line 113 of file OMKProcess.h.

Referenced by getMaxFrequencyOfHostedObjects(), and setMaxHostedFrequency().

SvmLink* OMK::Process::_svmLink [protected]

pointer to the link to the global controller

Definition at line 116 of file OMKProcess.h.

Referenced by getSvmLink(), pack(), setSvmLink(), and unpack().

int OMK::Process::_iterationFlag [protected]

CHADI.

Definition at line 119 of file OMKProcess.h.

Referenced by getIterationFlag(), incrementeIterationFlag(), and resetIterationFlag().

---