YACS::ENGINE::DeploymentTreeOnHeap Class Reference

#include <DeploymentTree.hxx>

Collaboration diagram for YACS::ENGINE::DeploymentTreeOnHeap:

Public Member Functions
	DeploymentTreeOnHeap ()
	~DeploymentTreeOnHeap ()
bool	decrRef ()
void	incrRef () const
unsigned char	appendTask (Task *task, Scheduler *cloner)
unsigned	getNumberOfCTDefContainer () const
unsigned	getNumberOfRTODefContainer () const
unsigned	getNumberOfCTDefComponentInstances () const
unsigned	getNumberOfRTODefComponentInstances () const
std::vector< Container * >	getAllContainers () const
std::vector< Container * >	getAllCTDefContainers () const
std::vector< Container * >	getAllRTODefContainers () const
std::vector< Task * >	getTasksLinkedToComponent (ComponentInstance *comp) const
std::vector< Task * >	getTasksLinkedToContainer (Container *cont) const
std::vector< ComponentInstance * >	getComponentsLinkedToContainer (Container *cont) const
bool	presenceOfDefaultContainer () const
std::vector< Task * >	getFreeDeployableTasks () const

Private Attributes
int	_cnt
std::vector< std::pair< Task *, Scheduler * > >	_freePlacableTasks
std::vector< std::vector< std::vector< std::pair< Task *, Scheduler * > > > >	_tree
	internal representation of tree. Scheduler is the duplicating Task, if it exists, on runtime unpredictable times on compil-time More...

Detailed Description

Definition at line 36 of file DeploymentTree.hxx.

Constructor & Destructor Documentation

DeploymentTreeOnHeap()

DeploymentTreeOnHeap::DeploymentTreeOnHeap

(

)

Definition at line 32 of file DeploymentTree.cxx.

                                          :_cnt(1)
{
}

~DeploymentTreeOnHeap()

DeploymentTreeOnHeap::~DeploymentTreeOnHeap

(

)

Definition at line 36 of file DeploymentTree.cxx.

{
}

Member Function Documentation

appendTask()

unsigned char DeploymentTreeOnHeap::appendTask	(	Task *	task,
		Scheduler *	cloner
	)

Definition at line 53 of file DeploymentTree.cxx.

{
  DEBTRACE( "DeploymentTreeOnHeap::appendTask: " << task );
  if(!task)
    return DeploymentTree::NULL_TASK;
  if(!task->isDeployable())//Task not needed to be placed.
    return DeploymentTree::NOT_DEPLOYABLE_TASK;
  ComponentInstance *ci=task->getComponent();
  Container *cont=task->getContainer();
  DEBTRACE( "DeploymentTreeOnHeap::appendTask component: " << ci );
  DEBTRACE( "DeploymentTreeOnHeap::appendTask container: " << cont );
  if(!ci && !cont)//Task is not attached to a Component or a Container -> not needed to be placed.
    {
      _freePlacableTasks.push_back(pair<Task *,Scheduler *>(task,cloner));
      return DeploymentTree::DEPLOYABLE_BUT_NOT_SPECIFIED;
    }
  DEBTRACE( "DeploymentTreeOnHeap::appendTask container: " << cont );
 
  // an iterator for Container level
  vector< vector< vector< pair<Task *, Scheduler *> > > >::iterator iter1;
  // an iterator for Component instance level
  vector< vector< pair<Task *, Scheduler * > > >::iterator iter2;
  // an iterator for a vector of tasks with same container and component instance
  vector< pair<Task *, Scheduler *> >::iterator iter3;
 
  // search an existing vector of tasks with container == cont
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      Task* task=(*iter1)[0][0].first;
      if(task->getContainer() == cont)
        break;
    }
  if(iter1==_tree.end())
    {
      // the vector does not exist : create it
      DEBTRACE("create a vector of vector of tasks for container " << cont);
      _tree.push_back(vector< vector< pair< Task *, Scheduler *> > >());
      iter1=_tree.end();
      iter1--;
    }
 
  // search a vector of tasks with component instance == ci
  for(iter2=(*iter1).begin();iter2!=(*iter1).end();iter2++)
    if(((*iter2)[0]).first->getComponent()==ci)
      break;
  if(iter2==(*iter1).end())
    {
      // the vector does not exist : create it
      DEBTRACE("create a vector of tasks for component instance " << ci);
      (*iter1).push_back(vector< pair< Task *, Scheduler *> >());
      iter2=(*iter1).end();
      iter2--;
    }
 
  // search the task in the vector. If it exists return 
  for(iter3=(*iter2).begin();iter3!=(*iter2).end();iter3++)
    if((*iter3).first==task)
      return DeploymentTree::ALREADY_IN_TREE;
 
  DEBTRACE("add task to vector of tasks " << task);
  (*iter2).push_back(pair<Task *,Scheduler *>(task,cloner));
  return DeploymentTree::APPEND_OK;
}

References _freePlacableTasks, _tree, YACS::ENGINE::DeploymentTree::ALREADY_IN_TREE, YACS::ENGINE::DeploymentTree::APPEND_OK, DEBTRACE, YACS::ENGINE::DeploymentTree::DEPLOYABLE_BUT_NOT_SPECIFIED, YACS::ENGINE::Task::getComponent(), YACS::ENGINE::Task::getContainer(), YACS::ENGINE::Task::isDeployable(), YACS::ENGINE::DeploymentTree::NOT_DEPLOYABLE_TASK, and YACS::ENGINE::DeploymentTree::NULL_TASK.

Referenced by YACS::ENGINE::DeploymentTree::appendTask().

decrRef()

bool DeploymentTreeOnHeap::decrRef

(

)

Definition at line 40 of file DeploymentTree.cxx.

{
  bool ret=(--_cnt==0);
  if(ret)
    delete this;
  return ret;
}

References _cnt.

Referenced by YACS::ENGINE::DeploymentTree::operator=(), and YACS::ENGINE::DeploymentTree::~DeploymentTree().

getAllContainers()

std::vector< Container * > DeploymentTreeOnHeap::getAllContainers

(

)

const

Definition at line 235 of file DeploymentTree.cxx.

{
  vector<Container *> ret;
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      Task* task=(*iter1)[0][0].first;
      ret.push_back(task->getContainer());
    }
  return ret;
}

References _tree, and YACS::ENGINE::Task::getContainer().

Referenced by YACS::ENGINE::DeploymentTree::getAllContainers().

getAllCTDefContainers()

std::vector< Container * > DeploymentTreeOnHeap::getAllCTDefContainers

(

)

const

Definition at line 247 of file DeploymentTree.cxx.

{
  DEBTRACE("getAllCTDefContainers");
  vector<Container *> ret;
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      bool isCTDefSurely1=true;
      for(iter2=(*iter1).begin();iter2!=(*iter1).end() && isCTDefSurely1;iter2++)
        {
          bool isCTDefSurely2=true;
          for(iter3=(*iter2).begin();iter3!=(*iter2).end() && isCTDefSurely2;iter3++)
            if((*iter3).second!=0)
              isCTDefSurely2=false;
          if(isCTDefSurely2)
            isCTDefSurely1=true;
          else if(((*iter2)[0].first)->getComponent())
            isCTDefSurely1=(((*iter2)[0].first)->getComponent()->isAttachedOnCloning());
          else
            isCTDefSurely1=false;
        }
      Container *cont=((*iter1)[0][0].first)->getContainer();
      if(isCTDefSurely1)
        {
          if(cont)
            ret.push_back(cont);
        }
      else
        if(cont)
          if(cont->isAttachedOnCloning())
            ret.push_back(cont);
      }
  return ret;
}

References _tree, DEBTRACE, and YACS::ENGINE::Container::isAttachedOnCloning().

Referenced by YACS::ENGINE::DeploymentTree::getAllCTDefContainers().

