#include <Switch.hxx>

Inheritance diagram for YACS::ENGINE::CollectorSwOutPort:

[legend]

Collaboration diagram for YACS::ENGINE::CollectorSwOutPort:

[legend]

Public Member Functions
void	getHumanReprOfIncompleteCases (std::ostream &stream) const

Public Member Functions inherited from YACS::ENGINE::OutPort
virtual void	checkConsistency (LinkInfo &info) const

virtual int	edGetNumberOfOutLinks () const

virtual std::set< InPort * >	edSetInPort () const =0

virtual bool	isAlreadyLinkedWith (InPort *withp) const =0

virtual void	getAllRepresented (std::set< OutPort * > &represented) const

virtual bool	addInPort (InPort *inPort)=0

virtual int	removeInPort (InPort *inPort, bool forward)=0

virtual	~OutPort ()

std::vector< DataPort * >	calculateHistoryOfLinkWith (InPort *end)

virtual std::string	typeName ()

Public Member Functions inherited from YACS::ENGINE::DataPort
TypeCode *	edGetType () const

void	edSetType (TypeCode *type)

std::string	getName () const

void	setName (std::string theName)

std::string	getNameOfTypeOfCurrentInstance () const

virtual TypeOfChannel	getTypeOfChannel () const =0
	returns type of channel the port will use for data exchange on runtime : DATAFLOW or DATASTREAM. More...

bool	isDifferentTypeOf (const DataPort *other) const

virtual void	edRemoveAllLinksLinkedWithMe ()=0

virtual std::string	typeName ()

virtual std::string	getAsString ()
	returns port value as a string that can be used in a GUI for example More...

Public Member Functions inherited from YACS::ENGINE::Port
virtual	~Port ()

Node *	getNode () const

virtual std::string	getNameOfTypeOfCurrentInstance () const

int	getNumId () const

virtual std::string	typeName ()

void	modified ()

Private Member Functions
int	edGetNumberOfOutLinks () const

std::set< InPort * >	edSetInPort () const

bool	isAlreadyLinkedWith (InPort *withp) const

std::string	getNameOfTypeOfCurrentInstance () const

void	edRemoveAllLinksLinkedWithMe ()

TypeOfChannel	getTypeOfChannel () const
	returns type of channel the port will use for data exchange on runtime : DATAFLOW or DATASTREAM. More...

void	getAllRepresented (std::set< OutPort * > &represented) const

bool	addInPort (InPort *inPort)

int	removeInPort (InPort *inPort, bool forward)

bool	removePotentialProducerForMaster ()

void	checkConsistency (LinkInfo &info) const

	CollectorSwOutPort (Switch master, InPort port)

	CollectorSwOutPort (const CollectorSwOutPort &other, Switch *master)

void	addPotentialProducerForMaster (OutPort *port)

bool	checkManagementOfPort (OutPort *port)

Private Attributes
InPort *	_consumer

std::string	_className

OutPort *	_currentProducer

std::map< int, OutPort * >	_potentialProducers

Friends
class	Switch

Additional Inherited Members
Static Public Member Functions inherited from YACS::ENGINE::DataPort
static DataPort *	isCrossingType (const std::vector< DataPort * > &historyOfLink)

Static Public Attributes inherited from YACS::ENGINE::DataPort
static const char	NAME [] ="DataPort"

Protected Member Functions inherited from YACS::ENGINE::OutPort
	OutPort (const OutPort &other, Node *newHelder)

	OutPort (const std::string &name, Node node, TypeCode type)

Protected Member Functions inherited from YACS::ENGINE::DataPort
virtual	~DataPort ()

	DataPort (const DataPort &other, Node *newHelder)

	DataPort (const std::string &name, Node node, TypeCode type)

Protected Member Functions inherited from YACS::ENGINE::Port
	Port (Node *node)

	Port (const Port &other, Node *newHelder)

Protected Attributes inherited from YACS::ENGINE::DataPort
TypeCode *	_type

std::string	_name

Protected Attributes inherited from YACS::ENGINE::Port
Node *	_node

int	_id

Static Protected Attributes inherited from YACS::ENGINE::Port
static int	_total = 0

static const char	NAME [] ="Port"

Detailed Description

Definition at line 37 of file Switch.hxx.

Constructor & Destructor Documentation

◆ CollectorSwOutPort() [1/2]

CollectorSwOutPort::CollectorSwOutPort	(	Switch *	master,
		InPort *	port
	)

private

