OpenRTM-aist-Python 1.2.1
Classes | Public Member Functions | List of all members
OpenRTM_aist.OutPortBase.OutPortBase Class Reference

Output base class. More...

Inheritance diagram for OpenRTM_aist.OutPortBase.OutPortBase:
OpenRTM_aist.PortBase.PortBase OpenRTM_aist.DataPortStatus.DataPortStatus OpenRTM_aist.OutPort.OutPort

Classes

class  connector_cleanup
 Functor to delete Connectors. More...
 
class  provider_cleanup
 Functor to delete Providers. More...
 

Public Member Functions

def __init__ (self, name, data_type)
 A constructor of OutPortBase class. More...
 
def __del__ (self, PortBase=OpenRTM_aist.PortBase)
 destructor More...
 
def init (self, prop)
 Initializing properties. More...
 
def write (self)
 Write data. More...
 
def connect (self, connector_profile)
 [CORBA interface] Connect the Port More...
 
def notify_connect (self, connector_profile)
 
def properties (self)
 Get properties. More...
 
def connectors (self)
 Connector listconst std::vector<OutPortConnector*>& OutPortBase::connectors()
 
def getConnectorProfiles (self)
 ConnectorProfile listConnectorBase::ConnectorInfoList OutPortBase::getConnectorProfiles()
 
def getConnectorIds (self)
 ConnectorId listcoil::vstring OutPortBase::getConnectorIds()
 
def getConnectorNames (self)
 Connector name listcoil::vstring OutPortBase::getConnectorNames()
 
def getConnectorById (self, id)
 Getting ConnectorProfile by ID. More...
 
def getConnectorByName (self, name)
 Getting Connector by name. More...
 
def getConnectorProfileById (self, id, prof)
 Getting ConnectorProfile by namebool OutPortBase::getConnectorProfileById(const char* id, ConnectorInfo& prof)
 
def getConnectorProfileByName (self, name, prof)
 Getting ConnectorProfile by namebool OutPortBase::getConnectorProfileByName(const char* name, ConnectorInfo& prof)
 
def activateInterfaces (self)
 Activate all Port interfacesvoid OutPortBase::activateInterfaces()
 
def deactivateInterfaces (self)
 Deactivate all Port interfacesvoid OutPortBase::deactivateInterfaces()
 
def addConnectorDataListener (self, listener_type, listener, autoclean=True)
 Adding BufferDataListener type listener. More...
 
def removeConnectorDataListener (self, listener_type, listener)
 Removing BufferDataListener type listener. More...
 
def addConnectorListener (self, callback_type, listener, autoclean=True)
 Adding ConnectorListener type listener. More...
 
def removeConnectorListener (self, callback_type, listener)
 Removing BufferDataListener type listener. More...
 
def configure (self)
 Configureing outportvoid OutPortBase::configure()
 
def publishInterfaces (self, cprof)
 Publish interface informationReturnCode_t OutPortBase::publishInterfaces(ConnectorProfile& cprof)
 
def subscribeInterfaces (self, cprof)
 Subscribe interfaceReturnCode_t OutPortBase::subscribeInterfaces(const ConnectorProfile& cprof)
 
def unsubscribeInterfaces (self, connector_profile)
 Unsubscribe interfacevoid OutPortBase::unsubscribeInterfaces(const ConnectorProfile& connector_profile)
 
def initProviders (self)
 OutPort provider initializationvoid OutPortBase::initProviders()
 
def initConsumers (self)
 InPort consumer initializationvoid OutPortBase::initConsumers()
 
def createProvider (self, cprof, prop)
 OutPort provider creationOutPortProvider* OutPortBase::createProvider(ConnectorProfile& cprof, coil::Properties& prop)
 
def createConsumer (self, cprof, prop)
 InPort consumer creationInPortConsumer* OutPortBase::createConsumer(const ConnectorProfile& cprof, coil::Properties& prop)
 
def createConnector (self, cprof, prop, provider_=None, consumer_=None)
 OutPortPushConnector creationOutPortConnector* OutPortBase::createConnector(const ConnectorProfile& cprof, coil::Properties& prop, InPortConsumer* consumer)
 
def getLocalInPort (self, profile)
 Getting local peer InPort if available. More...
 
- Public Member Functions inherited from OpenRTM_aist.PortBase.PortBase
def __init__ (self, name=None)
 Constructor. More...
 
def __del__ (self)
 Destructor. More...
 
def exit (self)
 
def get_port_profile (self)
 [CORBA interface] Get the PortProfile of the Port More...
 
def getPortProfile (self)
 Get the PortProfile of the Port. More...
 
def get_connector_profiles (self)
 [CORBA interface] Get the ConnectorProfileList of the Port More...
 
def get_connector_profile (self, connector_id)
 [CORBA interface] Get the ConnectorProfile More...
 
def connect (self, connector_profile)
 [CORBA interface] Connect the Port More...
 