getAllRTODefContainers()

std::vector< Container * > DeploymentTreeOnHeap::getAllRTODefContainers

(

)

const

Definition at line 284 of file DeploymentTree.cxx.

{
  DEBTRACE("getAllRTODefContainers");
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  vector<Container *> ret;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      bool isRTODefSurely1=true;
      for(iter2=(*iter1).begin();iter2!=(*iter1).end() && isRTODefSurely1;iter2++)
        {
          bool isRTODefSurely2=true;
          for(iter3=(*iter2).begin();iter3!=(*iter2).end() && isRTODefSurely2;iter3++)
            if((*iter3).second==0)
              isRTODefSurely2=false;
          if(isRTODefSurely2)
            {
              if(((*iter2)[0].first)->getComponent())
                isRTODefSurely1=!(((*iter2)[0].first)->getComponent()->isAttachedOnCloning());
              else
                isRTODefSurely1=false;
            }
          else
            isRTODefSurely1=false;
        }
      if(isRTODefSurely1)
        {
          Container* cont= (*iter1)[0][0].first->getContainer();
          if(cont)
            if(!cont->isAttachedOnCloning())
              ret.push_back(cont);
        }
    }
  return ret;
}

References _tree, DEBTRACE, and YACS::ENGINE::Container::isAttachedOnCloning().

Referenced by YACS::ENGINE::DeploymentTree::getAllRTODefContainers().

getComponentsLinkedToContainer()

std::vector< ComponentInstance * > DeploymentTreeOnHeap::getComponentsLinkedToContainer

(

Container *

cont

)

const

Definition at line 354 of file DeploymentTree.cxx.

{
  DEBTRACE("DeploymentTreeOnHeap::getComponentsLinkedToContainer ");
  vector<ComponentInstance *> ret;
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  //iterate on containers
  for(iter1=_tree.begin();iter1!=_tree.end();++iter1)
    {
      //iterate on components
      for(iter2=(*iter1).begin();iter2!=(*iter1).end();++iter2)
        {
          ComponentInstance *compo=(*iter2)[0].first->getComponent();
          if(compo)
            {
              //it's a real component, add it if its container is the right one
              if(compo->getContainer()==cont)
                ret.push_back(compo);
              else
                break;
            }
        }
    }
    
  return ret;
}

References _tree, DEBTRACE, and YACS::ENGINE::ComponentInstance::getContainer().

Referenced by YACS::ENGINE::DeploymentTree::getComponentsLinkedToContainer().

getFreeDeployableTasks()

std::vector< Task * > DeploymentTreeOnHeap::getFreeDeployableTasks

(

)

const

Definition at line 391 of file DeploymentTree.cxx.

{
  vector<Task *> ret;
  for(vector< pair<Task *,Scheduler *> >::const_iterator iter=_freePlacableTasks.begin();iter!=_freePlacableTasks.end();iter++)
    ret.push_back((*iter).first);
  return ret;
}

References _freePlacableTasks.

Referenced by YACS::ENGINE::DeploymentTree::getFreeDeployableTasks().

getNumberOfCTDefComponentInstances()

unsigned DeploymentTreeOnHeap::getNumberOfCTDefComponentInstances

(

)

const

Definition at line 192 of file DeploymentTree.cxx.

{
  DEBTRACE("getNumberOfCTDefComponentInstances");
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  unsigned ret=0;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    for(iter2=(*iter1).begin();iter2!=(*iter1).end();iter2++)
      {
        bool isCTDefSurely=true;
        for(iter3=(*iter2).begin();iter3!=(*iter2).end() && isCTDefSurely;iter3++)
          if((*iter3).second!=0)
            isCTDefSurely=false;
        if(isCTDefSurely)
          ret++;
        else
          if(((*iter2)[0].first)->getComponent() && ((*iter2)[0].first)->getComponent()->isAttachedOnCloning())
            ret++;
      }
  return ret;
}

References _tree, and DEBTRACE.

