19 from omniORB
import any
61 ON_BUFFER_WRITE_TIMEOUT = 2
62 ON_BUFFER_OVERWRITE = 3
67 ON_RECEIVER_TIMEOUT = 8
69 CONNECTOR_DATA_LISTENER_NUM = 10
212 typeString = [
"ON_BUFFER_WRITE",
214 "ON_BUFFER_WRITE_TIMEOUT",
215 "ON_BUFFER_OVERWRITE",
220 "ON_RECEIVER_TIMEOUT",
222 "CONNECTOR_DATA_LISTENER_NUM"]
224 if type < ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM:
225 return typeString[type]
229 toString = staticmethod(toString)
290 endian = info.properties.getProperty(
"serializer.cdr.endian",
"little")
291 if endian
is not "little" and endian
is not None:
292 endian = OpenRTM_aist.split(endian,
",")
293 endian = OpenRTM_aist.normalize(endian)
295 if endian ==
"little":
297 elif endian ==
"big":
302 _data = cdrUnmarshal(any.to_any(data).typecode(), cdrdata, endian)
339 ON_BUFFER_READ_TIMEOUT = 1
341 ON_SENDER_TIMEOUT = 3
345 CONNECTOR_LISTENER_NUM = 7
487 typeString = [
"ON_BUFFER_EMPTY",
488 "ON_BUFFER_READ_TIMEOUT",
494 "CONNECTOR_LISTENER_NUM"]
496 if type < ConnectorListenerType.CONNECTOR_LISTENER_NUM:
497 return typeString[type]
501 toString = staticmethod(toString)
542 for (k,v)
in listener.iteritems():
573 self._listeners.append({listener:autoclean})
598 for (i, _listener)
in enumerate(self.
_listeners):
599 if listener
in _listener:
629 for (k,v)
in listener.iteritems():
672 for (k,v)
in listener.iteritems():
703 self._listeners.append({listener:autoclean})
728 for (i, _listener)
in enumerate(self.
_listeners):
729 if listener
in _listener:
756 for (k,v)
in listener.iteritems():
def __init__(self)
Constructor.
This class is abstract base class for listener classes that provides callbacks for various events in ...
def addListener(self, listener, autoclean)
Add the listener.
def __init__(self)
Constructor.
def removeListener(self, listener)
Remove the listener.
def __call__(self, info, cdrdata, data)
Callback method.
def removeListener(self, listener)
Remove the listener.
def __call__(self, info, data)
def notify(self, info, cdrdata)
Notify listeners.
This class is abstract base class for listener classes that provides callbacks for various events in ...
def addListener(self, listener, autoclean)
Add the listener.
The types of ConnectorDataListener.
def __del__(self)
Destructor.
def __del__(self)
Destructor.
def notify(self, info)
Notify listeners.
This class is abstract base class for listener classes that provides callbacks for various events in ...
The types of ConnectorListener.