Note: : 'master' specifies the instance of Switch of which 'this' collects all of these direct or indirect outports going to the same port 'port' (which is out of scope of 'master').

Definition at line 112 of file Switch.cxx.

                                                                  :OutPort("",master,port->edGetType()),
                                                                     DataPort("",master,port->edGetType()),
                                                                     Port(master),
                                                                     _consumer(port),_currentProducer(0)
{
  _name="Representant_of_";
  _name+=master->getName();
  _name+="_for_inport_";
  _name+=port->getName();
}

References YACS::ENGINE::DataPort::_name, YACS::ENGINE::ComposedNode::getName(), and YACS::ENGINE::DataPort::getName().

◆ CollectorSwOutPort() [2/2]

CollectorSwOutPort::CollectorSwOutPort	(	const CollectorSwOutPort &	other,
		Switch *	master
	)

private

Definition at line 123 of file Switch.cxx.

                                                                                     :OutPort("",master,other.edGetType()),
                                                                                        DataPort("",master,other.edGetType()),
                                                                                        Port(master),
                                                                                        _consumer(0),_currentProducer(0)
{
  _name=other._name;
  Switch *othSw=(Switch *)other._node;
  for(map<int, OutPort *>::const_iterator iter=other._potentialProducers.begin();iter!=other._potentialProducers.end();iter++)
    {
      string name=othSw->getOutPortName((*iter).second);
      _potentialProducers[(*iter).first]=master->getOutPort(name);
    }
}

References YACS::ENGINE::DataPort::_name, YACS::ENGINE::Port::_node, _potentialProducers, YACS::ENGINE::Switch::getOutPort(), and YACS::ENGINE::ComposedNode::getOutPortName().

Member Function Documentation

◆ addInPort()

bool CollectorSwOutPort::addInPort ( InPort * inPort )

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 83 of file Switch.cxx.

{
  bool ret = false;
  if(_currentProducer)
    {//a specific link is beeing done
      ret=_currentProducer->addInPort(inPort);
      _currentProducer=0;
    }
  else//global links asked
    for(map<int, OutPort *>::iterator iter=_potentialProducers.begin();iter!=_potentialProducers.end();iter++)
      ret |= (*iter).second->addInPort(inPort);
  return ret;
}

References _currentProducer, _potentialProducers, and YACS::ENGINE::OutPort::addInPort().

◆ addPotentialProducerForMaster()

void CollectorSwOutPort::addPotentialProducerForMaster ( OutPort * port )

private

Definition at line 137 of file Switch.cxx.

{
  int i=((Switch *)_node)->getRankOfNode(port->getNode());
  map<int, OutPort *>::iterator pt=_potentialProducers.find(i);
  if(pt==_potentialProducers.end())
    {
      _potentialProducers[i]=port;
      _currentProducer=port;
    }
  else
    {
      _currentProducer=(*pt).second;
      if(_currentProducer!=port)
        {
          string what("CollectorSwOutPort::addPotentialProducerForMaster : In switch node "); what+=_node->getName();
          what+=" for input named \'"; what+=_consumer->getName(); what+="\' the output "; what+=_currentProducer->getName();
          what+=" already got out for case of label "; 
          what+=Switch::getRepresentationOfCase((*pt).first); 
          throw Exception(what);
        }
    }
  _className=port->getNameOfTypeOfCurrentInstance();
}

References _className, _consumer, _currentProducer, YACS::ENGINE::Port::_node, _potentialProducers, YACS::ENGINE::DataPort::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::DataPort::getNameOfTypeOfCurrentInstance(), YACS::ENGINE::Port::getNode(), YACS::ENGINE::Switch::getRepresentationOfCase(), and yacsorb.CORBAEngineTest::i.

Referenced by YACS::ENGINE::Switch::buildDelegateOf().

◆ checkConsistency()

void CollectorSwOutPort::checkConsistency ( LinkInfo & info ) const

privatevirtual

Called by Switch::checkCFLinks.

Reimplemented from YACS::ENGINE::OutPort.

Definition at line 201 of file Switch.cxx.

{
  if(((Switch *)_node)->getNbOfCases()!=_potentialProducers.size())
    info.pushErrSwitch((CollectorSwOutPort *)this);
  for(map<int, OutPort *>::const_iterator iter=_potentialProducers.begin();iter!=_potentialProducers.end();iter++)
    (*iter).second->checkConsistency(info);
}