Referenced by YACS::ENGINE::DeploymentTree::getNumberOfCTDefComponentInstances().

getNumberOfCTDefContainer()

unsigned DeploymentTreeOnHeap::getNumberOfCTDefContainer

(

)

const

Definition at line 117 of file DeploymentTree.cxx.

{
  DEBTRACE("getNumberOfCTDefContainer ");
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  unsigned ret=0;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      bool isCTDefSurely1=true;
      for(iter2=(*iter1).begin();iter2!=(*iter1).end() && isCTDefSurely1;iter2++)
        {
          bool isCTDefSurely2=true;
          for(iter3=(*iter2).begin();iter3!=(*iter2).end() && isCTDefSurely2;iter3++)
            if((*iter3).second!=0)
              isCTDefSurely2=false;
          if(isCTDefSurely2)
            isCTDefSurely1=true;
          else if(((*iter2)[0].first)->getComponent())
            isCTDefSurely1=(((*iter2)[0].first)->getComponent()->isAttachedOnCloning());
          else
            isCTDefSurely1=false;
        }
      Container *cont=((*iter1)[0][0].first)->getContainer();
      if(isCTDefSurely1)
        {
          if(cont)
            ret++;
        }
      else
        if(cont)
          if(cont->isAttachedOnCloning())
            ret++;
          else
            {
              unsigned val;
              if((*iter1)[0][0].second->isMultiplicitySpecified(val))
                ret+=val;
            }
      }
  return ret;
}

References _tree, DEBTRACE, and YACS::ENGINE::Container::isAttachedOnCloning().

Referenced by YACS::ENGINE::DeploymentTree::getNumberOfCTDefContainer().

getNumberOfRTODefComponentInstances()

unsigned DeploymentTreeOnHeap::getNumberOfRTODefComponentInstances

(

)

const

Definition at line 215 of file DeploymentTree.cxx.

{
  DEBTRACE("getNumberOfRTODefComponentInstances");
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  unsigned ret=0;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    for(iter2=(*iter1).begin();iter2!=(*iter1).end();iter2++)
      {
        bool isRTODef=false;
        for(iter3=(*iter2).begin();iter3!=(*iter2).end() && !isRTODef;iter3++)
          if((*iter3).second!=0)
            isRTODef=true;
        if(isRTODef && ((*iter2)[0].first)->getComponent() && !((*iter2)[0].first)->getComponent()->isAttachedOnCloning())
          ret++;
      }
  return ret;
}

References _tree, and DEBTRACE.

Referenced by YACS::ENGINE::DeploymentTree::getNumberOfRTODefComponentInstances().

getNumberOfRTODefContainer()

unsigned DeploymentTreeOnHeap::getNumberOfRTODefContainer

(

)

const

Definition at line 160 of file DeploymentTree.cxx.

{
  DEBTRACE("getNumberOfRTODefContainer");
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  unsigned ret=0;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      bool isRTODefSurely1=true;
      for(iter2=(*iter1).begin();iter2!=(*iter1).end() && isRTODefSurely1;iter2++)
        {
          bool isRTODefSurely2=true;
          for(iter3=(*iter2).begin();iter3!=(*iter2).end() && isRTODefSurely2;iter3++)
            if((*iter3).second==0)
              isRTODefSurely2=false;
          if(isRTODefSurely2)
            if(((*iter2)[0].first)->getComponent())
              isRTODefSurely1=!(((*iter2)[0].first)->getComponent()->isAttachedOnCloning());
            else
              isRTODefSurely1=false;
          else
            isRTODefSurely1=false;
        }
      if(isRTODefSurely1)
        if(((*iter1)[0][0].first)->getContainer())
          if(!((*iter1)[0][0].first)->getContainer()->isAttachedOnCloning())
            ret++;
    }
  return ret;
}

References _tree, and DEBTRACE.

Referenced by YACS::ENGINE::DeploymentTree::getNumberOfRTODefContainer().

getTasksLinkedToComponent()

