InPortProvider.py

Go to the documentation of this file.

#!/usr/bin/env python
# -*- coding: euc-jp -*-




import OpenRTM_aist
import SDOPackage, SDOPackage__POA



class InPortProvider(OpenRTM_aist.DataPortStatus):
  """
  """



  
  def __init__(self):
    self._properties = []
    self._interfaceType = ""
    self._dataflowType = ""
    self._subscriptionType = ""
    self._rtcout = OpenRTM_aist.Manager.instance().getLogbuf("InPortProvider")
    self._connector = None


  
  def publishInterfaceProfile(self, prop):
    self._rtcout.RTC_TRACE("publishInterfaceProfile()")
    OpenRTM_aist.NVUtil.appendStringValue(prop, "dataport.interface_type",
                                          self._interfaceType)
    OpenRTM_aist.NVUtil.append(prop, self._properties)

  
  def publishInterface(self, prop):
    self._rtcout.RTC_TRACE("publishInterface()")
    if not OpenRTM_aist.NVUtil.isStringValue(prop,
                                             "dataport.interface_type",
                                             self._interfaceType):
      return False

    OpenRTM_aist.NVUtil.append(prop, self._properties)
    return True


  
  def setInterfaceType(self, interface_type):
    self._rtcout.RTC_TRACE("setInterfaceType(%s)", interface_type)
    self._interfaceType = interface_type


  
  def setDataFlowType(self, dataflow_type):
    self._rtcout.RTC_TRACE("setDataFlowType(%s)", dataflow_type)
    self._dataflowType = dataflow_type


  
  def setSubscriptionType(self, subs_type):
    self._rtcout.RTC_TRACE("setSubscriptionType(%s)", subs_type)
    self._subscriptionType = subs_type



  def setConnector(self, connector):
    self._connector = connector


inportproviderfactory = None


class InPortProviderFactory(OpenRTM_aist.Factory,InPortProvider):
  def __init__(self):
    OpenRTM_aist.Factory.__init__(self) # Call GlobalFactory.Factory()
    InPortProvider.__init__(self)
    return


  def instance():
    global inportproviderfactory

    if inportproviderfactory is None:
      inportproviderfactory = InPortProviderFactory()

    return inportproviderfactory

  instance = staticmethod(instance)


  def __del__(self):
    pass