def notify_connect (self, connector_profile)
 [CORBA interface] Notify the Ports connection More...
 
def disconnect (self, connector_id)
 [CORBA interface] Disconnect the Port More...
 
def notify_disconnect (self, connector_id)
 [CORBA interface] Notify the Ports disconnection More...
 
def disconnect_all (self)
 [CORBA interface] Connect the Port More...
 
def setName (self, name)
 Set the name of this Port. More...
 
def getName (self)
 Get the name of this Port. More...
 
def getProfile (self)
 Get the PortProfile of the Port. More...
 
def setPortRef (self, port_ref)
 Set the object reference of this Port. More...
 
def getPortRef (self)
 Get the object reference of this Port. More...
 
def setOwner (self, owner)
 Set the owner RTObject of the Port. More...
 
def setOnPublishInterfaces (self, on_publish)
 Setting callback called on publish interfaces. More...
 
def setOnSubscribeInterfaces (self, on_subscribe)
 Setting callback called on publish interfaces. More...
 
def setOnConnected (self, on_connected)
 Setting callback called on connection established. More...
 
def setOnUnsubscribeInterfaces (self, on_subscribe)
 Setting callback called on unsubscribe interfaces. More...
 
def setOnDisconnected (self, on_disconnected)
 Setting callback called on disconnected. More...
 
def setPortConnectListenerHolder (self, portconnListeners)
 Setting PortConnectListener holder. More...
 
def publishInterfaces (self, connector_profile)
 Publish interface information. More...
 
def connectNext (self, connector_profile)
 Call notify_connect() of the next Port. More...
 
def disconnectNext (self, connector_profile)
 Call notify_disconnect() of the next Port. More...
 
def subscribeInterfaces (self, connector_profile)
 Publish interface information. More...
 
def unsubscribeInterfaces (self, connector_profile)
 Disconnect interface connection. More...
 
def setConnectionLimit (self, limit_value)
 Set the maximum number of connections. More...
 
def isEmptyId (self, connector_profile)
 Whether connector_id of ConnectorProfile is empty. More...
 
def getUUID (self)
 Get the UUID. More...
 
def setUUID (self, connector_profile)
 Create and set the UUID to the ConnectorProfile. More...
 
def isExistingConnId (self, id_)
 Whether the given id exists in stored ConnectorProfiles. More...
 
def findConnProfile (self, id_)
 Find ConnectorProfile with id. More...
 
def findConnProfileIndex (self, id_)
 Find ConnectorProfile with id. More...
 
def updateConnectorProfile (self, connector_profile)
 Append or update the ConnectorProfile list. More...
 
def eraseConnectorProfile (self, id_)
 Delete the ConnectorProfile. More...
 
def appendInterface (self, instance_name, type_name, pol)
 Append an interface to the PortInterfaceProfile. More...
 
def deleteInterface (self, name, pol)
 Delete an interface from the PortInterfaceProfile. More...
 
def addProperty (self, key, value)
 Add NameValue data to PortProfile's properties. More...
 
def appendProperty (self, key, value)
 Append NameValue data to PortProfile's properties. More...
 
def updateConnectors (self)
 Disconnect ports that doesn't exist. More...
 
def checkPorts (self, ports)
 Existence of ports. More...
 
- Public Member Functions inherited from OpenRTM_aist.DataPortStatus.DataPortStatus
def toString (status)
 Convert DataPortStatus into the string. More...
 

Additional Inherited Members

- Static Public Attributes inherited from OpenRTM_aist.DataPortStatus.DataPortStatus
int PORT_OK = 0
 DataPortStatus return codes. More...
 

Detailed Description

Output base class.

The base class of OutPort<T> which are implementations of OutPort

Form a kind of Observer pattern with OutPortBase and PublisherBase. attach(), detach(), notify() of OutPortBase and push() of PublisherBase are methods associated with the Observer pattern.

Since
0.2.0

Constructor & Destructor Documentation

def OpenRTM_aist.OutPortBase.OutPortBase.__init__ (   self,
  name,
  data_type 
)

A constructor of OutPortBase class.

Constructor of OutPortBase.

OutPortBase::OutPortBase(const char* name, const char* data_type)

def OpenRTM_aist.OutPortBase.OutPortBase.__del__ (   self,
  PortBase = OpenRTM_aist.PortBase 
)

destructor

Destructor

Member Function Documentation

def OpenRTM_aist.OutPortBase.OutPortBase.addConnectorDataListener (   self,
  listener_type,
  listener,
  autoclean = True 
)

Adding BufferDataListener type listener.