std::vector< Task * > DeploymentTreeOnHeap::getTasksLinkedToComponent

(

ComponentInstance *

comp

)

const

Definition at line 339 of file DeploymentTree.cxx.

{
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  
  std::vector<Task *> ret;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    for(iter2=(*iter1).begin();iter2!=(*iter1).end();iter2++)
      if(((*iter2)[0].first)->getComponent()==comp)
        for(iter3=(*iter2).begin();iter3!=(*iter2).end();iter3++)
          ret.push_back((*iter3).first);
  return ret;
}

References _tree, and yacsorb.CORBAEngineTest::comp.

Referenced by YACS::ENGINE::DeploymentTree::getTasksLinkedToComponent().

getTasksLinkedToContainer()

std::vector< Task * > DeploymentTreeOnHeap::getTasksLinkedToContainer

(

Container *

cont

)

const

Definition at line 321 of file DeploymentTree.cxx.

{
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  vector< vector< pair<Task *, Scheduler * > > >::const_iterator iter2;
  vector< pair<Task *, Scheduler *> >::const_iterator iter3;
  
  std::vector<Task *> ret;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    {
      if(((*iter1)[0][0].first)->getContainer()==cont)
        for(iter2=(*iter1).begin();iter2!=(*iter1).end();iter2++)
          if(((*iter2)[0].first)->getComponent()==0)
            for(iter3=(*iter2).begin();iter3!=(*iter2).end();iter3++)
              ret.push_back((*iter3).first);
    }
  return ret;
}

References _tree.

Referenced by YACS::ENGINE::DeploymentTree::getTasksLinkedToContainer().

incrRef()

void DeploymentTreeOnHeap::incrRef

(

)

const

Definition at line 48 of file DeploymentTree.cxx.

{
  _cnt++;
}

References _cnt.

Referenced by YACS::ENGINE::DeploymentTree::DeploymentTree(), and YACS::ENGINE::DeploymentTree::operator=().

presenceOfDefaultContainer()

bool DeploymentTreeOnHeap::presenceOfDefaultContainer

(

)

const

Definition at line 381 of file DeploymentTree.cxx.

{
  DEBTRACE("presenceOfDefaultContainer");
  vector< vector< vector< pair<Task *, Scheduler *> > > >::const_iterator iter1;
  for(iter1=_tree.begin();iter1!=_tree.end();iter1++)
    if(!((*iter1)[0][0].first)->getContainer())
      return true;
  return false;
}

References _tree, and DEBTRACE.

Referenced by YACS::ENGINE::DeploymentTree::presenceOfDefaultContainer().

Member Data Documentation

_cnt

int YACS::ENGINE::DeploymentTreeOnHeap::_cnt

mutableprivate

Definition at line 61 of file DeploymentTree.hxx.

Referenced by decrRef(), and incrRef().

_freePlacableTasks

std::vector< std::pair<Task *,Scheduler *> > YACS::ENGINE::DeploymentTreeOnHeap::_freePlacableTasks

private

Definition at line 62 of file DeploymentTree.hxx.

Referenced by appendTask(), and getFreeDeployableTasks().

_tree

std::vector< std::vector< std::vector< std::pair<Task *, Scheduler * > > > > YACS::ENGINE::DeploymentTreeOnHeap::_tree

private

internal representation of tree. Scheduler is the duplicating Task, if it exists, on runtime unpredictable times on compil-time

Definition at line 64 of file DeploymentTree.hxx.

Referenced by appendTask(), getAllContainers(), getAllCTDefContainers(), getAllRTODefContainers(), getComponentsLinkedToContainer(), getNumberOfCTDefComponentInstances(), getNumberOfCTDefContainer(), getNumberOfRTODefComponentInstances(), getNumberOfRTODefContainer(), getTasksLinkedToComponent(), getTasksLinkedToContainer(), and presenceOfDefaultContainer().

---

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

• src/engine/DeploymentTree.hxx
• src/engine/DeploymentTree.cxx