19 sys.path.insert(1,
"../")
23 from ConnectorListener
import *
29 from omniORB
import any
41 data = OpenRTM_aist.ConnectorDataListenerT.__call__(self, info, cdrdata, RTC.TimedLong(RTC.Time(0,0),0))
42 print "------------------------------" 43 print "Listener: ", self._name
44 print "------------------------------" 64 print "------------------------------" 65 print "Listener: ", self._name
66 print "------------------------------" 71 if type == OpenRTM_aist.ConnectorDataListenerType.ON_BUFFER_WRITE:
72 return "ON_BUFFER_WRITE" 74 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_BUFFER_FULL:
75 return "ON_BUFFER_FULL" 77 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_BUFFER_WRITE_TIMEOUT:
78 return "ON_BUFFER_WRITE_TIMEOUT" 80 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_BUFFER_OVERWRITE:
81 return "ON_BUFFER_OVERWRITE" 83 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_BUFFER_READ:
84 return "ON_BUFFER_READ" 86 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_SEND:
89 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_RECEIVED:
92 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_RECEIVER_FULL:
93 return "ON_RECEIVER_FULL" 95 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_RECEIVER_TIMEOUT:
96 return "ON_RECEIVER_TIMEOUT" 98 elif type == OpenRTM_aist.ConnectorDataListenerType.ON_RECEIVER_ERROR:
99 return "ON_RECEIVER_ERROR" 106 if type == OpenRTM_aist.ConnectorListenerType.ON_BUFFER_EMPTY:
107 return "ON_BUFFER_EMPTY" 109 elif type == OpenRTM_aist.ConnectorListenerType.ON_BUFFER_READ_TIMEOUT:
110 return "ON_BUFFER_READ_TIMEOUT" 112 elif type == OpenRTM_aist.ConnectorListenerType.ON_SENDER_EMPTY:
113 return "ON_SENDER_EMPTY" 115 elif type == OpenRTM_aist.ConnectorListenerType.ON_SENDER_TIMEOUT:
116 return "ON_SENDER_TIMEOUT" 118 elif type == OpenRTM_aist.ConnectorListenerType.ON_SENDER_ERROR:
119 return "ON_SENDER_ERROR" 136 for i
in range(OpenRTM_aist.ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM):
139 for i
in range(OpenRTM_aist.ConnectorListenerType.CONNECTOR_LISTENER_NUM):
147 for i
in range(OpenRTM_aist.ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM):
148 self._connectorListeners.connectorData_[i].addListener(self.
_datalisteners[i],
True)
151 for i
in range(OpenRTM_aist.ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM):
152 data = RTC.TimedLong(RTC.Time(0,0),i)
153 cdr_data = cdrMarshal(any.to_any(data).typecode(), data,
True)
154 self._connectorListeners.connectorData_[i].notify(self.
_info, cdr_data)
163 info.properties.setProperty(
"serializer.cdr.endian",
"big")
165 for i
in range(OpenRTM_aist.ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM):
166 data = RTC.TimedLong(RTC.Time(0,0),i)
167 cdr_data = cdrMarshal(any.to_any(data).typecode(), data,
False)
168 self._connectorListeners.connectorData_[i].notify(info, cdr_data)
173 for i
in range(OpenRTM_aist.ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM):
174 self._connectorListeners.connectorData_[i].removeListener(self.
_datalisteners[i])
176 for i
in range(OpenRTM_aist.ConnectorDataListenerType.CONNECTOR_DATA_LISTENER_NUM):
177 data = RTC.TimedLong(RTC.Time(0,0),i)
178 cdr_data = cdrMarshal(any.to_any(data).typecode(), data,
True)
179 self._connectorListeners.connectorData_[i].notify(self.
_info, cdr_data)
188 for i
in range(OpenRTM_aist.ConnectorListenerType.CONNECTOR_LISTENER_NUM):
189 self._connectorListeners.connector_[i].addListener(self.
_listeners[i],
True)
192 for i
in range(OpenRTM_aist.ConnectorListenerType.CONNECTOR_LISTENER_NUM):
193 self._connectorListeners.connector_[i].notify(self.
_info)
196 for i
in range(OpenRTM_aist.ConnectorListenerType.CONNECTOR_LISTENER_NUM):
197 self._connectorListeners.connector_[i].removeListener(self.
_listeners[i])
199 for i
in range(OpenRTM_aist.ConnectorListenerType.CONNECTOR_LISTENER_NUM):
200 self._connectorListeners.connector_[i].notify(self.
_info)
209 if __name__ ==
'__main__':
def typeToStringDataListener(type)
The Properties class represents a persistent set of properties.
This class is abstract base class for listener classes that provides callbacks for various events in ...
def test_ConnectorListener(self)
def typeToStringListener(type)
def __call__(self, info, cdrdata)
def test_ConnectorDataListenerT(self)
This class is abstract base class for listener classes that provides callbacks for various events in ...