PublisherBase.py

Go to the documentation of this file.

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



import OpenRTM_aist



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


  
  def init(self, prop):
    pass

  ## virtual ReturnCode setConsumer(InPortConsumer* consumer) = 0;
  def setConsumer(self, consumer):
    pass

  ## virtual ReturnCode setBuffer(BufferBase<cdrMemoryStream>* buffer) = 0;
  def setBuffer(self, buffer):
    pass

  # virtual ReturnCode setListener(ConnectorInfo& info,
  #                                ConnectorListeners* listeners) = 0;
  def setListener(self, info, listeners):
    pass

  # virtual ReturnCode write(const cdrMemoryStream& data,
  #                          unsigned long sec,
  #                          unsigned long usec) = 0;
  def write(self, data, sec, usec):
    pass

  ## virtual bool isActive() = 0;
  def isActive(self):
    pass

  ## virtual ReturnCode activate() = 0;
  def activate(self):
    pass

  ## virtual ReturnCode deactivate() = 0;
  def deactivate(self):
    pass


    
  
  def release(self):
    pass


publisherfactory = None

class PublisherFactory(OpenRTM_aist.Factory,PublisherBase):
  def __init__(self):
    OpenRTM_aist.Factory.__init__(self)
    pass


  def __del__(self):
    pass


  def instance():
    global publisherfactory

    if publisherfactory is None:
      publisherfactory = PublisherFactory()

    return publisherfactory

  instance = staticmethod(instance)