References YACS::ENGINE::Port::_node, _potentialProducers, and YACS::ENGINE::LinkInfo::pushErrSwitch().

◆ checkManagementOfPort()

bool CollectorSwOutPort::checkManagementOfPort ( OutPort * port )

private

Definition at line 187 of file Switch.cxx.

{
  for(map<int, OutPort *>::iterator iter=_potentialProducers.begin();iter!=_potentialProducers.end();iter++)
    if((*iter).second==port)
      {
        _currentProducer=port;
        return _potentialProducers.size()==1;
      }
  throw Exception("CollectorSwOutPort::checkManagementOfPort : unexported port");
}

References _currentProducer, and _potentialProducers.

◆ edGetNumberOfOutLinks()

int CollectorSwOutPort::edGetNumberOfOutLinks ( ) const

privatevirtual

Reimplemented from YACS::ENGINE::OutPort.

Definition at line 38 of file Switch.cxx.

{
  return 1;
}

◆ edRemoveAllLinksLinkedWithMe()

void CollectorSwOutPort::edRemoveAllLinksLinkedWithMe ( )

privatevirtual

Implements YACS::ENGINE::DataPort.

Definition at line 63 of file Switch.cxx.

{
  map<int, OutPort *>::iterator pt;
  if(_consumer)
    for(pt=_potentialProducers.begin();pt!=_potentialProducers.end();pt++)
      ((*pt).second)->removeInPort(_consumer,true);
}

References _consumer, _potentialProducers, and removeInPort().

◆ edSetInPort()

std::set< InPort * > CollectorSwOutPort::edSetInPort ( ) const

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 43 of file Switch.cxx.

{
  set<InPort *> ret;
  if(_consumer)
    ret.insert(_consumer);
  return ret;
}

References _consumer.

◆ getAllRepresented()

void CollectorSwOutPort::getAllRepresented ( std::set< OutPort * > & represented ) const

privatevirtual

Reimplemented from YACS::ENGINE::OutPort.

Definition at line 76 of file Switch.cxx.

{
  map<int, OutPort *>::const_iterator pt;
  for(pt=_potentialProducers.begin();pt!=_potentialProducers.end();pt++)
    ((*pt).second)->getAllRepresented(represented);
}

References _potentialProducers, and getAllRepresented().

Referenced by getAllRepresented().

◆ getHumanReprOfIncompleteCases()

void CollectorSwOutPort::getHumanReprOfIncompleteCases ( std::ostream & stream ) const

Called by LinkInfo::getErrRepr to have a comprehensible message on throw. When called, typically checkCompletenessOfCases has detected that some potential producers were laking...

Definition at line 213 of file Switch.cxx.

{
  set<int> lackingCases;
  for(map< int ,Node * >::const_iterator iter=((Switch *)_node)->_mapOfNode.begin();iter!=((Switch *)_node)->_mapOfNode.end();iter++)
    {
      if(_potentialProducers.find((*iter).first)==_potentialProducers.end())
        lackingCases.insert((*iter).first);
    }
  ostringstream streamForExc;
  stream << "For link to " <<  _consumer->getName() << " of node " << _consumer->getNode()->getName() 
         << " the cases of switch node named " << _node->getName() 
         << " do not define links for following cases ids :";
  for(set<int>::iterator iter=lackingCases.begin();iter!=lackingCases.end();iter++)
      stream << Switch::getRepresentationOfCase(*iter) << " ";
  stream << endl;
}

References _consumer, YACS::ENGINE::Port::_node, _potentialProducers, YACS::ENGINE::DataPort::getName(), YACS::ENGINE::Node::getName(), YACS::ENGINE::Port::getNode(), and YACS::ENGINE::Switch::getRepresentationOfCase().

◆ getNameOfTypeOfCurrentInstance()

std::string CollectorSwOutPort::getNameOfTypeOfCurrentInstance ( ) const

privatevirtual

Reimplemented from YACS::ENGINE::DataPort.

Definition at line 58 of file Switch.cxx.

{
  return _className;
}

References _className.

◆ getTypeOfChannel()

TypeOfChannel CollectorSwOutPort::getTypeOfChannel ( ) const

privatevirtual

returns type of channel the port will use for data exchange on runtime : DATAFLOW or DATASTREAM.

Implements YACS::ENGINE::DataPort.

Definition at line 71 of file Switch.cxx.

{
  return (*(_potentialProducers.begin())).second->getTypeOfChannel();
}

References _potentialProducers.

◆ isAlreadyLinkedWith()

bool CollectorSwOutPort::isAlreadyLinkedWith ( InPort * withp ) const

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 51 of file Switch.cxx.

{
  set<InPort *> s;
  with->getAllRepresentants(s);
  return s.find(_consumer)!=s.end();
}

References _consumer, and YACS::ENGINE::InPort::getAllRepresentants().

◆ removeInPort()

int CollectorSwOutPort::removeInPort	(	InPort *	inPort,
		bool	forward
	)

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 97 of file Switch.cxx.

{
  if(_currentProducer)
    {
      return _currentProducer->removeInPort(inPort,forward);
    }
  else
    throw Exception("CollectorSwOutputPort::edRemoveInputPort : internal error on link removal.");
  _currentProducer=0;
}

References _currentProducer, and YACS::ENGINE::OutPort::removeInPort().

Referenced by edRemoveAllLinksLinkedWithMe().

◆ removePotentialProducerForMaster()

bool CollectorSwOutPort::removePotentialProducerForMaster ( )

private

Definition at line 161 of file Switch.cxx.

{
  int i;
  map<int, OutPort *>::iterator result;
  for(result=_potentialProducers.begin();result!=_potentialProducers.end();result++)
    if((*result).second==_currentProducer)
      {
        i=(*result).first;
        break;
      }
  if(result==_potentialProducers.end())
    {
      ostringstream stream; stream << "CollectorSwOutPort::removePotentialProducerForMaster : link from the branch whith id ";
      stream << i << " not defined";
      throw Exception(stream.str());
    }
  if((*result).second!=_currentProducer)
    {
      ostringstream stream; stream << "CollectorSwOutPort::removePotentialProducerForMaster : link from the branch whith id ";
      stream << i << " defined but the output specified is not compatible";
      throw Exception(stream.str());
    }
  _potentialProducers.erase(result);
  return _potentialProducers.empty();
}

References _currentProducer, _potentialProducers, and yacsorb.CORBAEngineTest::i.

Referenced by YACS::ENGINE::Switch::releaseDelegateOf().

Friends And Related Function Documentation

◆ Switch

friend class Switch

friend

Definition at line 39 of file Switch.hxx.

Member Data Documentation

◆ _className

std::string YACS::ENGINE::CollectorSwOutPort::_className

private

Definition at line 61 of file Switch.hxx.

Referenced by addPotentialProducerForMaster(), and getNameOfTypeOfCurrentInstance().

◆ _consumer

InPort* YACS::ENGINE::CollectorSwOutPort::_consumer

private

Definition at line 60 of file Switch.hxx.

Referenced by addPotentialProducerForMaster(), edRemoveAllLinksLinkedWithMe(), edSetInPort(), getHumanReprOfIncompleteCases(), and isAlreadyLinkedWith().

◆ _currentProducer

OutPort* YACS::ENGINE::CollectorSwOutPort::_currentProducer

private

Definition at line 62 of file Switch.hxx.

Referenced by addInPort(), addPotentialProducerForMaster(), checkManagementOfPort(), removeInPort(), and removePotentialProducerForMaster().

◆ _potentialProducers

std::map<int, OutPort *> YACS::ENGINE::CollectorSwOutPort::_potentialProducers

private

Definition at line 63 of file Switch.hxx.

Referenced by addInPort(), addPotentialProducerForMaster(), checkConsistency(), checkManagementOfPort(), CollectorSwOutPort(), edRemoveAllLinksLinkedWithMe(), getAllRepresented(), getHumanReprOfIncompleteCases(), getTypeOfChannel(), and removePotentialProducerForMaster().

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

src/engine/Switch.hxx
src/engine/Switch.cxx

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ CollectorSwOutPort() [1/2]

◆ CollectorSwOutPort() [2/2]

Member Function Documentation

◆ addInPort()

◆ addPotentialProducerForMaster()

◆ checkConsistency()

◆ checkManagementOfPort()

◆ edGetNumberOfOutLinks()

◆ edRemoveAllLinksLinkedWithMe()

◆ edSetInPort()

◆ getAllRepresented()

◆ getHumanReprOfIncompleteCases()

◆ getNameOfTypeOfCurrentInstance()

◆ getTypeOfChannel()

◆ isAlreadyLinkedWith()

◆ removeInPort()

◆ removePotentialProducerForMaster()

Friends And Related Function Documentation

◆ Switch

Member Data Documentation

◆ _className

◆ _consumer

◆ _currentProducer

◆ _potentialProducers