This operation adds certain listeners related to buffer writing and reading events. The following listener types are available.

  • ON_BUFFER_WRITE: At the time of buffer write
  • ON_BUFFER_FULL: At the time of buffer full
  • ON_BUFFER_WRITE_TIMEOUT: At the time of buffer write timeout
  • ON_BUFFER_OVERWRITE: At the time of buffer overwrite
  • ON_BUFFER_READ: At the time of buffer read
  • ON_SEND: At the time of sending to InPort
  • ON_RECEIVED: At the time of finishing sending to InPort
  • ON_SENDER_TIMEOUT: At the time of timeout of OutPort
  • ON_SENDER_ERROR: At the time of error of OutPort
  • ON_RECEIVER_FULL: At the time of bufferfull of InPort
  • ON_RECEIVER_TIMEOUT: At the time of timeout of InPort
  • ON_RECEIVER_ERROR: At the time of error of InPort

Listeners should have the following function operator().

ConnectorDataListener:: operator()(const ConnectorProfile&, const cdrStream&)

The ownership of the given listener object is transferred to this OutPort object in default. The given listener object will be destroied automatically in the OutPort's dtor or if the listener is deleted by removeConnectorDataListener() function. If you want to keep ownership of the listener object, give "false" value to 3rd argument to inhibit automatic destruction.

Parameters
listener_typeA listener type
listenerA pointer to a listener object
autocleanA flag for automatic listener destruction

void addConnectorDataListener(ConnectorDataListenerType listener_type, ConnectorDataListener* listener, bool autoclean = true);

def OpenRTM_aist.OutPortBase.OutPortBase.addConnectorListener (   self,
  callback_type,
  listener,
  autoclean = True 
)

Adding ConnectorListener type listener.

This operation adds certain listeners related to buffer writing and reading events. The following listener types are available.

  • ON_BUFFER_EMPTY: At the time of buffer empty
  • ON_BUFFER_READTIMEOUT: At the time of buffer read timeout

Listeners should have the following function operator().

ConnectorListener::operator()(const ConnectorProfile&)

The ownership of the given listener object is transferred to this OutPort object in default. The given listener object will be destroied automatically in the OutPort's dtor or if the listener is deleted by removeConnectorListener() function. If you want to keep ownership of the listener object, give "false" value to 3rd argument to inhibit automatic destruction.

Parameters
listener_typeA listener type
listenerA pointer to a listener object
autocleanA flag for automatic listener destruction

void addConnectorListener(ConnectorListenerType callback_type, ConnectorListener* listener, bool autoclean = true);

def OpenRTM_aist.OutPortBase.OutPortBase.connect (   self,
  connector_profile 
)

[CORBA interface] Connect the Port

This operation establishes connection according to the given ConnectionProfile inforamtion. This function is premised on calling from mainly application program or tools.

Parameters
connector_profileThe ConnectorProfile.
Returns
ReturnCode_t The return code of ReturnCode_t type.
def OpenRTM_aist.OutPortBase.OutPortBase.getConnectorById (   self,
  id 
)

Getting ConnectorProfile by ID.

This operation returns Connector specified by ID.

Parameters
idConnector ID
Returns
A pointer to connector

OutPortConnector* getConnectorById(const char* id);

def OpenRTM_aist.OutPortBase.OutPortBase.getConnectorByName (   self,
  name 
)

Getting Connector by name.

This operation returns Connector specified by name.

Parameters
idConnector ID
Returns
A pointer to connector

OutPortConnector* getConnectorByName(const char* name);

def OpenRTM_aist.OutPortBase.OutPortBase.getLocalInPort (   self,
  profile 
)

Getting local peer InPort if available.

Parameters
self
profile
Returns

InPortBase* getLocalInPort(const ConnectorInfo& profile)

def OpenRTM_aist.OutPortBase.OutPortBase.init (   self,
  prop 
)

Initializing properties.

This operation initializes outport's properties

void init(coil::Properties& prop);

def OpenRTM_aist.OutPortBase.OutPortBase.notify_connect (   self,
  connector_profile 
)
Parameters
self
connector_profile
Returns
def OpenRTM_aist.OutPortBase.OutPortBase.properties (   self)

Get properties.

Getting properties of this OutPort

Returns
OutPort's properties

coil::Properties& OutPortBase::properties()

def OpenRTM_aist.OutPortBase.OutPortBase.removeConnectorDataListener (   self,
  listener_type,
  listener 
)

Removing BufferDataListener type listener.

This operation removes a specified listener.

Parameters
listener_typeA listener type
listenerA pointer to a listener object

void removeConnectorDataListener(ConnectorDataListenerType listener_type, ConnectorDataListener* listener);

def OpenRTM_aist.OutPortBase.OutPortBase.removeConnectorListener (   self,
  callback_type,
  listener 
)

Removing BufferDataListener type listener.

This operation removes a specified listener.

Parameters
listener_typeA listener type
listenerA pointer to a listener object

void removeConnectorListener(ConnectorListenerType callback_type, ConnectorListener* listener);

def OpenRTM_aist.OutPortBase.OutPortBase.write (   self)

Write data.

Write data to the port. Write the value, which was set to the bound variable, to the port.

Returns
Writing result (Successful:true, Failed:false)

virtual bool write() = 0;


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