Go to the documentation of this file.00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017 import sys
00018 sys.path.insert(1,"../")
00019
00020 import unittest
00021 import OpenRTM_aist
00022 from PortConnectListener import *
00023
00024 import RTC, RTC__POA
00025 import OpenRTM
00026
00027 from omniORB import *
00028 from omniORB import any
00029
00030 class MockPortConnectListener(PortConnectListener):
00031 def __init__(self):
00032 PortConnectListener.__init__(self)
00033 return
00034
00035 def __call__(self,portname,profile):
00036 return
00037
00038
00039 class MockPortConnectRetListener(PortConnectRetListener):
00040 def __init__(self):
00041 PortConnectRetListener.__init__(self)
00042 return
00043
00044 def __call__(self,portname,profile,ret):
00045 return
00046
00047
00048
00049 class TestListener(unittest.TestCase):
00050 def setUp(self):
00051 return
00052
00053 def tearDown(self):
00054 OpenRTM_aist.Manager.instance().shutdownManager()
00055 return
00056
00057 def test_PortConnectListener_toString(self):
00058 self.assertEqual("ON_NOTIFY_CONNECT",
00059 PortConnectListener.toString(
00060 PortConnectListenerType.ON_NOTIFY_CONNECT))
00061
00062 self.assertEqual("ON_NOTIFY_DISCONNECT",
00063 PortConnectListener.toString(
00064 PortConnectListenerType.ON_NOTIFY_DISCONNECT))
00065
00066 self.assertEqual("ON_UNSUBSCRIBE_INTERFACES",
00067 PortConnectListener.toString(
00068 PortConnectListenerType.ON_UNSUBSCRIBE_INTERFACES))
00069 return
00070
00071
00072 def test_PortConnectRetListener_toString(self):
00073 self.assertEqual("ON_PUBLISH_INTERFACES",
00074 PortConnectRetListener.toString(
00075 PortConnectRetListenerType.ON_PUBLISH_INTERFACES))
00076
00077 self.assertEqual("ON_CONNECT_NEXTPORT",
00078 PortConnectRetListener.toString(
00079 PortConnectRetListenerType.ON_CONNECT_NEXTPORT))
00080
00081 self.assertEqual("ON_SUBSCRIBE_INTERFACES",
00082 PortConnectRetListener.toString(
00083 PortConnectRetListenerType.ON_SUBSCRIBE_INTERFACES))
00084
00085 self.assertEqual("ON_CONNECTED",
00086 PortConnectRetListener.toString(
00087 PortConnectRetListenerType.ON_CONNECTED))
00088
00089 self.assertEqual("ON_DISCONNECT_NEXT",
00090 PortConnectRetListener.toString(
00091 PortConnectRetListenerType.ON_DISCONNECT_NEXT))
00092
00093 self.assertEqual("ON_DISCONNECTED",
00094 PortConnectRetListener.toString(
00095 PortConnectRetListenerType.ON_DISCONNECTED))
00096 return
00097
00098
00099 def test_PortConnectListenerHolder(self):
00100 portconlisteners = PortConnectListeners()
00101 listener = MockPortConnectListener()
00102 portconlisteners.portconnect_[0].addListener(listener,True)
00103 portconlisteners.portconnect_[0].notify("port_name",None)
00104 portconlisteners.portconnect_[0].removeListener(listener)
00105 return
00106
00107 def test_PortConnectRetListenerHolder(self):
00108 portconretlisteners = PortConnectRetListeners()
00109 listener = MockPortConnectRetListener()
00110 portconretlisteners.portconnret_[0].addListener(listener,True)
00111 portconretlisteners.portconnret_[0].notify("port_name",None)
00112 portconretlisteners.portconnret_[0].removeListener(listener)
00113 return
00114
00115
00116
00117 if __name__ == '__main__':
00118 unittest.main()
00119