#include <Switch.hxx>

Inheritance diagram for YACS::ENGINE::CollectorSwOutPort:

Collaboration diagram for YACS::ENGINE::CollectorSwOutPort:

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

Public Member Functions inherited from YACS::ENGINE::OutPort
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)

bool	isDifferentTypeOf (const DataPort *other) const

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

int	getNumId () const

void	modified ()

Private Member Functions
int	edGetNumberOfOutLinks () const

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

bool	isAlreadyLinkedWith (InPort *withp) const

std::string	getNameOfTypeOfCurrentInstance () const

void	edRemoveAllLinksLinkedWithMe () throw (Exception)

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) throw (Exception)

int	removeInPort (InPort *inPort, bool forward) throw (Exception)

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) throw (Exception)

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 Attributes inherited from YACS::ENGINE::DataPort
TypeCode *	_type

std::string	_name

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::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 111 of file Switch.cxx.

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

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

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

private

Definition at line 119 of file Switch.cxx.

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

                                                                                      :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);
     }
 }

Member Function Documentation

bool CollectorSwOutPort::addInPort ( InPort * inPort ) throw (Exception)

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 83 of file Switch.cxx.

References PMMLBasicsTestLauncher::ret.

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

void CollectorSwOutPort::addPotentialProducerForMaster ( OutPort * port )

private

Definition at line 133 of file Switch.cxx.

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 CORBAEngineTest::i.

 {
   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();
 }

void CollectorSwOutPort::checkConsistency ( LinkInfo & info ) const

privatevirtual

Called by Switch::checkCFLinks.

Reimplemented from YACS::ENGINE::OutPort.

Definition at line 197 of file Switch.cxx.

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

 {
   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);
 }

bool CollectorSwOutPort::checkManagementOfPort ( OutPort * port ) throw (Exception)

private

Definition at line 183 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");
 }

int CollectorSwOutPort::edGetNumberOfOutLinks ( ) const

privatevirtual

Reimplemented from YACS::ENGINE::OutPort.

Definition at line 38 of file Switch.cxx.

 {
   return 1;
 }

void CollectorSwOutPort::edRemoveAllLinksLinkedWithMe ( ) throw (Exception)

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);
 }

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

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 43 of file Switch.cxx.

References PMMLBasicsTestLauncher::ret.

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

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);
 }

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 209 of file Switch.cxx.

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

 {
   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;
 }

std::string CollectorSwOutPort::getNameOfTypeOfCurrentInstance ( ) const

privatevirtual

Reimplemented from YACS::ENGINE::DataPort.

Definition at line 58 of file Switch.cxx.

 {
   return _className;
 }

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();
 }

bool CollectorSwOutPort::isAlreadyLinkedWith ( InPort * withp ) const

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 51 of file Switch.cxx.

References YACS::ENGINE::InPort::getAllRepresentants().

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

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

privatevirtual

Implements YACS::ENGINE::OutPort.

Definition at line 96 of file Switch.cxx.

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

bool CollectorSwOutPort::removePotentialProducerForMaster ( )

private

Definition at line 157 of file Switch.cxx.

References _currentProducer, _potentialProducers, and CORBAEngineTest::i.

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

 {
   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();
 }

Friends And Related Function Documentation

friend class Switch

friend

Definition at line 39 of file Switch.hxx.

Member Data Documentation

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

private

Definition at line 61 of file Switch.hxx.

Referenced by addPotentialProducerForMaster().

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

private

Definition at line 60 of file Switch.hxx.

Referenced by addPotentialProducerForMaster(), CollectorSwOutPort(), and getHumanReprOfIncompleteCases().

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

private

Definition at line 62 of file Switch.hxx.

Referenced by addPotentialProducerForMaster(), and removePotentialProducerForMaster().

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

private

Definition at line 63 of file Switch.hxx.

Referenced by addPotentialProducerForMaster(), checkConsistency(), CollectorSwOutPort(), getHumanReprOfIncompleteCases(), 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

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation