YACS::ENGINE::Resource Class Reference

#include <PlayGround.hxx>

Collaboration diagram for YACS::ENGINE::Resource:

Public Member Functions
	Resource (const std::string &name, int nbCores)
	Resource (const std::pair< std::string, int > &p)
std::pair< std::string, int >	toPair () const
int	nbCores () const
std::string	name () const
std::size_t	getNumberOfFreePlace (int nbCoresPerCont) const
std::vector< std::size_t >	allocateFor (std::size_t &nbOfPlacesToTake, int nbCoresPerCont) const
void	release (std::size_t workerId, int nbCoresPerCont) const
std::size_t	getNumberOfWorkers (int nbCoresPerCont) const
void	printSelf (std::ostream &oss) const

Private Attributes
std::string	_name
int	_nbCores
std::vector< bool >	_occupied

Detailed Description

Definition at line 39 of file PlayGround.hxx.

Constructor & Destructor Documentation

Resource() [1/2]

YACS::ENGINE::Resource::Resource ( const std::string &  name, int  nbCores  )

inline

Definition at line 42 of file PlayGround.hxx.

:_name(name),_nbCores(nbCores),_occupied(_nbCores,false) { }

Resource() [2/2]

YACS::ENGINE::Resource::Resource ( const std::pair< std::string, int > &  p )

inline

Definition at line 43 of file PlayGround.hxx.

:_name(p.first),_nbCores(p.second),_occupied(_nbCores,false) { }

Member Function Documentation

allocateFor()

std::vector< std::size_t > Resource::allocateFor	(	std::size_t &	nbOfPlacesToTake,
		int	nbCoresPerCont
	)		const

Definition at line 49 of file PlayGround.cxx.

{
  std::vector<std::size_t> ret;
  std::size_t pos(0),curWorkerId(0);
  while( ( pos < _occupied.size() ) && ( nbOfPlacesToTake > 0 ) )
    {
      bool isChunckFree(true);
      int posInChunck(0);
      for( ; ( posInChunck < nbCoresPerCont ) && ( pos < _occupied.size() ) ; ++posInChunck, ++pos)
        if(_occupied[pos])
          isChunckFree = false;
      if( isChunckFree && (posInChunck == nbCoresPerCont) )
        {
          for(int i = 0 ; i < nbCoresPerCont ; ++i)
            _occupied[pos-nbCoresPerCont+i] = true;
          ret.push_back(curWorkerId);
          --nbOfPlacesToTake;
        }
      ++curWorkerId;
    }
  return ret;
}

References _occupied, and yacsorb.CORBAEngineTest::i.

getNumberOfFreePlace()

std::size_t Resource::getNumberOfFreePlace

(

int

nbCoresPerCont

)

const

Definition at line 33 of file PlayGround.cxx.

{
  std::size_t ret(0),pos(0);
  while( pos < _occupied.size() )
    {
      bool isChunckFree(true);
      int posInChunck(0);
      for( ; ( posInChunck < nbCoresPerCont ) && ( pos < _occupied.size() ) ; ++posInChunck, ++pos)
        if(_occupied[pos])
          isChunckFree = false;
      if( isChunckFree && (posInChunck == nbCoresPerCont) )
        ret++;
    }
  return ret;
}

References _occupied.

getNumberOfWorkers()

std::size_t Resource::getNumberOfWorkers

(

int

nbCoresPerCont

)

const

Definition at line 85 of file PlayGround.cxx.

{
  return static_cast<std::size_t>(this->nbCores())/static_cast<std::size_t>(nbCoresPerCont);
}

References nbCores().

Referenced by release().

name()

std::string YACS::ENGINE::Resource::name ( ) const

inline

Definition at line 46 of file PlayGround.hxx.

{ return _name; }

Referenced by printSelf().

nbCores()

int YACS::ENGINE::Resource::nbCores ( ) const

inline

Definition at line 45 of file PlayGround.hxx.

{ return _nbCores; }

Referenced by getNumberOfWorkers(), and printSelf().

printSelf()

void Resource::printSelf

(

std::ostream &

oss

)

const

Definition at line 90 of file PlayGround.cxx.

{
  oss << this->name() << " (" << this->nbCores() << ") : ";
  for(auto it : this->_occupied)
    {
      if(it)
        oss << "1";
      else
        oss << "0";
    }
}

References _occupied, name(), and nbCores().

release()

void Resource::release	(	std::size_t	workerId,
		int	nbCoresPerCont
	)		const

Definition at line 72 of file PlayGround.cxx.

{
  if(workerId >= this->getNumberOfWorkers(nbCoresPerCont))
    throw Exception("Resource::release : invalid worker id !");
  std::size_t pos(workerId*static_cast<std::size_t>(nbCoresPerCont));
  for(int i = 0 ; i < nbCoresPerCont ; ++i)
    {
      if(!_occupied[pos + static_cast<std::size_t>(i)])
        throw Exception("Resource::release : internal error ! A core is expected to be occupied !");
      _occupied[pos + static_cast<std::size_t>(i)] = false;
    }
}

References _occupied, getNumberOfWorkers(), and yacsorb.CORBAEngineTest::i.

toPair()

std::pair< std::string, int > YACS::ENGINE::Resource::toPair ( ) const

inline

Definition at line 44 of file PlayGround.hxx.

{ return {_name,_nbCores}; }

Member Data Documentation

_name

std::string YACS::ENGINE::Resource::_name

private

Definition at line 53 of file PlayGround.hxx.

_nbCores

int YACS::ENGINE::Resource::_nbCores

private

Definition at line 54 of file PlayGround.hxx.

_occupied

std::vector<bool> YACS::ENGINE::Resource::_occupied

mutableprivate

Definition at line 55 of file PlayGround.hxx.

Referenced by allocateFor(), getNumberOfFreePlace(), printSelf(), and release().

---

The documentation for this class was generated from the following files:

• src/engine/PlayGround.hxx
• src/engine/PlayGround.cxx